public class LookupCompactDiffRead extends AbstractDataTableRead<KeyValue>
InnerTableRead
that reads the data changed before and after compaction.Constructor and Description |
---|
LookupCompactDiffRead(MergeFileSplitRead mergeRead,
TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
void |
applyReadType(RowType readType) |
InnerTableRead |
forceKeepDelete() |
protected InnerTableRead |
innerWithFilter(Predicate predicate) |
RecordReader<InternalRow> |
reader(Split split) |
TableRead |
withIOManager(IOManager ioManager) |
createReader, executeFilter, withFilter, withProjection, withReadType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
withFilter
createReader, createReader
public LookupCompactDiffRead(MergeFileSplitRead mergeRead, TableSchema schema)
public void applyReadType(RowType readType)
applyReadType
in class AbstractDataTableRead<KeyValue>
public RecordReader<InternalRow> reader(Split split) throws IOException
reader
in class AbstractDataTableRead<KeyValue>
IOException
protected InnerTableRead innerWithFilter(Predicate predicate)
innerWithFilter
in class AbstractDataTableRead<KeyValue>
public InnerTableRead forceKeepDelete()
public TableRead withIOManager(IOManager ioManager)
withIOManager
in interface TableRead
withIOManager
in class AbstractDataTableRead<KeyValue>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.