org.apache.paimon.table.system

Class TableLineageTable.TableLineageRead

java.lang.Object

org.apache.paimon.table.system.TableLineageTable.TableLineageRead

All Implemented Interfaces:

InnerTableRead, TableRead

Enclosing class:

TableLineageTable

protected static class TableLineageTable.TableLineageRead
extends Object
implements InnerTableRead

Table lineage read with lineage meta query.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TableLineageRead(LineageMetaFactory lineageMetaFactory, Options options, java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery)

Method Summary

Modifier and Type	Method and Description
RecordReader<InternalRow>	createReader(Split split)
InnerTableRead	withFilter(Predicate predicate)
TableRead	withIOManager(IOManager ioManager)
InnerTableRead	withReadType(RowType readType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

executeFilter, forceKeepDelete, withFilter, withProjection

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

createReader, createReader

Constructor Detail

TableLineageRead

protected TableLineageRead(LineageMetaFactory lineageMetaFactory,
                           Options options,
                           java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery)

Method Detail

withFilter

public InnerTableRead withFilter(Predicate predicate)

Specified by:

withFilter in interface InnerTableRead

withReadType

public InnerTableRead withReadType(RowType readType)

Specified by:

withReadType in interface InnerTableRead

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

createReader

public RecordReader<InternalRow> createReader(Split split)
                                       throws IOException

Specified by:

createReader in interface TableRead

Throws:

IOException