org.apache.flink.streaming.api.datastream

Class JoinedStreams.Where.EqualTo

java.lang.Object

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

Enclosing class:

JoinedStreams.Where<KEY>

@Public
public class JoinedStreams.Where.EqualTo
extends Object

A join operation that has KeySelectors defined for both inputs.

Method Summary

Modifier and Type	Method and Description
<W extends Window> JoinedStreams.WithWindow<T1,T2,KEY,W>	window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the join 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> JoinedStreams.WithWindow<T1,T2,KEY,W> window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)

Specifies the window on which the join operation works.