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

Packages that use KeyedStream

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

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

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

Modifier and Type	Method and Description
KeyedStream<T,Tuple>	DataStream.keyBy(int... fields) Partitions the operator state of a DataStream by the given key positions.
<K> KeyedStream<T,K>	DataStream.keyBy(KeySelector<T,K> key) It creates a new KeyedStream that uses the provided key for partitioning its operator states.
KeyedStream<T,Tuple>	DataStream.keyBy(String... fields) Partitions the operator state of a DataStream using field expressions.
static <T,K> KeyedStream<T,K>	DataStreamUtils.reinterpretAsKeyedStream(DataStream<T> stream, KeySelector<T,K> keySelector) Reinterprets the given DataStream as a KeyedStream, which extracts keys with the given KeySelector.
static <T,K> KeyedStream<T,K>	DataStreamUtils.reinterpretAsKeyedStream(DataStream<T> stream, KeySelector<T,K> keySelector, TypeInformation<K> typeInfo) Reinterprets the given DataStream as a KeyedStream, which extracts keys with the given KeySelector.

Constructors in org.apache.flink.streaming.api.datastream with parameters of type KeyedStream

Constructor and Description
WindowedStream(KeyedStream<T,K> input, WindowAssigner<? super T,W> windowAssigner)