public class CoGroupedStreams.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 |
CoGroupedStreams.Where.EqualTo.WithWindow<W extends Window>
A co-group 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 co-group operation works.
|
public EqualTo(KeySelector<T2,KEY> keySelector2)
public <W extends Window> CoGroupedStreams.Where.EqualTo.WithWindow<W> window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.