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



Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.