Flink StreamPartitioner ChannelSelector

[2pc]

keyby

  public <K> KeyedStream<T, K> keyBy(KeySelector<T, K> key) {
      Preconditions.checkNotNull(key);
      return new KeyedStream<>(this, clean(key));
  }
  public KeyedStream(
          DataStream<T> dataStream,
          KeySelector<T, KEY> keySelector,
          TypeInformation<KEY> keyType) {
      this(
              dataStream,
              new PartitionTransformation<>(
                      dataStream.getTransformation(),
                      new KeyGroupStreamPartitioner<>(
                              keySelector,
                              StreamGraphGenerator.DEFAULT_LOWER_BOUND_MAX_PARALLELISM)),
              keySelector,
              keyType);
  }

shuffle

  public DataStream<T> shuffle() {
      return setConnectionType(new ShufflePartitioner<T>());
  }