org.apache.paimon.flink.lookup

Class LookupCompactDiffRead

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableRead

org.apache.paimon.flink.lookup.LookupCompactDiffRead

All Implemented Interfaces:

InnerTableRead, TableRead

public class LookupCompactDiffRead
extends AbstractDataTableRead

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, withMetricRegistry

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

reader

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

Specified by:

reader in class AbstractDataTableRead

Throws:

IOException

innerWithFilter

protected InnerTableRead innerWithFilter(Predicate predicate)

Specified by:

innerWithFilter in class AbstractDataTableRead

forceKeepDelete

public InnerTableRead forceKeepDelete()

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

Overrides:

withIOManager in class AbstractDataTableRead