TupleWrappingCollector (Flink : Java 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.api.java.operators.translation.TupleWrappingCollector<IN,K>

All Implemented Interfaces:

Serializable, org.apache.flink.util.Collector<IN>
```
@Internal
public class TupleWrappingCollector<IN,K>
extends Object
implements org.apache.flink.util.Collector<IN>, Serializable
```
Needed to wrap tuples to Tuple2<key, value> pairs for combine method of group reduce with key selector function.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

TupleWrappingCollector(TupleUnwrappingIterator<IN,K> 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.Tuple2<K,IN>> wrappedCollector)`

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

Constructor Detail

TupleWrappingCollector

public TupleWrappingCollector(TupleUnwrappingIterator<IN,K> tui)

Method Detail

set

public void set(org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple2<K,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>