|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||
| Class Summary | |
|---|---|
| CheckpointRebuilder | |
| FileChannel |
A durable Channel implementation that uses the local file system for
its storage. |
| FileChannelConfiguration | |
| Log | Stores FlumeEvents on disk and pointers to the events in a in memory queue. |
| LogFile | |
| LogFile.OperationRecordUpdater | This is an class meant to be an internal Flume API, and can change at any time. |
| LogFile.SequentialReader | |
| LogFileV3 | Represents a single data file on disk. |
| LogFileV3.SequentialReader | |
| LogRecord | |
| LogUtils | |
| Serialization | |
| TransactionEventRecord | Base class for records in data file: Put, Take, Rollback, Commit |
| TransactionIDOracle | |
| WriteOrderOracle | |
| Exception Summary | |
|---|---|
| BadCheckpointException | Exception thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written. |
| CorruptEventException | |
| LogFileRetryableIOException | |
| NoopRecordException | |
|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||