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
void	applyReadType(RowType readType)
InnerTableRead	forceKeepDelete()
protected InnerTableRead	innerWithFilter(Predicate predicate)
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, withReadType

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

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

applyReadType

public void applyReadType(RowType readType)

Specified by:

applyReadType 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)