@PublicEvolving public class IteratorInputFormat<T> extends GenericInputFormat<T> implements NonParallelInput
partitionNumber
Constructor and Description |
---|
IteratorInputFormat(Iterator<T> iterator) |
Modifier and Type | Method and Description |
---|---|
T |
nextRecord(T record)
Reads the next record from the input.
|
boolean |
reachedEnd()
Method used to check if the end of the input is reached.
|
close, configure, createInputSplits, getInputSplitAssigner, getStatistics, open
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public boolean reachedEnd()
InputFormat
When this method is called, the input format it guaranteed to be opened.
reachedEnd
in interface InputFormat<T,GenericInputSplit>
public T nextRecord(T record)
InputFormat
When this method is called, the input format it guaranteed to be opened.
nextRecord
in interface InputFormat<T,GenericInputSplit>
record
- Object that may be reused.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.