org.apache.paimon.table.source

Class AbstractDataTableRead<T>

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableRead<T>

All Implemented Interfaces:

InnerTableRead, TableRead

Direct Known Subclasses:

KeyValueTableRead, LookupCompactDiffRead

public abstract class AbstractDataTableRead<T>
extends Object
implements InnerTableRead

A InnerTableRead for data table.

Constructor Summary

Constructors

Constructor and Description
AbstractDataTableRead(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
abstract void	applyReadType(RowType readType)
RecordReader<InternalRow>	createReader(Split split)
TableRead	executeFilter()
protected abstract InnerTableRead	innerWithFilter(Predicate predicate)
abstract RecordReader<InternalRow>	reader(Split split)
InnerTableRead	withFilter(Predicate predicate)
TableRead	withIOManager(IOManager ioManager)
InnerTableRead	withProjection(int[] projection) Use InnerTableRead.withReadType(RowType) instead.
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

forceKeepDelete, withFilter

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

createReader, createReader

Constructor Detail

AbstractDataTableRead

public AbstractDataTableRead(TableSchema schema)

Method Detail

applyReadType

public abstract void applyReadType(RowType readType)

reader

public abstract RecordReader<InternalRow> reader(Split split)
                                          throws IOException

Throws:

IOException

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

withFilter

public final InnerTableRead withFilter(Predicate predicate)

Specified by:

withFilter in interface InnerTableRead

innerWithFilter

protected abstract InnerTableRead innerWithFilter(Predicate predicate)

executeFilter

public TableRead executeFilter()

Specified by:

executeFilter in interface InnerTableRead

Specified by:

executeFilter in interface TableRead

withProjection

public final InnerTableRead withProjection(int[] projection)

Description copied from interface: InnerTableRead

Use InnerTableRead.withReadType(RowType) instead.

Specified by:

withProjection in interface InnerTableRead

withReadType

public final InnerTableRead withReadType(RowType readType)

Specified by:

withReadType in interface InnerTableRead

createReader

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

Specified by:

createReader in interface TableRead

Throws:

IOException