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

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

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