org.apache.flink.table.runtime.operators.values

Class ValuesInputFormat

java.lang.Object

org.apache.flink.api.common.io.RichInputFormat<OT,GenericInputSplit>

org.apache.flink.api.common.io.GenericInputFormat<RowData>

org.apache.flink.table.runtime.operators.values.ValuesInputFormat

All Implemented Interfaces:

Serializable, InputFormat<RowData,GenericInputSplit>, NonParallelInput, ResultTypeQueryable<RowData>, InputSplitSource<GenericInputSplit>

public class ValuesInputFormat
extends GenericInputFormat<RowData>
implements NonParallelInput, ResultTypeQueryable<RowData>

Generated ValuesInputFormat.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.api.common.io.GenericInputFormat

partitionNumber

Constructor Summary

Constructors

Constructor and Description
ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput, InternalTypeInfo<RowData> returnType)

Method Summary

Modifier and Type	Method and Description
InternalTypeInfo<RowData>	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.
RowData	nextRecord(RowData 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.

Methods inherited from class org.apache.flink.api.common.io.GenericInputFormat

close, configure, createInputSplits, getInputSplitAssigner, getStatistics

Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ValuesInputFormat

public ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput,
                         InternalTypeInfo<RowData> returnType)

Method Detail

open

public void open(GenericInputSplit split)

Description copied from interface: InputFormat

Opens a parallel instance of the input format to work on a split.

When this method is called, the input format it guaranteed to be configured.

Specified by:

open in interface InputFormat<RowData,GenericInputSplit>

Overrides:

open in class GenericInputFormat<RowData>

Parameters:

split - The split to be opened.

reachedEnd

public boolean reachedEnd()
                   throws IOException

Description copied from interface: InputFormat

Method used to check if the end of the input is reached.

When this method is called, the input format it guaranteed to be opened.

Specified by:

reachedEnd in interface InputFormat<RowData,GenericInputSplit>

Returns:

True if the end is reached, otherwise false.

Throws:

IOException - Thrown, if an I/O error occurred.

nextRecord

public RowData nextRecord(RowData reuse)
                   throws IOException

Description copied from interface: InputFormat

Reads the next record from the input.

When this method is called, the input format it guaranteed to be opened.

Specified by:

nextRecord in interface InputFormat<RowData,GenericInputSplit>

Parameters:

reuse - Object that may be reused.

Returns:

Read record.

Throws:

IOException - Thrown, if an I/O error occurred.

getProducedType

public InternalTypeInfo<RowData> getProducedType()

Description copied from interface: ResultTypeQueryable

Gets the data type (as a TypeInformation) produced by this function or input format.

Specified by:

getProducedType in interface ResultTypeQueryable<RowData>

Returns:

The data type produced by this function or input format.