Uses of Interface
org.apache.flume.Sink

Packages that use Sink

Package	Description
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.hive
org.apache.flume.sink.http	This package provides an HTTP sink for Flume so that events can be sent out to a target HTTP endpoint.
org.apache.flume.sink.irc
org.apache.flume.sink.kafka
org.apache.flume.sink.kite
org.apache.flume.sink.solr.morphline

Uses of Sink in org.apache.flume

Methods in org.apache.flume that return Sink

Modifier and Type	Method and Description
Sink	SinkFactory.create(String name, String type)

Methods in org.apache.flume that return types with arguments of type Sink

Modifier and Type	Method and Description
Class<? extends Sink>	SinkFactory.getClass(String type)

Method parameters in org.apache.flume with type arguments of type Sink

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
Sink	DefaultSinkFactory.create(String name, String type)

Methods in org.apache.flume.sink that return types with arguments of type Sink

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
void	LoadBalancingSinkProcessor.SinkSelector.informSinkFailed(Sink failedSink)
void	AbstractSinkSelector.informSinkFailed(Sink failedSink)

Method parameters in org.apache.flume.sink with type arguments of type Sink

Modifier and Type	Method and Description
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

Constructor and Description
SinkGroup(List<Sink> groupSinks)

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

Classes in org.apache.flume.sink.elasticsearch that implement Sink

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
class	HDFSEventSink

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

Classes in org.apache.flume.sink.hive that implement Sink

Modifier and Type	Class and Description
class	HiveSink

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

Classes in org.apache.flume.sink.http that implement Sink

Modifier and Type	Class and Description
class	HttpSink Implementation of an HTTP sink.

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

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

Modifier and Type	Class and Description
class	IRCSink

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

Classes in org.apache.flume.sink.kafka that implement Sink

Modifier and Type	Class and Description
class	KafkaSink A Flume Sink that can publish messages to Kafka.

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

Classes in org.apache.flume.sink.kite that implement Sink

Modifier and Type	Class and Description
class	DatasetSink Sink that writes events to a Kite Dataset.

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

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

Modifier and Type	Class and Description
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.