Uses of Class
org.apache.flume.PollableSink.Status

Packages that use PollableSink.Status
org.apache.flume   
org.apache.flume.sink   
org.apache.flume.sink.hdfs   
 

Uses of PollableSink.Status in org.apache.flume
 

Methods in org.apache.flume that return PollableSink.Status
 PollableSink.Status PollableSink.process()
           
static PollableSink.Status PollableSink.Status.valueOf(String name)
          Returns the enum constant of this type with the specified name.
static PollableSink.Status[] PollableSink.Status.values()
          Returns an array containing the constants of this enum type, in the order they are declared.
 

Uses of PollableSink.Status in org.apache.flume.sink
 

Methods in org.apache.flume.sink that return PollableSink.Status
 PollableSink.Status RollingFileSink.process()
           
 PollableSink.Status NullSink.process()
           
 PollableSink.Status LoggerSink.process()
           
 PollableSink.Status AvroSink.process()
           
 

Uses of PollableSink.Status in org.apache.flume.sink.hdfs
 

Methods in org.apache.flume.sink.hdfs that return PollableSink.Status
 PollableSink.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
 



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