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

Packages that use TableRead

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