org.apache.paimon.table.source.splitread

Class IncrementalDiffSplitRead

java.lang.Object

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

All Implemented Interfaces:

SplitRead<InternalRow>

Direct Known Subclasses:

IncrementalCompactDiffSplitRead

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>	withReadType(RowType readType)

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>

withReadType

public SplitRead<InternalRow> withReadType(RowType readType)

Specified by:

withReadType 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