public interface FileRecordIterator<T> extends RecordReader.RecordIterator<T>
RecordReader.RecordIterator
to support returning the record's row position and file
Path.Modifier and Type | Method and Description |
---|---|
Path |
filePath() |
default FileRecordIterator<T> |
filter(Filter<T> filter)
Filters a
RecordReader.RecordIterator . |
long |
returnedPosition()
Get the row position of the row returned by
RecordReader.RecordIterator.next() . |
default <R> FileRecordIterator<R> |
transform(java.util.function.Function<T,R> function)
Returns an iterator that applies
function to each element. |
next, releaseBatch
long returnedPosition()
RecordReader.RecordIterator.next()
.Path filePath()
default <R> FileRecordIterator<R> transform(java.util.function.Function<T,R> function)
RecordReader.RecordIterator
function
to each element.transform
in interface RecordReader.RecordIterator<T>
default FileRecordIterator<T> filter(Filter<T> filter)
RecordReader.RecordIterator
RecordReader.RecordIterator
.filter
in interface RecordReader.RecordIterator<T>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.