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

Interface Summary

Interface	Description
ExecNode<T>	The representation of execution information for a FlinkPhysicalRel.
ExecNodeTranslator<T>	An ExecNodeTranslator is responsible for translating an ExecNode to Transformations.
FusionCodegenExecNode	A ExecNode which support operator fusion codegen.
MultipleTransformationTranslator<T>	An ExecNodeTranslator that will generate ZERO, ONE or more Transformations.
SingleTransformationTranslator<T>	An ExecNodeTranslator that will generate only ONE Transformation.

Class Summary

Class	Description
ExecEdge	The representation of an edge connecting two ExecNodes.
ExecEdge.Builder	Builder of the ExecEdge.
ExecEdge.HashShuffle	Records are shuffled by hash when passing through this edge.
ExecEdge.Shuffle	The ExecEdge.Shuffle defines how to exchange the records between ExecNodes.
ExecNodeBase<T>	Base class for ExecNode.
ExecNodeConfig	Configuration view which is used combine the PlannerBase.getTableConfig() with the ExecNodeBase.getPersistedConfig() configuration.
ExecNodeContext	Helper class that holds the necessary identifier fields that are used for JSON plan serialization and deserialization.
ExecNodeGraph	The ExecNodeGraph representing the ExecNode topology.
ExecNodeGraphGenerator	A generator that generates a ExecNode graph from a graph of FlinkPhysicalRels.
ExecNodeGraphValidator	This class validates the ExecNodeGraph.
InputProperty	The InputProperty describes the input information of the ExecNode.
InputProperty.Builder	Builder of the InputProperty.
InputProperty.HashDistribution	The input will read the records whose keys hash to a particular hash value.
InputProperty.KeepInputAsIsDistribution	A special distribution which indicators the data distribution is the same as its input. ' TODO This class can be removed once FLINK-21224 is finished.
InputProperty.RequiredDistribution	The required input data distribution for records when they are read in.
StateMetadata	It is used to describe the state metadata of a stateful operator, which is serialized/deserialized into/from those StreamExecNodes that can generate stateful operators.

Enum Summary

Enum	Description
ExecEdge.Shuffle.Type	Enumeration which describes the shuffle type for records when passing this edge.
InputProperty.DamBehavior	Enumeration which describes how an input record may trigger the output behavior of the target ExecNode.
InputProperty.DistributionType	Enumeration which describes the type of the input data distribution.

Annotation Types Summary

Annotation Type	Description
ExecNodeMetadata	Annotation to be used for ExecNodes to keep necessary metadata when serializing/deserializing them in a plan.
MultipleExecNodeMetadata	Helper annotation to enable multiple ExecNodeMetadata annotations on an ExecNode class.