org.apache.paimon.flink.lookup

Class LookupCompactDiffRead

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableRead<KeyValue>

org.apache.paimon.flink.lookup.LookupCompactDiffRead

All Implemented Interfaces:

InnerTableRead, TableRead

public class LookupCompactDiffRead
extends AbstractDataTableRead<KeyValue>

An InnerTableRead that reads the data changed before and after compaction.

Constructor Summary

Constructors

Constructor and Description
LookupCompactDiffRead(MergeFileSplitRead mergeRead, TableSchema schema)

Method Summary

Modifier and Type	Method and Description
void	applyReadType(RowType readType)
InnerTableRead	forceKeepDelete()
protected InnerTableRead	innerWithFilter(Predicate predicate)
RecordReader<InternalRow>	reader(Split split)
TableRead	withIOManager(IOManager ioManager)

Methods inherited from class org.apache.paimon.table.source.AbstractDataTableRead

createReader, executeFilter, withFilter, withProjection, 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.table.source.InnerTableRead

withFilter

Methods inherited from interface org.apache.paimon.table.source.TableRead

createReader, createReader

Constructor Detail

LookupCompactDiffRead

public LookupCompactDiffRead(MergeFileSplitRead mergeRead,
                             TableSchema schema)

Method Detail

applyReadType

public void applyReadType(RowType readType)

Specified by:

applyReadType in class AbstractDataTableRead<KeyValue>

reader

public RecordReader<InternalRow> reader(Split split)
                                 throws IOException

Specified by:

reader in class AbstractDataTableRead<KeyValue>

Throws:

IOException

innerWithFilter

protected InnerTableRead innerWithFilter(Predicate predicate)

Specified by:

innerWithFilter in class AbstractDataTableRead<KeyValue>

forceKeepDelete

public InnerTableRead forceKeepDelete()

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

Overrides:

withIOManager in class AbstractDataTableRead<KeyValue>