Package org.apache.flume.sink

Interface Summary
LoadBalancingSinkProcessor.SinkSelector An interface that allows the LoadBalancingSinkProcessor to use a load-balancing strategy such as round-robin, random distribution etc.
 

Class Summary
AbstractRpcSink This sink provides the basic RPC functionality for Flume.
AbstractSink  
AbstractSinkProcessor A convenience base class for sink processors.
AbstractSinkSelector  
AvroSink A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).
DefaultSinkFactory  
DefaultSinkProcessor Default sink processor that only accepts a single sink, passing on process results without any additional handling.
FailoverSinkProcessor FailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed.
LoadBalancingSinkProcessor Provides the ability to load-balance flow over multiple sinks.
LoggerSink A Sink implementation that logs all events received at the INFO level to the org.apache.flume.sink.LoggerSink logger.
NullSink A Sink implementation that simply discards all events it receives.
RollingFileSink  
SinkGroup Configuration concept for handling multiple sinks working together.
SinkProcessorFactory  
ThriftSink A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource).
 



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