org.apache.flink.api.scala

Class UnfinishedJoinOperationBase<L,R,O extends JoinFunctionAssigner<L,R>>

java.lang.Object

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

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

Direct Known Subclasses:

UnfinishedJoinOperation, UnfinishedOuterJoinOperation

public abstract class UnfinishedJoinOperationBase<L,R,O extends JoinFunctionAssigner<L,R>>
extends UnfinishedKeyPairOperation<L,R,O>

Constructor Summary

Constructors

Constructor and Description
UnfinishedJoinOperationBase(DataSet<L> leftSet, DataSet<R> rightSet, JoinOperatorBase.JoinHint joinHint, JoinType joinType)

Method Summary

Modifier and Type	Method and Description
JoinDataSet<L,R>	createDefaultJoin(Keys<L> leftKey, Keys<R> rightKey)
abstract O	createJoinFunctionAssigner(Keys<L> leftKey, Keys<R> rightKey)
O	finish(Keys<L> leftKey, Keys<R> rightKey)
JoinOperatorBase.JoinHint	joinHint()
JoinType	joinType()

Methods inherited from class org.apache.flink.api.scala.UnfinishedKeyPairOperation

leftInput, rightInput, where, where, where

Methods inherited from class java.lang.Object

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

Constructor Detail

UnfinishedJoinOperationBase

public UnfinishedJoinOperationBase(DataSet<L> leftSet,
                                   DataSet<R> rightSet,
                                   JoinOperatorBase.JoinHint joinHint,
                                   JoinType joinType)

Method Detail

joinHint

public JoinOperatorBase.JoinHint joinHint()

joinType

public JoinType joinType()

createJoinFunctionAssigner

public abstract O createJoinFunctionAssigner(Keys<L> leftKey,
                                             Keys<R> rightKey)

createDefaultJoin

public JoinDataSet<L,R> createDefaultJoin(Keys<L> leftKey,
                                          Keys<R> rightKey)

finish

public O finish(Keys<L> leftKey,
                Keys<R> rightKey)

Specified by:

finish in class UnfinishedKeyPairOperation<L,R,O extends JoinFunctionAssigner<L,R>>