public final class KeyValueTableRead extends AbstractDataTableRead<KeyValue>
MergeFileSplitRead
to provide reading of InternalRow
.Constructor and Description |
---|
KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier,
java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier,
TableSchema schema) |
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) |
createReader, executeFilter, withFilter, withProjection, withReadType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withFilter
createReader, createReader
public KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier, java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier, TableSchema schema)
public void applyReadType(RowType readType)
applyReadType
in class AbstractDataTableRead<KeyValue>
public InnerTableRead forceKeepDelete()
protected InnerTableRead innerWithFilter(Predicate predicate)
innerWithFilter
in class AbstractDataTableRead<KeyValue>
public TableRead withIOManager(IOManager ioManager)
withIOManager
in interface TableRead
withIOManager
in class AbstractDataTableRead<KeyValue>
public RecordReader<InternalRow> reader(Split split) throws IOException
reader
in class AbstractDataTableRead<KeyValue>
IOException
public static RecordReader<InternalRow> unwrap(RecordReader<KeyValue> reader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.