Uses of Class
org.apache.flume.EventDeliveryException

Packages that use EventDeliveryException

org.apache.flume
org.apache.flume.api
org.apache.flume.sink
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.irc
org.apache.flume.source

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.api

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

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	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	AvroSink.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 - take at the most txnEventMax, that's the maximum #events to hold in channel for a given transaction - find the corresponding bucket for the event, ensure the file is open - extract the pay-load and append to HDFS file WARNING: NOT THREAD SAFE

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.source

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

PollableSource.Status	StressSource.process()
PollableSource.Status	SequenceGeneratorSource.process()