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