org.apache.flink.streaming.api.scala

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

java.lang.Object

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

Enclosing class:

CoGroupedStreams.Where.EqualTo

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

A co-group 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(CoGroupFunction<T1,T2,T> function, TypeInformation<T> evidence$4) Completes the co-group operation with the user function that is executed for windowed groups.
<O> DataStream<O>	apply(scala.Function2<scala.collection.Iterator<T1>,scala.collection.Iterator<T2>,O> fun, TypeInformation<O> evidence$2) Completes the co-group operation with the user function that is executed for windowed groups.
<O> DataStream<O>	apply(scala.Function3<scala.collection.Iterator<T1>,scala.collection.Iterator<T2>,Collector<O>,scala.runtime.BoxedUnit> fun, TypeInformation<O> evidence$3) Completes the co-group operation with the user function that is executed for windowed groups.
CoGroupedStreams.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.
CoGroupedStreams.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 CoGroupedStreams.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 CoGroupedStreams.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<scala.collection.Iterator<T1>,scala.collection.Iterator<T2>,O> fun,
                               TypeInformation<O> evidence$2)

Completes the co-group operation with the user function that is executed for windowed groups.

apply

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

Completes the co-group operation with the user function that is executed for windowed groups.

apply

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

Completes the co-group operation with the user function that is executed for windowed groups.