Name | Description | Type | Package | Framework |
AbstractElasticSearchIndexRequestBuilderFactory | Abstract base class for custom implementations of ElasticSearchIndexRequestBuilderFactory. | Class | org.apache.flume.sink.elasticsearch | Flume |
|
AbstractHDFSWriter | | Class | org.apache.flume.sink.hdfs | Flume |
|
AbstractRpcSink | This sink provides the basic RPC functionality for Flume. | Class | org.apache.flume.sink | Flume |
|
AbstractSink | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.sink | Flume |
|
AbstractSinkProcessor | A convenience base class for sink processors. | Class | org.apache.flume.sink | Flume |
|
AbstractSinkSelector | | Class | org.apache.flume.sink | Flume |
|
AsyncHbaseEventSerializer | Interface for an event serializer which serializes the headers and body of an event to write them to hbase. | Interface | org.apache.flume.sink.hbase | Flume |
|
AsyncHBaseSink | A simple sink which reads events from a channel and writes them to HBase. | Class | org.apache.flume.sink.hbase | Flume |
|
AvroEventSerializer | This class serializes Flume events into Avro data files. | Class | org.apache.flume.sink.hdfs | Flume |
|
AvroEventSerializer .Builder | Constructor SummaryAvroEventSerializer. | Class | org.apache.flume.sink.hdfs.AvroEventSerializer | Flume |
|
AvroSink | A Sink implementation that can send events to an RPC server (such as Flume's AvroSource). | Class | org.apache.flume.sink | Flume |
|
BatchAware | This interface allows for implementing HBase serializers that are aware of batching. | Interface | org.apache.flume.sink.hbase | Flume |
|
BlobDeserializer | A deserializer that reads a Binary Large Object (BLOB) per event, typically one BLOB per file; To be used in conjunction with Flume SpoolDirectorySource. | Class | org.apache.flume.sink.solr.morphline | Flume |
|
BlobDeserializer .Builder | Builder implementations MUST have a public no-arg constructorConstructor SummaryBlobDeserializer. | Class | org.apache.flume.sink.solr.morphline.BlobDeserializer | Flume |
|
BlobHandler | BlobHandler for HTTPSource that returns event that contains the request parameters as well as the Binary Large Object (BLOB) uploaded with this | Class | org.apache.flume.sink.solr.morphline | Flume |
|
BucketClosedException | | Class | org.apache.flume.sink.hdfs | Flume |
|
ContentBuilderUtil | | Class | org.apache.flume.sink.elasticsearch | Flume |
|
DefaultSinkFactory | | Class | org.apache.flume.sink | Flume |
|
DefaultSinkProcessor | Default sink processor that only accepts a single sink, passing on process results without any additional handling. | Class | org.apache.flume.sink | Flume |
|
ElasticSearchClient | Interface for an ElasticSearch client which is responsible for sending bulks of events to ElasticSearch. | Interface | org.apache.flume.sink.elasticsearch.client | Flume |
|
ElasticSearchClientFactory | Internal ElasticSearch client factory. | Class | org.apache.flume.sink.elasticsearch.client | Flume |
|
ElasticSearchDynamicSerializer | Basic serializer that serializes the event body and header fields into A best effort will be used to determine the content-type, if it cannot be | Class | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchEventSerializer | Interface for an event serializer which serializes the headers and body of an event to write them to ElasticSearch. | Interface | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchIndexRequestBuilderFactory | Interface for creating ElasticSearch IndexRequestBuilder instances from serialized flume events. | Interface | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchLogStashEventSerializer | Serialize flume events into the same format LogStash uses This can be used to send events to ElasticSearch and use clients such as | Class | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchRestClient | Rest ElasticSearch client which is responsible for sending bulks of events to ElasticSearch using ElasticSearch HTTP API. | Class | org.apache.flume.sink.elasticsearch.client | Flume |
|
ElasticSearchSink | A sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github. | Class | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchSinkConstants | | Class | org.apache.flume.sink.elasticsearch | Flume |
|
ElasticSearchTransportClient | | Class | org.apache.flume.sink.elasticsearch.client | Flume |
|
EventSerializerIndexRequestBuilderFactory | Default implementation of ElasticSearchIndexRequestBuilderFactory. | Class | org.apache.flume.sink.elasticsearch | Flume |
|
FailoverSinkProcessor | FailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed. | Class | org.apache.flume.sink | Flume |
|
HbaseEventSerializer | Interface for an event serializer which serializes the headers and body of an event to write them to hbase. | Interface | org.apache.flume.sink.hbase | Flume |
|
HBaseSink | A simple sink which reads events from a channel and writes them to HBase. | Class | org.apache.flume.sink.hbase | Flume |
|
HBaseSinkConfigurationConstants | | Class | org.apache.flume.sink.hbase | Flume |
|
HBaseSinkSecurityManager | Class to handle logging into HBase with the credentials passed in. | Class | org.apache.flume.sink.hbase | Flume |
|
HDFSCompressedDataStream | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSDataStream | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSEventSink | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSSequenceFile | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSTextSerializer | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSTextSerializer .Builder | Constructor SummaryHDFSTextSerializer. | Class | org.apache.flume.sink.hdfs.HDFSTextSerializer | Flume |
|
HDFSWritableSerializer | | Class | org.apache.flume.sink.hdfs | Flume |
|
HDFSWritableSerializer .Builder | Constructor SummaryHDFSWritableSerializer. | Class | org.apache.flume.sink.hdfs.HDFSWritableSerializer | Flume |
|
HDFSWriter | | Interface | org.apache.flume.sink.hdfs | Flume |
|
HDFSWriterFactory | | Class | org.apache.flume.sink.hdfs | Flume |
|
IndexNameBuilder | | Interface | org.apache.flume.sink.elasticsearch | Flume |
|
IRCSink | | Class | org.apache.flume.sink.irc | Flume |
|
IRCSink .IRCConnectionListener | Fields inherited from interface org. | Class | org.apache.flume.sink.irc.IRCSink | Flume |
|
KerberosUser | Simple Pair class used to define a unique (principal, keyTab) combination. | Class | org.apache.flume.sink.hdfs | Flume |
|
LoadBalancingSinkProcessor | Provides the ability to load-balance flow over multiple sinks. | Class | org.apache.flume.sink | Flume |
|
LoadBalancingSinkProcessor .SinkSelector | An interface that allows the LoadBalancingSinkProcessor to use a load-balancing strategy such as round-robin, random distribution etc. | Interface | org.apache.flume.sink.LoadBalancingSinkProcessor | Flume |
|
LoggerSink | A Sink implementation that logs all events received at the INFO level to the org. | Class | org.apache.flume.sink | Flume |
|
MorphlineHandler | | Interface | org.apache.flume.sink.solr.morphline | Flume |
|
MorphlineHandlerImpl | A MorphlineHandler that processes it's events using a morphline Command chain. | Class | org.apache.flume.sink.solr.morphline | Flume |
|
MorphlineInterceptor | Flume Interceptor that executes a morphline on events that are intercepted. | Class | org.apache.flume.sink.solr.morphline | Flume |
|
MorphlineInterceptor .Builder | Builder implementations MUST have a public no-arg constructorConstructor SummaryMorphlineInterceptor. | Class | org.apache.flume.sink.solr.morphline.MorphlineInterceptor | Flume |
|
MorphlineSink | | Class | org.apache.flume.sink.solr.morphline | Flume |
|
MorphlineSolrSink | Flume sink that extracts search documents from Flume events, processes them using a morphline Command chain, and loads them into Apache Solr. | Class | org.apache.flume.sink.solr.morphline | Flume |
|
NullSink | A Sink implementation that simply discards all events it receives. | Class | org.apache.flume.sink | Flume |
|
RegexHbaseEventSerializer | An HbaseEventSerializer which parses columns based on a supplied regular expression and column name list. | Class | org.apache.flume.sink.hbase | Flume |
|
RollingFileSink | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.sink | Flume |
|
RoundRobinList | | Class | org.apache.flume.sink.elasticsearch.client | Flume |
|
SequenceFileSerializer | | Interface | org.apache.flume.sink.hdfs | Flume |
|
SequenceFileSerializer .Builder | Knows how to construct this output formatter. | Interface | org.apache.flume.sink.hdfs.SequenceFileSerializer | Flume |
|
SequenceFileSerializer .Record | A key-value pair making up a record in an HDFS SequenceFileConstructor SummarySequenceFileSerializer. | Class | org.apache.flume.sink.hdfs.SequenceFileSerializer | Flume |
|
SequenceFileSerializerFactory | Constructor SummarySequenceFileSerializerFactory()Methods inherited from class java. | Class | org.apache.flume.sink.hdfs | Flume |
|
SequenceFileSerializerType | enum SequenceFileSerializerTypeextends EnumEnum Constant SummaryOther | Class | org.apache.flume.sink.hdfs | Flume |
|
SimpleAsyncHbaseEventSerializer | A simple serializer to be used with the AsyncHBaseSink that returns puts from an event, by writing the event | Class | org.apache.flume.sink.hbase | Flume |
|
SimpleHbaseEventSerializer | A simple serializer that returns puts from an event, by writing the event body into it. | Class | org.apache.flume.sink.hbase | Flume |
|
SimpleHbaseEventSerializer .KeyType | | Class | org.apache.flume.sink.hbase.SimpleHbaseEventSerializer | Flume |
|
SimpleIndexNameBuilder | | Class | org.apache.flume.sink.elasticsearch | Flume |
|
SimpleRowKeyGenerator | Utility class for users to generate their own keys. | Class | org.apache.flume.sink.hbase | Flume |
|
Sink | A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according to | Interface | org.apache.flume | Flume |
|
Sink .Status | | Class | org.apache.flume.Sink | Flume |
|
SinkFactory | | Interface | org.apache.flume | Flume |
|
SinkGroup | Configuration concept for handling multiple sinks working together. | Class | org.apache.flume.sink | Flume |
|
SinkProcessor | Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunner | Interface | org.apache.flume | Flume |
|
SinkProcessorFactory | | Class | org.apache.flume.sink | Flume |
|
SinkRunner | A driver for sinks that polls them, attempting to process events if any are available in the | Class | org.apache.flume | Flume |
|
SinkRunner .PollingRunner | Runnable that polls a SinkProcessor and manages event delivery notification, | Class | org.apache.flume.SinkRunner | Flume |
|
ThriftSink | A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource). | Class | org.apache.flume.sink | Flume |
|
TimeBasedIndexNameBuilder | Default index name builder. | Class | org.apache.flume.sink.elasticsearch | Flume |
|
UUIDInterceptor | Flume Interceptor that sets a universally unique identifier on all events that are intercepted. | Class | org.apache.flume.sink.solr.morphline | Flume |
|
UUIDInterceptor .Builder | Builder implementations MUST have a public no-arg constructorConstructor SummaryUUIDInterceptor. | Class | org.apache.flume.sink.solr.morphline.UUIDInterceptor | Flume |