public class RecordReaderUtils extends Object
RecordReader
.Constructor and Description |
---|
RecordReaderUtils() |
Modifier and Type | Method and Description |
---|---|
static <T> void |
forEachRemaining(RecordReader<T> reader,
java.util.function.Consumer<? super T> action)
Performs the given action for each remaining element in
RecordReader until all
elements have been processed or the action throws an exception. |
static <L,R> RecordReader.RecordIterator<R> |
transform(RecordReader.RecordIterator<L> fromIterator,
java.util.function.Function<L,R> function)
Returns an iterator that applies
function to each element of fromIterator . |
static <L,R> RecordReader<R> |
transform(RecordReader<L> fromReader,
java.util.function.Function<L,R> function)
|
public static <T> void forEachRemaining(RecordReader<T> reader, java.util.function.Consumer<? super T> action) throws IOException
RecordReader
until all
elements have been processed or the action throws an exception.IOException
public static <L,R> RecordReader<R> transform(RecordReader<L> fromReader, java.util.function.Function<L,R> function)
public static <L,R> RecordReader.RecordIterator<R> transform(RecordReader.RecordIterator<L> fromIterator, java.util.function.Function<L,R> function)
function
to each element of fromIterator
.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.