Uses of Interface
org.apache.paimon.table.source.TableRead

Packages that use TableRead

Package	Description
org.apache.paimon.flink.lookup
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.table.source

Uses of TableRead in org.apache.paimon.flink.lookup

Classes in org.apache.paimon.flink.lookup that implement TableRead

Modifier and Type	Class and Description
class	LookupCompactDiffRead An InnerTableRead that reads the data changed before and after compaction.

Methods in org.apache.paimon.flink.lookup that return TableRead

Modifier and Type	Method and Description
TableRead	LookupCompactDiffRead.withIOManager(IOManager ioManager)

Uses of TableRead in org.apache.paimon.flink.source

Constructors in org.apache.paimon.flink.source with parameters of type TableRead

Constructor and Description
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, NestedProjectedRowData rowData)
FileStoreSourceSplitReader(TableRead tableRead, RecordLimiter limiter, FileStoreSourceReaderMetrics metrics)

Uses of TableRead in org.apache.paimon.flink.source.align

Constructors in org.apache.paimon.flink.source.align with parameters of type TableRead

Constructor and Description
AlignedSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, NestedProjectedRowData rowData)

Uses of TableRead in org.apache.paimon.table.source

Subinterfaces of TableRead in org.apache.paimon.table.source

Modifier and Type	Interface and Description
interface	InnerTableRead Inner TableRead contains filter and projection push down.

Classes in org.apache.paimon.table.source that implement TableRead

Modifier and Type	Class and Description
class	AbstractDataTableRead<T> A InnerTableRead for data table.
class	KeyValueTableRead An abstraction layer above MergeFileSplitRead to provide reading of InternalRow.

Methods in org.apache.paimon.table.source that return TableRead

Modifier and Type	Method and Description
default TableRead	InnerTableRead.executeFilter()
TableRead	TableRead.executeFilter()
TableRead	AbstractDataTableRead.executeFilter()
TableRead	ReadBuilderImpl.newRead()
TableRead	ReadBuilder.newRead() Create a TableRead to read Splits.
TableRead	TableRead.withIOManager(IOManager ioManager)
TableRead	AbstractDataTableRead.withIOManager(IOManager ioManager)
TableRead	KeyValueTableRead.withIOManager(IOManager ioManager)