Modifier and Type | Class and Description |
---|---|
class |
AbstractRpcSink
This sink provides the basic RPC functionality for Flume.
|
class |
AvroSink
A
Sink implementation that can send events to an RPC server (such as
Flume's AvroSource ). |
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 | 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 |
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 |
KafkaSink
A Flume Sink that can publish messages to Kafka.
|
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. |
Modifier and Type | Class and Description |
---|---|
class |
ExecSource
A
Source implementation that executes a Unix process and turns each
line of text into an event. |
class |
MultiportSyslogTCPSource |
class |
SequenceGeneratorSource |
class |
SpoolDirectorySource |
class |
StressSource
StressSource is an internal load-generating source implementation
which is very useful for stress tests.
|
Modifier and Type | Class and Description |
---|---|
class |
JMSSource |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSource
A Source for Kafka which reads messages from kafka topics.
|
Modifier and Type | Class and Description |
---|---|
class |
TaildirSource |
Modifier and Type | Class and Description |
---|---|
class |
TwitterSource
Demo Flume source that connects via Streaming API to the 1% sample twitter
firehose, continuously downloads tweets, converts them to Avro format and
sends Avro events to a downstream Flume sink.
|
Copyright © 2009-2022 Apache Software Foundation. All Rights Reserved.