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

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
RecordReader<InternalRow>	createReader(Split split)
TableRead	executeFilter()
protected abstract InnerTableRead	innerWithFilter(Predicate predicate)
abstract void	projection(int[][] projection)
abstract RecordReader<InternalRow>	reader(Split split)
InnerTableRead	withFilter(Predicate predicate)
TableRead	withIOManager(IOManager ioManager)
InnerTableRead	withProjection(int[][] projection)

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, withProjection

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

createReader, createReader

Constructor Detail

AbstractDataTableRead

public AbstractDataTableRead(TableSchema schema)

Method Detail

projection

public abstract void projection(int[][] projection)

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)

Specified by:

withProjection in interface InnerTableRead

createReader

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

Specified by:

createReader in interface TableRead

Throws:

IOException