Interface | Description |
---|---|
Appenderator |
An Appenderator indexes data.
|
AppenderatorConfig | |
AppenderatorFactory | |
SegmentAllocator | |
TransactionalSegmentPublisher | |
UsedSegmentChecker |
Class | Description |
---|---|
Appenderator.AppenderatorAddResult |
Result of
Appenderator.add(SegmentIdentifier, InputRow, Supplier, boolean) containing following information
- SegmentIdentifier - identifier of segment to which rows are being added
- int - positive number indicating how many summarized rows exist in this segment so far and
- boolean - true if is set to false and persist is required; false otherwise |
AppenderatorDriverAddResult |
Result of
BaseAppenderatorDriver#add(InputRow, String, Supplier, boolean) . |
AppenderatorDriverMetadata | |
AppenderatorImpl | |
AppenderatorPlumber | |
AppenderatorPlumberSchool | |
Appenderators | |
BaseAppenderatorDriver |
A BaseAppenderatorDriver drives an Appenderator to index a finite stream of data.
|
BatchAppenderatorDriver |
This class is specifialized for batch ingestion.
|
Committed | |
DefaultOfflineAppenderatorFactory | |
DefaultRealtimeAppenderatorFactory | |
SegmentIdentifier | |
SegmentsAndMetadata | |
SegmentWithState | |
SinkQuerySegmentWalker | |
StreamAppenderatorDriver |
This class is specialized for streaming ingestion.
|
Enum | Description |
---|---|
SegmentWithState.SegmentState |
Segment state transition is different in
BatchAppenderatorDriver and StreamAppenderatorDriver . |
Exception | Description |
---|---|
SegmentNotWritableException |
Copyright © 2011–2018. All rights reserved.