org.apache.paimon.table.source

Class KeyValueTableRead

java.lang.Object

org.apache.paimon.table.source.AbstractDataTableRead

org.apache.paimon.table.source.KeyValueTableRead

All Implemented Interfaces:

InnerTableRead, TableRead

public final class KeyValueTableRead
extends AbstractDataTableRead

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)
IOManager	ioManager()
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, withMetricRegistry

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

forceKeepDelete

public InnerTableRead forceKeepDelete()

innerWithFilter

protected InnerTableRead innerWithFilter(Predicate predicate)

Specified by:

innerWithFilter in class AbstractDataTableRead

withIOManager

public TableRead withIOManager(IOManager ioManager)

Specified by:

withIOManager in interface TableRead

Overrides:

withIOManager in class AbstractDataTableRead

reader

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

Specified by:

reader in class AbstractDataTableRead

Throws:

IOException

unwrap

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

ioManager

@VisibleForTesting
public IOManager ioManager()