org.apache.paimon.table.source

Class KeyValueTableRead

java.lang.Object

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

org.apache.paimon.table.source.KeyValueTableRead

All Implemented Interfaces:

InnerTableRead, TableRead

public final class KeyValueTableRead
extends AbstractDataTableRead<KeyValue>

An abstraction layer above MergeFileSplitRead to provide reading of InternalRow.

Constructor Summary

Constructors

Constructor and Description
KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier, java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier, TableSchema schema)

Method Summary

Modifier and Type	Method and Description
InnerTableRead	forceKeepDelete()
protected InnerTableRead	innerWithFilter(Predicate predicate)
void	projection(int[][] projection)
RecordReader<InternalRow>	reader(Split split)
static RecordReader<InternalRow>	unwrap(RecordReader<KeyValue> reader)
TableRead	withIOManager(IOManager ioManager)

Methods inherited from class org.apache.paimon.table.source.AbstractDataTableRead

createReader, executeFilter, withFilter, withProjection

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

withFilter, withProjection

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

createReader, createReader

Constructor Detail

KeyValueTableRead

public KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier,
                         java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier,
                         TableSchema schema)

Method Detail

projection

public void projection(int[][] projection)

Specified by:

projection in class AbstractDataTableRead<KeyValue>

forceKeepDelete

public InnerTableRead forceKeepDelete()

innerWithFilter

protected InnerTableRead innerWithFilter(Predicate predicate)

Specified by:

innerWithFilter in class AbstractDataTableRead<KeyValue>

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

Overrides:

withIOManager in class AbstractDataTableRead<KeyValue>

reader

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

Specified by:

reader in class AbstractDataTableRead<KeyValue>

Throws:

IOException

unwrap

public static RecordReader<InternalRow> unwrap(RecordReader<KeyValue> reader)