public class UnfinishedCoGroupOperation<L,R> extends UnfinishedKeyPairOperation<L,R,CoGroupDataSet<L,R>>
DataSet.coGroup
The keys for the left and
right side must be specified using first where
and then equalTo
. For example:
val left = ...
val right = ...
val coGroupResult = left.coGroup(right).where(...).equalTo(...)
Constructor and Description |
---|
UnfinishedCoGroupOperation(DataSet<L> leftInput,
DataSet<R> rightInput,
scala.reflect.ClassTag<L> evidence$1,
scala.reflect.ClassTag<R> evidence$2) |
Modifier and Type | Method and Description |
---|---|
CoGroupDataSet<L,R> |
finish(Keys<L> leftKey,
Keys<R> rightKey) |
leftInput, rightInput, where, where, where
public CoGroupDataSet<L,R> finish(Keys<L> leftKey, Keys<R> rightKey)
finish
in class UnfinishedKeyPairOperation<L,R,CoGroupDataSet<L,R>>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.