Uses of Interface
org.apache.paimon.operation.SplitRead

Packages that use SplitRead

Package	Description
org.apache.paimon
org.apache.paimon.flink.lookup
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.table.source.splitread

Uses of SplitRead in org.apache.paimon

Methods in org.apache.paimon that return SplitRead

Modifier and Type	Method and Description
SplitRead<T>	FileStore.newRead()

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

Classes in org.apache.paimon.flink.lookup that implement SplitRead

Modifier and Type	Class and Description
class	IncrementalCompactDiffSplitRead A SplitRead for streaming incremental diff after compaction.

Uses of SplitRead in org.apache.paimon.operation

Classes in org.apache.paimon.operation that implement SplitRead

Modifier and Type	Class and Description
class	MergeFileSplitRead An implementation for KeyValueFileStore, this class handle LSM merging and changelog row kind things, it will force reading fields such as sequence and row_kind.
class	RawFileSplitRead A SplitRead to read raw file directly from DataSplit.

Methods in org.apache.paimon.operation that return SplitRead

Modifier and Type	Method and Description
static <L,R> SplitRead<R>	SplitRead.convert(SplitRead<L> read, IOFunction<DataSplit,RecordReader<R>> convertedFactory)
SplitRead<InternalRow>	RawFileSplitRead.forceKeepDelete()
SplitRead<T>	SplitRead.forceKeepDelete()
SplitRead<T>	SplitRead.withFilter(Predicate predicate)
SplitRead<InternalRow>	RawFileSplitRead.withIOManager(IOManager ioManager)
SplitRead<T>	SplitRead.withIOManager(IOManager ioManager)
SplitRead<InternalRow>	RawFileSplitRead.withReadType(RowType readRowType)
SplitRead<T>	SplitRead.withReadType(RowType readType)

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

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

Uses of SplitRead in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege that return SplitRead

Modifier and Type	Method and Description
SplitRead<T>	PrivilegedFileStore.newRead()

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

Classes in org.apache.paimon.table.source.splitread that implement SplitRead

Modifier and Type	Class and Description
class	IncrementalDiffSplitRead A SplitRead for batch incremental diff.

Methods in org.apache.paimon.table.source.splitread that return SplitRead

Modifier and Type	Method and Description
SplitRead<InternalRow>	IncrementalDiffSplitRead.forceKeepDelete()
SplitRead<InternalRow>	SplitReadProvider.getOrCreate()
SplitRead<InternalRow>	RawFileSplitReadProvider.getOrCreate()
SplitRead<InternalRow>	IncrementalDiffReadProvider.getOrCreate()
SplitRead<InternalRow>	MergeFileSplitReadProvider.getOrCreate()
SplitRead<InternalRow>	IncrementalChangelogReadProvider.getOrCreate()
SplitRead<InternalRow>	IncrementalDiffSplitRead.withFilter(Predicate predicate)
SplitRead<InternalRow>	IncrementalDiffSplitRead.withIOManager(IOManager ioManager)
SplitRead<InternalRow>	IncrementalDiffSplitRead.withReadType(RowType readType)

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

Constructor and Description
IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
IncrementalDiffReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
MergeFileSplitReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
RawFileSplitReadProvider(java.util.function.Supplier<RawFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)