Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.scala |
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. |
Constructor and Description |
---|
WindowedStream(KeyedStream<T,K> input,
WindowAssigner<? super T,W> windowAssigner) |
Constructor and Description |
---|
KeyedStream(KeyedStream<T,K> javaStream) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.