Search Java Classes and Packages
#Org.apache.flume.channel Classes and Interfaces - 112 results found.
| Name | Description | Type | Package | Framework |
| AbstractChannel | Class | org.apache.flume.channel | Flume | |
| AbstractChannelSelector | Class | org.apache.flume.channel | Flume | |
| AESCTRNoPaddingProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| AESCTRNoPaddingProvider .DecryptorBuilder | Fields inherited from class org. | Class | org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider | Flume |
| AESCTRNoPaddingProvider .EncryptorBuilder | Fields inherited from class org. | Class | org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider | Flume |
| BadCheckpointException | Exception thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written. | Class | org.apache.flume.channel.file | Flume |
| BasicChannelSemantics | An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class, | Class | org.apache.flume.channel | Flume |
| BasicTransactionSemantics | An implementation of basic Transaction semantics designed to work in concert with BasicChannelSemantics to simplify | Class | org.apache.flume.channel | Flume |
| BasicTransactionSemantics .State | The state of the Transaction to which it belongs. | Class | org.apache.flume.channel.BasicTransactionSemantics | Flume |
| Channel | A channel connects a Source to a Sink. | Interface | org.apache.flume | Flume |
| ChannelException | A channel exception is raised whenever a channel operation fails. | Class | org.apache.flume | Flume |
| ChannelFactory | Interface | org.apache.flume | Flume | |
| ChannelFullException | Class | org.apache.flume | Flume | |
| ChannelProcessor | A channel processor exposes operations to put Events into Channels. | Class | org.apache.flume.channel | Flume |
| ChannelSelector | Allows the selection of a subset of channels from the given set based on its implementation policy. | Interface | org.apache.flume | Flume |
| ChannelSelectorFactory | Class | org.apache.flume.channel | Flume | |
| ChannelUtils | A collection of utilities for interacting with Channel objects. | Class | org.apache.flume.channel | Flume |
| CheckpointRebuilder | Class | org.apache.flume.channel.file | Flume | |
| CipherProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| CipherProvider .Decryptor | Class | org.apache.flume.channel.file.encryption.CipherProvider | Flume | |
| CipherProvider .Decryptor .Builder | Class | org.apache.flume.channel.file.encryption.CipherProvider.Decryptor | Flume | |
| CipherProvider .Encryptor | Class | org.apache.flume.channel.file.encryption.CipherProvider | Flume | |
| CipherProvider .Encryptor .Builder | Builder implementations MUST have a no-arg constructorConstructor SummaryCipherProvider. | Class | org.apache.flume.channel.file.encryption.CipherProvider.Encryptor | Flume |
| CipherProviderFactory | Class | org.apache.flume.channel.file.encryption | Flume | |
| CipherProviderType | enum CipherProviderTypeextends Enum | Class | org.apache.flume.channel.file.encryption | Flume |
| ConfigurationConstants | Contains configuration keys used by the JDBC channel implementation. | Class | org.apache.flume.channel.jdbc | Flume |
| CorruptEventException | See Also:Serialized FormConstructor SummaryCorruptEventException() | Class | org.apache.flume.channel.file | Flume |
| DatabaseType | enum DatabaseTypeextends Enum | Class | org.apache.flume.channel.jdbc | Flume |
| DecryptionFailureException | Exception that is thrown when the channel is unable to decrypt an even read from the channel. | Class | org.apache.flume.channel.file.encryption | Flume |
| DefaultChannelFactory | Class | org.apache.flume.channel | Flume | |
| DerbySchemaHandler | Schema handler for Derby Database. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| EncryptionConfiguration | Class | org.apache.flume.channel.file.encryption | Flume | |
| FileChannel | A durable Channel implementation that uses the local file system for FileChannel works by writing all transactions to a set of directories | Class | org.apache.flume.channel.file | Flume |
| FileChannelConfiguration | Class | org.apache.flume.channel.file | Flume | |
| JCEFileKeyProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| JCEFileKeyProvider .Builder | Constructor SummaryJCEFileKeyProvider. | Class | org.apache.flume.channel.file.encryption.JCEFileKeyProvider | Flume |
| JdbcChannel | A JDBC based channel implementation. | Class | org.apache.flume.channel.jdbc | Flume |
| JdbcChannelException | Class | org.apache.flume.channel.jdbc | Flume | |
| JdbcChannelProvider | Service provider interface for JDBC channel providers. | Interface | org.apache.flume.channel.jdbc | Flume |
| JdbcChannelProviderFactory | Class | org.apache.flume.channel.jdbc | Flume | |
| JdbcChannelProviderImpl | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| JdbcTransactionFactory | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| JdbcTransactionImpl | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| KeyProvider | Class | org.apache.flume.channel.file.encryption | Flume | |
| KeyProviderFactory | Class | org.apache.flume.channel.file.encryption | Flume | |
| KeyProviderType | enum KeyProviderTypeextends Enum | Class | org.apache.flume.channel.file.encryption | Flume |
| Log | Stores FlumeEvents on disk and pointers to the events in a in memory queue. | Class | org.apache.flume.channel.file | Flume |
| LogFile | Class | org.apache.flume.channel.file | Flume | |
| LogFile .OperationRecordUpdater | This is an class meant to be an internal Flume API, and can change at any time. | Class | org.apache.flume.channel.file.LogFile | Flume |
| LogFile .SequentialReader | Class | org.apache.flume.channel.file.LogFile | Flume | |
| LogFileRetryableIOException | See Also:Serialized FormConstructor SummaryLogFileRetryableIOException() | Class | org.apache.flume.channel.file | Flume |
| LogFileV3 | Represents a single data file on disk. | Class | org.apache.flume.channel.file | Flume |
| LogFileV3 .SequentialReader | Constructor SummaryLogFileV3. | Class | org.apache.flume.channel.file.LogFileV3 | Flume |
| LogRecord | Class | org.apache.flume.channel.file | Flume | |
| LogUtils | Constructor SummaryLogUtils()Methods inherited from class java. | Class | org.apache.flume.channel.file | Flume |
| MemoryChannel | MemoryChannel is the recommended channel to use when speeds which writing to disk is impractical is required or durability of data is not | Class | org.apache.flume.channel | Flume |
| MultiplexingChannelSelector | Class | org.apache.flume.channel | Flume | |
| MySQLSchemaHandler | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| NoopRecordException | See Also:Serialized FormConstructor SummaryNoopRecordException() | Class | org.apache.flume.channel.file | Flume |
| PersistableEvent | Class | org.apache.flume.channel.jdbc.impl | Flume | |
| PersistableEvent .Builder | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| PersistableEvent .HeaderEntry | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| PersistableEvent .SpillableString | Constructor SummaryPersistableEvent. | Class | org.apache.flume.channel.jdbc.impl.PersistableEvent | Flume |
| ProtosFactory | Class | org.apache.flume.channel.file.proto | Flume | |
| ProtosFactory .ActiveLog | Protobuf type ActiveLogSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .ActiveLog .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog | Flume | |
| ProtosFactory .ActiveLogOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Checkpoint | Protobuf type CheckpointSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Checkpoint .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint | Flume | |
| ProtosFactory .CheckpointOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Commit | Protobuf type CommitSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Commit .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Commit | Flume | |
| ProtosFactory .CommitOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .FlumeEvent | Protobuf type FlumeEventSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .FlumeEvent .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent | Flume | |
| ProtosFactory .FlumeEventHeader | Protobuf type FlumeEventHeaderSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .FlumeEventHeader .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader | Flume | |
| ProtosFactory .FlumeEventHeaderOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .FlumeEventOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .LogFileEncryption | Protobuf type LogFileEncryptionSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .LogFileEncryption .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption | Flume | |
| ProtosFactory .LogFileEncryptionOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .LogFileMetaData | Protobuf type LogFileMetaDataSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .LogFileMetaData .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData | Flume | |
| ProtosFactory .LogFileMetaDataOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Put | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Put .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Put | Flume | |
| ProtosFactory .PutOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Rollback | Protobuf type RollbackSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Rollback .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Rollback | Flume | |
| ProtosFactory .RollbackOrBuilder | Methods inherited from interface com. | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .Take | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .Take .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.Take | Flume | |
| ProtosFactory .TakeOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| ProtosFactory .TransactionEventFooter | Protobuf type TransactionEventFooterSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventFooter .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter | Flume | |
| ProtosFactory .TransactionEventFooterOrBuilder | Methods inherited from interface com. | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventHeader | Protobuf type TransactionEventHeaderSee Also:Serialized Form | Class | org.apache.flume.channel.file.proto.ProtosFactory | Flume |
| ProtosFactory .TransactionEventHeader .Builder | Class | org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader | Flume | |
| ProtosFactory .TransactionEventHeaderOrBuilder | Interface | org.apache.flume.channel.file.proto.ProtosFactory | Flume | |
| PseudoTxnMemoryChannel | A capacity-capped Channel implementation that supports in-memory buffering and delivery of events. | Class | org.apache.flume.channel | Flume |
| PseudoTxnMemoryChannel .NoOpTransaction | A no-op transaction implementation that does nothing at all. | Class | org.apache.flume.channel.PseudoTxnMemoryChannel | Flume |
| ReplicatingChannelSelector | Replicating channel selector. | Class | org.apache.flume.channel | Flume |
| SchemaHandler | A handler for creating and validating database schema for use by the JDBC channel implementation. | Interface | org.apache.flume.channel.jdbc.impl | Flume |
| SchemaHandlerFactory | A factory for SchemaHandlers. | Class | org.apache.flume.channel.jdbc.impl | Flume |
| Serialization | Class | org.apache.flume.channel.file | Flume | |
| SpillableMemoryChannel | SpillableMemoryChannel will use main memory for buffering events until it has reached capacity. | Class | org.apache.flume.channel | Flume |
| SpillableMemoryChannel .DrainOrderQueue | Class | org.apache.flume.channel.SpillableMemoryChannel | Flume | |
| TransactionEventRecord | Class | org.apache.flume.channel.file | Flume | |
| TransactionIDOracle | Class | org.apache.flume.channel.file | Flume | |
| TransactionIsolation | enum TransactionIsolationextends Enum | Class | org.apache.flume.channel.jdbc | Flume |
| WriteOrderOracle | Class | org.apache.flume.channel.file | Flume | |