Package | Description |
---|---|
org.apache.flink.api.java.operators |
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. |
CoGroupOperator<I1,I2,OUT> |
CoGroupOperator.withPartitioner(Partitioner<?> partitioner)
Sets a custom partitioner for the CoGroup operation.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.