Uses of Interface
org.apache.paimon.table.source.Split

Packages that use Split

Package	Description
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.flink.source.operator
org.apache.paimon.io
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system

Uses of Split in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return Split

Modifier and Type	Method and Description
Split	FileStoreSourceSplit.split()

Method parameters in org.apache.paimon.flink.source with type arguments of type Split

Modifier and Type	Method and Description
List<FileStoreSourceSplit>	FileStoreSourceSplitGenerator.createSplits(List<Split> splits)

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

Constructor and Description
FileStoreSourceSplit(String id, Split split)
FileStoreSourceSplit(String id, Split split, long recordsToSkip)

Constructor parameters in org.apache.paimon.flink.source with type arguments of type Split

Constructor and Description
SplitStatistics(List<Split> splits)

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

Classes in org.apache.paimon.flink.source.align that implement Split

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.

Uses of Split in org.apache.paimon.flink.source.operator

Method parameters in org.apache.paimon.flink.source.operator with type arguments of type Split

Modifier and Type	Method and Description
void	ReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Split> record)
void	MultiTablesReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<Split,String>> record)
void	MonitorFunction.run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<Split> ctx)

Uses of Split in org.apache.paimon.io

Method parameters in org.apache.paimon.io with type arguments of type Split

Modifier and Type	Method and Description
static RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism)
static RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism)
static <EXTRA> RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism, java.util.function.Function<Split,EXTRA> extraFunction, java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow)
static <EXTRA> RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism, java.util.function.Function<Split,EXTRA> extraFunction, java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow)
static <EXTRA> RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism, java.util.function.Function<Split,EXTRA> extraFunction, java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow)

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

Classes in org.apache.paimon.table.source that implement Split

Modifier and Type	Class and Description
class	DataSplit Input splits.
class	SingletonSplit Singleton split use for system table, in which, scan always just produce one split.

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

Modifier and Type	Method and Description
List<Split>	TableScan.Plan.splits()
List<Split>	PlanImpl.splits()
List<Split>	DataFilePlan.splits()
List<Split>	SnapshotNotExistPlan.splits()

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

Modifier and Type	Method and Description
RecordReader<InternalRow>	AbstractDataTableRead.createReader(Split split)
RecordReader<InternalRow>	TableRead.createReader(Split split)
RecordReader<InternalRow>	KeyValueTableRead.reader(Split split)
abstract RecordReader<InternalRow>	AbstractDataTableRead.reader(Split split)

Method parameters in org.apache.paimon.table.source with type arguments of type Split

Modifier and Type	Method and Description
default RecordReader<InternalRow>	TableRead.createReader(List<Split> splits)

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

Constructor and Description
PlanImpl(Long watermark, Long snapshotId, List<Split> splits)

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

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

Modifier and Type	Method and Description
List<Split>	SnapshotReader.Plan.splits() Result splits.

Uses of Split in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system with parameters of type Split

Modifier and Type	Method and Description
RecordReader<InternalRow>	TableLineageTable.TableLineageRead.createReader(Split split)