Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
Modifier and Type | Method and Description |
---|---|
CoGroupDataSet<L,R> |
UnfinishedCoGroupOperation.finish(Keys<L> leftKey,
Keys<R> rightKey) |
CoGroupDataSet<L,R> |
CoGroupDataSet.sortFirstGroup(int field,
Order order)
Adds a secondary sort key to the first input of this
CoGroupDataSet . |
CoGroupDataSet<L,R> |
CoGroupDataSet.sortFirstGroup(String field,
Order order)
Adds a secondary sort key to the first input of this
CoGroupDataSet . |
CoGroupDataSet<L,R> |
CoGroupDataSet.sortSecondGroup(int field,
Order order)
Adds a secondary sort key to the second input of this
CoGroupDataSet . |
CoGroupDataSet<L,R> |
CoGroupDataSet.sortSecondGroup(String field,
Order order)
Adds a secondary sort key to the second input of this
CoGroupDataSet . |
<K> CoGroupDataSet<L,R> |
CoGroupDataSet.withPartitioner(Partitioner<K> partitioner,
TypeInformation<K> evidence$7) |
Constructor and Description |
---|
OnCoGroupDataSet(CoGroupDataSet<L,R> ds) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.