public class ApplyDeletionFileRecordIterator extends Object implements FileRecordIterator<InternalRow>
Constructor and Description |
---|
ApplyDeletionFileRecordIterator(FileRecordIterator<InternalRow> iterator,
DeletionVector deletionVector) |
Modifier and Type | Method and Description |
---|---|
DeletionVector |
deletionVector() |
Path |
filePath() |
FileRecordIterator<InternalRow> |
iterator() |
InternalRow |
next()
Gets the next record from the iterator.
|
void |
releaseBatch()
Releases the batch that this iterator iterated over.
|
long |
returnedPosition()
Get the row position of the row returned by
RecordReader.RecordIterator.next() . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
filter, transform
public ApplyDeletionFileRecordIterator(FileRecordIterator<InternalRow> iterator, DeletionVector deletionVector)
public FileRecordIterator<InternalRow> iterator()
public DeletionVector deletionVector()
public long returnedPosition()
FileRecordIterator
RecordReader.RecordIterator.next()
.returnedPosition
in interface FileRecordIterator<InternalRow>
public Path filePath()
filePath
in interface FileRecordIterator<InternalRow>
@Nullable public InternalRow next() throws IOException
RecordReader.RecordIterator
next
in interface RecordReader.RecordIterator<InternalRow>
IOException
public void releaseBatch()
RecordReader.RecordIterator
releaseBatch
in interface RecordReader.RecordIterator<InternalRow>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.