[FLINK-11039] LogicalExchange and HashPartitioner realization

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.6.2, 1.7.0
• Fix Version/s: 1.7.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: ambition
• Created: 30/Nov/18 10:33
• Updated: 11/Dec/18 05:39
• Resolved: 11/Dec/18 05:39

Description

RelTimeIndicatorConverter.visit(exchange: LogicalExchange) function realization.

FlinkLogicalExchange realization org.apache.calcite.rel.logical.LogicalExchange.

HashPartitioner is Partitioner that implements hash-based partitioning using Java's `Object.hashCode`. support org.apache.calcite.rel.RelDistribution.Type HASH_DISTRIBUTED

Issue Links

• links to: GitHub Pull Request #7202