public DorisExecutionOptions()

in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java [60:91]

• 30 lines of code
• 1 McCabe index (conditional complexity)

    public DorisExecutionOptions(int checkInterval,
                                 int maxRetries,
                                 int bufferSize,
                                 int bufferCount,
                                 String labelPrefix,
                                 Properties streamLoadProp,
                                 Boolean enableDelete,
                                 Boolean enable2PC,
                                 boolean enableBatchMode,
                                 int flushQueueSize,
                                 int bufferFlushMaxRows,
                                 int bufferFlushMaxBytes,
                                 long bufferFlushIntervalMs,
                                 boolean ignoreUpdateBefore) {
        Preconditions.checkArgument(maxRetries >= 0);
        this.checkInterval = checkInterval;
        this.maxRetries = maxRetries;
        this.bufferSize = bufferSize;
        this.bufferCount = bufferCount;
        this.labelPrefix = labelPrefix;
        this.streamLoadProp = streamLoadProp;
        this.enableDelete = enableDelete;
        this.enable2PC = enable2PC;

        this.enableBatchMode = enableBatchMode;
        this.flushQueueSize = flushQueueSize;
        this.bufferFlushMaxRows = bufferFlushMaxRows;
        this.bufferFlushMaxBytes = bufferFlushMaxBytes;
        this.bufferFlushIntervalMs = bufferFlushIntervalMs;

        this.ignoreUpdateBefore = ignoreUpdateBefore;
    }