|
Class Summary |
| AbstractSink |
|
| 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 is in no way thread safe and expects to be run via
SinkRunner Additionally, setSinks must be called before configure, and
additional sinks cannot be added while running
To configure, set a sink groups processor to "failover" and set priorities
for individual sinks:
Ex)
host1.sinkgroups = group1
host1.sinkgroups.group1.sinks = sink1 sink2
host1.sinkgroups.group1.processor.type = failover
host1.sinkgroups.group1.processor.priority.sink1 = 5
host1.sinkgroups.group1.processor.priority.sink2 = 10 |
| 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 |
|