Uses of Interface
org.apache.flume.Sink

Packages that use Sink
org.apache.flume   
org.apache.flume.sink   
org.apache.flume.sink.elasticsearch   
org.apache.flume.sink.hbase   
org.apache.flume.sink.hdfs   
org.apache.flume.sink.irc   
 

Uses of Sink in org.apache.flume
 

Methods in org.apache.flume that return Sink
 Sink SinkFactory.create(String name, String type)
           
 

Methods in org.apache.flume with parameters of type Sink
 boolean SinkFactory.unregister(Sink sink)
           
 

Method parameters in org.apache.flume with type arguments of type Sink
 void SinkProcessor.setSinks(List<Sink> sinks)
          Set all sinks to work with.
 

Uses of Sink in org.apache.flume.sink
 

Classes in org.apache.flume.sink that implement Sink
 class AbstractSink
           
 class AvroSink
           A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).
 class LoggerSink
           A Sink implementation that logs all events received at the INFO level to the org.apache.flume.sink.LoggerSink logger.
 class NullSink
           A Sink implementation that simply discards all events it receives.
 class RollingFileSink
           
 

Methods in org.apache.flume.sink that return Sink
 Sink DefaultSinkFactory.create(String name, String type)
           
 

Methods in org.apache.flume.sink that return types with arguments of type Sink
 Iterator<Sink> LoadBalancingSinkProcessor.SinkSelector.createSinkIterator()
           
 Map<Class<?>,Map<String,Sink>> DefaultSinkFactory.getRegistryClone()
           
protected  List<Sink> AbstractSinkSelector.getSinks()
           
protected  List<Sink> AbstractSinkProcessor.getSinks()
           
 

Methods in org.apache.flume.sink with parameters of type Sink
 void LoadBalancingSinkProcessor.SinkSelector.informSinkFailed(Sink failedSink)
           
 void AbstractSinkSelector.informSinkFailed(Sink failedSink)
           
 boolean DefaultSinkFactory.unregister(Sink sink)
           
 

Method parameters in org.apache.flume.sink with type arguments of type Sink
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
 void LoadBalancingSinkProcessor.SinkSelector.setSinks(List<Sink> sinks)
           
 void FailoverSinkProcessor.setSinks(List<Sink> sinks)
           
 void DefaultSinkProcessor.setSinks(List<Sink> sinks)
           
 void AbstractSinkSelector.setSinks(List<Sink> sinks)
           
 void AbstractSinkProcessor.setSinks(List<Sink> sinks)
           
 

Constructor parameters in org.apache.flume.sink with type arguments of type Sink
SinkGroup(List<Sink> groupSinks)
           
 

Uses of Sink in org.apache.flume.sink.elasticsearch
 

Classes in org.apache.flume.sink.elasticsearch that implement Sink
 class ElasticSearchSink
          A sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.com/Aconex/elasticflume.git.
 

Uses of Sink in org.apache.flume.sink.hbase
 

Classes in org.apache.flume.sink.hbase that implement Sink
 class AsyncHBaseSink
          A simple sink which reads events from a channel and writes them to HBase.
 class HBaseSink
          A simple sink which reads events from a channel and writes them to HBase.
 

Uses of Sink in org.apache.flume.sink.hdfs
 

Classes in org.apache.flume.sink.hdfs that implement Sink
 class HDFSEventSink
           
 

Uses of Sink in org.apache.flume.sink.irc
 

Classes in org.apache.flume.sink.irc that implement Sink
 class IRCSink
           
 



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