org.apache.flink.api.java.operators.join

Interface JoinFunctionAssigner<I1,I2>

Type Parameters:

I1 - The type of the first input DataSet of the Join transformation.

I2 - The type of the second input DataSet of the Join transformation.

All Known Implementing Classes:

JoinOperator.DefaultJoin

@Public
public interface JoinFunctionAssigner<I1,I2>

A Join transformation that needs to be finished by specifying either a JoinFunction or a FlatJoinFunction before it can be used as an input to other operators.

Method Summary

Modifier and Type	Method and Description
<R> JoinOperator<I1,I2,R>	with(FlatJoinFunction<I1,I2,R> joinFunction)
<R> JoinOperator<I1,I2,R>	with(JoinFunction<I1,I2,R> joinFunction)

Method Detail

with

<R> JoinOperator<I1,I2,R> with(JoinFunction<I1,I2,R> joinFunction)

with

<R> JoinOperator<I1,I2,R> with(FlatJoinFunction<I1,I2,R> joinFunction)