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
 



Copyright © 2009-2013 Apache Software Foundation. All Rights Reserved.