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

Class ValuesInputFormat

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,org.apache.flink.core.io.GenericInputSplit>, org.apache.flink.api.common.io.NonParallelInput, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.io.GenericInputSplit>, org.apache.flink.streaming.api.lineage.LineageVertexProvider

public class ValuesInputFormat
extends org.apache.flink.api.common.io.GenericInputFormat<org.apache.flink.table.data.RowData>
implements org.apache.flink.api.common.io.NonParallelInput, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.lineage.LineageVertexProvider

Generated ValuesInputFormat.

See Also:

Serialized Form

Field Summary

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

partitionNumber

Constructor Summary

Constructors

Constructor	Description
ValuesInputFormat(GeneratedInput<org.apache.flink.api.common.io.GenericInputFormat<org.apache.flink.table.data.RowData>> generatedInput, InternalTypeInfo<org.apache.flink.table.data.RowData> returnType)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.streaming.api.lineage.LineageVertex	getLineageVertex()
InternalTypeInfo<org.apache.flink.table.data.RowData>	getProducedType()
org.apache.flink.table.data.RowData	nextRecord(org.apache.flink.table.data.RowData reuse)
void	open(org.apache.flink.core.io.GenericInputSplit split)
boolean	reachedEnd()

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<org.apache.flink.api.common.io.GenericInputFormat<org.apache.flink.table.data.RowData>> generatedInput,
                         InternalTypeInfo<org.apache.flink.table.data.RowData> returnType)

Method Detail

open

public void open(org.apache.flink.core.io.GenericInputSplit split)

Specified by:

open in interface org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,org.apache.flink.core.io.GenericInputSplit>

Overrides:

open in class org.apache.flink.api.common.io.GenericInputFormat<org.apache.flink.table.data.RowData>

reachedEnd

public boolean reachedEnd()
                   throws IOException

Specified by:

reachedEnd in interface org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,org.apache.flink.core.io.GenericInputSplit>

Throws:

IOException

nextRecord

public org.apache.flink.table.data.RowData nextRecord(org.apache.flink.table.data.RowData reuse)
                                               throws IOException

Specified by:

nextRecord in interface org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,org.apache.flink.core.io.GenericInputSplit>

Throws:

IOException

getProducedType

public InternalTypeInfo<org.apache.flink.table.data.RowData> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>

getLineageVertex

public org.apache.flink.streaming.api.lineage.LineageVertex getLineageVertex()

Specified by:

getLineageVertex in interface org.apache.flink.streaming.api.lineage.LineageVertexProvider