public class OnCoGroupDataSet<L,R> extends Object
param: ds The wrapped co-group data set
Constructor and Description |
---|
OnCoGroupDataSet(CoGroupDataSet<L,R> ds) |
Modifier and Type | Method and Description |
---|---|
<O> DataSet<O> |
projecting(scala.Function2<scala.collection.immutable.Stream<L>,scala.collection.immutable.Stream<R>,O> fun,
TypeInformation<O> evidence$1,
scala.reflect.ClassTag<O> evidence$2)
Co-groups the data sets using the function
fun to project elements from both in
the resulting data set |
public OnCoGroupDataSet(CoGroupDataSet<L,R> ds)
public <O> DataSet<O> projecting(scala.Function2<scala.collection.immutable.Stream<L>,scala.collection.immutable.Stream<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 co-group operationevidence$1
- (undocumented)evidence$2
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.