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