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
org.apache.paimon.table.system

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)
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)
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, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue)

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
TableRead	TableRead.executeFilter()
TableRead	AbstractDataTableRead.executeFilter()
default TableRead	InnerTableRead.executeFilter()
TableRead	ReadBuilderImpl.newRead()
TableRead	ReadBuilder.newRead() Create a TableRead to read Splits.
TableRead	TableRead.withIOManager(IOManager ioManager)
TableRead	KeyValueTableRead.withIOManager(IOManager ioManager)
TableRead	AbstractDataTableRead.withIOManager(IOManager ioManager)

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

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

Modifier and Type	Class and Description
protected static class	TableLineageTable.TableLineageRead Table lineage read with lineage meta query.

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

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