| Class | Description |
|---|---|
| CheckpointRebuilder | |
| EventUtils | |
| 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 | Description |
|---|---|
| BadCheckpointException |
Exception thrown when the checkpoint directory contains invalid data,
probably due to the channel stopping while the checkpoint was written.
|
| CorruptEventException | |
| LogFileRetryableIOException | |
| NoopRecordException |
Copyright © 2009-2022 Apache Software Foundation. All Rights Reserved.