Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
<O> UnfinishedCoGroupOperation<T,O> |
DataSet.coGroup(DataSet<O> other,
scala.reflect.ClassTag<O> evidence$30)
For each key in
this DataSet and the other DataSet, create a tuple containing a list
of elements for that key from both DataSets. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.