Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11039

LogicalExchange and HashPartitioner realization

    Details

      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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                ambition ambition
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: