Hierarchy For All Packages

Package Hierarchies:

com.cloudera.flume.handlers.thrift, org.apache.flume, org.apache.flume.annotations, org.apache.flume.api, org.apache.flume.channel, org.apache.flume.channel.file, org.apache.flume.channel.file.encryption, org.apache.flume.channel.file.proto, org.apache.flume.channel.jdbc, org.apache.flume.channel.jdbc.impl, org.apache.flume.channel.recoverable.memory, org.apache.flume.channel.recoverable.memory.wal, org.apache.flume.client.avro, org.apache.flume.clients.log4jappender, org.apache.flume.conf, org.apache.flume.conf.channel, org.apache.flume.conf.file, org.apache.flume.conf.properties, org.apache.flume.conf.sink, org.apache.flume.conf.source, org.apache.flume.event, org.apache.flume.formatter.output, org.apache.flume.instrumentation, org.apache.flume.instrumentation.http, org.apache.flume.instrumentation.util, org.apache.flume.interceptor, org.apache.flume.lifecycle, org.apache.flume.node, org.apache.flume.node.nodemanager, org.apache.flume.serialization, org.apache.flume.sink, org.apache.flume.sink.elasticsearch, org.apache.flume.sink.hbase, org.apache.flume.sink.hdfs, org.apache.flume.sink.irc, org.apache.flume.source, org.apache.flume.source.avroLegacy, org.apache.flume.source.http, org.apache.flume.source.scribe, org.apache.flume.source.thriftLegacy, org.apache.flume.tools, org.apache.flume.util

Class Hierarchy

• java.lang.Object
  • org.apache.flume.serialization.AbstractAvroEventSerializer<T> (implements org.apache.flume.conf.Configurable, org.apache.flume.serialization.EventSerializer)
    • org.apache.flume.serialization.FlumeEventAvroEventSerializer
  • org.apache.flume.channel.AbstractChannel (implements org.apache.flume.Channel, org.apache.flume.conf.Configurable, org.apache.flume.lifecycle.LifecycleAware)
    • org.apache.flume.channel.BasicChannelSemantics
      • org.apache.flume.channel.file.FileChannel
      • org.apache.flume.channel.MemoryChannel
      • org.apache.flume.channel.recoverable.memory.RecoverableMemoryChannel
    • org.apache.flume.channel.jdbc.JdbcChannel
    • org.apache.flume.channel.PseudoTxnMemoryChannel
  • org.apache.flume.channel.AbstractChannelSelector (implements org.apache.flume.ChannelSelector)
    • org.apache.flume.channel.MultiplexingChannelSelector
    • org.apache.flume.channel.ReplicatingChannelSelector
  • org.apache.flume.conf.file.AbstractFileConfigurationProvider (implements org.apache.flume.node.ConfigurationProvider)
    • org.apache.flume.conf.properties.PropertiesFileConfigurationProvider
  • org.apache.flume.conf.file.AbstractFileConfigurationProvider.FileWatcherRunnable (implements java.lang.Runnable)
  • org.apache.flume.node.nodemanager.AbstractLogicalNodeManager (implements org.apache.flume.node.NodeManager)
    • org.apache.flume.node.nodemanager.DefaultLogicalNodeManager (implements org.apache.flume.node.nodemanager.NodeConfigurationAware)
  • com.google.protobuf.AbstractMessageLite (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessage (implements java.io.Serializable)
        • org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog (implements org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint (implements org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Commit (implements org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent (implements org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader (implements org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption (implements org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData (implements org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Put (implements org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Rollback (implements org.apache.flume.channel.file.proto.ProtosFactory.RollbackOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Take (implements org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter (implements org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooterOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader (implements org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessage.Builder<BuilderType>
        • org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.RollbackOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooterOrBuilder)
        • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder (implements org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder)
  • org.apache.flume.api.AbstractRpcClient (implements org.apache.flume.api.RpcClient)
    • org.apache.flume.api.FailoverRpcClient (implements org.apache.flume.api.RpcClient)
    • org.apache.flume.api.LoadBalancingRpcClient
    • org.apache.flume.api.NettyAvroRpcClient (implements org.apache.flume.api.RpcClient)
  • org.apache.flume.sink.AbstractSink (implements org.apache.flume.lifecycle.LifecycleAware, org.apache.flume.Sink)
    • org.apache.flume.sink.hbase.AsyncHBaseSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.AvroSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.elasticsearch.ElasticSearchSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.hbase.HBaseSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.hdfs.HDFSEventSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.irc.IRCSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.LoggerSink
    • org.apache.flume.sink.NullSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.RollingFileSink (implements org.apache.flume.conf.Configurable)
  • org.apache.flume.sink.AbstractSinkProcessor (implements org.apache.flume.SinkProcessor)
    • org.apache.flume.sink.FailoverSinkProcessor
    • org.apache.flume.sink.LoadBalancingSinkProcessor
  • org.apache.flume.sink.AbstractSinkSelector (implements org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector)
  • org.apache.flume.source.AbstractSource (implements org.apache.flume.Source)
    • org.apache.flume.source.avroLegacy.AvroLegacySource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource, com.cloudera.flume.handlers.avro.FlumeOGEventAvroServer)
    • org.apache.flume.source.AvroSource (implements org.apache.flume.source.avro.AvroSourceProtocol, org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.ExecSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.http.HTTPSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.MultiportSyslogTCPSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.NetcatSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.scribe.ScribeSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.SequenceGeneratorSource (implements org.apache.flume.conf.Configurable, org.apache.flume.PollableSource)
    • org.apache.flume.source.SpoolDirectorySource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.StressSource (implements org.apache.flume.conf.Configurable, org.apache.flume.PollableSource)
    • org.apache.flume.source.SyslogTcpSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.SyslogUDPSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.thriftLegacy.ThriftLegacySource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
  • org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler)
    • org.apache.flume.clients.log4jappender.Log4jAppender
  • org.apache.flume.node.Application
  • org.apache.flume.client.avro.AvroCLIClient
  • org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
  • org.apache.flume.conf.BasicConfigurationConstants
  • org.apache.flume.channel.BasicTransactionSemantics (implements org.apache.flume.Transaction)
  • org.apache.flume.serialization.BodyTextEventSerializer (implements org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.serialization.BodyTextEventSerializer.Builder (implements org.apache.flume.serialization.EventSerializer.Builder)
  • org.apache.flume.formatter.output.BucketPath
  • org.apache.flume.client.avro.BufferedLineReader (implements org.apache.flume.client.avro.LineReader)
  • org.apache.flume.channel.ChannelProcessor (implements org.apache.flume.conf.Configurable)
  • org.apache.flume.channel.ChannelSelectorFactory
  • org.apache.flume.channel.ChannelUtils
  • org.apache.flume.channel.file.CheckpointRebuilder
  • org.apache.flume.channel.file.encryption.CipherProvider
    • org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider
  • org.apache.flume.channel.file.encryption.CipherProvider.Decryptor
  • org.apache.flume.channel.file.encryption.CipherProvider.Decryptor.Builder<T>
    • org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.DecryptorBuilder
  • org.apache.flume.channel.file.encryption.CipherProvider.Encryptor
  • org.apache.flume.channel.file.encryption.CipherProvider.Encryptor.Builder<T>
    • org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.EncryptorBuilder
  • org.apache.flume.channel.file.encryption.CipherProviderFactory
  • org.apache.flume.conf.ComponentConfiguration
    • org.apache.flume.conf.channel.ChannelConfiguration
    • org.apache.flume.conf.channel.ChannelSelectorConfiguration
    • org.apache.flume.conf.sink.SinkConfiguration
    • org.apache.flume.conf.sink.SinkGroupConfiguration
    • org.apache.flume.conf.sink.SinkProcessorConfiguration
    • org.apache.flume.conf.source.SourceConfiguration
  • org.apache.flume.conf.ComponentConfigurationFactory
  • org.apache.flume.conf.Configurables
  • org.apache.flume.channel.jdbc.ConfigurationConstants
  • org.apache.flume.Constants
  • org.apache.flume.sink.elasticsearch.ContentBuilderUtil
  • org.apache.flume.Context
  • org.apache.flume.CounterGroup
  • org.apache.flume.channel.DefaultChannelFactory (implements org.apache.flume.ChannelFactory)
  • org.apache.flume.sink.DefaultSinkFactory (implements org.apache.flume.SinkFactory)
  • org.apache.flume.sink.DefaultSinkProcessor (implements org.apache.flume.conf.ConfigurableComponent, org.apache.flume.SinkProcessor)
  • org.apache.flume.source.DefaultSourceFactory (implements org.apache.flume.SourceFactory)
  • org.apache.flume.channel.jdbc.impl.DerbySchemaHandler (implements org.apache.flume.channel.jdbc.impl.SchemaHandler)
  • org.apache.flume.tools.DirectMemoryUtils
  • org.apache.flume.Dummy
  • org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer (implements org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer)
  • org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer (implements org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer)
  • org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
  • org.apache.flume.channel.file.encryption.EncryptionConfiguration
  • org.apache.flume.event.EventBuilder
  • org.apache.flume.event.EventHelper
  • org.apache.flume.serialization.EventSerializerFactory
  • org.apache.flume.source.ExecSourceConfigurationConstants
  • org.apache.flume.channel.file.FileChannelConfiguration
  • org.apache.flume.conf.FlumeConfiguration
  • org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
  • org.apache.flume.conf.FlumeConfiguration.ComponentNameAndConfigKey
  • org.apache.flume.conf.FlumeConfigurationError
  • org.apache.flume.serialization.FlumeEventAvroEventSerializer.Builder (implements org.apache.flume.serialization.EventSerializer.Builder)
  • org.apache.flume.node.FlumeNode (implements org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.instrumentation.GangliaServer (implements org.apache.flume.instrumentation.MonitorService)
  • org.apache.flume.instrumentation.GangliaServer.GangliaCollector (implements java.lang.Runnable)
  • org.apache.flume.tools.GetJavaProperty
  • org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
  • org.apache.flume.sink.hdfs.HDFSCompressedDataStream (implements org.apache.flume.sink.hdfs.HDFSWriter)
  • org.apache.flume.sink.hdfs.HDFSDataStream (implements org.apache.flume.sink.hdfs.HDFSWriter)
  • org.apache.flume.sink.hdfs.HDFSFormatterFactory
  • org.apache.flume.sink.hdfs.HDFSSequenceFile (implements org.apache.flume.sink.hdfs.HDFSWriter)
  • org.apache.flume.sink.hdfs.HDFSTextFormatter (implements org.apache.flume.sink.FlumeFormatter)
  • org.apache.flume.sink.hdfs.HDFSWritableFormatter (implements org.apache.flume.sink.FlumeFormatter)
  • org.apache.flume.sink.hdfs.HDFSWriterFactory
  • org.apache.flume.api.HostInfo
  • org.apache.flume.interceptor.HostInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.HostInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.interceptor.HostInterceptor.Constants
  • org.apache.flume.instrumentation.http.HTTPMetricsServer (implements org.apache.flume.instrumentation.MonitorService)
  • org.apache.flume.source.http.HTTPSourceConfigurationConstants
  • org.apache.flume.interceptor.InterceptorBuilderFactory
  • org.apache.flume.interceptor.InterceptorChain (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.annotations.InterfaceAudience
  • org.apache.flume.annotations.InterfaceStability
  • org.apache.flume.sink.irc.IRCSink.IRCConnectionListener (implements org.schwering.irc.lib.IRCEventListener)
  • org.apache.flume.channel.file.encryption.JCEFileKeyProvider.Builder (implements org.apache.flume.channel.file.encryption.KeyProvider.Builder)
  • org.apache.flume.channel.jdbc.JdbcChannelProviderFactory
  • org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl (implements org.apache.flume.channel.jdbc.JdbcChannelProvider)
  • org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl (implements org.apache.flume.Transaction)
  • org.apache.flume.instrumentation.util.JMXPollUtil
  • org.apache.flume.event.JSONEvent (implements org.apache.flume.Event)
  • org.apache.flume.source.http.JSONHandler (implements org.apache.flume.source.http.HTTPSourceHandler)
  • org.apache.flume.sink.hdfs.KerberosUser
  • org.apache.flume.channel.file.encryption.KeyProvider
    • org.apache.flume.channel.file.encryption.JCEFileKeyProvider
  • org.apache.flume.channel.file.encryption.KeyProviderFactory
  • org.apache.flume.lifecycle.LifecycleController
  • org.apache.flume.lifecycle.LifecycleSupervisor (implements org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable (implements java.lang.Runnable)
  • org.apache.flume.lifecycle.LifecycleSupervisor.Status
  • org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy
    • org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy
    • org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy
  • org.apache.flume.source.scribe.LogEntry (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.channel.file.LogRecord (implements java.lang.Comparable<T>)
  • org.apache.flume.channel.file.LogUtils
  • org.apache.flume.instrumentation.MonitoredCounterGroup
    • org.apache.flume.instrumentation.ChannelCounter (implements org.apache.flume.instrumentation.ChannelCounterMBean)
    • org.apache.flume.instrumentation.ChannelProcessorCounter
    • org.apache.flume.instrumentation.SinkCounter (implements org.apache.flume.instrumentation.SinkCounterMBean)
    • org.apache.flume.instrumentation.SinkProcessorCounter
    • org.apache.flume.instrumentation.SourceCounter (implements org.apache.flume.instrumentation.SourceCounterMBean)
  • org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler (implements org.apache.flume.channel.jdbc.impl.SchemaHandler)
  • org.apache.flume.source.NetcatSourceConfigurationConstants
  • org.apache.flume.util.OrderSelector<T>
    • org.apache.flume.util.RandomOrderSelector<T>
    • org.apache.flume.util.RoundRobinOrderSelector<T>
  • org.apache.flume.formatter.output.PathManager
  • org.apache.flume.channel.jdbc.impl.PersistableEvent (implements org.apache.flume.Event)
  • org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder
  • org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
  • org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString
  • org.apache.flume.source.PollableSourceRunner.PollingRunner (implements java.lang.Runnable)
  • org.apache.flume.channel.file.proto.ProtosFactory
  • org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction (implements org.apache.flume.Transaction)
  • org.apache.flume.interceptor.RegexExtractorInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.RegexExtractorInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.interceptor.RegexExtractorInterceptorMillisSerializer (implements org.apache.flume.interceptor.RegexExtractorInterceptorSerializer)
  • org.apache.flume.interceptor.RegexExtractorInterceptorPassThroughSerializer (implements org.apache.flume.interceptor.RegexExtractorInterceptorSerializer)
  • org.apache.flume.interceptor.RegexFilteringInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.RegexFilteringInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.interceptor.RegexFilteringInterceptor.Constants
  • org.apache.flume.sink.hbase.RegexHbaseEventSerializer (implements org.apache.flume.sink.hbase.HbaseEventSerializer)
  • org.apache.flume.api.RpcClientConfigurationConstants
  • org.apache.flume.api.RpcClientFactory
  • org.apache.flume.channel.jdbc.impl.SchemaHandlerFactory
  • org.apache.flume.source.scribe.Scribe
  • org.apache.flume.source.scribe.Scribe.AsyncClient.Factory (implements org.apache.thrift.async.TAsyncClientFactory<T>)
  • org.apache.flume.source.scribe.Scribe.Client (implements org.apache.flume.source.scribe.Scribe.Iface, org.apache.thrift.TServiceClient)
  • org.apache.flume.source.scribe.Scribe.Client.Factory (implements org.apache.thrift.TServiceClientFactory<T>)
  • org.apache.flume.source.scribe.Scribe.Log_args (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.source.scribe.Scribe.Log_result (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.source.scribe.Scribe.Processor (implements org.apache.thrift.TProcessor)
  • org.apache.flume.channel.recoverable.memory.wal.SequenceIDBuffer (implements org.apache.hadoop.util.IndexedSortable)
  • org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer (implements org.apache.flume.sink.hbase.AsyncHbaseEventSerializer)
  • org.jboss.netty.channel.SimpleChannelHandler (implements org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelUpstreamHandler)
    • org.apache.flume.source.SyslogTcpSource.syslogTcpHandler
    • org.apache.flume.source.SyslogUDPSource.syslogHandler
  • org.apache.flume.event.SimpleEvent (implements org.apache.flume.Event)
  • org.apache.flume.sink.hbase.SimpleHbaseEventSerializer (implements org.apache.flume.sink.hbase.HbaseEventSerializer)
  • org.apache.flume.conf.file.SimpleNodeConfiguration (implements org.apache.flume.node.NodeConfiguration)
  • org.apache.flume.sink.hbase.SimpleRowKeyGenerator
  • org.apache.flume.sink.SinkGroup (implements org.apache.flume.conf.Configurable, org.apache.flume.conf.ConfigurableComponent)
  • org.apache.flume.sink.SinkProcessorFactory
  • org.apache.flume.SinkRunner (implements org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.SinkRunner.PollingRunner (implements java.lang.Runnable)
  • org.apache.flume.SourceRunner (implements org.apache.flume.lifecycle.LifecycleAware)
    • org.apache.flume.source.EventDrivenSourceRunner
    • org.apache.flume.source.PollableSourceRunner
  • org.apache.flume.util.SpecificOrderIterator<T> (implements java.util.Iterator<E>)
  • org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
  • org.apache.flume.client.avro.SpoolingFileLineReader (implements org.apache.flume.client.avro.LineReader)
  • org.apache.flume.interceptor.StaticInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.StaticInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.interceptor.StaticInterceptor.Constants
  • org.apache.flume.source.SyslogParser
  • org.apache.flume.source.SyslogSourceConfigurationConstants
  • org.apache.flume.source.SyslogUtils
  • org.apache.flume.SystemClock (implements org.apache.flume.Clock)
  • org.apache.thrift.async.TAsyncClient
    • org.apache.flume.source.scribe.Scribe.AsyncClient (implements org.apache.flume.source.scribe.Scribe.AsyncIface)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient (implements com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncIface)
  • org.apache.thrift.async.TAsyncMethodCall<T>
    • org.apache.flume.source.scribe.Scribe.AsyncClient.Log_call
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.append_call
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.close_call
  • org.apache.flume.formatter.output.TextDelimitedOutputFormatter (implements org.apache.flume.formatter.output.EventFormatter)
  • java.lang.ThreadLocal<T>
    • org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEvent (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.Factory (implements org.apache.thrift.async.TAsyncClientFactory<T>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client (implements com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Iface, org.apache.thrift.TServiceClient)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client.Factory (implements org.apache.thrift.TServiceClientFactory<T>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result (implements java.lang.Cloneable, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Processor (implements org.apache.thrift.TProcessor)
  • org.apache.flume.source.thriftLegacy.ThriftLegacySource.ThriftHandler (implements java.lang.Runnable)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.flume.EventDeliveryException
      • java.io.IOException
        • org.apache.flume.channel.file.LogFileRetryableIOException
      • org.apache.flume.lifecycle.LifecycleException
      • java.lang.RuntimeException
        • org.apache.flume.ChannelException
          • org.apache.flume.channel.jdbc.JdbcChannelException
        • org.apache.flume.FlumeException
          • org.apache.flume.conf.ConfigurationException
          • org.apache.flume.source.http.HTTPBadRequestException
  • org.apache.flume.interceptor.TimestampInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.TimestampInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.interceptor.TimestampInterceptor.Constants
  • org.apache.flume.tools.TimestampRoundDownUtil
  • org.apache.flume.channel.file.TransactionIDOracle
  • org.apache.flume.tools.VersionInfo
  • org.apache.flume.channel.recoverable.memory.wal.WAL<T> (implements java.io.Closeable)
  • org.apache.flume.channel.recoverable.memory.wal.WALEntry<T> (implements org.apache.hadoop.io.Writable)
  • org.apache.flume.channel.recoverable.memory.wal.WALReplayResult<T>
  • org.apache.flume.channel.file.WriteOrderOracle

Interface Hierarchy

• org.apache.flume.instrumentation.ChannelCounterMBean
• org.apache.flume.ChannelFactory
• org.apache.flume.Clock
• org.apache.flume.conf.Configurable
  • org.apache.flume.sink.hbase.AsyncHbaseEventSerializer (also extends org.apache.flume.conf.ConfigurableComponent)
  • org.apache.flume.ChannelSelector (also extends org.apache.flume.NamedComponent)
  • org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer (also extends org.apache.flume.conf.ConfigurableComponent)
  • org.apache.flume.sink.hbase.HbaseEventSerializer (also extends org.apache.flume.conf.ConfigurableComponent)
  • org.apache.flume.sink.hdfs.HDFSWriter
  • org.apache.flume.source.http.HTTPSourceHandler
  • org.apache.flume.interceptor.Interceptor.Builder
  • org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector (also extends org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.instrumentation.MonitorService
  • org.apache.flume.interceptor.RegexExtractorInterceptorSerializer (also extends org.apache.flume.conf.ConfigurableComponent)
  • org.apache.flume.SinkProcessor (also extends org.apache.flume.lifecycle.LifecycleAware)
• org.apache.flume.conf.ConfigurableComponent
  • org.apache.flume.sink.hbase.AsyncHbaseEventSerializer (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.sink.hbase.HbaseEventSerializer (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.interceptor.RegexExtractorInterceptorSerializer (also extends org.apache.flume.conf.Configurable)
• org.apache.flume.Event
• org.apache.flume.formatter.output.EventFormatter
• org.apache.flume.serialization.EventSerializer
• org.apache.flume.serialization.EventSerializer.Builder
• org.apache.flume.sink.FlumeFormatter
• org.apache.flume.sink.hdfs.HDFSEventSink.WriterCallback
• org.apache.flume.interceptor.Interceptor
• org.apache.flume.channel.jdbc.JdbcChannelProvider
• org.apache.flume.channel.file.encryption.KeyProvider.Builder
• org.apache.flume.lifecycle.LifecycleAware
  • org.apache.flume.Channel (also extends org.apache.flume.NamedComponent)
  • org.apache.flume.node.ConfigurationProvider
  • org.apache.flume.EventDrivenSource
  • org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.node.NodeManager
  • org.apache.flume.PollableSource
  • org.apache.flume.Sink (also extends org.apache.flume.NamedComponent)
  • org.apache.flume.SinkProcessor (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.Source (also extends org.apache.flume.NamedComponent)
    • org.apache.flume.EventDrivenSource
    • org.apache.flume.PollableSource
• org.apache.flume.client.avro.LineReader
• org.apache.flume.api.LoadBalancingRpcClient.HostSelector
• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.RollbackOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooterOrBuilder
    • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.RollbackOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooterOrBuilder
  • org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
• org.apache.flume.NamedComponent
  • org.apache.flume.Channel (also extends org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.ChannelSelector (also extends org.apache.flume.conf.Configurable)
  • org.apache.flume.EventDrivenSource
  • org.apache.flume.PollableSource
  • org.apache.flume.Sink (also extends org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.Source (also extends org.apache.flume.lifecycle.LifecycleAware)
    • org.apache.flume.EventDrivenSource
    • org.apache.flume.PollableSource
• org.apache.flume.node.NodeConfiguration
• org.apache.flume.node.nodemanager.NodeConfigurationAware
• org.apache.flume.api.RpcClient
• org.apache.flume.channel.jdbc.impl.SchemaHandler
• org.apache.flume.source.scribe.Scribe.AsyncIface
• org.apache.flume.source.scribe.Scribe.Iface
• org.apache.flume.source.scribe.Scribe.Processor.ProcessFunction
• org.apache.flume.instrumentation.SinkCounterMBean
• org.apache.flume.SinkFactory
• org.apache.flume.instrumentation.SourceCounterMBean
• org.apache.flume.SourceFactory
• com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncIface
• com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Iface
• com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Processor.ProcessFunction
• org.apache.flume.Transaction

Annotation Type Hierarchy

• org.apache.flume.VersionAnnotation (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceStability.Stable (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceStability.Evolving (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceStability.Unstable (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceAudience.Public (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceAudience.LimitedPrivate (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.InterfaceAudience.Private (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flume.api.RpcClientFactory.ClientType
    • org.apache.flume.Transaction.TransactionState
    • org.apache.flume.Sink.Status
    • org.apache.flume.PollableSource.Status
    • org.apache.flume.conf.FlumeConfigurationErrorType
    • org.apache.flume.conf.FlumeConfigurationError.ErrorOrWarning
    • org.apache.flume.conf.ComponentConfiguration.ComponentType
    • org.apache.flume.conf.channel.ChannelType
    • org.apache.flume.conf.channel.ChannelSelectorType
    • org.apache.flume.conf.channel.ChannelSelectorConfiguration.ChannelSelectorConfigurationType
    • org.apache.flume.conf.channel.ChannelConfiguration.ChannelConfigurationType
    • org.apache.flume.conf.sink.SinkType
    • org.apache.flume.conf.sink.SinkProcessorType
    • org.apache.flume.conf.sink.SinkProcessorConfiguration.SinkProcessorConfigurationType
    • org.apache.flume.conf.sink.SinkConfiguration.SinkConfigurationType
    • org.apache.flume.conf.source.SourceType
    • org.apache.flume.conf.source.SourceConfiguration.SourceConfigurationType
    • org.apache.flume.channel.BasicTransactionSemantics.State
    • org.apache.flume.instrumentation.MonitoringType
    • org.apache.flume.instrumentation.MonitoredCounterGroup.Type
    • org.apache.flume.interceptor.InterceptorType
    • org.apache.flume.lifecycle.LifecycleState
    • org.apache.flume.serialization.EventSerializerType
    • org.apache.flume.source.SyslogUtils.SyslogStatus
    • org.apache.flume.sink.hbase.SimpleHbaseEventSerializer.KeyType
    • org.apache.flume.source.scribe.Scribe.Log_args._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.source.scribe.Scribe.Log_result._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.source.scribe.ResultCode (implements org.apache.thrift.TEnum)
    • org.apache.flume.source.scribe.LogEntry._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.channel.jdbc.TransactionIsolation
    • org.apache.flume.channel.jdbc.DatabaseType
    • org.apache.flume.channel.file.encryption.KeyProviderType
    • org.apache.flume.channel.file.encryption.CipherProviderType
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields (implements org.apache.thrift.TFieldIdEnum)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields (implements org.apache.thrift.TFieldIdEnum)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields (implements org.apache.thrift.TFieldIdEnum)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields (implements org.apache.thrift.TFieldIdEnum)
    • com.cloudera.flume.handlers.thrift.Priority (implements org.apache.thrift.TEnum)
    • com.cloudera.flume.handlers.thrift.EventStatus (implements org.apache.thrift.TEnum)
    • org.apache.flume.clients.log4jappender.Log4jAvroHeaders