RichCombineToGroupCombineWrapper (Flink : Java 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,IN>
  - - org.apache.flink.api.java.operators.translation.RichCombineToGroupCombineWrapper<IN,OUT,F>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.GroupCombineFunction<IN,IN>, org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>, org.apache.flink.api.common.functions.RichFunction
```
public class RichCombineToGroupCombineWrapper<IN,OUT,F extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> & org.apache.flink.api.common.functions.CombineFunction<IN,IN>>
extends org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,IN>
implements org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>
```
A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

RichCombineToGroupCombineWrapper(F wrappedFunction)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`combine(Iterable<IN> values, org.apache.flink.util.Collector<IN> out)`
`void`	`open(org.apache.flink.configuration.Configuration config)`
`void`	`reduce(Iterable<IN> values, org.apache.flink.util.Collector<OUT> out)`

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RichCombineToGroupCombineWrapper
```
public RichCombineToGroupCombineWrapper(F wrappedFunction)
```
- Method Detail
  - open
```
public void open(org.apache.flink.configuration.Configuration config)
          throws Exception
```
    Specified by:
    
    open in interface org.apache.flink.api.common.functions.RichFunction
    
    Overrides:
    
    open in class org.apache.flink.api.common.functions.AbstractRichFunction
    
    Throws:
    
    Exception
  - combine
```
public void combine(Iterable<IN> values,
                    org.apache.flink.util.Collector<IN> out)
             throws Exception
```
    Specified by:
    
    combine in interface org.apache.flink.api.common.functions.GroupCombineFunction<IN,OUT>
    
    Specified by:
    
    combine in class org.apache.flink.api.common.functions.RichGroupCombineFunction<IN,IN>
    
    Throws:
    
    Exception
  - reduce
```
public void reduce(Iterable<IN> values,
                   org.apache.flink.util.Collector<OUT> out)
            throws Exception
```
    Specified by:
    
    reduce in interface org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>
    
    Throws:
    
    Exception