public static interface FlinkMetadata.FlinkDistribution
extends org.apache.calcite.rel.metadata.Metadata
If you are an operator consuming a relational expression, which subset of the rows are you seeing? You might be seeing all of them (BROADCAST or SINGLETON), only those whose key column values have a particular hash code (HASH) or only those whose column values have particular values or ranges of values (RANGE).
When a relational expression is partitioned, it is often partitioned among nodes, but it may be partitioned among threads running on the same node.
Modifier and Type | Interface and Description |
---|---|
static interface |
FlinkMetadata.FlinkDistribution.Handler
Handler API.
|
Modifier and Type | Field and Description |
---|---|
static org.apache.calcite.rel.metadata.MetadataDef<FlinkMetadata.FlinkDistribution> |
DEF |
static Method |
METHOD |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.planner.plan.trait.FlinkRelDistribution |
flinkDistribution()
Determines how the rows are distributed.
|
static final Method METHOD
static final org.apache.calcite.rel.metadata.MetadataDef<FlinkMetadata.FlinkDistribution> DEF
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.