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	Description
static <IN> UpsertTestSinkBuilder<IN>	UpsertTestSink.builder()	Create a UpsertTestSinkBuilder to construct a new UpsertTestSink.
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setKeySerializationSchema(org.apache.flink.api.common.serialization.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(org.apache.flink.api.common.serialization.SerializationSchema<IN> valueSerializationSchema)	Sets the value SerializationSchema that transforms incoming records to byte[].