Uses of Class
org.apache.flume.EventDeliveryException

Packages that use EventDeliveryException

Package	Description
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.hbase2
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
org.apache.flume.sink.http	This package provides an HTTP sink for Flume so that events can be sent out to a target HTTP endpoint.
org.apache.flume.sink.irc
org.apache.flume.sink.kafka
org.apache.flume.sink.kite
org.apache.flume.sink.kite.parser
org.apache.flume.sink.kite.policy
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.jms
org.apache.flume.source.kafka

Uses of EventDeliveryException in org.apache.flume

Methods in org.apache.flume that throw EventDeliveryException

Modifier and Type	Method and Description
PollableSource.Status	PollableSource.process() Attempt to pull an item from the source, sending it to the channel.
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

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

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

Modifier and Type	Method and Description
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

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

Uses of EventDeliveryException in org.apache.flume.sink

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

Modifier and Type	Method and Description
Sink.Status	LoggerSink.process()
Sink.Status	DefaultSinkProcessor.process()
Sink.Status	FailoverSinkProcessor.process()
Sink.Status	NullSink.process()
Sink.Status	LoadBalancingSinkProcessor.process()
Sink.Status	AbstractRpcSink.process()
Sink.Status	RollingFileSink.process()

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

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

Modifier and Type	Method and Description
Sink.Status	HBase2Sink.process()

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

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

Modifier and Type	Method and Description
Sink.Status	HDFSEventSink.process() Pull events out of channel and send it to HDFS.

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

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

Modifier and Type	Method and Description
Sink.Status	HiveSink.process() Pull events out of channel, find corresponding HiveWriter and write to it.

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

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

Modifier and Type	Method and Description
Sink.Status	HttpSink.process()

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

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

Modifier and Type	Method and Description
Sink.Status	IRCSink.process()

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

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

Modifier and Type	Method and Description
Sink.Status	KafkaSink.process()

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

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

Modifier and Type	Method and Description
Sink.Status	DatasetSink.process()

Uses of EventDeliveryException in org.apache.flume.sink.kite.parser

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

Modifier and Type	Method and Description
E	EntityParser.parse(Event event, E reuse) Parse a Kite entity from a Flume event
org.apache.avro.generic.GenericRecord	AvroParser.parse(Event event, org.apache.avro.generic.GenericRecord reuse) Parse the entity from the body of the given event.

Uses of EventDeliveryException in org.apache.flume.sink.kite.policy

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

Modifier and Type	Method and Description
void	SavePolicy.close()
void	RetryPolicy.close()
void	FailurePolicy.close() Close this FailurePolicy and release any resources.
void	SavePolicy.handle(Event event, Throwable cause)
void	RetryPolicy.handle(Event event, Throwable cause)
void	FailurePolicy.handle(Event event, Throwable cause) Handle a non-recoverable event.
void	SavePolicy.sync()
void	RetryPolicy.sync()
void	FailurePolicy.sync() Ensure any handled events are on stable storage.

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

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

Modifier and Type	Method and Description
Sink.Status	MorphlineSink.process()

Uses of EventDeliveryException in org.apache.flume.source

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

Modifier and Type	Method and Description
protected PollableSource.Status	StressSource.doProcess()
protected abstract PollableSource.Status	AbstractPollableSource.doProcess()
protected PollableSource.Status	SequenceGeneratorSource.doProcess()
PollableSource.Status	AbstractPollableSource.process()

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

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

Modifier and Type	Method and Description
protected PollableSource.Status	JMSSource.doProcess()

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

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

Modifier and Type	Method and Description
protected PollableSource.Status	KafkaSource.doProcess()