Uses of Class
org.apache.flink.streaming.api.scala.KeyedStream

Packages that use KeyedStream

Package	Description
org.apache.flink.streaming.api.scala

Uses of KeyedStream in org.apache.flink.streaming.api.scala

Methods in org.apache.flink.streaming.api.scala that return KeyedStream

Modifier and Type	Method and Description
<K> KeyedStream<T,K>	DataStream.keyBy(scala.Function1<T,K> fun, TypeInformation<K> evidence$1) Groups the elements of a DataStream by the given K key to be used with grouped operators like grouped reduce or grouped aggregations.
KeyedStream<T,Tuple>	DataStream.keyBy(scala.collection.Seq<Object> fields) Groups the elements of a DataStream by the given key positions (for tuple/array types) to be used with grouped operators like grouped reduce or grouped aggregations.
KeyedStream<T,Tuple>	DataStream.keyBy(String firstField, scala.collection.Seq<String> otherFields) Groups the elements of a DataStream by the given field expressions to be used with grouped operators like grouped reduce or grouped aggregations.