Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec |
Modifier and Type | Class and Description |
---|---|
static class |
InputProperty.HashDistribution
The input will read the records whose keys hash to a particular hash value.
|
static class |
InputProperty.KeepInputAsIsDistribution
A special distribution which indicators the data distribution is the same as its input.
|
Modifier and Type | Field and Description |
---|---|
static InputProperty.RequiredDistribution |
InputProperty.ANY_DISTRIBUTION
The input does not require any specific data distribution.
|
static InputProperty.RequiredDistribution |
InputProperty.BROADCAST_DISTRIBUTION
The input will read all records for each parallelism of the target node.
|
static InputProperty.RequiredDistribution |
InputProperty.SINGLETON_DISTRIBUTION
The input will read all records, and the parallelism of the target node must be 1.
|
static InputProperty.RequiredDistribution |
InputProperty.UNKNOWN_DISTRIBUTION
Returns a place-holder required distribution.
|
Modifier and Type | Method and Description |
---|---|
InputProperty.RequiredDistribution |
InputProperty.KeepInputAsIsDistribution.getInputDistribution() |
InputProperty.RequiredDistribution |
InputProperty.getRequiredDistribution() |
Modifier and Type | Method and Description |
---|---|
static InputProperty.KeepInputAsIsDistribution |
InputProperty.keepInputAsIsDistribution(InputProperty.RequiredDistribution inputDistribution,
boolean strict)
A special distribution which indicators the data distribution is the same as its input.
|
InputProperty.Builder |
InputProperty.Builder.requiredDistribution(InputProperty.RequiredDistribution requiredDistribution) |
ExecEdge.Builder |
ExecEdge.Builder.requiredDistribution(InputProperty.RequiredDistribution requiredDistribution) |
Constructor and Description |
---|
InputProperty(InputProperty.RequiredDistribution requiredDistribution,
InputProperty.DamBehavior damBehavior,
int priority) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.