|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
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 ). |
|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |