diff --git a/docs/dev/stream/operators/index.md b/docs/dev/stream/operators/index.md index b0325ca46e3f7..aaf3646053143 100644 --- a/docs/dev/stream/operators/index.md +++ b/docs/dev/stream/operators/index.md @@ -100,9 +100,9 @@ dataStream.filter(new FilterFunction() { KeyBy
DataStream → KeyedStream -

Logically partitions a stream into disjoint partitions, each partition containing elements of the same key. - Internally, this is implemented with hash partitioning. See keys on how to specify keys. - This transformation returns a KeyedStream.

+

Logically partitions a stream into disjoint partitions. All records with the same key are assigned to the same partition. Internally, keyBy() is implemented with hash partitioning. There are different ways to specify keys.

+

+ This transformation returns a KeyedStream, which is, among other things, required to use keyed state.

{% highlight java %} dataStream.keyBy("someKey") // Key by field "someKey" dataStream.keyBy(0) // Key by the first element of a Tuple