Uses of Class
org.apache.flink.streaming.api.datastream.CoGroupedStreams.TaggedUnion

Packages that use CoGroupedStreams.TaggedUnion

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

Uses of CoGroupedStreams.TaggedUnion in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream that return CoGroupedStreams.TaggedUnion

Modifier and Type	Method and Description
static <T1,T2> CoGroupedStreams.TaggedUnion<T1,T2>	CoGroupedStreams.TaggedUnion.one(T1 one)
static <T1,T2> CoGroupedStreams.TaggedUnion<T1,T2>	CoGroupedStreams.TaggedUnion.two(T2 two)

Method parameters in org.apache.flink.streaming.api.datastream with type arguments of type CoGroupedStreams.TaggedUnion

Modifier and Type	Method and Description
CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.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.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.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.WithWindow.trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger) Sets the Trigger that should be used to trigger window 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> CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the co-group operation works.
<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.

Constructor parameters in org.apache.flink.streaming.api.datastream with type arguments of type CoGroupedStreams.TaggedUnion

Constructor and Description
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, 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)