Package org.apache.flink.table.planner.plan.nodes.exec.stream

Class StreamExecValues

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase<RowData>

org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecValues

org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecValues

All Implemented Interfaces:

ExecNode<RowData>, ExecNodeTranslator<RowData>, FusionCodegenExecNode, SingleTransformationTranslator<RowData>, StreamExecNode<RowData>

@ExecNodeMetadata(name="stream-exec-values",
                  version=1,
                  producedTransformations="values",
                  minPlanVersion=v1_15,
                  minStateVersion=v1_15)
public class StreamExecValues
extends CommonExecValues
implements StreamExecNode<RowData>

Stream ExecNode that read records from given values.

Field Summary

Fields inherited from class org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecValues

FIELD_NAME_TUPLES, VALUES_TRANSFORMATION

Fields inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE

Constructor Summary

Constructors

Constructor	Description
StreamExecValues(int id, ExecNodeContext context, ReadableConfig persistedConfig, List<List<org.apache.calcite.rex.RexLiteral>> tuples, RowType outputType, String description)
StreamExecValues(ReadableConfig tableConfig, List<List<org.apache.calcite.rex.RexLiteral>> tuples, RowType outputType, String description)

Method Summary

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecValues

getTuples, translateToPlanInternal

Methods inherited from class org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase

accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, supportFusionCodegen, translateToFusionCodegenSpec, translateToFusionCodegenSpecInternal, translateToPlan

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNode

accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.ExecNodeTranslator

translateToPlan

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.exec.FusionCodegenExecNode

supportFusionCodegen, translateToFusionCodegenSpec

Constructor Detail

StreamExecValues

public StreamExecValues(ReadableConfig tableConfig,
                        List<List<org.apache.calcite.rex.RexLiteral>> tuples,
                        RowType outputType,
                        String description)

StreamExecValues

public StreamExecValues(int id,
                        ExecNodeContext context,
                        ReadableConfig persistedConfig,
                        List<List<org.apache.calcite.rex.RexLiteral>> tuples,
                        RowType outputType,
                        String description)