Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec |
Modifier and Type | Method and Description |
---|---|
static ExecEdge.RequiredShuffle |
ExecEdge.RequiredShuffle.any()
Returns a
ExecEdge.RequiredShuffle which does not require any specific shuffle type. |
static ExecEdge.RequiredShuffle |
ExecEdge.RequiredShuffle.broadcast()
Returns a required broadcast shuffle type.
|
ExecEdge.RequiredShuffle |
ExecEdge.getRequiredShuffle() |
static ExecEdge.RequiredShuffle |
ExecEdge.RequiredShuffle.hash(int[] keys)
Returns a required hash shuffle type.
|
static ExecEdge.RequiredShuffle |
ExecEdge.RequiredShuffle.singleton()
Returns a required singleton shuffle type.
|
static ExecEdge.RequiredShuffle |
ExecEdge.RequiredShuffle.unknown()
Returns a place-holder required shuffle type.
|
Modifier and Type | Method and Description |
---|---|
ExecEdge.Builder |
ExecEdge.Builder.requiredShuffle(ExecEdge.RequiredShuffle requiredShuffle) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.