org.apache.flink.streaming.api.scala

Class JoinedStreams.Where.EqualTo.WithWindow<W extends Window>

java.lang.Object

org.apache.flink.streaming.api.scala.JoinedStreams.Where.EqualTo.WithWindow<W>

Enclosing class:

JoinedStreams.Where.EqualTo

public class JoinedStreams.Where.EqualTo.WithWindow<W extends Window>
extends Object

A join operation that has KeySelectors defined for both inputs as well as a WindowAssigner.

Constructor Summary

Constructors

Constructor and Description
WithWindow(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor)

Method Summary

Modifier and Type	Method and Description
<T> DataStream<T>	apply(FlatJoinFunction<T1,T2,T> function, TypeInformation<T> evidence$5) Completes the join operation with the user function that is executed for windowed groups.
<O> DataStream<O>	apply(scala.Function2<T1,T2,O> fun, TypeInformation<O> evidence$2) Completes the join operation with the user function that is executed for windowed groups.
<O> DataStream<O>	apply(scala.Function3<T1,T2,Collector<O>,scala.runtime.BoxedUnit> fun, TypeInformation<O> evidence$3) Completes the join operation with the user function that is executed for windowed groups.
<T> DataStream<T>	apply(JoinFunction<T1,T2,T> function, TypeInformation<T> evidence$4) Completes the join operation with the user function that is executed for windowed groups.
JoinedStreams.Where.EqualTo.WithWindow<W>	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.Where.EqualTo.WithWindow<W>	trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger) Sets the Trigger that should be used to trigger window emission.

Methods inherited from class java.lang.Object

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

Constructor Detail

WithWindow

public WithWindow(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner,
                  Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger,
                  Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor)

Method Detail

trigger

public JoinedStreams.Where.EqualTo.WithWindow<W> trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger)

Sets the Trigger that should be used to trigger window emission.

evictor

public JoinedStreams.Where.EqualTo.WithWindow<W> 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.

Note: When using an evictor window performance will degrade significantly, since pre-aggregation of window results cannot be used.

apply

public <O> DataStream<O> apply(scala.Function2<T1,T2,O> fun,
                               TypeInformation<O> evidence$2)

Completes the join operation with the user function that is executed for windowed groups.

apply

public <O> DataStream<O> apply(scala.Function3<T1,T2,Collector<O>,scala.runtime.BoxedUnit> fun,
                               TypeInformation<O> evidence$3)

Completes the join operation with the user function that is executed for windowed groups.

apply

public <T> DataStream<T> apply(JoinFunction<T1,T2,T> function,
                               TypeInformation<T> evidence$4)

Completes the join operation with the user function that is executed for windowed groups.

apply

public <T> DataStream<T> apply(FlatJoinFunction<T1,T2,T> function,
                               TypeInformation<T> evidence$5)

Completes the join operation with the user function that is executed for windowed groups.