Class DorisBatchSink.Builder<IN>

  • Type Parameters:
    IN - record type.
    Enclosing class:
    DorisBatchSink<IN>

    public static class DorisBatchSink.Builder<IN>
    extends Object
    build for DorisBatchSink.
    • Constructor Detail

      • Builder

        public Builder()
    • 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)