| Modifier and Type | Interface and Description |
|---|---|
interface |
ChannelSelector
Allows the selection of a subset of channels from the given set based on
its implementation policy.
|
interface |
SinkProcessor
Interface for a device that allows abstraction of the behavior of multiple
sinks, always assigned to a SinkRunner
|
| Modifier and Type | Class and Description |
|---|---|
class |
EmbeddedSource
Simple source used to allow direct access to the channel for the Embedded
Agent.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractChannel |
class |
AbstractChannelSelector |
class |
BasicChannelSemantics
An implementation of basic
Channel semantics, including the
implied thread-local semantics of the Transaction class,
which is required to extend BasicTransactionSemantics. |
class |
ChannelProcessor
|
class |
MemoryChannel
MemoryChannel is the recommended channel to use when speeds which
writing to disk is impractical is required or durability of data is not
required.
|
class |
MultiplexingChannelSelector |
class |
PseudoTxnMemoryChannel
A capacity-capped
Channel implementation that supports in-memory
buffering and delivery of events. |
class |
ReplicatingChannelSelector
Replicating channel selector.
|
class |
SpillableMemoryChannel
SpillableMemoryChannel will use main memory for buffering events until it has reached capacity.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileChannel
A durable
Channel implementation that uses the local file system for
its storage. |
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcChannel
A JDBC based channel implementation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaChannel |
| Modifier and Type | Interface and Description |
|---|---|
interface |
MonitorService
Interface that any monitoring service should implement.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GangliaServer
A Ganglia server that polls JMX based at a configured frequency (defaults to
once every 60 seconds).
|
| Modifier and Type | Class and Description |
|---|---|
class |
HTTPMetricsServer
A Monitor service implementation that runs a web server on a configurable
port and returns the metrics for components in JSON format.
|
| Modifier and Type | Interface and Description |
|---|---|
static interface |
Interceptor.Builder
Builder implementations MUST have a no-arg constructor
|
interface |
RegexExtractorInterceptorSerializer
Serializer for serializing groups matched by the
RegexExtractorInterceptor |
| Modifier and Type | Class and Description |
|---|---|
static class |
HostInterceptor.Builder
Builder which builds new instances of the HostInterceptor.
|
static class |
RegexExtractorInterceptor.Builder |
class |
RegexExtractorInterceptorMillisSerializer
Serializer that converts the passed in value into milliseconds using the
specified formatting pattern
|
class |
RegexExtractorInterceptorPassThroughSerializer
Serializer that simply returns the passed in value
|
static class |
RegexFilteringInterceptor.Builder
Builder which builds new instance of the StaticInterceptor.
|
static class |
RemoveHeaderInterceptor.Builder
Builder which builds new instances of the
RemoveHeaderInterceptor. |
static class |
SearchAndReplaceInterceptor.Builder |
static class |
StaticInterceptor.Builder
Builder which builds new instance of the StaticInterceptor.
|
static class |
TimestampInterceptor.Builder
Builder which builds new instances of the TimestampInterceptor.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAvroEventSerializer<T>
This is a helper class provided to make it straightforward to serialize
Flume events into Avro data.
|
class |
FlumeEventAvroEventSerializer |
| Modifier and Type | Interface and Description |
|---|---|
static interface |
LoadBalancingSinkProcessor.SinkSelector
An interface that allows the LoadBalancingSinkProcessor to use
a load-balancing strategy such as round-robin, random distribution etc.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractRpcSink
This sink provides the basic RPC functionality for Flume.
|
class |
AbstractSinkProcessor
A convenience base class for sink processors.
|
class |
AbstractSinkSelector |
class |
AvroSink
A
Sink implementation that can send events to an RPC server (such as
Flume's AvroSource). |
class |
DefaultSinkProcessor
Default sink processor that only accepts a single sink, passing on process
results without any additional handling.
|
class |
FailoverSinkProcessor
FailoverSinkProcessor maintains a prioritized list of sinks,
guarranteeing that so long as one is available events will be processed.
|
class |
LoadBalancingSinkProcessor
Provides the ability to load-balance flow over multiple sinks.
|
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 |
SinkGroup
Configuration concept for handling multiple sinks working together.
|
class |
ThriftSink
A
Sink implementation that can send events to an RPC server (such as
Flume's ThriftSource). |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ElasticSearchEventSerializer
Interface for an event serializer which serializes the headers and body of an
event to write them to ElasticSearch.
|
interface |
ElasticSearchIndexRequestBuilderFactory
Interface for creating ElasticSearch
IndexRequestBuilder instances
from serialized flume events. |
interface |
IndexNameBuilder |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractElasticSearchIndexRequestBuilderFactory
Abstract base class for custom implementations of
ElasticSearchIndexRequestBuilderFactory. |
class |
ElasticSearchDynamicSerializer
Basic serializer that serializes the event body and header fields into
individual fields
|
class |
ElasticSearchLogStashEventSerializer
Serialize flume events into the same format LogStash uses
|
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.
|
class |
EventSerializerIndexRequestBuilderFactory
Default implementation of
ElasticSearchIndexRequestBuilderFactory. |
class |
SimpleIndexNameBuilder |
class |
TimeBasedIndexNameBuilder
Default index name builder.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ElasticSearchClient
Interface for an ElasticSearch client which is responsible for sending bulks
of events to ElasticSearch.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ElasticSearchRestClient
Rest ElasticSearch client which is responsible for sending bulks of events to
ElasticSearch using ElasticSearch HTTP API.
|
class |
ElasticSearchTransportClient |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AsyncHbaseEventSerializer
Interface for an event serializer which serializes the headers and body
of an event to write them to hbase.
|
interface |
HbaseEventSerializer
Interface for an event serializer which serializes the headers and body
of an event to write them to hbase.
|
| 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.
|
class |
RegexHbaseEventSerializer
An
HbaseEventSerializer which parses columns based on a supplied
regular expression and column name list. |
class |
SimpleAsyncHbaseEventSerializer
A simple serializer to be used with the AsyncHBaseSink
that returns puts from an event, by writing the event
body into it.
|
class |
SimpleHbaseEventSerializer
A simple serializer that returns puts from an event, by writing the event
body into it.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
HDFSWriter |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractHDFSWriter |
class |
AvroEventSerializer
This class serializes Flume events into Avro data files.
|
class |
HDFSCompressedDataStream |
class |
HDFSDataStream |
class |
HDFSEventSink |
class |
HDFSSequenceFile |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HiveEventSerializer |
| Modifier and Type | Class and Description |
|---|---|
class |
HiveDelimitedTextSerializer
Forwards the incoming event body to Hive unmodified
Sets up the delimiter and the field to column mapping
|
class |
HiveJsonSerializer
Forwards the incoming event body to Hive unmodified
Sets up the delimiter and the field to column mapping
|
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 | Interface and Description |
|---|---|
interface |
MorphlineHandler
Interface to load Flume events into Solr
|
| Modifier and Type | Class and Description |
|---|---|
class |
BlobHandler
BlobHandler for HTTPSource that returns event that contains the request
parameters as well as the Binary Large Object (BLOB) uploaded with this
request.
|
class |
MorphlineHandlerImpl
A
MorphlineHandler that processes it's events using a morphline Command chain. |
static class |
MorphlineInterceptor.Builder
Builder implementations MUST have a public no-arg constructor
|
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. |
static class |
UUIDInterceptor.Builder
Builder implementations MUST have a public no-arg constructor
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractEventDrivenSource
Base class which ensures sub-classes will inherit all the properties
of BasicSourceSemantics.
|
class |
AbstractPollableSource
Base class which ensures sub-classes will inherit all the properties
of BasicSourceSemantics in addition to:
Ensuring when configure/start throw an exception process will not
be called
Ensure that process will not be called unless configure and start
have successfully been called
|
class |
AvroSource
A
Source implementation that receives Avro events from clients that
implement AvroSourceProtocol. |
class |
BasicSourceSemantics
Alternative to AbstractSource, which:
Ensure configure cannot be called while started
Exceptions thrown during configure, start, stop put source in ERROR state
Exceptions thrown during start, stop will be logged but not re-thrown.
Exception in configure disables starting
|
class |
ExecSource
A
Source implementation that executes a Unix process and turns each
line of text into an event. |
class |
MultiportSyslogTCPSource |
class |
NetcatSource
A netcat-like source that listens on a given port and turns each line of text
into an event.
|
class |
SequenceGeneratorSource |
class |
SpoolDirectorySource |
class |
StressSource
StressSource is an internal load-generating source implementation
which is very useful for stress tests.
|
class |
SyslogTcpSource
Deprecated.
use
MultiportSyslogTCPSource instead. |
class |
SyslogUDPSource |
class |
ThriftSource |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroLegacySource
A
Source implementation that receives Avro events from Avro sink of
Flume OG |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HTTPSourceHandler |
| Modifier and Type | Class and Description |
|---|---|
class |
BLOBHandler
BLOBHandler for HTTPSource that accepts any binary stream of data as event.
|
class |
HTTPSource
A source which accepts Flume Events by HTTP POST and GET.
|
class |
JSONHandler
JSONHandler for HTTPSource that accepts an array of events.
|
| 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 |
ScribeSource
Flume should adopt the Scribe entry
LogEntry from existing
Scribe system. |
| Modifier and Type | Class and Description |
|---|---|
class |
TaildirSource |
| Modifier and Type | Class and Description |
|---|---|
class |
ThriftLegacySource |
| 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.
|
| Modifier and Type | Interface and Description |
|---|---|
static interface |
EventValidator.Builder |
Copyright © 2009-2017 Apache Software Foundation. All Rights Reserved.