Search Java Classes and Packages
#Org.apache.flume.sink Classes and Interfaces - 84 results found.
| 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 Enum | 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 |