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 . |
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.RequiredDistribution
The required input data distribution for records when they are read in.
|
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeBase
Base class for
ExecNode . |
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 . |
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 |
---|
ExecEdge
The representation of an edge connecting two
ExecNode s. |
ExecEdge.Shuffle
The
ExecEdge.Shuffle defines how to exchange the records between ExecNode s. |
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeGraph
The
ExecNodeGraph representing the ExecNode topology. |
InputProperty.RequiredDistribution
The required input data distribution for records when they are read in.
|
Class and Description |
---|
ExecNode
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeBase
Base class for
ExecNode . |
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 . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.