IN- type of records written to the file
@PublicEvolving public class UpsertTestSink<IN> extends Object implements Sink<IN>
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.
|Modifier and Type||Method and Description|
public static <IN> UpsertTestSinkBuilder<IN> builder()
IN- type of incoming records
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.