org.apache.paimon.flink.lookup

Class IncrementalCompactDiffSplitRead

java.lang.Object

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

org.apache.paimon.flink.lookup.IncrementalCompactDiffSplitRead

All Implemented Interfaces:

SplitRead<InternalRow>

public class IncrementalCompactDiffSplitRead
extends IncrementalDiffSplitRead

A SplitRead for streaming incremental diff after compaction.

Constructor Summary

Constructors

Constructor and Description
IncrementalCompactDiffSplitRead(MergeFileSplitRead mergeRead)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	createReader(DataSplit split) Create a RecordReader from split.

Methods inherited from class org.apache.paimon.table.source.splitread.IncrementalDiffSplitRead

forceKeepDelete, withFilter, withIOManager, withReadType

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

IncrementalCompactDiffSplitRead

public IncrementalCompactDiffSplitRead(MergeFileSplitRead mergeRead)

Method Detail

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>

Overrides:

createReader in class IncrementalDiffSplitRead

Throws:

IOException