Package org.apache.paimon.table.source

Interface Summary

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	An interface for building the TableScan and TableRead.
Split	An input split for reading.
SplitGenerator	Generate splits from DataFileMetas.
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	A scan of Table to generate Split splits.
TableScan.Plan	Plan of scan.

Class Summary

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 Summary

Enum	Description
ScanMode	Scan which part of the snapshot.

Exception Summary

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.