Package | Description |
---|---|
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.scala.extensions.impl.acceptPartialFunctions |
Modifier and Type | Method and Description |
---|---|
<K> KeyedStream<T,K> |
DataStream.keyBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$2)
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.
|
Modifier and Type | Method and Description |
---|---|
<K> KeyedStream<T,K> |
OnDataStream.keyingBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$3)
Keys the items according to a keying function
fun |
Constructor and Description |
---|
OnKeyedStream(KeyedStream<T,K> stream) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.