org.apache.paimon.table.source

Interface InnerTableRead

All Superinterfaces:

TableRead

All Known Implementing Classes:

AbstractDataTableRead, KeyValueTableRead, LookupCompactDiffRead, TableLineageTable.TableLineageRead

public interface InnerTableRead
extends TableRead

Inner TableRead contains filter and projection push down.

Method Summary

Modifier and Type	Method and Description
default TableRead	executeFilter()
default InnerTableRead	forceKeepDelete()
default InnerTableRead	withFilter(List<Predicate> predicates)
InnerTableRead	withFilter(Predicate predicate)
default InnerTableRead	withProjection(int[] projection) Deprecated.
default InnerTableRead	withReadType(RowType readType)

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

createReader, createReader, createReader, withIOManager

Method Detail

withFilter

default InnerTableRead withFilter(List<Predicate> predicates)

withFilter

InnerTableRead withFilter(Predicate predicate)

withProjection

@Deprecated
default InnerTableRead withProjection(int[] projection)

Deprecated.

Use withReadType(RowType) instead.

withReadType

default InnerTableRead withReadType(RowType readType)

forceKeepDelete

default InnerTableRead forceKeepDelete()

executeFilter

default TableRead executeFilter()

Specified by:

executeFilter in interface TableRead