Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
<R> CoGroupOperator<I1,I2,R> |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.with(CoGroupFunction<I1,I2,R> function)
Finalizes a CoGroup transformation by applying a
RichCoGroupFunction to groups of elements with identical keys.Each CoGroupFunction call returns an arbitrary number of keys. |
CoGroupOperator<I1,I2,OUT> |
CoGroupOperator.withPartitioner(Partitioner<?> partitioner)
Sets a custom partitioner for the CoGroup operation.
|
Constructor and Description |
---|
CoGroupDataSet(CoGroupOperator<L,R,scala.Tuple2<Object,Object>> defaultCoGroup,
DataSet<L> leftInput,
DataSet<R> rightInput,
Keys<L> leftKeys,
Keys<R> rightKeys) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.