apache-flume-1.7.0-bin.tar

【实例简介】
Flume 是Cloudera提供的分布式数据收集系统，它能够将不同数据源的海量日志数据进行高效的收集、聚合、移动，最后存储到存储中心。Flume NG支持（故障转移）failover和负载均衡。
【实例截图】
【核心代码】
4744302542903055293.tar
└── apache-flume-1.7.0-bin
├── bin
│   ├── flume-ng
│   ├── flume-ng.cmd
│   └── flume-ng.ps1
├── CHANGELOG
├── conf
│   ├── flume-conf.properties.template
│   ├── flume-env.ps1.template
│   ├── flume-env.sh.template
│   └── log4j.properties
├── DEVNOTES
├── doap_Flume.rdf
├── docs
│   ├── apidocs
│   │   ├── allclasses-frame.html
│   │   ├── allclasses-noframe.html
│   │   ├── com
│   │   │   └── cloudera
│   │   │   └── flume
│   │   │   └── handlers
│   │   │   └── thrift
│   │   │   ├── class-use
│   │   │   │   ├── EventStatus.html
│   │   │   │   ├── Priority.html
│   │   │   │   ├── ThriftFlumeEvent._Fields.html
│   │   │   │   ├── ThriftFlumeEvent.html
│   │   │   │   ├── ThriftFlumeEventServer.append_args._Fields.html
│   │   │   │   ├── ThriftFlumeEventServer.append_args.html
│   │   │   │   ├── ThriftFlumeEventServer.AsyncClient.append_call.html
│   │   │   │   ├── ThriftFlumeEventServer.AsyncClient.close_call.html
│   │   │   │   ├── ThriftFlumeEventServer.AsyncClient.Factory.html
│   │   │   │   ├── ThriftFlumeEventServer.AsyncClient.html
│   │   │   │   ├── ThriftFlumeEventServer.AsyncIface.html
│   │   │   │   ├── ThriftFlumeEventServer.Client.Factory.html
│   │   │   │   ├── ThriftFlumeEventServer.Client.html
│   │   │   │   ├── ThriftFlumeEventServer.close_args._Fields.html
│   │   │   │   ├── ThriftFlumeEventServer.close_args.html
│   │   │   │   ├── ThriftFlumeEventServer.close_result._Fields.html
│   │   │   │   ├── ThriftFlumeEventServer.close_result.html
│   │   │   │   ├── ThriftFlumeEventServer.html
│   │   │   │   ├── ThriftFlumeEventServer.Iface.html
│   │   │   │   └── ThriftFlumeEventServer.Processor.html
│   │   │   ├── EventStatus.html
│   │   │   ├── package-frame.html
│   │   │   ├── package-summary.html
│   │   │   ├── package-tree.html
│   │   │   ├── package-use.html
│   │   │   ├── Priority.html
│   │   │   ├── ThriftFlumeEvent._Fields.html
│   │   │   ├── ThriftFlumeEvent.html
│   │   │   ├── ThriftFlumeEventServer.append_args._Fields.html
│   │   │   ├── ThriftFlumeEventServer.append_args.html
│   │   │   ├── ThriftFlumeEventServer.AsyncClient.append_call.html
│   │   │   ├── ThriftFlumeEventServer.AsyncClient.close_call.html
│   │   │   ├── ThriftFlumeEventServer.AsyncClient.Factory.html
│   │   │   ├── ThriftFlumeEventServer.AsyncClient.html
│   │   │   ├── ThriftFlumeEventServer.AsyncIface.html
│   │   │   ├── ThriftFlumeEventServer.Client.Factory.html
│   │   │   ├── ThriftFlumeEventServer.Client.html
│   │   │   ├── ThriftFlumeEventServer.close_args._Fields.html
│   │   │   ├── ThriftFlumeEventServer.close_args.html
│   │   │   ├── ThriftFlumeEventServer.close_result._Fields.html
│   │   │   ├── ThriftFlumeEventServer.close_result.html
│   │   │   ├── ThriftFlumeEventServer.html
│   │   │   ├── ThriftFlumeEventServer.Iface.html
│   │   │   └── ThriftFlumeEventServer.Processor.html
│   │   ├── constant-values.html
│   │   ├── deprecated-list.html
│   │   ├── help-doc.html
│   │   ├── index-all.html
│   │   ├── index.html
│   │   ├── org
│   │   │   └── apache
│   │   │   └── flume
│   │   │   ├── agent
│   │   │   │   └── embedded
│   │   │   │   ├── class-use
│   │   │   │   │   ├── EmbeddedAgentConfiguration.html
│   │   │   │   │   ├── EmbeddedAgent.html
│   │   │   │   │   └── EmbeddedSource.html
│   │   │   │   ├── EmbeddedAgentConfiguration.html
│   │   │   │   ├── EmbeddedAgent.html
│   │   │   │   ├── EmbeddedSource.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   └── package-use.html
│   │   │   ├── annotations
│   │   │   │   ├── class-use
│   │   │   │   │   ├── Disposable.html
│   │   │   │   │   ├── InterfaceAudience.html
│   │   │   │   │   ├── InterfaceAudience.LimitedPrivate.html
│   │   │   │   │   ├── InterfaceAudience.Private.html
│   │   │   │   │   ├── InterfaceAudience.Public.html
│   │   │   │   │   ├── InterfaceStability.Evolving.html
│   │   │   │   │   ├── InterfaceStability.html
│   │   │   │   │   ├── InterfaceStability.Stable.html
│   │   │   │   │   ├── InterfaceStability.Unstable.html
│   │   │   │   │   └── Recyclable.html
│   │   │   │   ├── Disposable.html
│   │   │   │   ├── InterfaceAudience.html
│   │   │   │   ├── InterfaceAudience.LimitedPrivate.html
│   │   │   │   ├── InterfaceAudience.Private.html
│   │   │   │   ├── InterfaceAudience.Public.html
│   │   │   │   ├── InterfaceStability.Evolving.html
│   │   │   │   ├── InterfaceStability.html
│   │   │   │   ├── InterfaceStability.Stable.html
│   │   │   │   ├── InterfaceStability.Unstable.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   └── Recyclable.html
│   │   │   ├── api
│   │   │   │   ├── AbstractRpcClient.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractRpcClient.html
│   │   │   │   │   ├── FailoverRpcClient.html
│   │   │   │   │   ├── HostInfo.html
│   │   │   │   │   ├── LoadBalancingRpcClient.HostSelector.html
│   │   │   │   │   ├── LoadBalancingRpcClient.html
│   │   │   │   │   ├── NettyAvroRpcClient.html
│   │   │   │   │   ├── RpcClientConfigurationConstants.html
│   │   │   │   │   ├── RpcClientFactory.ClientType.html
│   │   │   │   │   ├── RpcClientFactory.html
│   │   │   │   │   ├── RpcClient.html
│   │   │   │   │   ├── SecureRpcClientFactory.html
│   │   │   │   │   ├── SecureThriftRpcClient.html
│   │   │   │   │   ├── SecureThriftRpcClient.UgiSaslClientTransport.html
│   │   │   │   │   └── ThriftRpcClient.html
│   │   │   │   ├── FailoverRpcClient.html
│   │   │   │   ├── HostInfo.html
│   │   │   │   ├── LoadBalancingRpcClient.HostSelector.html
│   │   │   │   ├── LoadBalancingRpcClient.html
│   │   │   │   ├── NettyAvroRpcClient.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── RpcClientConfigurationConstants.html
│   │   │   │   ├── RpcClientFactory.ClientType.html
│   │   │   │   ├── RpcClientFactory.html
│   │   │   │   ├── RpcClient.html
│   │   │   │   ├── SecureRpcClientFactory.html
│   │   │   │   ├── SecureThriftRpcClient.html
│   │   │   │   ├── SecureThriftRpcClient.UgiSaslClientTransport.html
│   │   │   │   └── ThriftRpcClient.html
│   │   │   ├── auth
│   │   │   │   ├── class-use
│   │   │   │   │   ├── FlumeAuthenticationUtil.html
│   │   │   │   │   ├── FlumeAuthenticator.html
│   │   │   │   │   ├── KerberosUser.html
│   │   │   │   │   ├── PrivilegedExecutor.html
│   │   │   │   │   └── SecurityException.html
│   │   │   │   ├── FlumeAuthenticationUtil.html
│   │   │   │   ├── FlumeAuthenticator.html
│   │   │   │   ├── KerberosUser.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PrivilegedExecutor.html
│   │   │   │   └── SecurityException.html
│   │   │   ├── channel
│   │   │   │   ├── AbstractChannel.html
│   │   │   │   ├── AbstractChannelSelector.html
│   │   │   │   ├── BasicChannelSemantics.html
│   │   │   │   ├── BasicTransactionSemantics.html
│   │   │   │   ├── BasicTransactionSemantics.State.html
│   │   │   │   ├── ChannelProcessor.html
│   │   │   │   ├── ChannelSelectorFactory.html
│   │   │   │   ├── ChannelUtils.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractChannel.html
│   │   │   │   │   ├── AbstractChannelSelector.html
│   │   │   │   │   ├── BasicChannelSemantics.html
│   │   │   │   │   ├── BasicTransactionSemantics.html
│   │   │   │   │   ├── BasicTransactionSemantics.State.html
│   │   │   │   │   ├── ChannelProcessor.html
│   │   │   │   │   ├── ChannelSelectorFactory.html
│   │   │   │   │   ├── ChannelUtils.html
│   │   │   │   │   ├── DefaultChannelFactory.html
│   │   │   │   │   ├── MemoryChannel.html
│   │   │   │   │   ├── MultiplexingChannelSelector.html
│   │   │   │   │   ├── PseudoTxnMemoryChannel.html
│   │   │   │   │   ├── PseudoTxnMemoryChannel.NoOpTransaction.html
│   │   │   │   │   ├── ReplicatingChannelSelector.html
│   │   │   │   │   ├── SpillableMemoryChannel.DrainOrderQueue.html
│   │   │   │   │   └── SpillableMemoryChannel.html
│   │   │   │   ├── DefaultChannelFactory.html
│   │   │   │   ├── file
│   │   │   │   │   ├── BadCheckpointException.html
│   │   │   │   │   ├── CheckpointRebuilder.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── BadCheckpointException.html
│   │   │   │   │   │   ├── CheckpointRebuilder.html
│   │   │   │   │   │   ├── CorruptEventException.html
│   │   │   │   │   │   ├── EventUtils.html
│   │   │   │   │   │   ├── FileChannelConfiguration.html
│   │   │   │   │   │   ├── FileChannel.html
│   │   │   │   │   │   ├── LogFile.html
│   │   │   │   │   │   ├── LogFile.OperationRecordUpdater.html
│   │   │   │   │   │   ├── LogFileRetryableIOException.html
│   │   │   │   │   │   ├── LogFile.SequentialReader.html
│   │   │   │   │   │   ├── LogFileV3.html
│   │   │   │   │   │   ├── LogFileV3.SequentialReader.html
│   │   │   │   │   │   ├── Log.html
│   │   │   │   │   │   ├── LogRecord.html
│   │   │   │   │   │   ├── LogUtils.html
│   │   │   │   │   │   ├── NoopRecordException.html
│   │   │   │   │   │   ├── Serialization.html
│   │   │   │   │   │   ├── TransactionEventRecord.html
│   │   │   │   │   │   ├── TransactionIDOracle.html
│   │   │   │   │   │   └── WriteOrderOracle.html
│   │   │   │   │   ├── CorruptEventException.html
│   │   │   │   │   ├── encryption
│   │   │   │   │   │   ├── AESCTRNoPaddingProvider.DecryptorBuilder.html
│   │   │   │   │   │   ├── AESCTRNoPaddingProvider.EncryptorBuilder.html
│   │   │   │   │   │   ├── AESCTRNoPaddingProvider.html
│   │   │   │   │   │   ├── CipherProvider.Decryptor.Builder.html
│   │   │   │   │   │   ├── CipherProvider.Decryptor.html
│   │   │   │   │   │   ├── CipherProvider.Encryptor.Builder.html
│   │   │   │   │   │   ├── CipherProvider.Encryptor.html
│   │   │   │   │   │   ├── CipherProviderFactory.html
│   │   │   │   │   │   ├── CipherProvider.html
│   │   │   │   │   │   ├── CipherProviderType.html
│   │   │   │   │   │   ├── class-use
│   │   │   │   │   │   │   ├── AESCTRNoPaddingProvider.DecryptorBuilder.html
│   │   │   │   │   │   │   ├── AESCTRNoPaddingProvider.EncryptorBuilder.html
│   │   │   │   │   │   │   ├── AESCTRNoPaddingProvider.html
│   │   │   │   │   │   │   ├── CipherProvider.Decryptor.Builder.html
│   │   │   │   │   │   │   ├── CipherProvider.Decryptor.html
│   │   │   │   │   │   │   ├── CipherProvider.Encryptor.Builder.html
│   │   │   │   │   │   │   ├── CipherProvider.Encryptor.html
│   │   │   │   │   │   │   ├── CipherProviderFactory.html
│   │   │   │   │   │   │   ├── CipherProvider.html
│   │   │   │   │   │   │   ├── CipherProviderType.html
│   │   │   │   │   │   │   ├── DecryptionFailureException.html
│   │   │   │   │   │   │   ├── EncryptionConfiguration.html
│   │   │   │   │   │   │   ├── JCEFileKeyProvider.Builder.html
│   │   │   │   │   │   │   ├── JCEFileKeyProvider.html
│   │   │   │   │   │   │   ├── KeyProvider.Builder.html
│   │   │   │   │   │   │   ├── KeyProviderFactory.html
│   │   │   │   │   │   │   ├── KeyProvider.html
│   │   │   │   │   │   │   └── KeyProviderType.html
│   │   │   │   │   │   ├── DecryptionFailureException.html
│   │   │   │   │   │   ├── EncryptionConfiguration.html
│   │   │   │   │   │   ├── JCEFileKeyProvider.Builder.html
│   │   │   │   │   │   ├── JCEFileKeyProvider.html
│   │   │   │   │   │   ├── KeyProvider.Builder.html
│   │   │   │   │   │   ├── KeyProviderFactory.html
│   │   │   │   │   │   ├── KeyProvider.html
│   │   │   │   │   │   ├── KeyProviderType.html
│   │   │   │   │   │   ├── package-frame.html
│   │   │   │   │   │   ├── package-summary.html
│   │   │   │   │   │   ├── package-tree.html
│   │   │   │   │   │   └── package-use.html
│   │   │   │   │   ├── EventUtils.html
│   │   │   │   │   ├── FileChannelConfiguration.html
│   │   │   │   │   ├── FileChannel.html
│   │   │   │   │   ├── LogFile.html
│   │   │   │   │   ├── LogFile.OperationRecordUpdater.html
│   │   │   │   │   ├── LogFileRetryableIOException.html
│   │   │   │   │   ├── LogFile.SequentialReader.html
│   │   │   │   │   ├── LogFileV3.html
│   │   │   │   │   ├── LogFileV3.SequentialReader.html
│   │   │   │   │   ├── Log.html
│   │   │   │   │   ├── LogRecord.html
│   │   │   │   │   ├── LogUtils.html
│   │   │   │   │   ├── NoopRecordException.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── proto
│   │   │   │   │   │   ├── class-use
│   │   │   │   │   │   │   ├── ProtosFactory.ActiveLog.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.ActiveLog.html
│   │   │   │   │   │   │   ├── ProtosFactory.ActiveLogOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Checkpoint.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Checkpoint.html
│   │   │   │   │   │   │   ├── ProtosFactory.CheckpointOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Commit.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Commit.html
│   │   │   │   │   │   │   ├── ProtosFactory.CommitOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEvent.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeader.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeader.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeaderOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEvent.html
│   │   │   │   │   │   │   ├── ProtosFactory.FlumeEventOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileEncryption.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileEncryption.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileEncryptionOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileMetaData.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileMetaData.html
│   │   │   │   │   │   │   ├── ProtosFactory.LogFileMetaDataOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Put.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Put.html
│   │   │   │   │   │   │   ├── ProtosFactory.PutOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Rollback.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Rollback.html
│   │   │   │   │   │   │   ├── ProtosFactory.RollbackOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Take.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.Take.html
│   │   │   │   │   │   │   ├── ProtosFactory.TakeOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooter.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooter.html
│   │   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooterOrBuilder.html
│   │   │   │   │   │   │   ├── ProtosFactory.TransactionEventHeader.Builder.html
│   │   │   │   │   │   │   ├── ProtosFactory.TransactionEventHeader.html
│   │   │   │   │   │   │   └── ProtosFactory.TransactionEventHeaderOrBuilder.html
│   │   │   │   │   │   ├── package-frame.html
│   │   │   │   │   │   ├── package-summary.html
│   │   │   │   │   │   ├── package-tree.html
│   │   │   │   │   │   ├── package-use.html
│   │   │   │   │   │   ├── ProtosFactory.ActiveLog.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.ActiveLog.html
│   │   │   │   │   │   ├── ProtosFactory.ActiveLogOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.Checkpoint.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.Checkpoint.html
│   │   │   │   │   │   ├── ProtosFactory.CheckpointOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.Commit.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.Commit.html
│   │   │   │   │   │   ├── ProtosFactory.CommitOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEvent.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeader.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeader.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEventHeaderOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEvent.html
│   │   │   │   │   │   ├── ProtosFactory.FlumeEventOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileEncryption.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileEncryption.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileEncryptionOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileMetaData.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileMetaData.html
│   │   │   │   │   │   ├── ProtosFactory.LogFileMetaDataOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.Put.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.Put.html
│   │   │   │   │   │   ├── ProtosFactory.PutOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.Rollback.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.Rollback.html
│   │   │   │   │   │   ├── ProtosFactory.RollbackOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.Take.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.Take.html
│   │   │   │   │   │   ├── ProtosFactory.TakeOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooter.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooter.html
│   │   │   │   │   │   ├── ProtosFactory.TransactionEventFooterOrBuilder.html
│   │   │   │   │   │   ├── ProtosFactory.TransactionEventHeader.Builder.html
│   │   │   │   │   │   ├── ProtosFactory.TransactionEventHeader.html
│   │   │   │   │   │   └── ProtosFactory.TransactionEventHeaderOrBuilder.html
│   │   │   │   │   ├── Serialization.html
│   │   │   │   │   ├── TransactionEventRecord.html
│   │   │   │   │   ├── TransactionIDOracle.html
│   │   │   │   │   └── WriteOrderOracle.html
│   │   │   │   ├── jdbc
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── ConfigurationConstants.html
│   │   │   │   │   │   ├── DatabaseType.html
│   │   │   │   │   │   ├── JdbcChannelException.html
│   │   │   │   │   │   ├── JdbcChannel.html
│   │   │   │   │   │   ├── JdbcChannelProviderFactory.html
│   │   │   │   │   │   ├── JdbcChannelProvider.html
│   │   │   │   │   │   └── TransactionIsolation.html
│   │   │   │   │   ├── ConfigurationConstants.html
│   │   │   │   │   ├── DatabaseType.html
│   │   │   │   │   ├── impl
│   │   │   │   │   │   ├── class-use
│   │   │   │   │   │   │   ├── DerbySchemaHandler.html
│   │   │   │   │   │   │   ├── JdbcChannelProviderImpl.html
│   │   │   │   │   │   │   ├── JdbcTransactionFactory.html
│   │   │   │   │   │   │   ├── JdbcTransactionImpl.html
│   │   │   │   │   │   │   ├── MySQLSchemaHandler.html
│   │   │   │   │   │   │   ├── PersistableEvent.Builder.html
│   │   │   │   │   │   │   ├── PersistableEvent.HeaderEntry.html
│   │   │   │   │   │   │   ├── PersistableEvent.html
│   │   │   │   │   │   │   ├── PersistableEvent.SpillableString.html
│   │   │   │   │   │   │   ├── SchemaHandlerFactory.html
│   │   │   │   │   │   │   └── SchemaHandler.html
│   │   │   │   │   │   ├── DerbySchemaHandler.html
│   │   │   │   │   │   ├── JdbcChannelProviderImpl.html
│   │   │   │   │   │   ├── JdbcTransactionFactory.html
│   │   │   │   │   │   ├── JdbcTransactionImpl.html
│   │   │   │   │   │   ├── MySQLSchemaHandler.html
│   │   │   │   │   │   ├── package-frame.html
│   │   │   │   │   │   ├── package-summary.html
│   │   │   │   │   │   ├── package-tree.html
│   │   │   │   │   │   ├── package-use.html
│   │   │   │   │   │   ├── PersistableEvent.Builder.html
│   │   │   │   │   │   ├── PersistableEvent.HeaderEntry.html
│   │   │   │   │   │   ├── PersistableEvent.html
│   │   │   │   │   │   ├── PersistableEvent.SpillableString.html
│   │   │   │   │   │   ├── SchemaHandlerFactory.html
│   │   │   │   │   │   └── SchemaHandler.html
│   │   │   │   │   ├── JdbcChannelException.html
│   │   │   │   │   ├── JdbcChannel.html
│   │   │   │   │   ├── JdbcChannelProviderFactory.html
│   │   │   │   │   ├── JdbcChannelProvider.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   └── TransactionIsolation.html
│   │   │   │   ├── kafka
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── KafkaChannelConfiguration.html
│   │   │   │   │   │   └── KafkaChannel.html
│   │   │   │   │   ├── KafkaChannelConfiguration.html
│   │   │   │   │   ├── KafkaChannel.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── MemoryChannel.html
│   │   │   │   ├── MultiplexingChannelSelector.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PseudoTxnMemoryChannel.html
│   │   │   │   ├── PseudoTxnMemoryChannel.NoOpTransaction.html
│   │   │   │   ├── ReplicatingChannelSelector.html
│   │   │   │   ├── SpillableMemoryChannel.DrainOrderQueue.html
│   │   │   │   └── SpillableMemoryChannel.html
│   │   │   ├── ChannelException.html
│   │   │   ├── ChannelFactory.html
│   │   │   ├── ChannelFullException.html
│   │   │   ├── Channel.html
│   │   │   ├── ChannelSelector.html
│   │   │   ├── class-use
│   │   │   │   ├── ChannelException.html
│   │   │   │   ├── ChannelFactory.html
│   │   │   │   ├── ChannelFullException.html
│   │   │   │   ├── Channel.html
│   │   │   │   ├── ChannelSelector.html
│   │   │   │   ├── Clock.html
│   │   │   │   ├── Constants.html
│   │   │   │   ├── Context.html
│   │   │   │   ├── CounterGroup.html
│   │   │   │   ├── Dummy.html
│   │   │   │   ├── EventDeliveryException.html
│   │   │   │   ├── EventDrivenSource.html
│   │   │   │   ├── Event.html
│   │   │   │   ├── FlumeException.html
│   │   │   │   ├── NamedComponent.html
│   │   │   │   ├── PollableSource.html
│   │   │   │   ├── PollableSource.Status.html
│   │   │   │   ├── SinkFactory.html
│   │   │   │   ├── Sink.html
│   │   │   │   ├── SinkProcessor.html
│   │   │   │   ├── SinkRunner.html
│   │   │   │   ├── SinkRunner.PollingRunner.html
│   │   │   │   ├── Sink.Status.html
│   │   │   │   ├── SourceFactory.html
│   │   │   │   ├── Source.html
│   │   │   │   ├── SourceRunner.html
│   │   │   │   ├── SystemClock.html
│   │   │   │   ├── Transaction.html
│   │   │   │   ├── Transaction.TransactionState.html
│   │   │   │   └── VersionAnnotation.html
│   │   │   ├── client
│   │   │   │   └── avro
│   │   │   │   ├── AvroCLIClient.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AvroCLIClient.html
│   │   │   │   │   ├── EventReader.html
│   │   │   │   │   ├── ReliableEventReader.html
│   │   │   │   │   ├── ReliableSpoolingFileEventReader.Builder.html
│   │   │   │   │   ├── ReliableSpoolingFileEventReader.html
│   │   │   │   │   └── SimpleTextLineEventReader.html
│   │   │   │   ├── EventReader.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── ReliableEventReader.html
│   │   │   │   ├── ReliableSpoolingFileEventReader.Builder.html
│   │   │   │   ├── ReliableSpoolingFileEventReader.html
│   │   │   │   └── SimpleTextLineEventReader.html
│   │   │   ├── clients
│   │   │   │   └── log4jappender
│   │   │   │   ├── class-use
│   │   │   │   │   ├── LoadBalancingLog4jAppender.html
│   │   │   │   │   ├── Log4jAppender.html
│   │   │   │   │   └── Log4jAvroHeaders.html
│   │   │   │   ├── LoadBalancingLog4jAppender.html
│   │   │   │   ├── Log4jAppender.html
│   │   │   │   ├── Log4jAvroHeaders.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   └── package-use.html
│   │   │   ├── Clock.html
│   │   │   ├── conf
│   │   │   │   ├── BasicConfigurationConstants.html
│   │   │   │   ├── channel
│   │   │   │   │   ├── ChannelConfiguration.ChannelConfigurationType.html
│   │   │   │   │   ├── ChannelConfiguration.html
│   │   │   │   │   ├── ChannelSelectorConfiguration.ChannelSelectorConfigurationType.html
│   │   │   │   │   ├── ChannelSelectorConfiguration.html
│   │   │   │   │   ├── ChannelSelectorType.html
│   │   │   │   │   ├── ChannelType.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── ChannelConfiguration.ChannelConfigurationType.html
│   │   │   │   │   │   ├── ChannelConfiguration.html
│   │   │   │   │   │   ├── ChannelSelectorConfiguration.ChannelSelectorConfigurationType.html
│   │   │   │   │   │   ├── ChannelSelectorConfiguration.html
│   │   │   │   │   │   ├── ChannelSelectorType.html
│   │   │   │   │   │   └── ChannelType.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── BasicConfigurationConstants.html
│   │   │   │   │   ├── ComponentConfiguration.ComponentType.html
│   │   │   │   │   ├── ComponentConfigurationFactory.html
│   │   │   │   │   ├── ComponentConfiguration.html
│   │   │   │   │   ├── ConfigurableComponent.html
│   │   │   │   │   ├── Configurable.html
│   │   │   │   │   ├── Configurables.html
│   │   │   │   │   ├── ConfigurationException.html
│   │   │   │   │   ├── FlumeConfiguration.AgentConfiguration.html
│   │   │   │   │   ├── FlumeConfiguration.ComponentNameAndConfigKey.html
│   │   │   │   │   ├── FlumeConfigurationError.ErrorOrWarning.html
│   │   │   │   │   ├── FlumeConfigurationError.html
│   │   │   │   │   ├── FlumeConfigurationErrorType.html
│   │   │   │   │   ├── FlumeConfiguration.html
│   │   │   │   │   └── LogPrivacyUtil.html
│   │   │   │   ├── ComponentConfiguration.ComponentType.html
│   │   │   │   ├── ComponentConfigurationFactory.html
│   │   │   │   ├── ComponentConfiguration.html
│   │   │   │   ├── ConfigurableComponent.html
│   │   │   │   ├── Configurable.html
│   │   │   │   ├── Configurables.html
│   │   │   │   ├── ConfigurationException.html
│   │   │   │   ├── FlumeConfiguration.AgentConfiguration.html
│   │   │   │   ├── FlumeConfiguration.ComponentNameAndConfigKey.html
│   │   │   │   ├── FlumeConfigurationError.ErrorOrWarning.html
│   │   │   │   ├── FlumeConfigurationError.html
│   │   │   │   ├── FlumeConfigurationErrorType.html
│   │   │   │   ├── FlumeConfiguration.html
│   │   │   │   ├── LogPrivacyUtil.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── sink
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── SinkConfiguration.html
│   │   │   │   │   │   ├── SinkConfiguration.SinkConfigurationType.html
│   │   │   │   │   │   ├── SinkGroupConfiguration.html
│   │   │   │   │   │   ├── SinkProcessorConfiguration.html
│   │   │   │   │   │   ├── SinkProcessorConfiguration.SinkProcessorConfigurationType.html
│   │   │   │   │   │   ├── SinkProcessorType.html
│   │   │   │   │   │   └── SinkType.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── SinkConfiguration.html
│   │   │   │   │   ├── SinkConfiguration.SinkConfigurationType.html
│   │   │   │   │   ├── SinkGroupConfiguration.html
│   │   │   │   │   ├── SinkProcessorConfiguration.html
│   │   │   │   │   ├── SinkProcessorConfiguration.SinkProcessorConfigurationType.html
│   │   │   │   │   ├── SinkProcessorType.html
│   │   │   │   │   └── SinkType.html
│   │   │   │   └── source
│   │   │   │   ├── class-use
│   │   │   │   │   ├── SourceConfiguration.html
│   │   │   │   │   ├── SourceConfiguration.SourceConfigurationType.html
│   │   │   │   │   └── SourceType.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── SourceConfiguration.html
│   │   │   │   ├── SourceConfiguration.SourceConfigurationType.html
│   │   │   │   └── SourceType.html
│   │   │   ├── Constants.html
│   │   │   ├── Context.html
│   │   │   ├── CounterGroup.html
│   │   │   ├── Dummy.html
│   │   │   ├── event
│   │   │   │   ├── class-use
│   │   │   │   │   ├── EventBuilder.html
│   │   │   │   │   ├── EventHelper.html
│   │   │   │   │   ├── JSONEvent.html
│   │   │   │   │   └── SimpleEvent.html
│   │   │   │   ├── EventBuilder.html
│   │   │   │   ├── EventHelper.html
│   │   │   │   ├── JSONEvent.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   └── SimpleEvent.html
│   │   │   ├── EventDeliveryException.html
│   │   │   ├── EventDrivenSource.html
│   │   │   ├── Event.html
│   │   │   ├── FlumeException.html
│   │   │   ├── formatter
│   │   │   │   └── output
│   │   │   │   ├── BucketPath.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── BucketPath.html
│   │   │   │   │   ├── DefaultPathManager.Builder.html
│   │   │   │   │   ├── DefaultPathManager.html
│   │   │   │   │   ├── EventFormatter.html
│   │   │   │   │   ├── PathManager.Builder.html
│   │   │   │   │   ├── PathManagerFactory.html
│   │   │   │   │   ├── PathManager.html
│   │   │   │   │   ├── PathManagerType.html
│   │   │   │   │   ├── RollTimePathManager.Builder.html
│   │   │   │   │   ├── RollTimePathManager.html
│   │   │   │   │   └── TextDelimitedOutputFormatter.html
│   │   │   │   ├── DefaultPathManager.Builder.html
│   │   │   │   ├── DefaultPathManager.html
│   │   │   │   ├── EventFormatter.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PathManager.Builder.html
│   │   │   │   ├── PathManagerFactory.html
│   │   │   │   ├── PathManager.html
│   │   │   │   ├── PathManagerType.html
│   │   │   │   ├── RollTimePathManager.Builder.html
│   │   │   │   ├── RollTimePathManager.html
│   │   │   │   └── TextDelimitedOutputFormatter.html
│   │   │   ├── instrumentation
│   │   │   │   ├── ChannelCounter.html
│   │   │   │   ├── ChannelCounterMBean.html
│   │   │   │   ├── ChannelProcessorCounter.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── ChannelCounter.html
│   │   │   │   │   ├── ChannelCounterMBean.html
│   │   │   │   │   ├── ChannelProcessorCounter.html
│   │   │   │   │   ├── GangliaServer.GangliaCollector.html
│   │   │   │   │   ├── GangliaServer.html
│   │   │   │   │   ├── MonitoredCounterGroup.html
│   │   │   │   │   ├── MonitoredCounterGroup.Type.html
│   │   │   │   │   ├── MonitoringType.html
│   │   │   │   │   ├── MonitorService.html
│   │   │   │   │   ├── SinkCounter.html
│   │   │   │   │   ├── SinkCounterMBean.html
│   │   │   │   │   ├── SinkProcessorCounter.html
│   │   │   │   │   ├── SourceCounter.html
│   │   │   │   │   └── SourceCounterMBean.html
│   │   │   │   ├── GangliaServer.GangliaCollector.html
│   │   │   │   ├── GangliaServer.html
│   │   │   │   ├── http
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   └── HTTPMetricsServer.html
│   │   │   │   │   ├── HTTPMetricsServer.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── kafka
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── KafkaChannelCounter.html
│   │   │   │   │   │   ├── KafkaChannelCounterMBean.html
│   │   │   │   │   │   ├── KafkaSinkCounter.html
│   │   │   │   │   │   ├── KafkaSinkCounterMBean.html
│   │   │   │   │   │   ├── KafkaSourceCounter.html
│   │   │   │   │   │   └── KafkaSourceCounterMBean.html
│   │   │   │   │   ├── KafkaChannelCounter.html
│   │   │   │   │   ├── KafkaChannelCounterMBean.html
│   │   │   │   │   ├── KafkaSinkCounter.html
│   │   │   │   │   ├── KafkaSinkCounterMBean.html
│   │   │   │   │   ├── KafkaSourceCounter.html
│   │   │   │   │   ├── KafkaSourceCounterMBean.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── MonitoredCounterGroup.html
│   │   │   │   ├── MonitoredCounterGroup.Type.html
│   │   │   │   ├── MonitoringType.html
│   │   │   │   ├── MonitorService.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── SinkCounter.html
│   │   │   │   ├── SinkCounterMBean.html
│   │   │   │   ├── SinkProcessorCounter.html
│   │   │   │   ├── SourceCounter.html
│   │   │   │   ├── SourceCounterMBean.html
│   │   │   │   └── util
│   │   │   │   ├── class-use
│   │   │   │   │   └── JMXPollUtil.html
│   │   │   │   ├── JMXPollUtil.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   └── package-use.html
│   │   │   ├── interceptor
│   │   │   │   ├── class-use
│   │   │   │   │   ├── HostInterceptor.Builder.html
│   │   │   │   │   ├── HostInterceptor.Constants.html
│   │   │   │   │   ├── HostInterceptor.html
│   │   │   │   │   ├── InterceptorBuilderFactory.html
│   │   │   │   │   ├── Interceptor.Builder.html
│   │   │   │   │   ├── InterceptorChain.html
│   │   │   │   │   ├── Interceptor.html
│   │   │   │   │   ├── InterceptorType.html
│   │   │   │   │   ├── RegexExtractorInterceptor.Builder.html
│   │   │   │   │   ├── RegexExtractorInterceptor.html
│   │   │   │   │   ├── RegexExtractorInterceptorMillisSerializer.html
│   │   │   │   │   ├── RegexExtractorInterceptorPassThroughSerializer.html
│   │   │   │   │   ├── RegexExtractorInterceptorSerializer.html
│   │   │   │   │   ├── RegexFilteringInterceptor.Builder.html
│   │   │   │   │   ├── RegexFilteringInterceptor.Constants.html
│   │   │   │   │   ├── RegexFilteringInterceptor.html
│   │   │   │   │   ├── SearchAndReplaceInterceptor.Builder.html
│   │   │   │   │   ├── SearchAndReplaceInterceptor.html
│   │   │   │   │   ├── StaticInterceptor.Builder.html
│   │   │   │   │   ├── StaticInterceptor.Constants.html
│   │   │   │   │   ├── StaticInterceptor.html
│   │   │   │   │   ├── TimestampInterceptor.Builder.html
│   │   │   │   │   ├── TimestampInterceptor.Constants.html
│   │   │   │   │   └── TimestampInterceptor.html
│   │   │   │   ├── HostInterceptor.Builder.html
│   │   │   │   ├── HostInterceptor.Constants.html
│   │   │   │   ├── HostInterceptor.html
│   │   │   │   ├── InterceptorBuilderFactory.html
│   │   │   │   ├── Interceptor.Builder.html
│   │   │   │   ├── InterceptorChain.html
│   │   │   │   ├── Interceptor.html
│   │   │   │   ├── InterceptorType.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── RegexExtractorInterceptor.Builder.html
│   │   │   │   ├── RegexExtractorInterceptor.html
│   │   │   │   ├── RegexExtractorInterceptorMillisSerializer.html
│   │   │   │   ├── RegexExtractorInterceptorPassThroughSerializer.html
│   │   │   │   ├── RegexExtractorInterceptorSerializer.html
│   │   │   │   ├── RegexFilteringInterceptor.Builder.html
│   │   │   │   ├── RegexFilteringInterceptor.Constants.html
│   │   │   │   ├── RegexFilteringInterceptor.html
│   │   │   │   ├── SearchAndReplaceInterceptor.Builder.html
│   │   │   │   ├── SearchAndReplaceInterceptor.html
│   │   │   │   ├── StaticInterceptor.Builder.html
│   │   │   │   ├── StaticInterceptor.Constants.html
│   │   │   │   ├── StaticInterceptor.html
│   │   │   │   ├── TimestampInterceptor.Builder.html
│   │   │   │   ├── TimestampInterceptor.Constants.html
│   │   │   │   └── TimestampInterceptor.html
│   │   │   ├── lifecycle
│   │   │   │   ├── class-use
│   │   │   │   │   ├── LifecycleAware.html
│   │   │   │   │   ├── LifecycleController.html
│   │   │   │   │   ├── LifecycleException.html
│   │   │   │   │   ├── LifecycleState.html
│   │   │   │   │   ├── LifecycleSupervisor.html
│   │   │   │   │   ├── LifecycleSupervisor.MonitorRunnable.html
│   │   │   │   │   ├── LifecycleSupervisor.Status.html
│   │   │   │   │   ├── LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy.html
│   │   │   │   │   ├── LifecycleSupervisor.SupervisorPolicy.html
│   │   │   │   │   └── LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy.html
│   │   │   │   ├── LifecycleAware.html
│   │   │   │   ├── LifecycleController.html
│   │   │   │   ├── LifecycleException.html
│   │   │   │   ├── LifecycleState.html
│   │   │   │   ├── LifecycleSupervisor.html
│   │   │   │   ├── LifecycleSupervisor.MonitorRunnable.html
│   │   │   │   ├── LifecycleSupervisor.Status.html
│   │   │   │   ├── LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy.html
│   │   │   │   ├── LifecycleSupervisor.SupervisorPolicy.html
│   │   │   │   ├── LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   └── package-use.html
│   │   │   ├── NamedComponent.html
│   │   │   ├── node
│   │   │   │   ├── AbstractConfigurationProvider.html
│   │   │   │   ├── AbstractZooKeeperConfigurationProvider.html
│   │   │   │   ├── Application.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractConfigurationProvider.html
│   │   │   │   │   ├── AbstractZooKeeperConfigurationProvider.html
│   │   │   │   │   ├── Application.html
│   │   │   │   │   ├── ConfigurationProvider.html
│   │   │   │   │   ├── MaterializedConfiguration.html
│   │   │   │   │   ├── PollingPropertiesFileConfigurationProvider.FileWatcherRunnable.html
│   │   │   │   │   ├── PollingPropertiesFileConfigurationProvider.html
│   │   │   │   │   ├── PollingZooKeeperConfigurationProvider.html
│   │   │   │   │   ├── PropertiesFileConfigurationProvider.html
│   │   │   │   │   ├── SimpleMaterializedConfiguration.html
│   │   │   │   │   └── StaticZooKeeperConfigurationProvider.html
│   │   │   │   ├── ConfigurationProvider.html
│   │   │   │   ├── MaterializedConfiguration.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PollingPropertiesFileConfigurationProvider.FileWatcherRunnable.html
│   │   │   │   ├── PollingPropertiesFileConfigurationProvider.html
│   │   │   │   ├── PollingZooKeeperConfigurationProvider.html
│   │   │   │   ├── PropertiesFileConfigurationProvider.html
│   │   │   │   ├── SimpleMaterializedConfiguration.html
│   │   │   │   └── StaticZooKeeperConfigurationProvider.html
│   │   │   ├── package-frame.html
│   │   │   ├── package-summary.html
│   │   │   ├── package-tree.html
│   │   │   ├── package-use.html
│   │   │   ├── PollableSource.html
│   │   │   ├── PollableSource.Status.html
│   │   │   ├── serialization
│   │   │   │   ├── AbstractAvroEventSerializer.html
│   │   │   │   ├── AvroEventDeserializer.AvroSchemaType.html
│   │   │   │   ├── AvroEventDeserializer.Builder.html
│   │   │   │   ├── AvroEventDeserializer.html
│   │   │   │   ├── AvroEventSerializerConfigurationConstants.html
│   │   │   │   ├── BodyTextEventSerializer.Builder.html
│   │   │   │   ├── BodyTextEventSerializer.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractAvroEventSerializer.html
│   │   │   │   │   ├── AvroEventDeserializer.AvroSchemaType.html
│   │   │   │   │   ├── AvroEventDeserializer.Builder.html
│   │   │   │   │   ├── AvroEventDeserializer.html
│   │   │   │   │   ├── AvroEventSerializerConfigurationConstants.html
│   │   │   │   │   ├── BodyTextEventSerializer.Builder.html
│   │   │   │   │   ├── BodyTextEventSerializer.html
│   │   │   │   │   ├── DecodeErrorPolicy.html
│   │   │   │   │   ├── DurablePositionTracker.html
│   │   │   │   │   ├── EventDeserializer.Builder.html
│   │   │   │   │   ├── EventDeserializerFactory.html
│   │   │   │   │   ├── EventDeserializer.html
│   │   │   │   │   ├── EventDeserializerType.html
│   │   │   │   │   ├── EventSerDe.Builder.html
│   │   │   │   │   ├── EventSerDe.html
│   │   │   │   │   ├── EventSerializer.Builder.html
│   │   │   │   │   ├── EventSerializerFactory.html
│   │   │   │   │   ├── EventSerializer.html
│   │   │   │   │   ├── EventSerializerType.html
│   │   │   │   │   ├── FlumeEventAvroEventSerializer.Builder.html
│   │   │   │   │   ├── FlumeEventAvroEventSerializer.html
│   │   │   │   │   ├── HeaderAndBodyTextEventSerializer.Builder.html
│   │   │   │   │   ├── HeaderAndBodyTextEventSerializer.html
│   │   │   │   │   ├── LengthMeasurable.html
│   │   │   │   │   ├── LineDeserializer.Builder.html
│   │   │   │   │   ├── LineDeserializer.html
│   │   │   │   │   ├── PositionTracker.html
│   │   │   │   │   ├── RemoteMarkable.html
│   │   │   │   │   ├── ResettableFileInputStream.html
│   │   │   │   │   ├── Resettable.html
│   │   │   │   │   ├── ResettableInputStream.html
│   │   │   │   │   └── Seekable.html
│   │   │   │   ├── DecodeErrorPolicy.html
│   │   │   │   ├── DurablePositionTracker.html
│   │   │   │   ├── EventDeserializer.Builder.html
│   │   │   │   ├── EventDeserializerFactory.html
│   │   │   │   ├── EventDeserializer.html
│   │   │   │   ├── EventDeserializerType.html
│   │   │   │   ├── EventSerDe.Builder.html
│   │   │   │   ├── EventSerDe.html
│   │   │   │   ├── EventSerializer.Builder.html
│   │   │   │   ├── EventSerializerFactory.html
│   │   │   │   ├── EventSerializer.html
│   │   │   │   ├── EventSerializerType.html
│   │   │   │   ├── FlumeEventAvroEventSerializer.Builder.html
│   │   │   │   ├── FlumeEventAvroEventSerializer.html
│   │   │   │   ├── HeaderAndBodyTextEventSerializer.Builder.html
│   │   │   │   ├── HeaderAndBodyTextEventSerializer.html
│   │   │   │   ├── LengthMeasurable.html
│   │   │   │   ├── LineDeserializer.Builder.html
│   │   │   │   ├── LineDeserializer.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PositionTracker.html
│   │   │   │   ├── RemoteMarkable.html
│   │   │   │   ├── ResettableFileInputStream.html
│   │   │   │   ├── Resettable.html
│   │   │   │   ├── ResettableInputStream.html
│   │   │   │   └── Seekable.html
│   │   │   ├── shared
│   │   │   │   └── kafka
│   │   │   │   └── test
│   │   │   │   ├── class-use
│   │   │   │   │   ├── KafkaPartitionTestUtil.html
│   │   │   │   │   ├── PartitionOption.html
│   │   │   │   │   └── PartitionTestScenario.html
│   │   │   │   ├── KafkaPartitionTestUtil.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PartitionOption.html
│   │   │   │   └── PartitionTestScenario.html
│   │   │   ├── sink
│   │   │   │   ├── AbstractRpcSink.html
│   │   │   │   ├── AbstractSink.html
│   │   │   │   ├── AbstractSinkProcessor.html
│   │   │   │   ├── AbstractSinkSelector.html
│   │   │   │   ├── AvroSink.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractRpcSink.html
│   │   │   │   │   ├── AbstractSink.html
│   │   │   │   │   ├── AbstractSinkProcessor.html
│   │   │   │   │   ├── AbstractSinkSelector.html
│   │   │   │   │   ├── AvroSink.html
│   │   │   │   │   ├── DefaultSinkFactory.html
│   │   │   │   │   ├── DefaultSinkProcessor.html
│   │   │   │   │   ├── FailoverSinkProcessor.html
│   │   │   │   │   ├── LoadBalancingSinkProcessor.html
│   │   │   │   │   ├── LoadBalancingSinkProcessor.SinkSelector.html
│   │   │   │   │   ├── LoggerSink.html
│   │   │   │   │   ├── NullSink.html
│   │   │   │   │   ├── RollingFileSink.html
│   │   │   │   │   ├── SinkGroup.html
│   │   │   │   │   ├── SinkProcessorFactory.html
│   │   │   │   │   └── ThriftSink.html
│   │   │   │   ├── DefaultSinkFactory.html
│   │   │   │   ├── DefaultSinkProcessor.html
│   │   │   │   ├── elasticsearch
│   │   │   │   │   ├── AbstractElasticSearchIndexRequestBuilderFactory.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── AbstractElasticSearchIndexRequestBuilderFactory.html
│   │   │   │   │   │   ├── ContentBuilderUtil.html
│   │   │   │   │   │   ├── ElasticSearchDynamicSerializer.html
│   │   │   │   │   │   ├── ElasticSearchEventSerializer.html
│   │   │   │   │   │   ├── ElasticSearchIndexRequestBuilderFactory.html
│   │   │   │   │   │   ├── ElasticSearchLogStashEventSerializer.html
│   │   │   │   │   │   ├── ElasticSearchSinkConstants.html
│   │   │   │   │   │   ├── ElasticSearchSink.html
│   │   │   │   │   │   ├── EventSerializerIndexRequestBuilderFactory.html
│   │   │   │   │   │   ├── IndexNameBuilder.html
│   │   │   │   │   │   ├── SimpleIndexNameBuilder.html
│   │   │   │   │   │   └── TimeBasedIndexNameBuilder.html
│   │   │   │   │   ├── client
│   │   │   │   │   │   ├── class-use
│   │   │   │   │   │   │   ├── ElasticSearchClientFactory.html
│   │   │   │   │   │   │   ├── ElasticSearchClient.html
│   │   │   │   │   │   │   ├── ElasticSearchRestClient.html
│   │   │   │   │   │   │   ├── ElasticSearchTransportClient.html
│   │   │   │   │   │   │   └── RoundRobinList.html
│   │   │   │   │   │   ├── ElasticSearchClientFactory.html
│   │   │   │   │   │   ├── ElasticSearchClient.html
│   │   │   │   │   │   ├── ElasticSearchRestClient.html
│   │   │   │   │   │   ├── ElasticSearchTransportClient.html
│   │   │   │   │   │   ├── package-frame.html
│   │   │   │   │   │   ├── package-summary.html
│   │   │   │   │   │   ├── package-tree.html
│   │   │   │   │   │   ├── package-use.html
│   │   │   │   │   │   └── RoundRobinList.html
│   │   │   │   │   ├── ContentBuilderUtil.html
│   │   │   │   │   ├── ElasticSearchDynamicSerializer.html
│   │   │   │   │   ├── ElasticSearchEventSerializer.html
│   │   │   │   │   ├── ElasticSearchIndexRequestBuilderFactory.html
│   │   │   │   │   ├── ElasticSearchLogStashEventSerializer.html
│   │   │   │   │   ├── ElasticSearchSinkConstants.html
│   │   │   │   │   ├── ElasticSearchSink.html
│   │   │   │   │   ├── EventSerializerIndexRequestBuilderFactory.html
│   │   │   │   │   ├── IndexNameBuilder.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── SimpleIndexNameBuilder.html
│   │   │   │   │   └── TimeBasedIndexNameBuilder.html
│   │   │   │   ├── FailoverSinkProcessor.html
│   │   │   │   ├── hbase
│   │   │   │   │   ├── AsyncHbaseEventSerializer.html
│   │   │   │   │   ├── AsyncHBaseSink.html
│   │   │   │   │   ├── BatchAware.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── AsyncHbaseEventSerializer.html
│   │   │   │   │   │   ├── AsyncHBaseSink.html
│   │   │   │   │   │   ├── BatchAware.html
│   │   │   │   │   │   ├── HbaseEventSerializer.html
│   │   │   │   │   │   ├── HBaseSinkConfigurationConstants.html
│   │   │   │   │   │   ├── HBaseSink.html
│   │   │   │   │   │   ├── RegexHbaseEventSerializer.html
│   │   │   │   │   │   ├── SimpleAsyncHbaseEventSerializer.html
│   │   │   │   │   │   ├── SimpleHbaseEventSerializer.html
│   │   │   │   │   │   ├── SimpleHbaseEventSerializer.KeyType.html
│   │   │   │   │   │   └── SimpleRowKeyGenerator.html
│   │   │   │   │   ├── HbaseEventSerializer.html
│   │   │   │   │   ├── HBaseSinkConfigurationConstants.html
│   │   │   │   │   ├── HBaseSink.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── RegexHbaseEventSerializer.html
│   │   │   │   │   ├── SimpleAsyncHbaseEventSerializer.html
│   │   │   │   │   ├── SimpleHbaseEventSerializer.html
│   │   │   │   │   ├── SimpleHbaseEventSerializer.KeyType.html
│   │   │   │   │   └── SimpleRowKeyGenerator.html
│   │   │   │   ├── hdfs
│   │   │   │   │   ├── AbstractHDFSWriter.html
│   │   │   │   │   ├── AvroEventSerializer.Builder.html
│   │   │   │   │   ├── AvroEventSerializer.html
│   │   │   │   │   ├── BucketClosedException.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── AbstractHDFSWriter.html
│   │   │   │   │   │   ├── AvroEventSerializer.Builder.html
│   │   │   │   │   │   ├── AvroEventSerializer.html
│   │   │   │   │   │   ├── BucketClosedException.html
│   │   │   │   │   │   ├── HDFSCompressedDataStream.html
│   │   │   │   │   │   ├── HDFSDataStream.html
│   │   │   │   │   │   ├── HDFSEventSink.html
│   │   │   │   │   │   ├── HDFSEventSink.WriterCallback.html
│   │   │   │   │   │   ├── HDFSSequenceFile.html
│   │   │   │   │   │   ├── HDFSTextSerializer.Builder.html
│   │   │   │   │   │   ├── HDFSTextSerializer.html
│   │   │   │   │   │   ├── HDFSWritableSerializer.Builder.html
│   │   │   │   │   │   ├── HDFSWritableSerializer.html
│   │   │   │   │   │   ├── HDFSWriterFactory.html
│   │   │   │   │   │   ├── HDFSWriter.html
│   │   │   │   │   │   ├── KerberosUser.html
│   │   │   │   │   │   ├── SequenceFileSerializer.Builder.html
│   │   │   │   │   │   ├── SequenceFileSerializerFactory.html
│   │   │   │   │   │   ├── SequenceFileSerializer.html
│   │   │   │   │   │   ├── SequenceFileSerializer.Record.html
│   │   │   │   │   │   └── SequenceFileSerializerType.html
│   │   │   │   │   ├── HDFSCompressedDataStream.html
│   │   │   │   │   ├── HDFSDataStream.html
│   │   │   │   │   ├── HDFSEventSink.html
│   │   │   │   │   ├── HDFSEventSink.WriterCallback.html
│   │   │   │   │   ├── HDFSSequenceFile.html
│   │   │   │   │   ├── HDFSTextSerializer.Builder.html
│   │   │   │   │   ├── HDFSTextSerializer.html
│   │   │   │   │   ├── HDFSWritableSerializer.Builder.html
│   │   │   │   │   ├── HDFSWritableSerializer.html
│   │   │   │   │   ├── HDFSWriterFactory.html
│   │   │   │   │   ├── HDFSWriter.html
│   │   │   │   │   ├── KerberosUser.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── SequenceFileSerializer.Builder.html
│   │   │   │   │   ├── SequenceFileSerializerFactory.html
│   │   │   │   │   ├── SequenceFileSerializer.html
│   │   │   │   │   ├── SequenceFileSerializer.Record.html
│   │   │   │   │   └── SequenceFileSerializerType.html
│   │   │   │   ├── hive
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── Config.html
│   │   │   │   │   │   ├── HiveDelimitedTextSerializer.html
│   │   │   │   │   │   ├── HiveEventSerializer.html
│   │   │   │   │   │   ├── HiveJsonSerializer.html
│   │   │   │   │   │   └── HiveSink.html
│   │   │   │   │   ├── Config.html
│   │   │   │   │   ├── HiveDelimitedTextSerializer.html
│   │   │   │   │   ├── HiveEventSerializer.html
│   │   │   │   │   ├── HiveJsonSerializer.html
│   │   │   │   │   ├── HiveSink.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── irc
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── IRCSink.html
│   │   │   │   │   │   └── IRCSink.IRCConnectionListener.html
│   │   │   │   │   ├── IRCSink.html
│   │   │   │   │   ├── IRCSink.IRCConnectionListener.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── kafka
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── KafkaSinkConstants.html
│   │   │   │   │   │   └── KafkaSink.html
│   │   │   │   │   ├── KafkaSinkConstants.html
│   │   │   │   │   ├── KafkaSink.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── kite
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── DatasetSinkConstants.html
│   │   │   │   │   │   ├── DatasetSink.html
│   │   │   │   │   │   └── NonRecoverableEventException.html
│   │   │   │   │   ├── DatasetSinkConstants.html
│   │   │   │   │   ├── DatasetSink.html
│   │   │   │   │   ├── NonRecoverableEventException.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── parser
│   │   │   │   │   │   ├── AvroParser.Builder.html
│   │   │   │   │   │   ├── AvroParser.html
│   │   │   │   │   │   ├── class-use
│   │   │   │   │   │   │   ├── AvroParser.Builder.html
│   │   │   │   │   │   │   ├── AvroParser.html
│   │   │   │   │   │   │   ├── EntityParser.Builder.html
│   │   │   │   │   │   │   ├── EntityParserFactory.html
│   │   │   │   │   │   │   └── EntityParser.html
│   │   │   │   │   │   ├── EntityParser.Builder.html
│   │   │   │   │   │   ├── EntityParserFactory.html
│   │   │   │   │   │   ├── EntityParser.html
│   │   │   │   │   │   ├── package-frame.html
│   │   │   │   │   │   ├── package-summary.html
│   │   │   │   │   │   ├── package-tree.html
│   │   │   │   │   │   └── package-use.html
│   │   │   │   │   └── policy
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── FailurePolicy.Builder.html
│   │   │   │   │   │   ├── FailurePolicyFactory.html
│   │   │   │   │   │   ├── FailurePolicy.html
│   │   │   │   │   │   ├── RetryPolicy.Builder.html
│   │   │   │   │   │   ├── RetryPolicy.html
│   │   │   │   │   │   ├── SavePolicy.Builder.html
│   │   │   │   │   │   └── SavePolicy.html
│   │   │   │   │   ├── FailurePolicy.Builder.html
│   │   │   │   │   ├── FailurePolicyFactory.html
│   │   │   │   │   ├── FailurePolicy.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── RetryPolicy.Builder.html
│   │   │   │   │   ├── RetryPolicy.html
│   │   │   │   │   ├── SavePolicy.Builder.html
│   │   │   │   │   └── SavePolicy.html
│   │   │   │   ├── LoadBalancingSinkProcessor.html
│   │   │   │   ├── LoadBalancingSinkProcessor.SinkSelector.html
│   │   │   │   ├── LoggerSink.html
│   │   │   │   ├── NullSink.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── RollingFileSink.html
│   │   │   │   ├── SinkGroup.html
│   │   │   │   ├── SinkProcessorFactory.html
│   │   │   │   ├── solr
│   │   │   │   │   └── morphline
│   │   │   │   │   ├── BlobDeserializer.Builder.html
│   │   │   │   │   ├── BlobDeserializer.html
│   │   │   │   │   ├── BlobHandler.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── BlobDeserializer.Builder.html
│   │   │   │   │   │   ├── BlobDeserializer.html
│   │   │   │   │   │   ├── BlobHandler.html
│   │   │   │   │   │   ├── MorphlineHandler.html
│   │   │   │   │   │   ├── MorphlineHandlerImpl.html
│   │   │   │   │   │   ├── MorphlineInterceptor.Builder.html
│   │   │   │   │   │   ├── MorphlineInterceptor.html
│   │   │   │   │   │   ├── MorphlineSink.html
│   │   │   │   │   │   ├── MorphlineSolrSink.html
│   │   │   │   │   │   ├── UUIDInterceptor.Builder.html
│   │   │   │   │   │   └── UUIDInterceptor.html
│   │   │   │   │   ├── MorphlineHandler.html
│   │   │   │   │   ├── MorphlineHandlerImpl.html
│   │   │   │   │   ├── MorphlineInterceptor.Builder.html
│   │   │   │   │   ├── MorphlineInterceptor.html
│   │   │   │   │   ├── MorphlineSink.html
│   │   │   │   │   ├── MorphlineSolrSink.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── UUIDInterceptor.Builder.html
│   │   │   │   │   └── UUIDInterceptor.html
│   │   │   │   └── ThriftSink.html
│   │   │   ├── SinkFactory.html
│   │   │   ├── Sink.html
│   │   │   ├── SinkProcessor.html
│   │   │   ├── SinkRunner.html
│   │   │   ├── SinkRunner.PollingRunner.html
│   │   │   ├── Sink.Status.html
│   │   │   ├── source
│   │   │   │   ├── AbstractEventDrivenSource.html
│   │   │   │   ├── AbstractPollableSource.html
│   │   │   │   ├── AbstractSource.html
│   │   │   │   ├── avroLegacy
│   │   │   │   │   ├── AvroLegacySource.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   └── AvroLegacySource.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── AvroSource.html
│   │   │   │   ├── BasicSourceSemantics.html
│   │   │   │   ├── class-use
│   │   │   │   │   ├── AbstractEventDrivenSource.html
│   │   │   │   │   ├── AbstractPollableSource.html
│   │   │   │   │   ├── AbstractSource.html
│   │   │   │   │   ├── AvroSource.html
│   │   │   │   │   ├── BasicSourceSemantics.html
│   │   │   │   │   ├── DefaultSourceFactory.html
│   │   │   │   │   ├── EventDrivenSourceRunner.html
│   │   │   │   │   ├── ExecSourceConfigurationConstants.html
│   │   │   │   │   ├── ExecSource.html
│   │   │   │   │   ├── MultiportSyslogTCPSource.html
│   │   │   │   │   ├── NetcatSourceConfigurationConstants.html
│   │   │   │   │   ├── NetcatSource.html
│   │   │   │   │   ├── PollableSourceConstants.html
│   │   │   │   │   ├── PollableSourceRunner.html
│   │   │   │   │   ├── PollableSourceRunner.PollingRunner.html
│   │   │   │   │   ├── SequenceGeneratorSource.html
│   │   │   │   │   ├── SpoolDirectorySourceConfigurationConstants.ConsumeOrder.html
│   │   │   │   │   ├── SpoolDirectorySourceConfigurationConstants.html
│   │   │   │   │   ├── SpoolDirectorySource.html
│   │   │   │   │   ├── StressSource.html
│   │   │   │   │   ├── SyslogParser.html
│   │   │   │   │   ├── SyslogSourceConfigurationConstants.html
│   │   │   │   │   ├── SyslogTcpSource.html
│   │   │   │   │   ├── SyslogTcpSource.syslogTcpHandler.html
│   │   │   │   │   ├── SyslogUDPSource.html
│   │   │   │   │   ├── SyslogUDPSource.syslogHandler.html
│   │   │   │   │   ├── SyslogUtils.html
│   │   │   │   │   ├── SyslogUtils.SyslogStatus.html
│   │   │   │   │   └── ThriftSource.html
│   │   │   │   ├── DefaultSourceFactory.html
│   │   │   │   ├── EventDrivenSourceRunner.html
│   │   │   │   ├── ExecSourceConfigurationConstants.html
│   │   │   │   ├── ExecSource.html
│   │   │   │   ├── http
│   │   │   │   │   ├── BLOBHandler.html
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── BLOBHandler.html
│   │   │   │   │   │   ├── HTTPBadRequestException.html
│   │   │   │   │   │   ├── HTTPSourceConfigurationConstants.html
│   │   │   │   │   │   ├── HTTPSourceHandler.html
│   │   │   │   │   │   ├── HTTPSource.html
│   │   │   │   │   │   └── JSONHandler.html
│   │   │   │   │   ├── HTTPBadRequestException.html
│   │   │   │   │   ├── HTTPSourceConfigurationConstants.html
│   │   │   │   │   ├── HTTPSourceHandler.html
│   │   │   │   │   ├── HTTPSource.html
│   │   │   │   │   ├── JSONHandler.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── jms
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── DefaultJMSMessageConverter.Builder.html
│   │   │   │   │   │   ├── DefaultJMSMessageConverter.html
│   │   │   │   │   │   ├── InitialContextFactory.html
│   │   │   │   │   │   ├── JMSDestinationLocator.html
│   │   │   │   │   │   ├── JMSDestinationType.html
│   │   │   │   │   │   ├── JMSMessageConsumerFactory.html
│   │   │   │   │   │   ├── JMSMessageConverter.Builder.html
│   │   │   │   │   │   ├── JMSMessageConverter.html
│   │   │   │   │   │   ├── JMSSourceConfiguration.html
│   │   │   │   │   │   └── JMSSource.html
│   │   │   │   │   ├── DefaultJMSMessageConverter.Builder.html
│   │   │   │   │   ├── DefaultJMSMessageConverter.html
│   │   │   │   │   ├── InitialContextFactory.html
│   │   │   │   │   ├── JMSDestinationLocator.html
│   │   │   │   │   ├── JMSDestinationType.html
│   │   │   │   │   ├── JMSMessageConsumerFactory.html
│   │   │   │   │   ├── JMSMessageConverter.Builder.html
│   │   │   │   │   ├── JMSMessageConverter.html
│   │   │   │   │   ├── JMSSourceConfiguration.html
│   │   │   │   │   ├── JMSSource.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── kafka
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── KafkaSourceConstants.html
│   │   │   │   │   │   ├── KafkaSource.html
│   │   │   │   │   │   └── KafkaSource.Subscriber.html
│   │   │   │   │   ├── KafkaSourceConstants.html
│   │   │   │   │   ├── KafkaSource.html
│   │   │   │   │   ├── KafkaSource.Subscriber.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   └── package-use.html
│   │   │   │   ├── MultiportSyslogTCPSource.html
│   │   │   │   ├── NetcatSourceConfigurationConstants.html
│   │   │   │   ├── NetcatSource.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PollableSourceConstants.html
│   │   │   │   ├── PollableSourceRunner.html
│   │   │   │   ├── PollableSourceRunner.PollingRunner.html
│   │   │   │   ├── scribe
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── LogEntry._Fields.html
│   │   │   │   │   │   ├── LogEntry.html
│   │   │   │   │   │   ├── ResultCode.html
│   │   │   │   │   │   ├── Scribe.AsyncClient.Factory.html
│   │   │   │   │   │   ├── Scribe.AsyncClient.html
│   │   │   │   │   │   ├── Scribe.AsyncClient.Log_call.html
│   │   │   │   │   │   ├── Scribe.AsyncIface.html
│   │   │   │   │   │   ├── Scribe.Client.Factory.html
│   │   │   │   │   │   ├── Scribe.Client.html
│   │   │   │   │   │   ├── Scribe.html
│   │   │   │   │   │   ├── Scribe.Iface.html
│   │   │   │   │   │   ├── Scribe.Log_args._Fields.html
│   │   │   │   │   │   ├── Scribe.Log_args.html
│   │   │   │   │   │   ├── Scribe.Log_result._Fields.html
│   │   │   │   │   │   ├── Scribe.Log_result.html
│   │   │   │   │   │   ├── Scribe.Processor.html
│   │   │   │   │   │   └── ScribeSource.html
│   │   │   │   │   ├── LogEntry._Fields.html
│   │   │   │   │   ├── LogEntry.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── ResultCode.html
│   │   │   │   │   ├── Scribe.AsyncClient.Factory.html
│   │   │   │   │   ├── Scribe.AsyncClient.html
│   │   │   │   │   ├── Scribe.AsyncClient.Log_call.html
│   │   │   │   │   ├── Scribe.AsyncIface.html
│   │   │   │   │   ├── Scribe.Client.Factory.html
│   │   │   │   │   ├── Scribe.Client.html
│   │   │   │   │   ├── Scribe.html
│   │   │   │   │   ├── Scribe.Iface.html
│   │   │   │   │   ├── Scribe.Log_args._Fields.html
│   │   │   │   │   ├── Scribe.Log_args.html
│   │   │   │   │   ├── Scribe.Log_result._Fields.html
│   │   │   │   │   ├── Scribe.Log_result.html
│   │   │   │   │   ├── Scribe.Processor.html
│   │   │   │   │   └── ScribeSource.html
│   │   │   │   ├── SequenceGeneratorSource.html
│   │   │   │   ├── SpoolDirectorySourceConfigurationConstants.ConsumeOrder.html
│   │   │   │   ├── SpoolDirectorySourceConfigurationConstants.html
│   │   │   │   ├── SpoolDirectorySource.html
│   │   │   │   ├── StressSource.html
│   │   │   │   ├── SyslogParser.html
│   │   │   │   ├── SyslogSourceConfigurationConstants.html
│   │   │   │   ├── SyslogTcpSource.html
│   │   │   │   ├── SyslogTcpSource.syslogTcpHandler.html
│   │   │   │   ├── SyslogUDPSource.html
│   │   │   │   ├── SyslogUDPSource.syslogHandler.html
│   │   │   │   ├── SyslogUtils.html
│   │   │   │   ├── SyslogUtils.SyslogStatus.html
│   │   │   │   ├── taildir
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── ReliableTaildirEventReader.Builder.html
│   │   │   │   │   │   ├── ReliableTaildirEventReader.html
│   │   │   │   │   │   ├── TaildirMatcher.html
│   │   │   │   │   │   ├── TaildirSourceConfigurationConstants.html
│   │   │   │   │   │   ├── TaildirSource.html
│   │   │   │   │   │   └── TailFile.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── ReliableTaildirEventReader.Builder.html
│   │   │   │   │   ├── ReliableTaildirEventReader.html
│   │   │   │   │   ├── TaildirMatcher.html
│   │   │   │   │   ├── TaildirSourceConfigurationConstants.html
│   │   │   │   │   ├── TaildirSource.html
│   │   │   │   │   └── TailFile.html
│   │   │   │   ├── thriftLegacy
│   │   │   │   │   ├── class-use
│   │   │   │   │   │   ├── ThriftLegacySource.html
│   │   │   │   │   │   └── ThriftLegacySource.ThriftHandler.html
│   │   │   │   │   ├── package-frame.html
│   │   │   │   │   ├── package-summary.html
│   │   │   │   │   ├── package-tree.html
│   │   │   │   │   ├── package-use.html
│   │   │   │   │   ├── ThriftLegacySource.html
│   │   │   │   │   └── ThriftLegacySource.ThriftHandler.html
│   │   │   │   ├── ThriftSource.html
│   │   │   │   └── twitter
│   │   │   │   ├── class-use
│   │   │   │   │   └── TwitterSource.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   └── TwitterSource.html
│   │   │   ├── SourceFactory.html
│   │   │   ├── Source.html
│   │   │   ├── SourceRunner.html
│   │   │   ├── SystemClock.html
│   │   │   ├── thrift
│   │   │   │   ├── class-use
│   │   │   │   │   ├── Status.html
│   │   │   │   │   ├── ThriftFlumeEvent._Fields.html
│   │   │   │   │   ├── ThriftFlumeEvent.html
│   │   │   │   │   ├── ThriftSourceProtocol.append_args._Fields.html
│   │   │   │   │   ├── ThriftSourceProtocol.append_args.html
│   │   │   │   │   ├── ThriftSourceProtocol.appendBatch_args._Fields.html
│   │   │   │   │   ├── ThriftSourceProtocol.appendBatch_args.html
│   │   │   │   │   ├── ThriftSourceProtocol.appendBatch_result._Fields.html
│   │   │   │   │   ├── ThriftSourceProtocol.appendBatch_result.html
│   │   │   │   │   ├── ThriftSourceProtocol.append_result._Fields.html
│   │   │   │   │   ├── ThriftSourceProtocol.append_result.html
│   │   │   │   │   ├── ThriftSourceProtocol.AsyncClient.appendBatch_call.html
│   │   │   │   │   ├── ThriftSourceProtocol.AsyncClient.append_call.html
│   │   │   │   │   ├── ThriftSourceProtocol.AsyncClient.Factory.html
│   │   │   │   │   ├── ThriftSourceProtocol.AsyncClient.html
│   │   │   │   │   ├── ThriftSourceProtocol.AsyncIface.html
│   │   │   │   │   ├── ThriftSourceProtocol.Client.Factory.html
│   │   │   │   │   ├── ThriftSourceProtocol.Client.html
│   │   │   │   │   ├── ThriftSourceProtocol.html
│   │   │   │   │   ├── ThriftSourceProtocol.Iface.html
│   │   │   │   │   └── ThriftSourceProtocol.Processor.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── Status.html
│   │   │   │   ├── ThriftFlumeEvent._Fields.html
│   │   │   │   ├── ThriftFlumeEvent.html
│   │   │   │   ├── ThriftSourceProtocol.append_args._Fields.html
│   │   │   │   ├── ThriftSourceProtocol.append_args.html
│   │   │   │   ├── ThriftSourceProtocol.appendBatch_args._Fields.html
│   │   │   │   ├── ThriftSourceProtocol.appendBatch_args.html
│   │   │   │   ├── ThriftSourceProtocol.appendBatch_result._Fields.html
│   │   │   │   ├── ThriftSourceProtocol.appendBatch_result.html
│   │   │   │   ├── ThriftSourceProtocol.append_result._Fields.html
│   │   │   │   ├── ThriftSourceProtocol.append_result.html
│   │   │   │   ├── ThriftSourceProtocol.AsyncClient.appendBatch_call.html
│   │   │   │   ├── ThriftSourceProtocol.AsyncClient.append_call.html
│   │   │   │   ├── ThriftSourceProtocol.AsyncClient.Factory.html
│   │   │   │   ├── ThriftSourceProtocol.AsyncClient.html
│   │   │   │   ├── ThriftSourceProtocol.AsyncIface.html
│   │   │   │   ├── ThriftSourceProtocol.Client.Factory.html
│   │   │   │   ├── ThriftSourceProtocol.Client.html
│   │   │   │   ├── ThriftSourceProtocol.html
│   │   │   │   ├── ThriftSourceProtocol.Iface.html
│   │   │   │   └── ThriftSourceProtocol.Processor.html
│   │   │   ├── tools
│   │   │   │   ├── class-use
│   │   │   │   │   ├── DirectMemoryUtils.html
│   │   │   │   │   ├── EventValidator.Builder.html
│   │   │   │   │   ├── EventValidator.html
│   │   │   │   │   ├── FileChannelIntegrityTool.html
│   │   │   │   │   ├── FlumeTool.html
│   │   │   │   │   ├── FlumeToolsMain.html
│   │   │   │   │   ├── FlumeToolType.html
│   │   │   │   │   ├── GetJavaProperty.html
│   │   │   │   │   ├── HTTPServerConstraintUtil.html
│   │   │   │   │   ├── PlatformDetect.html
│   │   │   │   │   ├── TimestampRoundDownUtil.html
│   │   │   │   │   └── VersionInfo.html
│   │   │   │   ├── DirectMemoryUtils.html
│   │   │   │   ├── EventValidator.Builder.html
│   │   │   │   ├── EventValidator.html
│   │   │   │   ├── FileChannelIntegrityTool.html
│   │   │   │   ├── FlumeTool.html
│   │   │   │   ├── FlumeToolsMain.html
│   │   │   │   ├── FlumeToolType.html
│   │   │   │   ├── GetJavaProperty.html
│   │   │   │   ├── HTTPServerConstraintUtil.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── PlatformDetect.html
│   │   │   │   ├── TimestampRoundDownUtil.html
│   │   │   │   └── VersionInfo.html
│   │   │   ├── Transaction.html
│   │   │   ├── Transaction.TransactionState.html
│   │   │   ├── util
│   │   │   │   ├── class-use
│   │   │   │   │   ├── OrderSelector.html
│   │   │   │   │   ├── RandomOrderSelector.html
│   │   │   │   │   ├── RoundRobinOrderSelector.html
│   │   │   │   │   └── SpecificOrderIterator.html
│   │   │   │   ├── OrderSelector.html
│   │   │   │   ├── package-frame.html
│   │   │   │   ├── package-summary.html
│   │   │   │   ├── package-tree.html
│   │   │   │   ├── package-use.html
│   │   │   │   ├── RandomOrderSelector.html
│   │   │   │   ├── RoundRobinOrderSelector.html
│   │   │   │   └── SpecificOrderIterator.html
│   │   │   └── VersionAnnotation.html
│   │   ├── overview-frame.html
│   │   ├── overview-summary.html
│   │   ├── overview-tree.html
│   │   ├── package-list
│   │   ├── resources
│   │   │   ├── background.gif
│   │   │   ├── tab.gif
│   │   │   ├── titlebar_end.gif
│   │   │   └── titlebar.gif
│   │   ├── serialized-form.html
│   │   └── stylesheet.css
│   ├── css
│   │   ├── apache-maven-fluido.min.css
│   │   ├── print.css
│   │   └── site.css
│   ├── FlumeDeveloperGuide.html
│   ├── FlumeUserGuide.html
│   ├── genindex.html
│   ├── _images
│   │   ├── DevGuide_image00.png
│   │   ├── DevGuide_image01.png
│   │   ├── UserGuide_image00.png
│   │   ├── UserGuide_image01.png
│   │   ├── UserGuide_image02.png
│   │   └── UserGuide_image03.png
│   ├── images
│   │   ├── accessories-text-editor.png
│   │   ├── add.gif
│   │   ├── apache-maven-project-2.png
│   │   ├── application-certificate.png
│   │   ├── collapsed.png
│   │   ├── contact-new.png
│   │   ├── document-properties.png
│   │   ├── drive-harddisk.png
│   │   ├── expanded.png
│   │   ├── fix.gif
│   │   ├── icon_error_sml.gif
│   │   ├── icon_help_sml.gif
│   │   ├── icon_info_sml.gif
│   │   ├── icon_success_sml.gif
│   │   ├── icon_warning_sml.gif
│   │   ├── image-x-generic.png
│   │   ├── internet-web-browser.png
│   │   ├── logos
│   │   │   ├── build-by-maven-black.png
│   │   │   ├── build-by-maven-white.png
│   │   │   └── maven-feather.png
│   │   ├── network-server.png
│   │   ├── package-x-generic.png
│   │   ├── remove.gif
│   │   ├── rss.png
│   │   ├── update.gif
│   │   └── window-new.png
│   ├── index.html
│   ├── issue-tracking.html
│   ├── js
│   │   └── apache-maven-fluido.min.js
│   ├── license.html
│   ├── mail-lists.html
│   ├── objects.inv
│   ├── project-info.html
│   ├── project-reports.html
│   ├── search.html
│   ├── searchindex.js
│   ├── _sources
│   │   ├── FlumeDeveloperGuide.txt
│   │   ├── FlumeUserGuide.txt
│   │   └── index.txt
│   ├── _static
│   │   ├── ajax-loader.gif
│   │   ├── basic.css
│   │   ├── comment-bright.png
│   │   ├── comment-close.png
│   │   ├── comment.png
│   │   ├── default.css
│   │   ├── doctools.js
│   │   ├── down.png
│   │   ├── down-pressed.png
│   │   ├── file.png
│   │   ├── flume-logo.png
│   │   ├── jquery.js
│   │   ├── minus.png
│   │   ├── plus.png
│   │   ├── pygments.css
│   │   ├── searchtools.js
│   │   ├── sidebar.js
│   │   ├── underscore.js
│   │   ├── up.png
│   │   ├── up-pressed.png
│   │   └── websupport.js
│   └── team-list.html
├── lib
│   ├── apache-log4j-extras-1.1.jar
│   ├── async-1.4.0.jar
│   ├── asynchbase-1.7.0.jar
│   ├── avro-1.7.4.jar
│   ├── avro-ipc-1.7.4.jar
│   ├── commons-cli-1.2.jar
│   ├── commons-codec-1.8.jar
│   ├── commons-collections-3.2.2.jar
│   ├── commons-compress-1.4.1.jar
│   ├── commons-dbcp-1.4.jar
│   ├── commons-io-2.1.jar
│   ├── commons-jexl-2.1.1.jar
│   ├── commons-lang-2.5.jar
│   ├── commons-logging-1.1.1.jar
│   ├── commons-pool-1.5.4.jar
│   ├── curator-client-2.6.0.jar
│   ├── curator-framework-2.6.0.jar
│   ├── curator-recipes-2.6.0.jar
│   ├── derby-10.11.1.1.jar
│   ├── flume-avro-source-1.7.0.jar
│   ├── flume-dataset-sink-1.7.0.jar
│   ├── flume-file-channel-1.7.0.jar
│   ├── flume-hdfs-sink-1.7.0.jar
│   ├── flume-hive-sink-1.7.0.jar
│   ├── flume-irc-sink-1.7.0.jar
│   ├── flume-jdbc-channel-1.7.0.jar
│   ├── flume-jms-source-1.7.0.jar
│   ├── flume-kafka-channel-1.7.0.jar
│   ├── flume-kafka-source-1.7.0.jar
│   ├── flume-ng-auth-1.7.0.jar
│   ├── flume-ng-configuration-1.7.0.jar
│   ├── flume-ng-core-1.7.0.jar
│   ├── flume-ng-elasticsearch-sink-1.7.0.jar
│   ├── flume-ng-embedded-agent-1.7.0.jar
│   ├── flume-ng-hbase-sink-1.7.0.jar
│   ├── flume-ng-kafka-sink-1.7.0.jar
│   ├── flume-ng-log4jappender-1.7.0.jar
│   ├── flume-ng-morphline-solr-sink-1.7.0.jar
│   ├── flume-ng-node-1.7.0.jar
│   ├── flume-ng-sdk-1.7.0.jar
│   ├── flume-scribe-source-1.7.0.jar
│   ├── flume-spillable-memory-channel-1.7.0.jar
│   ├── flume-taildir-source-1.7.0.jar
│   ├── flume-thrift-source-1.7.0.jar
│   ├── flume-tools-1.7.0.jar
│   ├── flume-twitter-source-1.7.0.jar
│   ├── gson-2.2.2.jar
│   ├── guava-11.0.2.jar
│   ├── httpclient-4.2.1.jar
│   ├── httpcore-4.1.3.jar
│   ├── irclib-1.10.jar
│   ├── jackson-annotations-2.3.0.jar
│   ├── jackson-core-2.3.1.jar
│   ├── jackson-core-asl-1.9.3.jar
│   ├── jackson-databind-2.3.1.jar
│   ├── jackson-mapper-asl-1.9.3.jar
│   ├── jetty-6.1.26.jar
│   ├── jetty-util-6.1.26.jar
│   ├── joda-time-2.1.jar
│   ├── jopt-simple-3.2.jar
│   ├── jsr305-1.3.9.jar
│   ├── kafka_2.10-0.9.0.1.jar
│   ├── kafka-clients-0.9.0.1.jar
│   ├── kite-data-core-1.0.0.jar
│   ├── kite-data-hbase-1.0.0.jar
│   ├── kite-data-hive-1.0.0.jar
│   ├── kite-hadoop-compatibility-1.0.0.jar
│   ├── libthrift-0.9.0.jar
│   ├── log4j-1.2.17.jar
│   ├── lz4-1.2.0.jar
│   ├── mapdb-0.9.9.jar
│   ├── metrics-core-2.2.0.jar
│   ├── mina-core-2.0.4.jar
│   ├── netty-3.9.4.Final.jar
│   ├── opencsv-2.3.jar
│   ├── paranamer-2.3.jar
│   ├── parquet-avro-1.4.1.jar
│   ├── parquet-column-1.4.1.jar
│   ├── parquet-common-1.4.1.jar
│   ├── parquet-encoding-1.4.1.jar
│   ├── parquet-format-2.0.0.jar
│   ├── parquet-generator-1.4.1.jar
│   ├── parquet-hadoop-1.4.1.jar
│   ├── parquet-hive-bundle-1.4.1.jar
│   ├── parquet-jackson-1.4.1.jar
│   ├── protobuf-java-2.5.0.jar
│   ├── scala-library-2.10.5.jar
│   ├── serializer-2.7.2.jar
│   ├── servlet-api-2.5-20110124.jar
│   ├── slf4j-api-1.6.1.jar
│   ├── slf4j-log4j12-1.6.1.jar
│   ├── snappy-java-1.1.0.jar
│   ├── twitter4j-core-3.0.3.jar
│   ├── twitter4j-media-support-3.0.3.jar
│   ├── twitter4j-stream-3.0.3.jar
│   ├── velocity-1.7.jar
│   ├── xalan-2.7.2.jar
│   ├── xercesImpl-2.9.1.jar
│   ├── xml-apis-1.3.04.jar
│   ├── xz-1.0.jar
│   └── zkclient-0.7.jar
├── LICENSE
├── NOTICE
├── README.md
├── RELEASE-NOTES
└── tools
└── flume-ng-log4jappender-1.7.0-jar-with-dependencies.jar

136 directories, 1546 files