protected static class TableLineageTable.TableLineageRead extends Object implements InnerTableRead
Modifier | Constructor and Description |
---|---|
protected |
TableLineageRead(LineageMetaFactory lineageMetaFactory,
Options options,
java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery) |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
createReader(Split split) |
InnerTableRead |
withFilter(Predicate predicate) |
TableRead |
withIOManager(IOManager ioManager) |
InnerTableRead |
withReadType(RowType readType) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
executeFilter, forceKeepDelete, withFilter, withProjection
createReader, createReader
protected TableLineageRead(LineageMetaFactory lineageMetaFactory, Options options, java.util.function.BiFunction<LineageMeta,Predicate,Iterator<TableLineageEntity>> tableLineageQuery)
public InnerTableRead withFilter(Predicate predicate)
withFilter
in interface InnerTableRead
public InnerTableRead withReadType(RowType readType)
withReadType
in interface InnerTableRead
public TableRead withIOManager(IOManager ioManager)
withIOManager
in interface TableRead
public RecordReader<InternalRow> createReader(Split split) throws IOException
createReader
in interface TableRead
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.