org.apache.flink.api.scala

Interface JoinFunctionAssigner<L,R>

All Known Implementing Classes:

JoinDataSet

public interface JoinFunctionAssigner<L,R>

Method Summary

Modifier and Type	Method and Description
<O> DataSet<O>	apply(FlatJoinFunction<L,R,O> fun, TypeInformation<O> evidence$24, scala.reflect.ClassTag<O> evidence$25)
<O> DataSet<O>	apply(scala.Function2<L,R,O> fun, TypeInformation<O> evidence$20, scala.reflect.ClassTag<O> evidence$21)
<O> DataSet<O>	apply(scala.Function3<L,R,Collector<O>,scala.runtime.BoxedUnit> fun, TypeInformation<O> evidence$22, scala.reflect.ClassTag<O> evidence$23)
<O> DataSet<O>	apply(JoinFunction<L,R,O> fun, TypeInformation<O> evidence$26, scala.reflect.ClassTag<O> evidence$27)
<K> JoinFunctionAssigner<L,R>	withPartitioner(Partitioner<K> part, TypeInformation<K> evidence$19)

Method Detail

withPartitioner

<K> JoinFunctionAssigner<L,R> withPartitioner(Partitioner<K> part,
                                              TypeInformation<K> evidence$19)

apply

<O> DataSet<O> apply(scala.Function2<L,R,O> fun,
                     TypeInformation<O> evidence$20,
                     scala.reflect.ClassTag<O> evidence$21)

apply

<O> DataSet<O> apply(scala.Function3<L,R,Collector<O>,scala.runtime.BoxedUnit> fun,
                     TypeInformation<O> evidence$22,
                     scala.reflect.ClassTag<O> evidence$23)

apply

<O> DataSet<O> apply(FlatJoinFunction<L,R,O> fun,
                     TypeInformation<O> evidence$24,
                     scala.reflect.ClassTag<O> evidence$25)

apply

<O> DataSet<O> apply(JoinFunction<L,R,O> fun,
                     TypeInformation<O> evidence$26,
                     scala.reflect.ClassTag<O> evidence$27)