Modifier and Type | Method and Description |
---|---|
Sink |
SinkFactory.create(String name,
String type) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Sink> |
SinkFactory.getClass(String type) |
Modifier and Type | Method and Description |
---|---|
void |
SinkProcessor.setSinks(List<Sink> sinks)
Set all sinks to work with.
|
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 ). |
Modifier and Type | Method and Description |
---|---|
Sink |
DefaultSinkFactory.create(String name,
String type) |
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() |
Modifier and Type | Method and Description |
---|---|
void |
LoadBalancingSinkProcessor.SinkSelector.informSinkFailed(Sink failedSink) |
void |
AbstractSinkSelector.informSinkFailed(Sink failedSink) |
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 and Description |
---|
SinkGroup(List<Sink> groupSinks) |
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.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
HDFSEventSink |
Modifier and Type | Class and Description |
---|---|
class |
HiveSink |
Modifier and Type | Class and Description |
---|---|
class |
IRCSink |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSink
A Flume Sink that can publish messages to Kafka.
|
Modifier and Type | Class and Description |
---|---|
class |
DatasetSink
Sink that writes events to a Kite Dataset.
|
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. |
Copyright © 2009-2016 Apache Software Foundation. All Rights Reserved.