public class OnCrossDataSet<L,R> extends Object
param: ds The wrapped cross data set
Constructor and Description |
---|
OnCrossDataSet(CrossDataSet<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)
Starting from a cross data set, uses the function
fun to project elements from
both the input data sets in the resulting data set |
public OnCrossDataSet(CrossDataSet<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 the input data sets in the resulting data set
fun
- The function that defines the projection of the joinevidence$1
- (undocumented)evidence$2
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.