org.apache.paimon.table.source

Interface InnerTableRead

All Superinterfaces:

TableRead

All Known Implementing Classes:

AbstractDataTableRead, KeyValueTableRead, 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)
InnerTableRead	withProjection(int[][] projection)

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

default InnerTableRead withProjection(int[] projection)

withProjection

InnerTableRead withProjection(int[][] projection)

forceKeepDelete

default InnerTableRead forceKeepDelete()

executeFilter

default TableRead executeFilter()

Specified by:

executeFilter in interface TableRead