Class and Description |
---|
DeletionFile
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
Class and Description |
---|
DeletionFile
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
Class and Description |
---|
StreamTableScan
TableScan for streaming, supports StreamTableScan.checkpoint() and StreamTableScan.restore(java.lang.Long) . |
Class and Description |
---|
AbstractDataTableRead
A
InnerTableRead for data table. |
AbstractDataTableScan
An abstraction layer above
FileStoreScan to provide input split generation. |
DataSplit
Input splits.
|
DataTableScan
Table scan for data table.
|
DataTableStreamScan
StreamTableScan implementation for streaming planning. |
InnerTableRead
Inner
TableRead contains filter and projection push down. |
InnerTableScan
Inner
TableScan contains filter push down. |
Split
An input split for reading.
|
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 |
Class and Description |
---|
ReadBuilder |
Split
An input split for reading.
|
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.Plan
Plan of scan.
|
Class and Description |
---|
DataSplit
Input splits.
|
ReadBuilder |
Split
An input split for reading.
|
StreamTableScan
TableScan for streaming, supports StreamTableScan.checkpoint() and StreamTableScan.restore(java.lang.Long) . |
TableRead
An abstraction layer above
SplitRead to provide reading of InternalRow . |
Class and Description |
---|
ReadBuilder |
Split
An input split for reading.
|
Class and Description |
---|
DataSplit
Input splits.
|
ReadBuilder |
Class and Description |
---|
DeletionFile
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
Class and Description |
---|
Split
An input split for reading.
|
Class and Description |
---|
DataSplit
Input splits.
|
Class and Description |
---|
DataSplit
Input splits.
|
DeletionFile
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
ScanMode
Scan which part of the snapshot.
|
Class and Description |
---|
DataTableScan
Table scan for data table.
|
InnerTableRead
Inner
TableRead contains filter and projection push down. |
StreamDataTableScan
Streaming
InnerTableScan with StreamTableScan . |
Class and Description |
---|
DataSplit
Input splits.
|
DataTableScan
Table scan for data table.
|
InnerTableRead
Inner
TableRead contains filter and projection push down. |
InnerTableScan
Inner
TableScan contains filter push down. |
ReadBuilder |
StreamDataTableScan
Streaming
InnerTableScan with StreamTableScan . |
Class and Description |
---|
AbstractDataTableRead
A
InnerTableRead for data table. |
AbstractDataTableScan
An abstraction layer above
FileStoreScan to provide input split generation. |
DataSplit
Input splits.
|
DataSplit.Builder
Builder for
DataSplit . |
DataTableScan
Table scan for data table.
|
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.
|
DeletionFile.Factory
Interface to create
DeletionFile . |
IndexFile
Index file for data file.
|
InnerTableRead
Inner
TableRead contains filter and projection push down. |
InnerTableScan
Inner
TableScan contains filter push down. |
RawFile
A data file from the table which can be read directly without merging.
|
ReadBuilder |
ResetRowKindRecordIterator
A
RecordReader.RecordIterator which resets RowKind.INSERT to previous key value. |
ScanMode
Scan which part of the snapshot.
|
SnapshotNotExistPlan
This is used to distinguish the case where the snapshot does not exist and the plan is empty.
|
Split
An input split for reading.
|
SplitGenerator
Generate splits from
DataFileMeta s. |
SplitGenerator.SplitGroup
Split group.
|
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 and Description |
---|
DataSplit
Input splits.
|
ScanMode
Scan which part of the snapshot.
|
Split
An input split for reading.
|
SplitGenerator
Generate splits from
DataFileMeta s. |
TableScan.Plan
Plan of scan.
|
Class and Description |
---|
DataSplit
Input splits.
|
Class and Description |
---|
DataTableBatchScan
TableScan implementation for batch planning. |
DataTableScan
Table scan for data table.
|
InnerTableRead
Inner
TableRead contains filter and projection push down. |
InnerTableScan
Inner
TableScan contains filter push down. |
Split
An input split for reading.
|
StreamDataTableScan
Streaming
InnerTableScan with StreamTableScan . |
TableRead
An abstraction layer above
SplitRead to provide reading of InternalRow . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.