public class JoinedStreams.Where.EqualTo extends Object
KeySelector
defined for the first and the second input.
A window can now be specified using window()
.
Modifier and Type | Class and Description |
---|---|
class |
JoinedStreams.Where.EqualTo.WithWindow<W extends Window>
A join operation that has
KeySelector s defined for both inputs as
well as a WindowAssigner . |
Constructor and Description |
---|
EqualTo(KeySelector<T2,KEY> keySelector2) |
Modifier and Type | Method and Description |
---|---|
<W extends Window> |
window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
Specifies the window on which the join operation works.
|
public EqualTo(KeySelector<T2,KEY> keySelector2)
public <W extends Window> JoinedStreams.Where.EqualTo.WithWindow<W> window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
assigner
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.