| Interface | Description |
|---|---|
| LoadBalancingSinkProcessor.SinkSelector |
An interface that allows the LoadBalancingSinkProcessor to use
a load-balancing strategy such as round-robin, random distribution etc.
|
| Class | Description |
|---|---|
| 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–2019 Apache Software Foundation. All rights reserved.