Uses of Class
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow

Packages that use JoinedStreams.WithWindow

Package	Description
org.apache.flink.streaming.api.datastream

Uses of JoinedStreams.WithWindow in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream that return JoinedStreams.WithWindow

Modifier and Type	Method and Description
JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.WithWindow.allowedLateness(Time newLateness) Sets the time by which elements are allowed to be late.
JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.WithWindow.evictor(Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newEvictor) Sets the Evictor that should be used to evict elements from a window before emission.
JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.WithWindow.trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger) Sets the Trigger that should be used to trigger window emission.
<W extends Window> JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the join operation works.