org.apache.flink.api.scala

Class HalfUnfinishedKeyPairOperation<L,R,O>

java.lang.Object

org.apache.flink.api.scala.HalfUnfinishedKeyPairOperation<L,R,O>

public class HalfUnfinishedKeyPairOperation<L,R,O>
extends Object

Constructor Summary

Constructors

Constructor and Description
HalfUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> unfinished, Keys<L> leftKey)

Method Summary

Modifier and Type	Method and Description
<K> O	equalTo(scala.Function1<R,K> fun, TypeInformation<K> evidence$2) Specify the key selector function for the right side of the key based operation.
O	equalTo(scala.collection.Seq<Object> rightKeys) Specify the key fields for the right side of the key based operation.
O	equalTo(String firstRightField, scala.collection.Seq<String> otherRightFields) Specify the key fields for the right side of the key based operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

HalfUnfinishedKeyPairOperation

public HalfUnfinishedKeyPairOperation(UnfinishedKeyPairOperation<L,R,O> unfinished,
                                      Keys<L> leftKey)

Method Detail

equalTo

public O equalTo(scala.collection.Seq<Object> rightKeys)

Specify the key fields for the right side of the key based operation. This returns the finished operation.

This only works on a Tuple DataSet.

equalTo

public O equalTo(String firstRightField,
                 scala.collection.Seq<String> otherRightFields)

Specify the key fields for the right side of the key based operation. This returns the finished operation.

equalTo

public <K> O equalTo(scala.Function1<R,K> fun,
                     TypeInformation<K> evidence$2)

Specify the key selector function for the right side of the key based operation. This returns the finished operation.