UpsertTestSink (Flink : Test utils : Utils 2.2.0 API)

java.lang.Object
- org.apache.flink.connector.upserttest.sink.UpsertTestSink<IN>

Type Parameters:

IN - type of records written to the file

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.sink2.Sink<IN>
```
@PublicEvolving
public class UpsertTestSink<IN>
extends Object
implements org.apache.flink.api.connector.sink2.Sink<IN>
```
Flink Sink to upsert test data into a file. This Sink is intended for testing internal functionality and is **not** production-ready.
Please note that the UpsertTestSink needs to run with a parallelism of 1 to function correctly. There is currently no support for using multiple writers at once.

See Also:

on how to construct an UpsertTestSink, Serialized Form

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <IN> UpsertTestSinkBuilder<IN>`	`builder()`	Create a `UpsertTestSinkBuilder` to construct a new `UpsertTestSink`.
`org.apache.flink.api.connector.sink2.SinkWriter<IN>`	`createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)`

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

- Method Detail
  - builder
```
public static <IN> UpsertTestSinkBuilder<IN> builder()
```
    Create a UpsertTestSinkBuilder to construct a new UpsertTestSink.
    
    Type Parameters:
    
    IN - type of incoming records
    
    Returns:
    
    UpsertTestSinkBuilder
  - createWriter
```
@Internal
public org.apache.flink.api.connector.sink2.SinkWriter<IN> createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)
```
    Specified by:
    
    createWriter in interface org.apache.flink.api.connector.sink2.Sink<IN>