Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Org.apache.flume.sink Classes and Interfaces - 84 results found.
NameDescriptionTypePackageFramework
AbstractElasticSearchIndexRequestBuilderFactoryAbstract base class for custom implementations of ElasticSearchIndexRequestBuilderFactory.Classorg.apache.flume.sink.elasticsearchFlume
AbstractHDFSWriterClassorg.apache.flume.sink.hdfsFlume
AbstractRpcSinkThis sink provides the basic RPC functionality for Flume.Classorg.apache.flume.sinkFlume
AbstractSinkNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.sinkFlume
AbstractSinkProcessorA convenience base class for sink processors.Classorg.apache.flume.sinkFlume
AbstractSinkSelectorClassorg.apache.flume.sinkFlume
AsyncHbaseEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to hbase.Interfaceorg.apache.flume.sink.hbaseFlume
AsyncHBaseSinkA simple sink which reads events from a channel and writes them to HBase.Classorg.apache.flume.sink.hbaseFlume
AvroEventSerializer This class serializes Flume events into Avro data files.Classorg.apache.flume.sink.hdfsFlume
AvroEventSerializer .BuilderConstructor SummaryAvroEventSerializer.Classorg.apache.flume.sink.hdfs.AvroEventSerializerFlume
AvroSink A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).Classorg.apache.flume.sinkFlume
BatchAwareThis interface allows for implementing HBase serializers that are aware of batching.Interfaceorg.apache.flume.sink.hbaseFlume
BlobDeserializerA deserializer that reads a Binary Large Object (BLOB) per event, typically one BLOB per file; To be used in conjunction with Flume SpoolDirectorySource.Classorg.apache.flume.sink.solr.morphlineFlume
BlobDeserializer .BuilderBuilder implementations MUST have a public no-arg constructorConstructor SummaryBlobDeserializer.Classorg.apache.flume.sink.solr.morphline.BlobDeserializerFlume
BlobHandlerBlobHandler for HTTPSource that returns event that contains the request parameters as well as the Binary Large Object (BLOB) uploaded with thisClassorg.apache.flume.sink.solr.morphlineFlume
BucketClosedExceptionClassorg.apache.flume.sink.hdfsFlume
ContentBuilderUtilClassorg.apache.flume.sink.elasticsearchFlume
DefaultSinkFactoryClassorg.apache.flume.sinkFlume
DefaultSinkProcessorDefault sink processor that only accepts a single sink, passing on process results without any additional handling.Classorg.apache.flume.sinkFlume
ElasticSearchClientInterface for an ElasticSearch client which is responsible for sending bulks of events to ElasticSearch.Interfaceorg.apache.flume.sink.elasticsearch.clientFlume
ElasticSearchClientFactoryInternal ElasticSearch client factory.Classorg.apache.flume.sink.elasticsearch.clientFlume
ElasticSearchDynamicSerializerBasic serializer that serializes the event body and header fields into A best effort will be used to determine the content-type, if it cannot beClassorg.apache.flume.sink.elasticsearchFlume
ElasticSearchEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to ElasticSearch.Interfaceorg.apache.flume.sink.elasticsearchFlume
ElasticSearchIndexRequestBuilderFactoryInterface for creating ElasticSearch IndexRequestBuilder instances from serialized flume events.Interfaceorg.apache.flume.sink.elasticsearchFlume
ElasticSearchLogStashEventSerializerSerialize flume events into the same format LogStash uses This can be used to send events to ElasticSearch and use clients such asClassorg.apache.flume.sink.elasticsearchFlume
ElasticSearchRestClientRest ElasticSearch client which is responsible for sending bulks of events to ElasticSearch using ElasticSearch HTTP API.Classorg.apache.flume.sink.elasticsearch.clientFlume
ElasticSearchSinkA sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.Classorg.apache.flume.sink.elasticsearchFlume
ElasticSearchSinkConstantsClassorg.apache.flume.sink.elasticsearchFlume
ElasticSearchTransportClientClassorg.apache.flume.sink.elasticsearch.clientFlume
EventSerializerIndexRequestBuilderFactoryDefault implementation of ElasticSearchIndexRequestBuilderFactory.Classorg.apache.flume.sink.elasticsearchFlume
FailoverSinkProcessorFailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed.Classorg.apache.flume.sinkFlume
HbaseEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to hbase.Interfaceorg.apache.flume.sink.hbaseFlume
HBaseSinkA simple sink which reads events from a channel and writes them to HBase.Classorg.apache.flume.sink.hbaseFlume
HBaseSinkConfigurationConstantsClassorg.apache.flume.sink.hbaseFlume
HBaseSinkSecurityManagerClass to handle logging into HBase with the credentials passed in.Classorg.apache.flume.sink.hbaseFlume
HDFSCompressedDataStreamClassorg.apache.flume.sink.hdfsFlume
HDFSDataStreamClassorg.apache.flume.sink.hdfsFlume
HDFSEventSinkClassorg.apache.flume.sink.hdfsFlume
HDFSSequenceFileClassorg.apache.flume.sink.hdfsFlume
HDFSTextSerializerClassorg.apache.flume.sink.hdfsFlume
HDFSTextSerializer .BuilderConstructor SummaryHDFSTextSerializer.Classorg.apache.flume.sink.hdfs.HDFSTextSerializerFlume
HDFSWritableSerializerClassorg.apache.flume.sink.hdfsFlume
HDFSWritableSerializer .BuilderConstructor SummaryHDFSWritableSerializer.Classorg.apache.flume.sink.hdfs.HDFSWritableSerializerFlume
HDFSWriterInterfaceorg.apache.flume.sink.hdfsFlume
HDFSWriterFactoryClassorg.apache.flume.sink.hdfsFlume
IndexNameBuilderInterfaceorg.apache.flume.sink.elasticsearchFlume
IRCSinkClassorg.apache.flume.sink.ircFlume
IRCSink .IRCConnectionListenerFields inherited from interface org.Classorg.apache.flume.sink.irc.IRCSinkFlume
KerberosUserSimple Pair class used to define a unique (principal, keyTab) combination.Classorg.apache.flume.sink.hdfsFlume
LoadBalancingSinkProcessorProvides the ability to load-balance flow over multiple sinks.Classorg.apache.flume.sinkFlume
LoadBalancingSinkProcessor .SinkSelector An interface that allows the LoadBalancingSinkProcessor to use a load-balancing strategy such as round-robin, random distribution etc.Interfaceorg.apache.flume.sink.LoadBalancingSinkProcessorFlume
LoggerSink A Sink implementation that logs all events received at the INFO level to the org.Classorg.apache.flume.sinkFlume
MorphlineHandlerInterfaceorg.apache.flume.sink.solr.morphlineFlume
MorphlineHandlerImplA MorphlineHandler that processes it's events using a morphline Command chain.Classorg.apache.flume.sink.solr.morphlineFlume
MorphlineInterceptorFlume Interceptor that executes a morphline on events that are intercepted.Classorg.apache.flume.sink.solr.morphlineFlume
MorphlineInterceptor .BuilderBuilder implementations MUST have a public no-arg constructorConstructor SummaryMorphlineInterceptor.Classorg.apache.flume.sink.solr.morphline.MorphlineInterceptorFlume
MorphlineSinkClassorg.apache.flume.sink.solr.morphlineFlume
MorphlineSolrSinkFlume sink that extracts search documents from Flume events, processes them using a morphline Command chain, and loads them into Apache Solr.Classorg.apache.flume.sink.solr.morphlineFlume
NullSink A Sink implementation that simply discards all events it receives.Classorg.apache.flume.sinkFlume
RegexHbaseEventSerializerAn HbaseEventSerializer which parses columns based on a supplied regular expression and column name list.Classorg.apache.flume.sink.hbaseFlume
RollingFileSinkNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.sinkFlume
RoundRobinListClassorg.apache.flume.sink.elasticsearch.clientFlume
SequenceFileSerializerInterfaceorg.apache.flume.sink.hdfsFlume
SequenceFileSerializer .BuilderKnows how to construct this output formatter.Interfaceorg.apache.flume.sink.hdfs.SequenceFileSerializerFlume
SequenceFileSerializer .RecordA key-value pair making up a record in an HDFS SequenceFileConstructor SummarySequenceFileSerializer.Classorg.apache.flume.sink.hdfs.SequenceFileSerializerFlume
SequenceFileSerializerFactoryConstructor SummarySequenceFileSerializerFactory()Methods inherited from class java.Classorg.apache.flume.sink.hdfsFlume
SequenceFileSerializerTypeenum SequenceFileSerializerTypeextends EnumEnum Constant SummaryOtherClassorg.apache.flume.sink.hdfsFlume
SimpleAsyncHbaseEventSerializerA simple serializer to be used with the AsyncHBaseSink that returns puts from an event, by writing the eventClassorg.apache.flume.sink.hbaseFlume
SimpleHbaseEventSerializerA simple serializer that returns puts from an event, by writing the event body into it.Classorg.apache.flume.sink.hbaseFlume
SimpleHbaseEventSerializer .KeyTypeClassorg.apache.flume.sink.hbase.SimpleHbaseEventSerializerFlume
SimpleIndexNameBuilderClassorg.apache.flume.sink.elasticsearchFlume
SimpleRowKeyGeneratorUtility class for users to generate their own keys.Classorg.apache.flume.sink.hbaseFlume
Sink A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according toInterfaceorg.apache.flumeFlume
Sink .StatusClassorg.apache.flume.SinkFlume
SinkFactoryInterfaceorg.apache.flumeFlume
SinkGroupConfiguration concept for handling multiple sinks working together.Classorg.apache.flume.sinkFlume
SinkProcessor Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunnerInterfaceorg.apache.flumeFlume
SinkProcessorFactoryClassorg.apache.flume.sinkFlume
SinkRunner A driver for sinks that polls them, attempting to process events if any are available in theClassorg.apache.flumeFlume
SinkRunner .PollingRunnerRunnable that polls a SinkProcessor and manages event delivery notification,Classorg.apache.flume.SinkRunnerFlume
ThriftSink A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource).Classorg.apache.flume.sinkFlume
TimeBasedIndexNameBuilderDefault index name builder.Classorg.apache.flume.sink.elasticsearchFlume
UUIDInterceptorFlume Interceptor that sets a universally unique identifier on all events that are intercepted.Classorg.apache.flume.sink.solr.morphlineFlume
UUIDInterceptor .BuilderBuilder implementations MUST have a public no-arg constructorConstructor SummaryUUIDInterceptor.Classorg.apache.flume.sink.solr.morphline.UUIDInterceptorFlume