public class CRowValuesInputFormat extends GenericInputFormat<CRow> implements NonParallelInput, ResultTypeQueryable<CRow>, Compiler<GenericInputFormat<Row>>, Logging
partitionNumber
Constructor and Description |
---|
CRowValuesInputFormat(String name,
String code,
TypeInformation<CRow> returnType) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<CRow> |
getProducedType()
Gets the data type (as a
TypeInformation ) produced by this function or input format. |
CRow |
nextRecord(CRow 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<CRow> |
returnType() |
close, configure, createInputSplits, getInputSplitAssigner, getStatistics
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public CRowValuesInputFormat(String name, String code, TypeInformation<CRow> returnType)
public TypeInformation<CRow> returnType()
public void open(GenericInputSplit split)
InputFormat
When this method is called, the input format it guaranteed to be configured.
open
in interface InputFormat<CRow,GenericInputSplit>
open
in class GenericInputFormat<CRow>
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<CRow,GenericInputSplit>
public CRow nextRecord(CRow reuse)
InputFormat
When this method is called, the input format it guaranteed to be opened.
nextRecord
in interface InputFormat<CRow,GenericInputSplit>
reuse
- Object that may be reused.public TypeInformation<CRow> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<CRow>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.