Uses of Class
org.apache.flink.connector.upserttest.sink.UpsertTestSinkBuilder

Packages that use UpsertTestSinkBuilder

Package	Description
org.apache.flink.connector.upserttest.sink

Uses of UpsertTestSinkBuilder in org.apache.flink.connector.upserttest.sink

Methods in org.apache.flink.connector.upserttest.sink that return UpsertTestSinkBuilder

Modifier and Type	Method and Description
static <IN> UpsertTestSinkBuilder<IN>	UpsertTestSink.builder() Create a UpsertTestSinkBuilder to construct a new UpsertTestSink.
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setKeySerializationSchema(SerializationSchema<IN> keySerializationSchema) Sets the key SerializationSchema that transforms incoming records to byte[].
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setOutputFile(File outputFile) Sets the output File to write to.
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setValueSerializationSchema(SerializationSchema<IN> valueSerializationSchema) Sets the value SerializationSchema that transforms incoming records to byte[].