Hierarchy For All Packages

Package Hierarchies:

• com.cloudera.flume.handlers.thrift,
• org.apache.flume,
• org.apache.flume.agent.embedded,
• org.apache.flume.annotations,
• org.apache.flume.api,
• org.apache.flume.auth,
• org.apache.flume.channel,
• org.apache.flume.channel.file,
• org.apache.flume.channel.file.encryption,
• org.apache.flume.channel.file.instrumentation,
• org.apache.flume.channel.file.proto,
• org.apache.flume.channel.jdbc,
• org.apache.flume.channel.jdbc.impl,
• org.apache.flume.channel.kafka,
• org.apache.flume.client.avro,
• org.apache.flume.clients.log4jappender,
• org.apache.flume.conf,
• org.apache.flume.conf.channel,
• org.apache.flume.conf.configfilter,
• org.apache.flume.conf.sink,
• org.apache.flume.conf.source,
• org.apache.flume.configfilter,
• org.apache.flume.event,
• org.apache.flume.formatter.output,
• org.apache.flume.instrumentation,
• org.apache.flume.instrumentation.http,
• org.apache.flume.instrumentation.kafka,
• org.apache.flume.instrumentation.util,
• org.apache.flume.interceptor,
• org.apache.flume.lifecycle,
• org.apache.flume.node,
• org.apache.flume.serialization,
• org.apache.flume.shared.kafka,
• org.apache.flume.shared.kafka.test,
• org.apache.flume.sink,
• org.apache.flume.sink.hbase,
• org.apache.flume.sink.hbase2,
• org.apache.flume.sink.hdfs,
• org.apache.flume.sink.hive,
• org.apache.flume.sink.http,
• org.apache.flume.sink.irc,
• org.apache.flume.sink.kafka,
• org.apache.flume.sink.kite,
• org.apache.flume.sink.kite.parser,
• org.apache.flume.sink.kite.policy,
• org.apache.flume.sink.solr.morphline,
• org.apache.flume.source,
• org.apache.flume.source.avroLegacy,
• org.apache.flume.source.http,
• org.apache.flume.source.jms,
• org.apache.flume.source.kafka,
• org.apache.flume.source.scribe,
• org.apache.flume.source.shaded.guava,
• org.apache.flume.source.taildir,
• org.apache.flume.source.thriftLegacy,
• org.apache.flume.source.twitter,
• org.apache.flume.thrift,
• 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 (implements org.apache.flume.conf.TransactionCapacitySupported)
        • org.apache.flume.channel.SpillableMemoryChannel
      • org.apache.flume.channel.kafka.KafkaChannel
      • org.apache.flume.channel.MemoryChannel (implements org.apache.flume.conf.TransactionCapacitySupported)
    • 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.configfilter.AbstractConfigFilter (implements org.apache.flume.configfilter.ConfigFilter)
    • org.apache.flume.configfilter.EnvironmentVariableConfigFilter
    • org.apache.flume.configfilter.ExternalProcessConfigFilter
    • org.apache.flume.configfilter.HadoopCredentialStoreConfigFilter
  • org.apache.flume.node.AbstractConfigurationProvider (implements org.apache.flume.node.ConfigurationProvider)
    • org.apache.flume.node.AbstractZooKeeperConfigurationProvider
      • org.apache.flume.node.PollingZooKeeperConfigurationProvider (implements org.apache.flume.lifecycle.LifecycleAware)
      • org.apache.flume.node.StaticZooKeeperConfigurationProvider
    • org.apache.flume.node.PropertiesFileConfigurationProvider
      • org.apache.flume.node.PollingPropertiesFileConfigurationProvider (implements org.apache.flume.lifecycle.LifecycleAware)
  • org.apache.flume.sink.hdfs.AbstractHDFSWriter (implements org.apache.flume.sink.hdfs.HDFSWriter)
    • org.apache.flume.sink.hdfs.HDFSCompressedDataStream
    • org.apache.flume.sink.hdfs.HDFSDataStream
    • org.apache.flume.sink.hdfs.HDFSSequenceFile
  • 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.SSLContextAwareAbstractRpcClient
      • org.apache.flume.api.NettyAvroRpcClient
      • org.apache.flume.api.ThriftRpcClient
        • org.apache.flume.api.SecureThriftRpcClient
  • org.apache.flume.sink.AbstractSink (implements org.apache.flume.lifecycle.LifecycleAware, org.apache.flume.Sink)
    • org.apache.flume.sink.AbstractRpcSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
      • org.apache.flume.sink.AvroSink
      • org.apache.flume.sink.ThriftSink
    • org.apache.flume.sink.kite.DatasetSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.hbase2.HBase2Sink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
      • org.apache.flume.sink.hbase.HBaseSink
    • org.apache.flume.sink.hdfs.HDFSEventSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.hive.HiveSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.http.HttpSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.irc.IRCSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.kafka.KafkaSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.LoggerSink (implements org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.solr.morphline.MorphlineSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
      • org.apache.flume.sink.solr.morphline.MorphlineSolrSink
    • org.apache.flume.sink.NullSink (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.RollingFileSink (implements org.apache.flume.conf.BatchSizeSupported, 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.agent.embedded.EmbeddedSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.ExecSource (implements org.apache.flume.conf.BatchSizeSupported, 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.NetcatUdpSource (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.SpoolDirectorySource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.SslContextAwareAbstractSource
      • 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.http.HTTPSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
      • org.apache.flume.source.MultiportSyslogTCPSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
      • org.apache.flume.source.SyslogTcpSource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
      • org.apache.flume.source.ThriftSource (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.taildir.TaildirSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable, org.apache.flume.PollableSource)
    • org.apache.flume.source.thriftLegacy.ThriftLegacySource (implements org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.twitter.TwitterSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable, org.apache.flume.EventDrivenSource, twitter4j.StatusListener)
  • org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler)
    • org.apache.flume.clients.log4jappender.Log4jAppender
      • org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
  • org.apache.flume.node.Application
  • org.apache.thrift.AsyncProcessFunction<I,T,R>
    • org.apache.flume.source.scribe.Scribe.AsyncProcessor.Log<I>
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncProcessor.append<I>
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncProcessor.close<I>
    • org.apache.flume.thrift.ThriftSourceProtocol.AsyncProcessor.append<I>
    • org.apache.flume.thrift.ThriftSourceProtocol.AsyncProcessor.appendBatch<I>
  • org.apache.flume.client.avro.AvroCLIClient
  • org.apache.flume.serialization.AvroEventDeserializer (implements org.apache.flume.serialization.EventDeserializer)
  • org.apache.flume.serialization.AvroEventDeserializer.Builder (implements org.apache.flume.serialization.EventDeserializer.Builder)
  • org.apache.flume.sink.hdfs.AvroEventSerializer (implements org.apache.flume.conf.Configurable, org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.sink.hdfs.AvroEventSerializer.Builder (implements org.apache.flume.serialization.EventSerializer.Builder)
  • org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
  • org.apache.flume.sink.kite.parser.AvroParser (implements org.apache.flume.sink.kite.parser.EntityParser<E>)
  • org.apache.flume.sink.kite.parser.AvroParser.Builder (implements org.apache.flume.sink.kite.parser.EntityParser.Builder<E>)
  • org.apache.flume.conf.BasicConfigurationConstants
  • org.apache.flume.source.BasicSourceSemantics (implements org.apache.flume.conf.Configurable, org.apache.flume.Source)
    • org.apache.flume.source.AbstractEventDrivenSource (implements org.apache.flume.EventDrivenSource)
    • org.apache.flume.source.AbstractPollableSource (implements org.apache.flume.PollableSource)
      • org.apache.flume.source.jms.JMSSource (implements org.apache.flume.conf.BatchSizeSupported)
      • org.apache.flume.source.kafka.KafkaSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
      • org.apache.flume.source.SequenceGeneratorSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
      • org.apache.flume.source.StressSource (implements org.apache.flume.conf.BatchSizeSupported, org.apache.flume.conf.Configurable)
  • org.apache.flume.channel.BasicTransactionSemantics (implements org.apache.flume.Transaction)
  • org.apache.flume.sink.solr.morphline.BlobDeserializer (implements org.apache.flume.serialization.EventDeserializer)
  • org.apache.flume.sink.solr.morphline.BlobDeserializer.Builder (implements org.apache.flume.serialization.EventDeserializer.Builder)
  • org.apache.flume.sink.solr.morphline.BlobHandler (implements org.apache.flume.source.http.HTTPSourceHandler)
  • org.apache.flume.source.http.BLOBHandler (implements org.apache.flume.source.http.HTTPSourceHandler)
  • 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.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.configfilter.ConfigFilterConfiguration
    • 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.sink.hive.Config
  • org.apache.flume.conf.ConfigFilterFactory
  • org.apache.flume.conf.Configurables
  • org.apache.flume.channel.jdbc.ConfigurationConstants
  • org.apache.flume.Constants
  • org.apache.flume.Context
  • org.apache.flume.CounterGroup
  • org.apache.flume.sink.kite.DatasetSinkConstants
  • org.apache.flume.channel.DefaultChannelFactory (implements org.apache.flume.ChannelFactory)
  • org.apache.flume.source.jms.DefaultJMSMessageConverter (implements org.apache.flume.source.jms.JMSMessageConverter)
  • org.apache.flume.source.jms.DefaultJMSMessageConverter.Builder (implements org.apache.flume.source.jms.JMSMessageConverter.Builder)
  • org.apache.flume.formatter.output.DefaultPathManager (implements org.apache.flume.formatter.output.PathManager)
    • org.apache.flume.formatter.output.RollTimePathManager
  • org.apache.flume.formatter.output.DefaultPathManager.Builder (implements org.apache.flume.formatter.output.PathManager.Builder)
  • 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)
  • java.util.Dictionary<K,V>
    • java.util.Hashtable<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.Properties
        • org.apache.flume.node.EnvVarResolverProperties
  • org.apache.flume.tools.DirectMemoryUtils
  • org.apache.flume.Dummy
  • org.apache.flume.serialization.DurablePositionTracker (implements org.apache.flume.serialization.PositionTracker)
  • org.apache.flume.agent.embedded.EmbeddedAgent
  • org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
  • org.apache.flume.channel.file.encryption.EncryptionConfiguration
  • org.apache.flume.sink.kite.parser.EntityParserFactory
  • org.apache.flume.event.EventBuilder
  • org.apache.flume.serialization.EventDeserializerFactory
  • org.apache.flume.event.EventHelper
  • org.apache.flume.serialization.EventSerializerFactory
  • org.apache.flume.channel.file.EventUtils
  • org.apache.flume.source.ExecSourceConfigurationConstants
  • org.apache.flume.sink.kite.policy.FailurePolicyFactory
  • org.apache.flume.channel.file.FileChannelConfiguration
  • org.apache.flume.tools.FileChannelIntegrityTool (implements org.apache.flume.tools.FlumeTool)
  • org.apache.flume.auth.FlumeAuthenticationUtil
  • org.apache.flume.tools.FlumeBeanConfigurator
  • 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.tools.FlumeToolsMain (implements org.apache.flume.tools.FlumeTool)
  • 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.hbase2.HBase2SinkConfigurationConstants
  • org.apache.flume.sink.hdfs.HDFSTextSerializer (implements org.apache.flume.sink.hdfs.SequenceFileSerializer)
  • org.apache.flume.sink.hdfs.HDFSTextSerializer.Builder (implements org.apache.flume.sink.hdfs.SequenceFileSerializer.Builder)
  • org.apache.flume.sink.hdfs.HDFSWritableSerializer (implements org.apache.flume.sink.hdfs.SequenceFileSerializer)
  • org.apache.flume.sink.hdfs.HDFSWritableSerializer.Builder (implements org.apache.flume.sink.hdfs.SequenceFileSerializer.Builder)
  • org.apache.flume.sink.hdfs.HDFSWriterFactory
  • org.apache.flume.serialization.HeaderAndBodyTextEventSerializer (implements org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.serialization.HeaderAndBodyTextEventSerializer.Builder (implements org.apache.flume.serialization.EventSerializer.Builder)
  • org.apache.flume.sink.hive.HiveDelimitedTextSerializer (implements org.apache.flume.sink.hive.HiveEventSerializer)
  • org.apache.flume.sink.hive.HiveJsonSerializer (implements org.apache.flume.sink.hive.HiveEventSerializer)
  • 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.tools.HTTPServerConstraintUtil
  • org.apache.flume.source.http.HTTPSourceConfigurationConstants
  • org.apache.flume.source.jms.InitialContextFactory
  • 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.source.jms.JMSSourceConfiguration
  • 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.channel.kafka.KafkaChannelConfiguration
  • org.apache.flume.shared.kafka.test.KafkaPartitionTestUtil
  • org.apache.flume.sink.kafka.KafkaSinkConstants
  • org.apache.flume.source.kafka.KafkaSource.Subscriber<T>
  • org.apache.flume.source.kafka.KafkaSourceConstants
  • org.apache.flume.shared.kafka.KafkaSSLUtil
  • org.apache.flume.auth.KerberosUser
  • 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.serialization.LineDeserializer (implements org.apache.flume.serialization.EventDeserializer)
  • org.apache.flume.serialization.LineDeserializer.Builder (implements org.apache.flume.serialization.EventDeserializer.Builder)
  • org.apache.flume.channel.file.Log
  • org.apache.flume.source.scribe.LogEntry (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.channel.file.LogFile
    • org.apache.flume.channel.file.LogFileV3
  • org.apache.flume.channel.file.LogFile.OperationRecordUpdater
  • org.apache.flume.channel.file.LogFile.SequentialReader
    • org.apache.flume.channel.file.LogFileV3.SequentialReader
  • org.apache.flume.conf.LogPrivacyUtil
  • 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.channel.file.instrumentation.FileChannelCounter (implements org.apache.flume.channel.file.instrumentation.FileChannelCounterMBean)
      • org.apache.flume.instrumentation.kafka.KafkaChannelCounter (implements org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean)
    • org.apache.flume.instrumentation.ChannelProcessorCounter
    • org.apache.flume.instrumentation.SinkCounter (implements org.apache.flume.instrumentation.SinkCounterMBean)
      • org.apache.flume.instrumentation.kafka.KafkaSinkCounter (implements org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean)
    • org.apache.flume.instrumentation.SinkProcessorCounter
    • org.apache.flume.instrumentation.SourceCounter (implements org.apache.flume.instrumentation.SourceCounterMBean)
      • org.apache.flume.instrumentation.kafka.KafkaSourceCounter (implements org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean)
  • org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl (implements org.apache.flume.sink.solr.morphline.MorphlineHandler)
  • org.apache.flume.sink.solr.morphline.MorphlineInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.sink.solr.morphline.MorphlineInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • 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.PathManagerFactory
  • 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.tools.PlatformDetect
  • org.apache.flume.source.PollableSourceConstants
  • org.apache.flume.source.PollableSourceRunner.PollingRunner (implements java.lang.Runnable)
  • org.apache.flume.node.PollingPropertiesFileConfigurationProvider.FileWatcherRunnable (implements java.lang.Runnable)
  • org.apache.thrift.ProcessFunction<I,T>
    • org.apache.flume.source.scribe.Scribe.Processor.Log<I>
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Processor.append<I>
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Processor.close<I>
    • org.apache.flume.thrift.ThriftSourceProtocol.Processor.append<I>
    • org.apache.flume.thrift.ThriftSourceProtocol.Processor.appendBatch<I>
  • org.apache.flume.channel.file.proto.ProtosFactory
  • org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction (implements org.apache.flume.Transaction)
  • org.apache.flume.source.shaded.guava.RateLimiter
  • 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.hbase2.RegexHBase2EventSerializer (implements org.apache.flume.sink.hbase2.HBase2EventSerializer)
    • org.apache.flume.sink.hbase.RegexHbaseEventSerializer (implements org.apache.flume.sink.hbase.HbaseEventSerializer)
  • org.apache.flume.client.avro.ReliableSpoolingFileEventReader (implements org.apache.flume.client.avro.ReliableEventReader)
  • org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
  • org.apache.flume.source.taildir.ReliableTaildirEventReader (implements org.apache.flume.client.avro.ReliableEventReader)
  • org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
  • org.apache.flume.interceptor.RemoveHeaderInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.RemoveHeaderInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.serialization.ResettableInputStream (implements java.io.Closeable, org.apache.flume.serialization.Resettable, org.apache.flume.serialization.Seekable)
    • org.apache.flume.serialization.ResettableFileInputStream (implements org.apache.flume.serialization.LengthMeasurable, org.apache.flume.serialization.RemoteMarkable)
  • org.apache.flume.sink.kite.policy.RetryPolicy (implements org.apache.flume.sink.kite.policy.FailurePolicy)
  • org.apache.flume.sink.kite.policy.RetryPolicy.Builder (implements org.apache.flume.sink.kite.policy.FailurePolicy.Builder)
  • org.apache.flume.formatter.output.RollTimePathManager.Builder (implements org.apache.flume.formatter.output.PathManager.Builder)
  • org.apache.flume.api.RpcClientConfigurationConstants
  • org.apache.flume.api.RpcClientFactory
  • org.apache.flume.sink.kite.policy.SavePolicy (implements org.apache.flume.sink.kite.policy.FailurePolicy)
  • org.apache.flume.sink.kite.policy.SavePolicy.Builder (implements org.apache.flume.sink.kite.policy.FailurePolicy.Builder)
  • 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.Factory (implements org.apache.thrift.TServiceClientFactory<T>)
  • org.apache.flume.source.scribe.Scribe.Log_args (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.source.scribe.Scribe.Log_result (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.interceptor.SearchAndReplaceInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.interceptor.SearchAndReplaceInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.api.SecureRpcClientFactory
  • org.apache.flume.sink.hdfs.SequenceFileSerializer.Record
  • org.apache.flume.sink.hdfs.SequenceFileSerializerFactory
  • org.apache.flume.channel.file.Serialization
  • org.jboss.netty.channel.SimpleChannelHandler (implements org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelUpstreamHandler)
    • org.apache.flume.source.NetcatUdpSource.NetcatHandler
    • 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.hbase2.SimpleHBase2EventSerializer (implements org.apache.flume.sink.hbase2.HBase2EventSerializer)
    • org.apache.flume.sink.hbase.SimpleHbaseEventSerializer (implements org.apache.flume.sink.hbase.HbaseEventSerializer)
  • org.apache.flume.node.SimpleMaterializedConfiguration (implements org.apache.flume.node.MaterializedConfiguration)
  • org.apache.flume.sink.hbase2.SimpleRowKeyGenerator
  • org.apache.flume.client.avro.SimpleTextLineEventReader (implements org.apache.flume.client.avro.EventReader)
  • 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.channel.SpillableMemoryChannel.DrainOrderQueue
  • org.apache.flume.source.SpoolDirectorySource.SpoolDirectoryRunnable (implements java.lang.Runnable)
  • org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
  • org.apache.flume.util.SSLUtil
  • 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.shaded.guava.Stopwatch
  • 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.flume.source.taildir.TaildirMatcher
  • org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
  • org.apache.flume.source.taildir.TailFile
  • 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.flume.thrift.ThriftSourceProtocol.AsyncClient (implements org.apache.flume.thrift.ThriftSourceProtocol.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.thrift.ThriftSourceProtocol.AsyncClient.append_call
    • org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient.appendBatch_call
  • org.apache.thrift.TBaseAsyncProcessor<I> (implements org.apache.thrift.TAsyncProcessor, org.apache.thrift.TProcessor)
    • org.apache.flume.source.scribe.Scribe.AsyncProcessor<I>
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncProcessor<I>
    • org.apache.flume.thrift.ThriftSourceProtocol.AsyncProcessor<I>
  • org.apache.thrift.TBaseProcessor<I> (implements org.apache.thrift.TProcessor)
    • org.apache.flume.source.scribe.Scribe.Processor<I> (implements org.apache.thrift.TProcessor)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Processor<I> (implements org.apache.thrift.TProcessor)
    • org.apache.flume.thrift.ThriftSourceProtocol.Processor<I> (implements org.apache.thrift.TProcessor)
  • org.apache.flume.formatter.output.TextDelimitedOutputFormatter (implements org.apache.flume.formatter.output.EventFormatter)
  • java.lang.ThreadLocal<T>
    • org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory
  • org.apache.flume.thrift.ThriftFlumeEvent (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEvent (implements java.lang.Cloneable, java.lang.Comparable<T>, 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.lang.Comparable<T>, 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.Factory (implements org.apache.thrift.TServiceClientFactory<T>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.source.thriftLegacy.ThriftLegacySource.ThriftHandler (implements java.lang.Runnable)
  • org.apache.flume.thrift.ThriftSourceProtocol
  • org.apache.flume.thrift.ThriftSourceProtocol.append_args (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.thrift.ThriftSourceProtocol.append_result (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result (implements java.lang.Cloneable, java.lang.Comparable<T>, java.io.Serializable, org.apache.thrift.TBase<T,F>)
  • org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient.Factory (implements org.apache.thrift.async.TAsyncClientFactory<T>)
  • org.apache.flume.thrift.ThriftSourceProtocol.Client.Factory (implements org.apache.thrift.TServiceClientFactory<T>)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.flume.channel.file.CorruptEventException
      • org.apache.flume.EventDeliveryException
      • java.io.IOException
        • org.apache.flume.channel.file.LogFileRetryableIOException
      • org.apache.flume.lifecycle.LifecycleException
      • org.apache.flume.sink.kite.NonRecoverableEventException
      • org.apache.flume.channel.file.NoopRecordException
      • java.lang.RuntimeException
        • org.apache.flume.ChannelException
          • org.apache.flume.ChannelFullException
          • org.apache.flume.channel.jdbc.JdbcChannelException
        • org.apache.flume.FlumeException
          • org.apache.flume.channel.file.BadCheckpointException
          • org.apache.flume.sink.hdfs.BucketClosedException
          • org.apache.flume.conf.ConfigurationException
          • org.apache.flume.channel.file.encryption.DecryptionFailureException
          • org.apache.flume.source.http.HTTPBadRequestException
        • org.apache.flume.auth.SecurityException
  • 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.TransactionEventRecord
  • org.apache.flume.channel.file.TransactionIDOracle
  • org.apache.thrift.TServiceClient
    • org.apache.flume.source.scribe.Scribe.Client (implements org.apache.flume.source.scribe.Scribe.Iface)
    • com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client (implements com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Iface)
    • org.apache.flume.thrift.ThriftSourceProtocol.Client (implements org.apache.flume.thrift.ThriftSourceProtocol.Iface)
  • org.apache.thrift.transport.TTransport (implements java.io.Closeable)
    • org.apache.thrift.transport.TSaslClientTransport
      • org.apache.flume.api.SecureThriftRpcClient.UgiSaslClientTransport
  • org.apache.flume.source.shaded.guava.Uninterruptibles
  • org.apache.flume.sink.solr.morphline.UUIDInterceptor (implements org.apache.flume.interceptor.Interceptor)
  • org.apache.flume.sink.solr.morphline.UUIDInterceptor.Builder (implements org.apache.flume.interceptor.Interceptor.Builder)
  • org.apache.flume.tools.VersionInfo
  • org.apache.flume.channel.file.WriteOrderOracle

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flume.serialization.EventDeserializer (also extends org.apache.flume.serialization.Resettable)
      • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventSerializer)
    • org.apache.flume.client.avro.EventReader
      • org.apache.flume.client.avro.ReliableEventReader
    • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventDeserializer, org.apache.flume.serialization.EventSerializer)
    • org.apache.flume.serialization.PositionTracker
    • org.apache.flume.client.avro.ReliableEventReader
  • org.apache.flume.serialization.EventDeserializer (also extends java.io.Closeable, org.apache.flume.serialization.Resettable)
    • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.client.avro.EventReader
    • org.apache.flume.client.avro.ReliableEventReader
  • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventDeserializer, org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.serialization.PositionTracker
  • org.apache.flume.client.avro.ReliableEventReader
• org.apache.flume.sink.hbase2.BatchAware
• org.apache.flume.conf.BatchSizeSupported
• org.apache.flume.instrumentation.ChannelCounterMBean
  • org.apache.flume.channel.file.instrumentation.FileChannelCounterMBean
• org.apache.flume.ChannelFactory
• org.apache.flume.Clock
• org.apache.flume.conf.ComponentWithClassName
• org.apache.flume.configfilter.ConfigFilter
• org.apache.flume.conf.Configurable
  • org.apache.flume.ChannelSelector (also extends org.apache.flume.NamedComponent)
  • org.apache.flume.tools.EventValidator.Builder
  • org.apache.flume.sink.hbase2.HBase2EventSerializer (also extends org.apache.flume.conf.ConfigurableComponent)
    • org.apache.flume.sink.hbase.HbaseEventSerializer
  • org.apache.flume.sink.hbase.HbaseEventSerializer
  • org.apache.flume.sink.hdfs.HDFSWriter
  • org.apache.flume.sink.hive.HiveEventSerializer
  • 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.sink.solr.morphline.MorphlineHandler
  • 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.hbase2.HBase2EventSerializer (also extends org.apache.flume.conf.Configurable)
    • org.apache.flume.sink.hbase.HbaseEventSerializer
  • org.apache.flume.sink.hbase.HbaseEventSerializer
  • org.apache.flume.interceptor.RegexExtractorInterceptorSerializer (also extends org.apache.flume.conf.Configurable)
• org.apache.flume.node.ConfigurationProvider
• org.apache.flume.sink.kite.parser.EntityParser<E>
• org.apache.flume.sink.kite.parser.EntityParser.Builder<E>
• org.apache.flume.Event
• org.apache.flume.serialization.EventDeserializer.Builder
• org.apache.flume.formatter.output.EventFormatter
• org.apache.flume.serialization.EventSerDe.Builder
• org.apache.flume.serialization.EventSerializer
  • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventDeserializer)
• org.apache.flume.serialization.EventSerializer.Builder
• org.apache.flume.tools.EventValidator
• org.apache.flume.sink.kite.policy.FailurePolicy
• org.apache.flume.sink.kite.policy.FailurePolicy.Builder
• org.apache.flume.tools.FlumeTool
• org.apache.flume.sink.hdfs.HDFSEventSink.WriterCallback
• org.apache.flume.interceptor.Interceptor
• org.apache.flume.channel.jdbc.JdbcChannelProvider
• org.apache.flume.source.jms.JMSMessageConverter
• org.apache.flume.source.jms.JMSMessageConverter.Builder
• org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
• org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
• org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
• org.apache.flume.channel.file.encryption.KeyProvider.Builder
• org.apache.flume.serialization.LengthMeasurable
• org.apache.flume.lifecycle.LifecycleAware
  • org.apache.flume.Channel (also extends org.apache.flume.NamedComponent)
  • org.apache.flume.EventDrivenSource
  • org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector (also extends org.apache.flume.conf.Configurable)
  • 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.api.LoadBalancingRpcClient.HostSelector
• org.apache.flume.node.MaterializedConfiguration
• 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.formatter.output.PathManager
• org.apache.flume.formatter.output.PathManager.Builder
• org.apache.flume.auth.PrivilegedExecutor
  • org.apache.flume.auth.FlumeAuthenticator
• org.apache.flume.serialization.RemoteMarkable
• org.apache.flume.serialization.Resettable
  • org.apache.flume.serialization.EventDeserializer (also extends java.io.Closeable)
    • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventSerializer)
  • org.apache.flume.serialization.EventSerDe (also extends org.apache.flume.serialization.EventDeserializer, org.apache.flume.serialization.EventSerializer)
• 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.serialization.Seekable
• org.apache.flume.sink.hdfs.SequenceFileSerializer
• org.apache.flume.sink.hdfs.SequenceFileSerializer.Builder
• 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
• org.apache.flume.thrift.ThriftSourceProtocol.AsyncIface
• org.apache.flume.thrift.ThriftSourceProtocol.Iface
• org.apache.flume.Transaction
• org.apache.flume.conf.TransactionCapacitySupported

Annotation Type Hierarchy

• org.apache.flume.VersionAnnotation (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.Recyclable (implements java.lang.annotation.Annotation)
• org.apache.flume.annotations.Disposable (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.PollableSource.Status
    • org.apache.flume.Sink.Status
    • org.apache.flume.Transaction.TransactionState
    • org.apache.flume.api.RpcClientFactory.ClientType
    • org.apache.flume.thrift.Status (implements org.apache.thrift.TEnum)
    • org.apache.flume.thrift.ThriftFlumeEvent._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields (implements org.apache.thrift.TFieldIdEnum)
    • org.apache.flume.conf.FlumeConfigurationErrorType
    • org.apache.flume.conf.ComponentConfiguration.ComponentType
    • org.apache.flume.conf.FlumeConfigurationError.ErrorOrWarning
    • org.apache.flume.conf.channel.ChannelType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.channel.ChannelSelectorConfiguration.ChannelSelectorConfigurationType
    • org.apache.flume.conf.channel.ChannelConfiguration.ChannelConfigurationType
    • org.apache.flume.conf.channel.ChannelSelectorType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.configfilter.ConfigFilterConfiguration.ConfigFilterConfigurationType
    • org.apache.flume.conf.configfilter.ConfigFilterType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.sink.SinkProcessorType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.sink.SinkType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.sink.SinkProcessorConfiguration.SinkProcessorConfigurationType
    • org.apache.flume.conf.sink.SinkConfiguration.SinkConfigurationType
    • org.apache.flume.conf.source.SourceType (implements org.apache.flume.conf.ComponentWithClassName)
    • org.apache.flume.conf.source.SourceConfiguration.SourceConfigurationType
    • org.apache.flume.channel.BasicTransactionSemantics.State
    • org.apache.flume.client.avro.ReliableSpoolingFileEventReader.TrackingPolicy
    • org.apache.flume.formatter.output.PathManagerType
    • 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.serialization.AvroEventDeserializer.AvroSchemaType
    • org.apache.flume.serialization.EventDeserializerType
    • org.apache.flume.serialization.DecodeErrorPolicy
    • org.apache.flume.source.SyslogUtils.SyslogStatus
    • org.apache.flume.source.SpoolDirectorySourceConfigurationConstants.ConsumeOrder
    • org.apache.flume.tools.FlumeToolType
    • org.apache.flume.sink.hdfs.SequenceFileSerializerType
    • 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
    • org.apache.flume.sink.hbase2.SimpleHBase2EventSerializer.KeyType
    • org.apache.flume.shared.kafka.test.PartitionOption
    • org.apache.flume.shared.kafka.test.PartitionTestScenario
    • 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.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.jms.JMSDestinationLocator
    • org.apache.flume.source.jms.JMSDestinationType
    • com.cloudera.flume.handlers.thrift.EventStatus (implements org.apache.thrift.TEnum)
    • 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)
    • org.apache.flume.clients.log4jappender.Log4jAvroHeaders