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