Search Java Classes and Packages
#Org.apache.flume Classes and Interfaces - 461 results found.
| Name | Description | Type | Package | Framework |
| AbstractAvroEventSerializer | This is a helper class provided to make it straightforward to serialize Flume events into Avro data. | Class | org.apache.flume.serialization | Flume |
| AbstractChannel | Class | org.apache.flume.channel | Flume | |
| AbstractChannelSelector | Class | org.apache.flume.channel | Flume | |
| AbstractConfigurationProvider | Class | org.apache.flume.node | Flume | |
| AbstractElasticSearchIndexRequestBuilderFactory | Abstract base class for custom implementations of ElasticSearchIndexRequestBuilderFactory. | Class | org.apache.flume.sink.elasticsearch | Flume |
| AbstractEventDrivenSource | Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics. | Class | org.apache.flume.source | Flume |
| AbstractHDFSWriter | Class | org.apache.flume.sink.hdfs | Flume | |
| AbstractPollableSource | Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to: | Class | org.apache.flume.source | Flume |
| AbstractRpcClient | Class | org.apache.flume.api | 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 | |
| AbstractSource | Class | org.apache.flume.source | Flume | |
| AESCTRNoPaddingProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| AESCTRNoPaddingProvider .DecryptorBuilder | Fields inherited from class org. | Class | org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider | Flume |
| AESCTRNoPaddingProvider .EncryptorBuilder | Fields inherited from class org. | Class | org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider | Flume |
| Application | Class | org.apache.flume.node | 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 |
| AvroCLIClient | Class | org.apache.flume.client.avro | Flume | |
| AvroEventDeserializer | A deserializer that parses Avro container files, generating one Flume event per record in the Avro file, and storing binary avro-encoded records in | Class | org.apache.flume.serialization | Flume |
| AvroEventDeserializer .AvroSchemaType | Class | org.apache.flume.serialization.AvroEventDeserializer | Flume | |
| AvroEventDeserializer .Builder | Constructor SummaryAvroEventDeserializer. | Class | org.apache.flume.serialization.AvroEventDeserializer | 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 |
| AvroEventSerializerConfigurationConstants | Class | org.apache.flume.serialization | Flume | |
| AvroLegacySource | A Source implementation that receives Avro events from Avro sink of Configuration options | Class | org.apache.flume.source.avroLegacy | Flume |
| AvroSink | A Sink implementation that can send events to an RPC server (such as Flume's AvroSource). | Class | org.apache.flume.sink | Flume |
| AvroSource | A Source implementation that receives Avro events from clients that implement AvroSourceProtocol. | Class | org.apache.flume.source | Flume |
| BadCheckpointException | Exception thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written. | Class | org.apache.flume.channel.file | Flume |
| BasicChannelSemantics | An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class, | Class | org.apache.flume.channel | Flume |
| BasicConfigurationConstants | Class | org.apache.flume.conf | Flume | |
| BasicSourceSemantics | Alternative to AbstractSource, which: Ensure configure cannot be called while startedExceptions thrown during configure, start, stop put source in ERROR stateExceptions thrown during start, stop will be logged but not re-thrown. | Class | org.apache.flume.source | Flume |
| BasicTransactionSemantics | An implementation of basic Transaction semantics designed to work in concert with BasicChannelSemantics to simplify | Class | org.apache.flume.channel | Flume |
| BasicTransactionSemantics .State | The state of the Transaction to which it belongs. | Class | org.apache.flume.channel.BasicTransactionSemantics | 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 |
| BodyTextEventSerializer | This class simply writes the body of the event to the output stream and appends a newline after each event. | Class | org.apache.flume.serialization | Flume |
| BodyTextEventSerializer .Builder | Constructor SummaryBodyTextEventSerializer. | Class | org.apache.flume.serialization.BodyTextEventSerializer | Flume |
| BucketClosedException | Class | org.apache.flume.sink.hdfs | Flume | |
| BucketPath | Class | org.apache.flume.formatter.output | Flume | |
| Channel | A channel connects a Source to a Sink. | Interface | org.apache.flume | Flume |
| ChannelConfiguration | Class | org.apache.flume.conf.channel | Flume | |
| ChannelConfiguration .ChannelConfigurationType | Class | org.apache.flume.conf.channel.ChannelConfiguration | Flume | |
| ChannelCounter | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.instrumentation | Flume |
| ChannelCounterMBean | This interface represents a channel counter mbean. | Interface | org.apache.flume.instrumentation | Flume |
| ChannelException | A channel exception is raised whenever a channel operation fails. | Class | org.apache.flume | Flume |
| ChannelFactory | Interface | org.apache.flume | Flume | |
| ChannelFullException | Class | org.apache.flume | Flume | |
| ChannelProcessor | A channel processor exposes operations to put Events into Channels. | Class | org.apache.flume.channel | Flume |
| ChannelProcessorCounter | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.instrumentation | Flume |
| ChannelSelector | Allows the selection of a subset of channels from the given set based on its implementation policy. | Interface | org.apache.flume | Flume |
| ChannelSelectorConfiguration | Class | org.apache.flume.conf.channel | Flume | |
| ChannelSelectorConfiguration .ChannelSelectorConfigurationType | Class | org.apache.flume.conf.channel.ChannelSelectorConfiguration | Flume | |
| ChannelSelectorFactory | Class | org.apache.flume.channel | Flume | |
| ChannelSelectorType | enum ChannelSelectorTypeextends Enum | Class | org.apache.flume.conf.channel | Flume |
| ChannelType | enum ChannelTypeextends Enum | Class | org.apache.flume.conf.channel | Flume |
| ChannelUtils | A collection of utilities for interacting with Channel objects. | Class | org.apache.flume.channel | Flume |
| CheckpointRebuilder | Class | org.apache.flume.channel.file | Flume | |
| CipherProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| CipherProvider .Decryptor | Class | org.apache.flume.channel.file.encryption.CipherProvider | Flume | |
| CipherProvider .Decryptor .Builder | Class | org.apache.flume.channel.file.encryption.CipherProvider.Decryptor | Flume | |
| CipherProvider .Encryptor | Class | org.apache.flume.channel.file.encryption.CipherProvider | Flume | |
| CipherProvider .Encryptor .Builder | Builder implementations MUST have a no-arg constructorConstructor SummaryCipherProvider. | Class | org.apache.flume.channel.file.encryption.CipherProvider.Encryptor | Flume |
| CipherProviderFactory | Class | org.apache.flume.channel.file.encryption | Flume | |
| CipherProviderType | enum CipherProviderTypeextends Enum | Class | org.apache.flume.channel.file.encryption | Flume |
| Clock | Facade for System. | Interface | org.apache.flume | Flume |
| ComponentConfiguration | Abstract implementation of the Component Configuration Manager. | Class | org.apache.flume.conf | Flume |
| ComponentConfiguration .ComponentType | Class | org.apache.flume.conf.ComponentConfiguration | Flume | |
| ComponentConfigurationFactory | Class | org.apache.flume.conf | Flume | |
| Configurable | Any class marked as Configurable may have a context including its sub-configuration passed to it, requesting it configure itself. | Interface | org.apache.flume.conf | Flume |
| ConfigurableComponent | Interface | org.apache.flume.conf | Flume | |
| Configurables | Methods for working with Configurables. | Class | org.apache.flume.conf | Flume |
| ConfigurationConstants | Contains configuration keys used by the JDBC channel implementation. | Class | org.apache.flume.channel.jdbc | Flume |
| ConfigurationException | Class | org.apache.flume.conf | Flume | |
| ConfigurationProvider | Interface | org.apache.flume.node | Flume | |
| Constants | Class | org.apache.flume | Flume | |
| ContentBuilderUtil | Class | org.apache.flume.sink.elasticsearch | Flume | |
| Context | The context is a key-value store used to pass configuration information throughout the system. | Class | org.apache.flume | Flume |
| CorruptEventException | See Also:Serialized FormConstructor SummaryCorruptEventException() | Class | org.apache.flume.channel.file | Flume |
| CounterGroup | Used for counting events, collecting metrics, etc. | Class | org.apache.flume | Flume |
| DatabaseType | enum DatabaseTypeextends Enum | Class | org.apache.flume.channel.jdbc | Flume |
| DecodeErrorPolicy | enum DecodeErrorPolicyextends Enum | Class | org.apache.flume.serialization | Flume |
| DecryptionFailureException | Exception that is thrown when the channel is unable to decrypt an even read from the channel. | Class | org.apache.flume.channel.file.encryption | Flume |
| DefaultChannelFactory | Class | org.apache.flume.channel | Flume | |
| DefaultJMSMessageConverter | Converts BytesMessage, TextMessage, and ObjectMessage to a Flume Event. | Class | org.apache.flume.source.jms | Flume |
| DefaultJMSMessageConverter .Builder | Constructor SummaryDefaultJMSMessageConverter. | Class | org.apache.flume.source.jms.DefaultJMSMessageConverter | 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 |
| DefaultSourceFactory | Class | org.apache.flume.source | Flume | |
| DerbySchemaHandler | Schema handler for Derby Database. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| DirectMemoryUtils | Class | org.apache.flume.tools | Flume | |
| Dummy | Placeholder class so the git mirror does not leave out the src/main/java dirConstructor SummaryDummy() | Class | org.apache.flume | Flume |
| DurablePositionTracker | Class that stores object state in an avro container file. | Class | org.apache.flume.serialization | 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 | |
| EmbeddedAgent | EmbeddedAgent gives Flume users the ability to embed simple agents in applications. | Class | org.apache.flume.agent.embedded | Flume |
| EmbeddedAgentConfiguration | Stores publicly accessible configuration constants and private configuration constants and methods. | Class | org.apache.flume.agent.embedded | Flume |
| EmbeddedSource | Simple source used to allow direct access to the channel for the EmbeddedConstructor SummaryEmbeddedSource() | Class | org.apache.flume.agent.embedded | Flume |
| EncryptionConfiguration | Class | org.apache.flume.channel.file.encryption | Flume | |
| Event | Basic representation of a data object in Flume. | Interface | org.apache.flume | Flume |
| EventBuilder | Class | org.apache.flume.event | Flume | |
| EventDeliveryException | An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations. | Class | org.apache.flume | Flume |
| EventDeserializer | Establishes a contract for reading events stored in arbitrary formats from reliable, resettable streams. | Interface | org.apache.flume.serialization | Flume |
| EventDeserializer .Builder | Knows how to construct this deserializer. | Interface | org.apache.flume.serialization.EventDeserializer | Flume |
| EventDeserializerFactory | Class | org.apache.flume.serialization | Flume | |
| EventDeserializerType | enum EventDeserializerTypeextends Enum | Class | org.apache.flume.serialization | Flume |
| EventDrivenSource | A Source that does not need an external driver to poll for events to ingest; it provides its own event-driven | Interface | org.apache.flume | Flume |
| EventDrivenSourceRunner | Starts, stops, and manages event-driven sources. | Class | org.apache.flume.source | Flume |
| EventHelper | Class | org.apache.flume.event | Flume | |
| EventReader | A line reader produces a stream of lines for the AvroCLIClient to ingest into Flume. | Interface | org.apache.flume.client.avro | Flume |
| EventSerDe | A class that is able to both serialize and deserialize events. | Interface | org.apache.flume.serialization | Flume |
| EventSerDe .Builder | Knows how to construct this serde. | Interface | org.apache.flume.serialization.EventSerDe | Flume |
| EventSerializer | This interface provides callbacks for important serialization-related events. | Interface | org.apache.flume.serialization | Flume |
| EventSerializer .Builder | Knows how to construct this event serializer. | Interface | org.apache.flume.serialization.EventSerializer | Flume |
| EventSerializerFactory | Class | org.apache.flume.serialization | Flume | |
| EventSerializerIndexRequestBuilderFactory | Default implementation of ElasticSearchIndexRequestBuilderFactory. | Class | org.apache.flume.sink.elasticsearch | Flume |
| EventSerializerType | enum EventSerializerTypeextends Enum | Class | org.apache.flume.serialization | Flume |
| ExecSource | A Source implementation that executes a Unix process and turns each line of text into an event. | Class | org.apache.flume.source | Flume |
| ExecSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| FailoverRpcClient | Avro/Netty implementation of RpcClient which supports failover. | Class | org.apache.flume.api | 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 |
| FileChannel | A durable Channel implementation that uses the local file system for FileChannel works by writing all transactions to a set of directories | Class | org.apache.flume.channel.file | Flume |
| FileChannelConfiguration | Class | org.apache.flume.channel.file | Flume | |
| FileChannelIntegrityTool | Class | org.apache.flume.tools | Flume | |
| FlumeConfiguration | FlumeConfiguration is an in memory representation of the hierarchical configuration namespace required by the ConfigurationProvider. | Class | org.apache.flume.conf | Flume |
| FlumeConfiguration .AgentConfiguration | Class | org.apache.flume.conf.FlumeConfiguration | Flume | |
| FlumeConfiguration .ComponentNameAndConfigKey | Class | org.apache.flume.conf.FlumeConfiguration | Flume | |
| FlumeConfigurationError | Class | org.apache.flume.conf | Flume | |
| FlumeConfigurationError .ErrorOrWarning | Class | org.apache.flume.conf.FlumeConfigurationError | Flume | |
| FlumeConfigurationErrorType | enum FlumeConfigurationErrorTypeextends Enum | Class | org.apache.flume.conf | Flume |
| FlumeEventAvroEventSerializer | Class | org.apache.flume.serialization | Flume | |
| FlumeEventAvroEventSerializer .Builder | Constructor SummaryFlumeEventAvroEventSerializer. | Class | org.apache.flume.serialization.FlumeEventAvroEventSerializer | Flume |
| FlumeException | Base class of all flume exceptions. | Class | org.apache.flume | Flume |
| FlumeTool | Interface | org.apache.flume.tools | Flume | |
| FlumeToolsMain | Class | org.apache.flume.tools | Flume | |
| FlumeToolType | enum FlumeToolTypeextends Enum | Class | org.apache.flume.tools | Flume |
| GangliaServer | A Ganglia server that polls JMX based at a configured frequency (defaults to once every 60 seconds). | Class | org.apache.flume.instrumentation | Flume |
| GetJavaProperty | A generic way for querying Java properties. | Class | org.apache.flume.tools | 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 | |
| HeaderAndBodyTextEventSerializer | This class simply writes the body of the event to the output stream and appends a newline after each event. | Class | org.apache.flume.serialization | Flume |
| HeaderAndBodyTextEventSerializer .Builder | Constructor SummaryHeaderAndBodyTextEventSerializer. | Class | org.apache.flume.serialization.HeaderAndBodyTextEventSerializer | Flume |
| HostInfo | A convenience class that holds the property reference name along with the hostname and port number of a specified host address. | Class | org.apache.flume.api | Flume |
| HostInterceptor | Simple Interceptor class that sets the host name or IP on all events that are intercepted. | Class | org.apache.flume.interceptor | Flume |
| HostInterceptor .Builder | Builder which builds new instances of the HostInterceptor. | Class | org.apache.flume.interceptor.HostInterceptor | Flume |
| HostInterceptor .Constants | Class | org.apache.flume.interceptor.HostInterceptor | Flume | |
| HTTPBadRequestException | Exception thrown by an HTTP Handler if the request was not parsed correctly into an event because the request was not in the expected format. | Class | org.apache.flume.source.http | Flume |
| HTTPMetricsServer | A Monitor service implementation that runs a web server on a configurable port and returns the metrics for components in JSON format. | Class | org.apache.flume.instrumentation.http | Flume |
| HTTPServerConstraintUtil | Class | org.apache.flume.tools | Flume | |
| HTTPSource | A source which accepts Flume Events by HTTP POST and GET. | Class | org.apache.flume.source.http | Flume |
| HTTPSourceConfigurationConstants | Class | org.apache.flume.source.http | Flume | |
| HTTPSourceHandler | Interface | org.apache.flume.source.http | Flume | |
| IndexNameBuilder | Interface | org.apache.flume.sink.elasticsearch | Flume | |
| InitialContextFactory | Class | org.apache.flume.source.jms | Flume | |
| Interceptor | Interface | org.apache.flume.interceptor | Flume | |
| Interceptor .Builder | Builder implementations MUST have a no-arg constructorMethods inherited from interface org. | Interface | org.apache.flume.interceptor.Interceptor | Flume |
| InterceptorBuilderFactory | Factory used to register instances of Interceptors & their builders, as well as to instantiate the builders. | Class | org.apache.flume.interceptor | Flume |
| InterceptorChain | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.interceptor | Flume |
| InterceptorType | enum InterceptorTypeextends Enum | Class | org.apache.flume.interceptor | Flume |
| InterfaceAudience | Annotation to inform users of a package, class or method's intended audience. | Class | org.apache.flume.annotations | Flume |
| InterfaceAudience .LimitedPrivate | Intended only for the project(s) specified in the annotation. | Class | org.apache.flume.annotations.InterfaceAudience | Flume |
| InterfaceStability | Annotation to inform users of how much to rely on a particular package, class or method not changing over time. | Class | org.apache.flume.annotations | Flume |
| IRCSink | Class | org.apache.flume.sink.irc | Flume | |
| IRCSink .IRCConnectionListener | Fields inherited from interface org. | Class | org.apache.flume.sink.irc.IRCSink | Flume |
| JCEFileKeyProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| JCEFileKeyProvider .Builder | Constructor SummaryJCEFileKeyProvider. | Class | org.apache.flume.channel.file.encryption.JCEFileKeyProvider | Flume |
| JdbcChannel | A JDBC based channel implementation. | Class | org.apache.flume.channel.jdbc | Flume |
| JdbcChannelException | Class | org.apache.flume.channel.jdbc | Flume | |
| JdbcChannelProvider | Service provider interface for JDBC channel providers. | Interface | org.apache.flume.channel.jdbc | Flume |
| JdbcChannelProviderFactory | Class | org.apache.flume.channel.jdbc | Flume | |
| JdbcChannelProviderImpl | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| JdbcTransactionFactory | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| JdbcTransactionImpl | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| JMSDestinationLocator | enum JMSDestinationLocatorextends Enum | Class | org.apache.flume.source.jms | Flume |
| JMSDestinationType | enum JMSDestinationTypeextends Enum | Class | org.apache.flume.source.jms | Flume |
| JMSMessageConsumerFactory | Constructor SummaryJMSMessageConsumerFactory()Methods inherited from class java. | Class | org.apache.flume.source.jms | Flume |
| JMSMessageConverter | Converts a JMS Message to an Event. | Interface | org.apache.flume.source.jms | Flume |
| JMSMessageConverter .Builder | a suitable builder or implement the Configurable interface. | Interface | org.apache.flume.source.jms.JMSMessageConverter | Flume |
| JMSSource | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.source.jms | Flume |
| JMSSourceConfiguration | Class | org.apache.flume.source.jms | Flume | |
| JMXPollUtil | Class | org.apache.flume.instrumentation.util | Flume | |
| JSONEvent | Class | org.apache.flume.event | Flume | |
| JSONHandler | JSONHandler for HTTPSource that accepts an array of events. | Class | org.apache.flume.source.http | Flume |
| KerberosUser | Simple Pair class used to define a unique (principal, keyTab) combination. | Class | org.apache.flume.sink.hdfs | Flume |
| KeyProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| KeyProviderFactory | Class | org.apache.flume.channel.file.encryption | Flume | |
| KeyProviderType | enum KeyProviderTypeextends Enum | Class | org.apache.flume.channel.file.encryption | Flume |
| LengthMeasurable | Interface | org.apache.flume.serialization | Flume | |
| LifecycleAware | An interface implemented by any class that has a defined, stateful, Implementations of LifecycleAware conform to a standard method of | Interface | org.apache.flume.lifecycle | Flume |
| LifecycleController | Class | org.apache.flume.lifecycle | Flume | |
| LifecycleException | See Also:Serialized FormConstructor SummaryLifecycleException() | Class | org.apache.flume.lifecycle | Flume |
| LifecycleState | enum LifecycleStateextends Enum | Class | org.apache.flume.lifecycle | Flume |
| LifecycleSupervisor | Class | org.apache.flume.lifecycle | Flume | |
| LifecycleSupervisor .MonitorRunnable | Class | org.apache.flume.lifecycle.LifecycleSupervisor | Flume | |
| LifecycleSupervisor .Status | Class | org.apache.flume.lifecycle.LifecycleSupervisor | Flume | |
| LifecycleSupervisor .SupervisorPolicy | Class | org.apache.flume.lifecycle.LifecycleSupervisor | Flume | |
| LifecycleSupervisor .SupervisorPolicy .AlwaysRestartPolicy | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy | Flume |
| LifecycleSupervisor .SupervisorPolicy .OnceOnlyPolicy | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy | Flume |
| LineDeserializer | A deserializer that parses text lines from a file. | Class | org.apache.flume.serialization | Flume |
| LineDeserializer .Builder | Constructor SummaryLineDeserializer. | Class | org.apache.flume.serialization.LineDeserializer | Flume |
| LoadBalancingLog4jAppender | Appends Log4j Events to an external Flume client which is decribed by the Log4j configuration file. | Class | org.apache.flume.clients.log4jappender | Flume |
| LoadBalancingRpcClient | An implementation of RpcClient interface that uses NettyAvroRpcClient instances to load-balance the requests over many different hosts. | Class | org.apache.flume.api | Flume |
| LoadBalancingRpcClient .HostSelector | Interface | org.apache.flume.api.LoadBalancingRpcClient | 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 |
| Log | Stores FlumeEvents on disk and pointers to the events in a in memory queue. | Class | org.apache.flume.channel.file | Flume |
| Log4jAppender | Appends Log4j Events to an external Flume client which is decribed by the Log4j configuration file. | Class | org.apache.flume.clients.log4jappender | Flume |
| Log4jAvroHeaders | enum Log4jAvroHeadersextends Enum | Class | org.apache.flume.clients.log4jappender | Flume |
| LogEntry | Class | org.apache.flume.source.scribe | Flume | |
| LogEntry ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.LogEntry | Flume |
| LogFile | Class | org.apache.flume.channel.file | Flume | |
| LogFile .OperationRecordUpdater | This is an class meant to be an internal Flume API, and can change at any time. | Class | org.apache.flume.channel.file.LogFile | Flume |
| LogFile .SequentialReader | Class | org.apache.flume.channel.file.LogFile | Flume | |
| LogFileRetryableIOException | See Also:Serialized FormConstructor SummaryLogFileRetryableIOException() | Class | org.apache.flume.channel.file | Flume |
| LogFileV3 | Represents a single data file on disk. | Class | org.apache.flume.channel.file | Flume |
| LogFileV3 .SequentialReader | Constructor SummaryLogFileV3. | Class | org.apache.flume.channel.file.LogFileV3 | Flume |
| LoggerSink | A Sink implementation that logs all events received at the INFO level to the org. | Class | org.apache.flume.sink | Flume |
| LogRecord | Class | org.apache.flume.channel.file | Flume | |
| LogUtils | Constructor SummaryLogUtils()Methods inherited from class java. | Class | org.apache.flume.channel.file | Flume |
| MaterializedConfiguration | MaterializedConfiguration represents the materialization of a Flume properties file. | Interface | org.apache.flume.node | Flume |
| MemoryChannel | MemoryChannel is the recommended channel to use when speeds which writing to disk is impractical is required or durability of data is not | Class | org.apache.flume.channel | Flume |
| MonitoredCounterGroup | Used for keeping track of internal metrics using atomic integers This is used by a variety of component types such as Sources, Channels, | Class | org.apache.flume.instrumentation | Flume |
| MonitoredCounterGroup .Type | Component Enum Constants Used by each component's constructor to distinguish which type the | Class | org.apache.flume.instrumentation.MonitoredCounterGroup | Flume |
| MonitoringType | enum MonitoringTypeextends Enum | Class | org.apache.flume.instrumentation | Flume |
| MonitorService | Interface that any monitoring service should implement. | Interface | org.apache.flume.instrumentation | 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 |
| MultiplexingChannelSelector | Class | org.apache.flume.channel | Flume | |
| MultiportSyslogTCPSource | Class | org.apache.flume.source | Flume | |
| MySQLSchemaHandler | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| NamedComponent | Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system. | Interface | org.apache.flume | Flume |
| NetcatSource | A netcat-like source that listens on a given port and turns each line of text This source, primarily built for testing and exceedingly simple systems, acts | Class | org.apache.flume.source | Flume |
| NetcatSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| NettyAvroRpcClient | Avro/Netty implementation of RpcClient. | Class | org.apache.flume.api | Flume |
| NoopRecordException | See Also:Serialized FormConstructor SummaryNoopRecordException() | Class | org.apache.flume.channel.file | Flume |
| NullSink | A Sink implementation that simply discards all events it receives. | Class | org.apache.flume.sink | Flume |
| OrderSelector | A basic implementation of an order selector that implements a simple exponential backoff algorithm. | Class | org.apache.flume.util | Flume |
| PathManager | Class | org.apache.flume.formatter.output | Flume | |
| PersistableEvent | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| PersistableEvent .Builder | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| PersistableEvent .HeaderEntry | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| PersistableEvent .SpillableString | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| PlatformDetect | Utilities for platform & operating system detectionConstructor SummaryPlatformDetect() | Class | org.apache.flume.tools | Flume |
| PollableSource | A Source that requires an external driver to poll to determine whether there are events that are available to ingest | Interface | org.apache.flume | Flume |
| PollableSource .Status | Class | org.apache.flume.PollableSource | Flume | |
| PollableSourceRunner | An implementation of SourceRunner that can drive a A PollableSourceRunner wraps a PollableSource in the required | Class | org.apache.flume.source | Flume |
| PollableSourceRunner .PollingRunner | Constructor SummaryPollableSourceRunner. | Class | org.apache.flume.source.PollableSourceRunner | Flume |
| PollingPropertiesFileConfigurationProvider | Class | org.apache.flume.node | Flume | |
| PositionTracker | Defines an interface for tracking the offset position in a target file. | Interface | org.apache.flume.serialization | Flume |
| PropertiesFileConfigurationProvider | A configuration provider that uses properties file for specifying configuration. | Class | org.apache.flume.node | Flume |
| ProtosFactory | Class | org.apache.flume.channel.file.proto | Flume | |
| ProtosFactory .ActiveLog | Protobuf type ActiveLogSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .ActiveLog .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog | Flume | |
| ProtosFactory .ActiveLogOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Checkpoint | Protobuf type CheckpointSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Checkpoint .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint | Flume | |
| ProtosFactory .CheckpointOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Commit | Protobuf type CommitSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Commit .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Commit | Flume | |
| ProtosFactory .CommitOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .FlumeEvent | Protobuf type FlumeEventSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .FlumeEvent .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent | Flume | |
| ProtosFactory .FlumeEventHeader | Protobuf type FlumeEventHeaderSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .FlumeEventHeader .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader | Flume | |
| ProtosFactory .FlumeEventHeaderOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .FlumeEventOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .LogFileEncryption | Protobuf type LogFileEncryptionSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .LogFileEncryption .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption | Flume | |
| ProtosFactory .LogFileEncryptionOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .LogFileMetaData | Protobuf type LogFileMetaDataSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .LogFileMetaData .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData | Flume | |
| ProtosFactory .LogFileMetaDataOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Put | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Put .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Put | Flume | |
| ProtosFactory .PutOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Rollback | Protobuf type RollbackSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Rollback .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Rollback | Flume | |
| ProtosFactory .RollbackOrBuilder | Methods inherited from interface com. | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Take | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Take .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Take | Flume | |
| ProtosFactory .TakeOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .TransactionEventFooter | Protobuf type TransactionEventFooterSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventFooter .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter | Flume | |
| ProtosFactory .TransactionEventFooterOrBuilder | Methods inherited from interface com. | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventHeader | Protobuf type TransactionEventHeaderSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventHeader .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader | Flume | |
| ProtosFactory .TransactionEventHeaderOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| PseudoTxnMemoryChannel | A capacity-capped Channel implementation that supports in-memory buffering and delivery of events. | Class | org.apache.flume.channel | Flume |
| PseudoTxnMemoryChannel .NoOpTransaction | A no-op transaction implementation that does nothing at all. | Class | org.apache.flume.channel.PseudoTxnMemoryChannel | Flume |
| RandomOrderSelector | An implementation of OrderSelector which returns objects in random order. | Class | org.apache.flume.util | Flume |
| RegexExtractorInterceptor | Interceptor that extracts matches using a specified regular expression and appends the matches to the event headers using the specified serializers | Class | org.apache.flume.interceptor | Flume |
| RegexExtractorInterceptor .Builder | Constructor SummaryRegexExtractorInterceptor. | Class | org.apache.flume.interceptor.RegexExtractorInterceptor | Flume |
| RegexExtractorInterceptorMillisSerializer | Serializer that converts the passed in value into milliseconds using the specified formatting pattern | Class | org.apache.flume.interceptor | Flume |
| RegexExtractorInterceptorPassThroughSerializer | Serializer that simply returns the passed in valueConstructor SummaryRegexExtractorInterceptorPassThroughSerializer() | Class | org.apache.flume.interceptor | Flume |
| RegexExtractorInterceptorSerializer | Serializer for serializing groups matched by the RegexExtractorInterceptor | Interface | org.apache.flume.interceptor | Flume |
| RegexFilteringInterceptor | Interceptor that filters events selectively based on a configured regular expression matching against the event body. | Class | org.apache.flume.interceptor | Flume |
| RegexFilteringInterceptor .Builder | Builder which builds new instance of the StaticInterceptor. | Class | org.apache.flume.interceptor.RegexFilteringInterceptor | Flume |
| RegexFilteringInterceptor .Constants | Class | org.apache.flume.interceptor.RegexFilteringInterceptor | Flume | |
| RegexHbaseEventSerializer | An HbaseEventSerializer which parses columns based on a supplied regular expression and column name list. | Class | org.apache.flume.sink.hbase | Flume |
| ReliableEventReader | A reliable event reader. | Interface | org.apache.flume.client.avro | Flume |
| ReliableSpoolingFileEventReader | A ReliableEventReader which reads log data from files stored in a spooling directory and renames each file once all of its data has been | Class | org.apache.flume.client.avro | Flume |
| ReliableSpoolingFileEventReader .Builder | Special builder class for ReliableSpoolingFileEventReaderConstructor SummaryReliableSpoolingFileEventReader. | Class | org.apache.flume.client.avro.ReliableSpoolingFileEventReader | Flume |
| RemoteMarkable | Interface | org.apache.flume.serialization | Flume | |
| ReplicatingChannelSelector | Replicating channel selector. | Class | org.apache.flume.channel | Flume |
| Resettable | Defines an API for objects that can be mark()ed and reset() on arbitrary boundaries. | Interface | org.apache.flume.serialization | Flume |
| ResettableFileInputStream | This class makes the following assumptions: The underlying file is not changing while it is being read | Class | org.apache.flume.serialization | Flume |
| ResettableInputStream | This abstract class defines an interface for which the stream may be marked and reset with no limit to | Class | org.apache.flume.serialization | Flume |
| ResultCode | enum ResultCodeextends Enum | Class | org.apache.flume.source.scribe | 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 | |
| RoundRobinOrderSelector | An implementation of OrderSelector which returns objects in round robin order. | Class | org.apache.flume.util | Flume |
| RpcClient | Public client interface for sending data to Flume. | Interface | org.apache.flume.api | Flume |
| RpcClientConfigurationConstants | Configuration constants used by the RpcClient. | Class | org.apache.flume.api | Flume |
| RpcClientFactory | Factory class to construct Flume RPCClient implementations. | Class | org.apache.flume.api | Flume |
| RpcClientFactory .ClientType | Class | org.apache.flume.api.RpcClientFactory | Flume | |
| SchemaHandler | A handler for creating and validating database schema for use by the JDBC channel implementation. | Interface | org.apache.flume.channel.jdbc.impl | Flume |
| SchemaHandlerFactory | A factory for SchemaHandlers. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| Scribe | Class | org.apache.flume.source.scribe | Flume | |
| Scribe .AsyncClient | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .AsyncClient .Factory | Constructor SummaryScribe. | Class | org.apache.flume.source.scribe.Scribe.AsyncClient | Flume |
| Scribe .AsyncClient .Log_call | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.source.scribe.Scribe.AsyncClient | Flume |
| Scribe .AsyncIface | Interface | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Client | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Client .Factory | Constructor SummaryScribe. | Class | org.apache.flume.source.scribe.Scribe.Client | Flume |
| Scribe .Iface | Interface | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_args | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.Scribe.Log_args | Flume |
| Scribe .Log_result | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.Scribe.Log_result | Flume |
| Scribe .Processor | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| ScribeSource | Flume should adopt the Scribe entry LogEntry from existing Scribe system. | Class | org.apache.flume.source.scribe | Flume |
| Seekable | Interface | org.apache.flume.serialization | 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 |
| SequenceGeneratorSource | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.source | Flume |
| Serialization | Class | org.apache.flume.channel.file | 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 |
| SimpleEvent | Class | org.apache.flume.event | 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 | |
| SimpleMaterializedConfiguration | Class | org.apache.flume.node | Flume | |
| SimpleRowKeyGenerator | Utility class for users to generate their own keys. | Class | org.apache.flume.sink.hbase | Flume |
| SimpleTextLineEventReader | Class | org.apache.flume.client.avro | 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 | |
| SinkConfiguration | Class | org.apache.flume.conf.sink | Flume | |
| SinkConfiguration .SinkConfigurationType | Class | org.apache.flume.conf.sink.SinkConfiguration | Flume | |
| SinkCounter | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.instrumentation | Flume |
| SinkCounterMBean | This interface represents a sink counter mbean. | Interface | org.apache.flume.instrumentation | Flume |
| SinkFactory | Interface | org.apache.flume | Flume | |
| SinkGroup | Configuration concept for handling multiple sinks working together. | Class | org.apache.flume.sink | Flume |
| SinkGroupConfiguration | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.conf.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 |
| SinkProcessorConfiguration | Class | org.apache.flume.conf.sink | Flume | |
| SinkProcessorConfiguration .SinkProcessorConfigurationType | Class | org.apache.flume.conf.sink.SinkProcessorConfiguration | Flume | |
| SinkProcessorCounter | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.instrumentation | Flume |
| SinkProcessorFactory | Class | org.apache.flume.sink | Flume | |
| SinkProcessorType | enum SinkProcessorTypeextends Enum | Class | org.apache.flume.conf.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 |
| SinkType | enum SinkTypeextends Enum | Class | org.apache.flume.conf.sink | Flume |
| Source | A source generates and calls methods on the configured ChannelProcessor to persist those events into the | Interface | org.apache.flume | Flume |
| SourceConfiguration | Class | org.apache.flume.conf.source | Flume | |
| SourceConfiguration .SourceConfigurationType | Class | org.apache.flume.conf.source.SourceConfiguration | Flume | |
| SourceCounter | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.instrumentation | Flume |
| SourceCounterMBean | This interface represents a source counter mbean. | Interface | org.apache.flume.instrumentation | Flume |
| SourceFactory | Interface | org.apache.flume | Flume | |
| SourceRunner | A source runner controls how a source is driven. | Class | org.apache.flume | Flume |
| SourceType | enum SourceTypeextends Enum | Class | org.apache.flume.conf.source | Flume |
| SpecificOrderIterator | A utility class that iterates over the given ordered list of items via the specified order array. | Class | org.apache.flume.util | Flume |
| SpillableMemoryChannel | SpillableMemoryChannel will use main memory for buffering events until it has reached capacity. | Class | org.apache.flume.channel | Flume |
| SpillableMemoryChannel .DrainOrderQueue | Class | org.apache.flume.channel.SpillableMemoryChannel | Flume | |
| SpoolDirectorySource | Class | org.apache.flume.source | Flume | |
| SpoolDirectorySourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| SpoolDirectorySourceConfigurationConstants .ConsumeOrder | Class | org.apache.flume.source.SpoolDirectorySourceConfigurationConstants | Flume | |
| StaticInterceptor | Interceptor class that appends a static, pre-configured header to all events. | Class | org.apache.flume.interceptor | Flume |
| StaticInterceptor .Builder | Builder which builds new instance of the StaticInterceptor. | Class | org.apache.flume.interceptor.StaticInterceptor | Flume |
| StaticInterceptor .Constants | Class | org.apache.flume.interceptor.StaticInterceptor | Flume | |
| Status | enum Statusextends Enum | Class | org.apache.flume.thrift | Flume |
| StressSource | Internal load-generating source implementation. | Class | org.apache.flume.source | Flume |
| SyslogParser | Class | org.apache.flume.source | Flume | |
| SyslogSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| SyslogTcpSource | Class | org.apache.flume.source | Flume | |
| SyslogUDPSource | Class | org.apache.flume.source | Flume | |
| SyslogUtils | Class | org.apache.flume.source | Flume | |
| SyslogUtils .SyslogStatus | Class | org.apache.flume.source.SyslogUtils | Flume | |
| SystemClock | Default implementation of Clock which uses SystemConstructor SummarySystemClock() | Class | org.apache.flume | Flume |
| TextDelimitedOutputFormatter | Class | org.apache.flume.formatter.output | Flume | |
| ThriftFlumeEvent | Class | org.apache.flume.thrift | Flume | |
| ThriftFlumeEvent ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.thrift.ThriftFlumeEvent | Flume |
| ThriftLegacySource | Class | org.apache.flume.source.thriftLegacy | Flume | |
| ThriftLegacySource .ThriftHandler | Constructor SummaryThriftLegacySource. | Class | org.apache.flume.source.thriftLegacy.ThriftLegacySource | Flume |
| ThriftRpcClient | Fields inherited from class org. | Class | org.apache.flume.api | Flume |
| ThriftSink | A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource). | Class | org.apache.flume.sink | Flume |
| ThriftSource | Class | org.apache.flume.source | Flume | |
| ThriftSourceProtocol | Class | org.apache.flume.thrift | Flume | |
| ThriftSourceProtocol .append_args | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .append_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.thrift.ThriftSourceProtocol.append_args | Flume |
| ThriftSourceProtocol .append_result | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .append_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.thrift.ThriftSourceProtocol.append_result | Flume |
| ThriftSourceProtocol .appendBatch_args | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .appendBatch_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args | Flume |
| ThriftSourceProtocol .appendBatch_result | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .appendBatch_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result | Flume |
| ThriftSourceProtocol .AsyncClient | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .AsyncClient .append_call | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient | Flume |
| ThriftSourceProtocol .AsyncClient .appendBatch_call | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient | Flume |
| ThriftSourceProtocol .AsyncClient .Factory | Constructor SummaryThriftSourceProtocol. | Class | org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient | Flume |
| ThriftSourceProtocol .AsyncIface | Interface | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .Client | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .Client .Factory | Constructor SummaryThriftSourceProtocol. | Class | org.apache.flume.thrift.ThriftSourceProtocol.Client | Flume |
| ThriftSourceProtocol .Iface | Interface | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| ThriftSourceProtocol .Processor | Class | org.apache.flume.thrift.ThriftSourceProtocol | Flume | |
| TimeBasedIndexNameBuilder | Default index name builder. | Class | org.apache.flume.sink.elasticsearch | Flume |
| TimestampInterceptor | Simple Interceptor class that sets the current system timestamp on all events that are intercepted. | Class | org.apache.flume.interceptor | Flume |
| TimestampInterceptor .Builder | Builder which builds new instances of the TimestampInterceptor. | Class | org.apache.flume.interceptor.TimestampInterceptor | Flume |
| TimestampInterceptor .Constants | Class | org.apache.flume.interceptor.TimestampInterceptor | Flume | |
| TimestampRoundDownUtil | Class | org.apache.flume.tools | Flume | |
| Transaction | Provides the transaction boundary while accessing a channel. | Interface | org.apache.flume | Flume |
| Transaction .TransactionState | Class | org.apache.flume.Transaction | Flume | |
| TransactionEventRecord | Class | org.apache.flume.channel.file | Flume | |
| TransactionIDOracle | Class | org.apache.flume.channel.file | Flume | |
| TransactionIsolation | enum TransactionIsolationextends Enum | Class | org.apache.flume.channel.jdbc | Flume |
| TwitterSource | Demo Flume source that connects via Streaming API to the 1% sample twitter firehose, continously downloads tweets, converts them to Avro format and | Class | org.apache.flume.source.twitter | 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 |
| VersionAnnotation | This class is about package attribute that captures version info of Flume that was compiled. | Class | org.apache.flume | Flume |
| VersionInfo | Class | org.apache.flume.tools | Flume | |
| WriteOrderOracle | Class | org.apache.flume.channel.file | Flume | |