Uses of Class
org.apache.flume.EventDeliveryException

Packages that use EventDeliveryException

org.apache.flume
org.apache.flume.agent.embedded	This package provides Flume users the ability to embed simple agents in applications.
org.apache.flume.api
org.apache.flume.sink
org.apache.flume.sink.elasticsearch
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.irc
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.jms

Uses of EventDeliveryException in org.apache.flume

Methods in org.apache.flume that throw EventDeliveryException

Sink.Status	SinkProcessor.process() Handle a request to poll the owned sinks.
Sink.Status	Sink.process() Requests the sink to attempt to consume data from attached channel
PollableSource.Status	PollableSource.process() Attempt to pull an item from the source, sending it to the channel.

Uses of EventDeliveryException in org.apache.flume.agent.embedded

Methods in org.apache.flume.agent.embedded that throw EventDeliveryException

void	EmbeddedAgent.put(Event event) Adds event to the channel owned by the agent.
void	EmbeddedAgent.putAll(List<Event> events) Adds events to the channel owned by the agent.

Uses of EventDeliveryException in org.apache.flume.api

Methods in org.apache.flume.api that throw EventDeliveryException

void	ThriftRpcClient.append(Event event)
void	RpcClient.append(Event event) Send a single Event to the associated Flume source.
void	NettyAvroRpcClient.append(Event event)
void	LoadBalancingRpcClient.append(Event event)
void	FailoverRpcClient.append(Event event) Tries to append an event to the currently connected client.
abstract void	AbstractRpcClient.append(Event event)
void	ThriftRpcClient.appendBatch(List<Event> events)
void	RpcClient.appendBatch(List<Event> events) Send a list of events to the associated Flume source.
void	NettyAvroRpcClient.appendBatch(List<Event> events)
void	LoadBalancingRpcClient.appendBatch(List<Event> events)
void	FailoverRpcClient.appendBatch(List<Event> events) Tries to append a list of events to the currently connected client.
abstract void	AbstractRpcClient.appendBatch(List<Event> events)

Uses of EventDeliveryException in org.apache.flume.sink

Methods in org.apache.flume.sink that throw EventDeliveryException

Sink.Status	RollingFileSink.process()
Sink.Status	NullSink.process()
Sink.Status	LoggerSink.process()
Sink.Status	LoadBalancingSinkProcessor.process()
Sink.Status	FailoverSinkProcessor.process()
Sink.Status	DefaultSinkProcessor.process()
Sink.Status	AbstractRpcSink.process()

Uses of EventDeliveryException in org.apache.flume.sink.elasticsearch

Methods in org.apache.flume.sink.elasticsearch that throw EventDeliveryException

Sink.Status

ElasticSearchSink.process()

Uses of EventDeliveryException in org.apache.flume.sink.hbase

Methods in org.apache.flume.sink.hbase that throw EventDeliveryException

Sink.Status	HBaseSink.process()
Sink.Status	AsyncHBaseSink.process()

Uses of EventDeliveryException in org.apache.flume.sink.hdfs

Methods in org.apache.flume.sink.hdfs that throw EventDeliveryException

Sink.Status

HDFSEventSink.process() Pull events out of channel and send it to HDFS.

Uses of EventDeliveryException in org.apache.flume.sink.irc

Methods in org.apache.flume.sink.irc that throw EventDeliveryException

Sink.Status

IRCSink.process()

Uses of EventDeliveryException in org.apache.flume.sink.solr.morphline

Methods in org.apache.flume.sink.solr.morphline that throw EventDeliveryException

Sink.Status

MorphlineSink.process()

Uses of EventDeliveryException in org.apache.flume.source

Methods in org.apache.flume.source that throw EventDeliveryException

protected abstract PollableSource.Status	AbstractPollableSource.doProcess()
PollableSource.Status	StressSource.process()
PollableSource.Status	SequenceGeneratorSource.process()
PollableSource.Status	AbstractPollableSource.process()

Uses of EventDeliveryException in org.apache.flume.source.jms

Methods in org.apache.flume.source.jms that throw EventDeliveryException

protected PollableSource.Status

JMSSource.doProcess()