Class and Description |
---|
ExecNodeGraph
The
ExecNodeGraph representing the ExecNode topology. |
Class and Description |
---|
ExecEdge
The representation of an edge connecting two
ExecNode s. |
ExecEdge.Builder
Builder of the
ExecEdge . |
ExecEdge.Shuffle
The
ExecEdge.Shuffle defines how to exchange the records between ExecNode s. |
ExecEdge.Shuffle.Type
Enumeration which describes the shuffle type for records when passing this edge.
|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
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. |
ExecNodeTranslator |
InputProperty
The
InputProperty describes the input information of the ExecNode . |
InputProperty.Builder
Builder of the
InputProperty . |
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.
|
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.
|
InputProperty.RequiredDistribution
The required input data distribution for records when they are read in.
|
Class and Description |
---|
ExecEdge
The representation of an edge connecting two
ExecNode s. |
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeBase
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.
|
ExecNodeTranslator |
InputProperty
The
InputProperty describes the input information of the ExecNode . |
MultipleTransformationTranslator
An
ExecNodeTranslator that will generate ZERO, ONE or more Transformation s. |
SingleTransformationTranslator
An
ExecNodeTranslator that will generate only ONE Transformation . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeBase
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.
|
ExecNodeTranslator |
InputProperty
The
InputProperty describes the input information of the ExecNode . |
MultipleTransformationTranslator
An
ExecNodeTranslator that will generate ZERO, ONE or more Transformation s. |
SingleTransformationTranslator
An
ExecNodeTranslator that will generate only ONE Transformation . |
Class and Description |
---|
ExecNodeGraph
The
ExecNodeGraph representing the ExecNode topology. |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
InputProperty.DamBehavior
Enumeration which describes how an input record may trigger the output behavior of the target
ExecNode . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeBase
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.
|
ExecNodeMetadata
Annotation to be used for
ExecNode s to keep necessary metadata when
serializing/deserializing them in a plan. |
ExecNodeTranslator |
InputProperty
The
InputProperty describes the input information of the ExecNode . |
MultipleTransformationTranslator
An
ExecNodeTranslator that will generate ZERO, ONE or more Transformation s. |
SingleTransformationTranslator
An
ExecNodeTranslator that will generate only ONE Transformation . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeGraph
The
ExecNodeGraph representing the ExecNode topology. |
InputProperty
The
InputProperty describes the input information of the ExecNode . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeConfig
Configuration view which is used combine the
PlannerBase.getTableConfig() with the ExecNodeBase.getPersistedConfig() configuration. |
ExecNodeMetadata
Annotation to be used for
ExecNode s to keep necessary metadata when
serializing/deserializing them in a plan. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.