public class CoGroupedStreams<T1,T2> extends Object
DataStreams that have been co-grouped. A streaming co-group operation is evaluated over elements in a window.
To finalize the co-group operation you also need to specify a
both the first and second input and a
Note: Right now, the groups are being built in memory so you need to ensure that they don't get too big. Otherwise the JVM might crash.
val one: DataStream[(String, Int)] = ... val two: DataStream[(String, Int)] = ... val result = one.coGroup(two) .where(new MyFirstKeySelector()) .equalTo(new MyFirstKeySelector()) .window(TumblingEventTimeWindows.of(Time.of(5, TimeUnit.SECONDS))) .apply(new MyCoGroupFunction()) }
|Modifier and Type||Class and Description|
A co-group operation that has
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns a "closure-cleaned" version of the given function.
public <KEY> CoGroupedStreams.Where<KEY> where(scala.Function1<T1,KEY> keySelector, TypeInformation<KEY> evidence$1)
KeySelectorfor elements from the first input.
public <F> F clean(F f)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.