Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.sink |
Modifier and Type | Method and Description |
---|---|
SinkProcessor |
SinkRunner.getPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
SinkRunner.setSink(SinkProcessor policy) |
Constructor and Description |
---|
SinkRunner(SinkProcessor policy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSinkProcessor
A convenience base class for sink processors.
|
class |
DefaultSinkProcessor
Default sink processor that only accepts a single sink, passing on process
results without any additional handling.
|
class |
FailoverSinkProcessor
FailoverSinkProcessor maintains a prioritized list of sinks,
guarranteeing that so long as one is available events will be processed.
|
class |
LoadBalancingSinkProcessor
Provides the ability to load-balance flow over multiple sinks.
|
Modifier and Type | Method and Description |
---|---|
SinkProcessor |
SinkGroup.getProcessor() |
static SinkProcessor |
SinkProcessorFactory.getProcessor(ComponentConfiguration conf,
List<Sink> sinks) |
static SinkProcessor |
SinkProcessorFactory.getProcessor(Context context,
List<Sink> sinks)
Creates a sink processor and configures it using the provided context
|
Copyright © 2009-2016 Apache Software Foundation. All Rights Reserved.