Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec | |
org.apache.flink.table.planner.plan.nodes.exec.serde |
Modifier and Type | Class and Description |
---|---|
static class |
InputProperty.HashDistribution
The input will read the records whose keys hash to a particular hash value.
|
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.getRequiredDistribution() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
InputProperty.RequiredDistribution |
RequiredDistributionJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
RequiredDistributionJsonSerializer.serialize(InputProperty.RequiredDistribution requiredDistribution,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider serializerProvider) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.