public class JoinedStreams.Where<KEY> extends Object
KeySelector
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 |
JoinedStreams.Where.EqualTo
A join operation that has 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 |
---|---|
JoinedStreams.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 JoinedStreams.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.