|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EventDeliveryException | |
---|---|
org.apache.flume | |
org.apache.flume.api | |
org.apache.flume.sink | |
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()
|
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 |
RpcClient.appendBatch(List<Event> events)
Send a list of events to the associated Flume source. |
void |
NettyAvroRpcClient.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 |
FailoverSinkProcessor.process()
|
Sink.Status |
DefaultSinkProcessor.process()
|
Sink.Status |
AvroSink.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 |
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 |
SequenceGeneratorSource.process()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |