org.apache.flink.streaming.api.datastream

Class CoGroupedStreams.Where.EqualTo

java.lang.Object

org.apache.flink.streaming.api.datastream.CoGroupedStreams.Where.EqualTo

Enclosing class:

CoGroupedStreams.Where<KEY>

@Public
public class CoGroupedStreams.Where.EqualTo
extends Object

A co-group operation that has KeySelectors defined for both inputs.

Method Summary

Modifier and Type	Method and Description
<W extends Window> CoGroupedStreams.WithWindow<T1,T2,KEY,W>	window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the co-group operation works.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

window

@PublicEvolving
public <W extends Window> CoGroupedStreams.WithWindow<T1,T2,KEY,W> window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)

Specifies the window on which the co-group operation works.