public class JoinedStreams.Where.EqualTo.WithWindow<W extends Window> extends Object
KeySelector
s defined for both inputs as
well as a WindowAssigner
.
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) |
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. |
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)
public JoinedStreams.Where.EqualTo.WithWindow<W> trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger)
Trigger
that should be used to trigger window emission.newTrigger
- (undocumented)public JoinedStreams.Where.EqualTo.WithWindow<W> evictor(Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newEvictor)
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.
newEvictor
- (undocumented)public <O> DataStream<O> apply(scala.Function2<T1,T2,O> fun, TypeInformation<O> evidence$2)
fun
- (undocumented)evidence$2
- (undocumented)public <O> DataStream<O> apply(scala.Function3<T1,T2,Collector<O>,scala.runtime.BoxedUnit> fun, TypeInformation<O> evidence$3)
fun
- (undocumented)evidence$3
- (undocumented)public <T> DataStream<T> apply(JoinFunction<T1,T2,T> function, TypeInformation<T> evidence$4)
function
- (undocumented)evidence$4
- (undocumented)public <T> DataStream<T> apply(FlatJoinFunction<T1,T2,T> function, TypeInformation<T> evidence$5)
function
- (undocumented)evidence$5
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.