Modifier and Type | Class and Description |
---|---|
class |
PlaceholderSplit
Used as a placeholder for an empty snapshot, indicating that the current snapshot does not
contain any
Split . |
Constructor and Description |
---|
PlaceholderSplit(DataSplit dataSplit) |
Modifier and Type | Method and Description |
---|---|
DataSplit |
PaimonInputSplit.split() |
Constructor and Description |
---|
PaimonInputSplit(String path,
DataSplit split,
FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
MergeFileSplitRead.createReader(DataSplit split) |
RecordReader<InternalRow> |
RawFileSplitRead.createReader(DataSplit split) |
RecordReader<T> |
SplitRead.createReader(DataSplit split)
Create a
RecordReader from split. |
Modifier and Type | Method and Description |
---|---|
static <L,R> SplitRead<R> |
SplitRead.convert(SplitRead<L> read,
IOFunction<DataSplit,RecordReader<R>> convertedFactory) |
Modifier and Type | Method and Description |
---|---|
DataSplit |
DataSplit.Builder.build() |
static DataSplit |
DataSplit.deserialize(DataInputView in) |
Constructor and Description |
---|
DataFilePlan(List<DataSplit> splits) |
Modifier and Type | Method and Description |
---|---|
default List<DataSplit> |
SnapshotReader.Plan.dataSplits() |
List<DataSplit> |
StartingScanner.ScannedResult.splits() |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
IncrementalDiffSplitRead.createReader(DataSplit split) |
boolean |
IncrementalDiffReadProvider.match(DataSplit split,
boolean forceKeepDelete) |
boolean |
MergeFileSplitReadProvider.match(DataSplit split,
boolean forceKeepDelete) |
boolean |
SplitReadProvider.match(DataSplit split,
boolean forceKeepDelete) |
boolean |
RawFileSplitReadProvider.match(DataSplit split,
boolean forceKeepDelete) |
boolean |
IncrementalChangelogReadProvider.match(DataSplit split,
boolean forceKeepDelete) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.