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.elasticsearch
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
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
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

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

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

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

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

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

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

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.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 PollableSource.Status	SequenceGeneratorSource.doProcess()
protected abstract PollableSource.Status	AbstractPollableSource.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()