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
org.apache.flume.sink.solr.morphline

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 that return types with arguments of type Sink

Class<? extends Sink>

SinkFactory.getClass(String type)

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	AbstractRpcSink This sink provides the basic RPC functionality for Flume.
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
class	ThriftSink A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource).

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()
Class<? extends Sink>	DefaultSinkFactory.getClass(String type)
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)

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

Uses of Sink in org.apache.flume.sink.solr.morphline

Classes in org.apache.flume.sink.solr.morphline that implement Sink

class	MorphlineSink Flume sink that extracts search documents from Flume events and processes them using a morphline Command chain.
class	MorphlineSolrSink Flume sink that extracts search documents from Flume events, processes them using a morphline Command chain, and loads them into Apache Solr.