docs: public <K> KeyedStream<T, K> keyBy(KeySelector<T, K> key, TypeInformation<K> keyType) {
  		Preconditions.checkNotNull(key);
  		Preconditions.checkNotNull(keyType);
  		return new KeyedStream<>(this, clean(key), keyType);
  	}