public class CoGroupedStreams.Where<KEY> extends Object
KeySelector
s defined for the first input.
You need to specify a KeySelector
for the second input using equalTo()
before you can proceeed with specifying a WindowAssigner
using EqualTo.window()
.
Modifier and Type | Class and Description |
---|---|
class |
CoGroupedStreams.Where.EqualTo
A co-group operation that a
KeySelector defined for the first and the second input. |
Constructor and Description |
---|
Where(KeySelector<T1,KEY> keySelector1,
TypeInformation<KEY> keyType) |
Modifier and Type | Method and Description |
---|---|
CoGroupedStreams.Where.EqualTo |
equalTo(scala.Function1<T2,KEY> keySelector)
Specifies a
KeySelector for elements from the second input. |
public Where(KeySelector<T1,KEY> keySelector1, TypeInformation<KEY> keyType)
public CoGroupedStreams.Where.EqualTo equalTo(scala.Function1<T2,KEY> keySelector)
KeySelector
for elements from the second input.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.