org.apache.paimon.table.source.splitread

Class IncrementalDiffSplitRead

java.lang.Object

org.apache.paimon.table.source.splitread.IncrementalDiffSplitRead

All Implemented Interfaces:

SplitRead<InternalRow>

public class IncrementalDiffSplitRead
extends Object
implements SplitRead<InternalRow>

A SplitRead for batch incremental diff.

Constructor Summary

Constructors

Constructor and Description
IncrementalDiffSplitRead(MergeFileSplitRead mergeRead)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	createReader(DataSplit split) Create a RecordReader from split.
SplitRead<InternalRow>	forceKeepDelete()
SplitRead<InternalRow>	withFilter(Predicate predicate)
SplitRead<InternalRow>	withIOManager(IOManager ioManager)
SplitRead<InternalRow>	withProjection(int[][] projectedFields)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.operation.SplitRead

convert

Constructor Detail

IncrementalDiffSplitRead

public IncrementalDiffSplitRead(MergeFileSplitRead mergeRead)

Method Detail

forceKeepDelete

public SplitRead<InternalRow> forceKeepDelete()

Specified by:

forceKeepDelete in interface SplitRead<InternalRow>

withIOManager

public SplitRead<InternalRow> withIOManager(@Nullable
                                            IOManager ioManager)

Specified by:

withIOManager in interface SplitRead<InternalRow>

withProjection

public SplitRead<InternalRow> withProjection(@Nullable
                                             int[][] projectedFields)

Specified by:

withProjection in interface SplitRead<InternalRow>

withFilter

public SplitRead<InternalRow> withFilter(@Nullable
                                         Predicate predicate)

Specified by:

withFilter in interface SplitRead<InternalRow>

createReader

public RecordReader<InternalRow> createReader(DataSplit split)
                                       throws IOException

Description copied from interface: SplitRead

Create a RecordReader from split.

Specified by:

createReader in interface SplitRead<InternalRow>

Throws:

IOException