org.apache.flink.streaming.api.datastream

Class JoinedStreams.Where<KEY>

java.lang.Object

org.apache.flink.streaming.api.datastream.JoinedStreams.Where<KEY>

Type Parameters:

KEY - The type of the key.

Enclosing class:

JoinedStreams<T1,T2>

@Public
public class JoinedStreams.Where<KEY>
extends Object

Joined streams that have the key for one side defined.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JoinedStreams.Where.EqualTo A join operation that has KeySelectors defined for both inputs.

Method Summary

Modifier and Type	Method and Description
JoinedStreams.Where.EqualTo	equalTo(KeySelector<T2,KEY> keySelector) Specifies a KeySelector for elements from the second input.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

equalTo

public JoinedStreams.Where.EqualTo equalTo(KeySelector<T2,KEY> keySelector)

Specifies a KeySelector for elements from the second input.