Interface | Description |
---|---|
ExecNode<T> |
The representation of execution information for a
FlinkPhysicalRel . |
ExecNodeTranslator<T> | |
MultipleTransformationTranslator<T> |
An
ExecNodeTranslator that will generate ZERO, ONE or more Transformation s. |
SingleTransformationTranslator<T> |
An
ExecNodeTranslator that will generate only ONE Transformation . |
Class | Description |
---|---|
ExecEdge |
The representation of an edge connecting two
ExecNode s. |
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 ExecNode s. |
ExecNodeBase<T> |
Base class for
ExecNode . |
ExecNodeGraph |
The
ExecNodeGraph representing the ExecNode topology. |
ExecNodeGraphGenerator |
A generator that generates a
ExecNode graph from a graph of FlinkPhysicalRel s. |
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.RequiredDistribution |
The required input data distribution for records when they are read in.
|
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.