Interface | Description |
---|---|
DataTableScan |
Table scan for data table.
|
DeletionFile.Factory |
Interface to create
DeletionFile . |
InnerTableRead |
Inner
TableRead contains filter and projection push down. |
InnerTableScan |
Inner
TableScan contains filter push down. |
ReadBuilder | |
Split |
An input split for reading.
|
SplitGenerator |
Generate splits from
DataFileMeta s. |
StreamDataTableScan |
Streaming
InnerTableScan with StreamTableScan . |
StreamTableScan |
TableScan for streaming, supports StreamTableScan.checkpoint() and StreamTableScan.restore(java.lang.Long) . |
TableRead |
An abstraction layer above
SplitRead to provide reading of InternalRow . |
TableScan | |
TableScan.Plan |
Plan of scan.
|
Class | Description |
---|---|
AbstractDataTableRead<T> |
A
InnerTableRead for data table. |
AbstractDataTableScan |
An abstraction layer above
FileStoreScan to provide input split generation. |
AppendOnlySplitGenerator |
Append only implementation of
SplitGenerator . |
DataFilePlan |
Scanning plan containing snapshot ID and input splits.
|
DataSplit |
Input splits.
|
DataSplit.Builder |
Builder for
DataSplit . |
DataTableBatchScan |
TableScan implementation for batch planning. |
DataTableStreamScan |
StreamTableScan implementation for streaming planning. |
DeletionFile |
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
IndexFile |
Index file for data file.
|
KeyValueTableRead |
An abstraction layer above
MergeFileSplitRead to provide reading of InternalRow . |
MergeTreeSplitGenerator |
Merge tree implementation of
SplitGenerator . |
PlanImpl |
An implementation of
SnapshotReader.Plan . |
RawFile |
A data file from the table which can be read directly without merging.
|
ReadBuilderImpl |
Implementation for
ReadBuilder . |
ReadOnceTableScan |
An
InnerTableScan for reading only once, this is for batch scan. |
ResetRowKindRecordIterator |
A
RecordReader.RecordIterator which resets RowKind.INSERT to previous key value. |
SingletonSplit |
Singleton split use for system table, in which, scan always just produce one split.
|
SnapshotNotExistPlan |
This is used to distinguish the case where the snapshot does not exist and the plan is empty.
|
SplitGenerator.SplitGroup |
Split group.
|
ValueContentRowDataRecordIterator |
A
RecordReader.RecordIterator mapping a KeyValue to its value. |
Enum | Description |
---|---|
ScanMode |
Scan which part of the snapshot.
|
Exception | Description |
---|---|
EndOfScanException |
Signals that an end of scanning has been reached unexpectedly during input.
|
OutOfRangeException |
Indicates that the snapshot to be consumed has been deleted from storage.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.