public class OnJoinFunctionAssigner<L,R> extends Object
Constructor and Description |
---|
OnJoinFunctionAssigner(JoinFunctionAssigner<L,R> ds) |
Modifier and Type | Method and Description |
---|---|
<O> DataSet<O> |
projecting(scala.Function2<L,R,O> fun,
TypeInformation<O> evidence$1,
scala.reflect.ClassTag<O> evidence$2)
Joins the data sets using the function
fun to project elements from both in the
resulting data set |
public OnJoinFunctionAssigner(JoinFunctionAssigner<L,R> ds)
public <O> DataSet<O> projecting(scala.Function2<L,R,O> fun, TypeInformation<O> evidence$1, scala.reflect.ClassTag<O> evidence$2)
fun
to project elements from both in the
resulting data set
fun
- The function that defines the projection of the joinCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.