Tuple3WrappingCollector (Flink : Java 1.20.1-cp2 API)

java.lang.Object
- org.apache.flink.api.java.operators.translation.Tuple3WrappingCollector<IN,K1,K2>

All Implemented Interfaces:

Serializable, org.apache.flink.util.Collector<IN>
```
@Internal
public class Tuple3WrappingCollector<IN,K1,K2>
extends Object
implements org.apache.flink.util.Collector<IN>, Serializable
```
Needed to wrap tuples to Tuple3<groupKey, sortKey, value> for combine method of group reduce with key selector sorting.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

Tuple3WrappingCollector(Tuple3UnwrappingIterator<IN,K1,K2> tui)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`void`	`collect(IN record)`
`void`	`set(org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple3<K1,K2,IN>> wrappedCollector)`

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

Constructor Detail

Tuple3WrappingCollector

public Tuple3WrappingCollector(Tuple3UnwrappingIterator<IN,K1,K2> tui)

Method Detail

set

public void set(org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple3<K1,K2,IN>> wrappedCollector)

close
```
public void close()
```
Specified by:

close in interface org.apache.flink.util.Collector<IN>

collect
```
public void collect(IN record)
```
Specified by:

collect in interface org.apache.flink.util.Collector<IN>