Class DorisBatchSink.Builder<IN>
- java.lang.Object
-
- org.apache.doris.flink.sink.batch.DorisBatchSink.Builder<IN>
-
- Type Parameters:
IN- record type.
- Enclosing class:
- DorisBatchSink<IN>
public static class DorisBatchSink.Builder<IN> extends Object
build for DorisBatchSink.
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DorisBatchSink<IN>build()DorisBatchSink.Builder<IN>setDorisExecutionOptions(org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions)DorisBatchSink.Builder<IN>setDorisOptions(org.apache.doris.flink.cfg.DorisOptions dorisOptions)DorisBatchSink.Builder<IN>setDorisReadOptions(org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions)DorisBatchSink.Builder<IN>setSerializer(org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer<IN> serializer)
-
-
-
Method Detail
-
setDorisOptions
public DorisBatchSink.Builder<IN> setDorisOptions(org.apache.doris.flink.cfg.DorisOptions dorisOptions)
-
setDorisReadOptions
public DorisBatchSink.Builder<IN> setDorisReadOptions(org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions)
-
setDorisExecutionOptions
public DorisBatchSink.Builder<IN> setDorisExecutionOptions(org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions)
-
setSerializer
public DorisBatchSink.Builder<IN> setSerializer(org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer<IN> serializer)
-
build
public DorisBatchSink<IN> build()
-
-