Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.sink | |
org.apache.flume.sink.hbase | |
org.apache.flume.sink.hbase2 | |
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 |
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 |
AbstractSinkSelector.informSinkFailed(Sink failedSink) |
void |
LoadBalancingSinkProcessor.SinkSelector.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 |
DefaultSinkProcessor.setSinks(List<Sink> sinks) |
void |
FailoverSinkProcessor.setSinks(List<Sink> sinks) |
void |
AbstractSinkSelector.setSinks(List<Sink> sinks) |
void |
AbstractSinkProcessor.setSinks(List<Sink> sinks) |
void |
LoadBalancingSinkProcessor.SinkSelector.setSinks(List<Sink> sinks) |
Constructor and Description |
---|
SinkGroup(List<Sink> groupSinks) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseSink
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
HBase2Sink
A simple sink which reads events from a channel and writes them to HBase 2.
|
Modifier and Type | Class and Description |
---|---|
class |
HDFSEventSink |
Modifier and Type | Class and Description |
---|---|
class |
HiveSink |
Modifier and Type | Class and Description |
---|---|
class |
HttpSink
Implementation of an HTTP sink.
|
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–2019 Apache Software Foundation. All rights reserved.