Uses of Interface
org.apache.flume.SinkProcessor

Packages that use SinkProcessor

Package	Description
org.apache.flume
org.apache.flume.sink

Uses of SinkProcessor in org.apache.flume

Methods in org.apache.flume that return SinkProcessor

Modifier and Type	Method and Description
SinkProcessor	SinkRunner.getPolicy()

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

Modifier and Type	Method and Description
void	SinkRunner.setSink(SinkProcessor policy)

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

Constructor and Description
SinkRunner(SinkProcessor policy)

Uses of SinkProcessor in org.apache.flume.sink

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

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.

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

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