Uses of Interface
org.apache.flume.SinkProcessor

Packages that use SinkProcessor

org.apache.flume
org.apache.flume.sink

Uses of SinkProcessor in org.apache.flume

Methods in org.apache.flume that return SinkProcessor

SinkProcessor

SinkRunner.getPolicy()

Methods in org.apache.flume with parameters of type SinkProcessor

void	SinkRunner.setSink(SinkProcessor policy)

Constructors in org.apache.flume with parameters of type SinkProcessor

SinkRunner(SinkProcessor policy)

Uses of SinkProcessor in org.apache.flume.sink

Classes in org.apache.flume.sink that implement SinkProcessor

class

DefaultSinkProcessor Default sink processor that only accepts a single sink, passing on process results without any additional handling.

class

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

Methods in org.apache.flume.sink that return SinkProcessor

SinkProcessor	SinkGroup.getProcessor()
static SinkProcessor	SinkProcessorFactory.getProcessor(Context context, List<Sink> sinks) Creates a sink processor and configures it using the provided context