public class ValuesInputFormat extends GenericInputFormat<BaseRow> implements NonParallelInput, ResultTypeQueryable<BaseRow>
partitionNumber
Constructor and Description |
---|
ValuesInputFormat(GeneratedInput<GenericInputFormat<BaseRow>> generatedInput,
BaseRowTypeInfo returnType) |
Modifier and Type | Method and Description |
---|---|
BaseRowTypeInfo |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
BaseRow |
nextRecord(BaseRow 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.
|
close, configure, createInputSplits, getInputSplitAssigner, getStatistics
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public ValuesInputFormat(GeneratedInput<GenericInputFormat<BaseRow>> generatedInput, BaseRowTypeInfo returnType)
public void open(GenericInputSplit split)
InputFormat
When this method is called, the input format it guaranteed to be configured.
open
in interface InputFormat<BaseRow,GenericInputSplit>
open
in class GenericInputFormat<BaseRow>
split
- The split to be opened.public boolean reachedEnd() throws IOException
InputFormat
When this method is called, the input format it guaranteed to be opened.
reachedEnd
in interface InputFormat<BaseRow,GenericInputSplit>
IOException
- Thrown, if an I/O error occurred.public BaseRow nextRecord(BaseRow reuse) throws IOException
InputFormat
When this method is called, the input format it guaranteed to be opened.
nextRecord
in interface InputFormat<BaseRow,GenericInputSplit>
reuse
- Object that may be reused.IOException
- Thrown, if an I/O error occurred.public BaseRowTypeInfo getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<BaseRow>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.