|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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.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 | |
---|---|
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.hive |
---|
Methods in org.apache.flume.sink.hive that throw EventDeliveryException | |
---|---|
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 | |
---|---|
Sink.Status |
IRCSink.process()
|
Uses of EventDeliveryException in org.apache.flume.sink.kafka |
---|
Methods in org.apache.flume.sink.kafka that throw EventDeliveryException | |
---|---|
Sink.Status |
KafkaSink.process()
|
Uses of EventDeliveryException in org.apache.flume.sink.kite |
---|
Methods in org.apache.flume.sink.kite that throw EventDeliveryException | |
---|---|
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 | |
---|---|
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 | |
---|---|
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 | |
---|---|
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()
|
Uses of EventDeliveryException in org.apache.flume.source.kafka |
---|
Methods in org.apache.flume.source.kafka that throw EventDeliveryException | |
---|---|
PollableSource.Status |
KafkaSource.process()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |