Uses of Class
org.apache.paimon.table.source.DataSplit

Packages that use DataSplit

Package	Description
org.apache.paimon.flink.lookup
org.apache.paimon.flink.source.align
org.apache.paimon.hive.mapred
org.apache.paimon.manifest
org.apache.paimon.operation
org.apache.paimon.table
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.source.splitread

Uses of DataSplit in org.apache.paimon.flink.lookup

Methods in org.apache.paimon.flink.lookup with parameters of type DataSplit

Modifier and Type	Method and Description
RecordReader<InternalRow>	IncrementalCompactDiffSplitRead.createReader(DataSplit split)

Uses of DataSplit in org.apache.paimon.flink.source.align

Subclasses of DataSplit in org.apache.paimon.flink.source.align

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.

Constructors in org.apache.paimon.flink.source.align with parameters of type DataSplit

Constructor and Description
PlaceholderSplit(DataSplit dataSplit)

Uses of DataSplit in org.apache.paimon.hive.mapred

Methods in org.apache.paimon.hive.mapred that return DataSplit

Modifier and Type	Method and Description
DataSplit	PaimonInputSplit.split()

Constructors in org.apache.paimon.hive.mapred with parameters of type DataSplit

Constructor and Description
PaimonInputSplit(String path, DataSplit split, FileStoreTable table)

Uses of DataSplit in org.apache.paimon.manifest

Method parameters in org.apache.paimon.manifest with type arguments of type DataSplit

Modifier and Type	Method and Description
static Collection<PartitionEntry>	PartitionEntry.mergeSplits(Collection<DataSplit> splits)

Uses of DataSplit in org.apache.paimon.operation

Methods in org.apache.paimon.operation with parameters of type DataSplit

Modifier and Type	Method and Description
RecordReader<InternalRow>	RawFileSplitRead.createReader(DataSplit split)
RecordReader<KeyValue>	MergeFileSplitRead.createReader(DataSplit split)
RecordReader<T>	SplitRead.createReader(DataSplit split) Create a RecordReader from split.

Method parameters in org.apache.paimon.operation with type arguments of type DataSplit

Modifier and Type	Method and Description
static <L,R> SplitRead<R>	SplitRead.convert(SplitRead<L> read, IOFunction<DataSplit,RecordReader<R>> convertedFactory)

Uses of DataSplit in org.apache.paimon.table

Methods in org.apache.paimon.table that return DataSplit

Modifier and Type	Method and Description
DataSplit[]	KnownSplitsTable.splits()

Methods in org.apache.paimon.table with parameters of type DataSplit

Modifier and Type	Method and Description
static KnownSplitsTable	KnownSplitsTable.create(InnerTable origin, DataSplit[] splits)

Uses of DataSplit in org.apache.paimon.table.source

Methods in org.apache.paimon.table.source that return DataSplit

Modifier and Type	Method and Description
DataSplit	DataSplit.Builder.build()
static DataSplit	DataSplit.deserialize(DataInputView in)

Constructor parameters in org.apache.paimon.table.source with type arguments of type DataSplit

Constructor and Description
DataFilePlan(List<DataSplit> splits)

Uses of DataSplit in org.apache.paimon.table.source.snapshot

Methods in org.apache.paimon.table.source.snapshot that return types with arguments of type DataSplit

Modifier and Type	Method and Description
default List<DataSplit>	SnapshotReader.Plan.dataSplits()
List<DataSplit>	StartingScanner.ScannedResult.splits()

Uses of DataSplit in org.apache.paimon.table.source.splitread

Methods in org.apache.paimon.table.source.splitread with parameters of type DataSplit

Modifier and Type	Method and Description
RecordReader<InternalRow>	IncrementalDiffSplitRead.createReader(DataSplit split)
boolean	SplitReadProvider.match(DataSplit split, boolean forceKeepDelete)
boolean	RawFileSplitReadProvider.match(DataSplit split, boolean forceKeepDelete)
boolean	IncrementalDiffReadProvider.match(DataSplit split, boolean forceKeepDelete)
boolean	MergeFileSplitReadProvider.match(DataSplit split, boolean forceKeepDelete)
boolean	IncrementalChangelogReadProvider.match(DataSplit split, boolean forceKeepDelete)