public class ValuesInputFormat extends GenericInputFormat<Row> implements NonParallelInput, ResultTypeQueryable<Row>, Compiler<GenericInputFormat<Row>>, Logging
partitionNumber
Constructor and Description |
---|
ValuesInputFormat(String name,
String code,
TypeInformation<Row> returnType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
Row |
nextRecord(Row reuse)
Reads the next record from the input.
|
void |
open(GenericInputSplit split)
Opens a parallel instance of the input format to work on a split.
|
boolean |
reachedEnd()
Method used to check if the end of the input is reached.
|
TypeInformation<Row> |
returnType() |
close, configure, createInputSplits, getInputSplitAssigner, getStatistics
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public ValuesInputFormat(String name, String code, TypeInformation<Row> returnType)
public TypeInformation<Row> returnType()
public void open(GenericInputSplit split)
InputFormat
When this method is called, the input format it guaranteed to be configured.
open
in interface InputFormat<Row,GenericInputSplit>
open
in class GenericInputFormat<Row>
split
- The split to be opened.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.public TypeInformation<Row> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<Row>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.