public void register()

in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java [109:186]
77 lines of code
1 McCabe index (conditional complexity)

    public void register(SinkWriterMetricGroup sinkMetricGroup) {
        totalFlushNumberTotalRows =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, COUNTER_TOTAL_FLUSH_ROWS));
        totalFlushLoadedRows =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                COUNTER_TOTAL_FLUSH_LOADED_ROWS));
        totalFlushLoadBytes =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, COUNTER_TOTAL_FLUSH_BYTES));
        totalFlushFilteredRows =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, COUNTER_TOTAL_FILTERED_ROWS));
        totalFlushUnselectedRows =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                COUNTER_TOTAL_UNSELECTED_ROWS));
        totalFlushSucceededTimes =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                COUNTER_TOTAL_FLUSH_SUCCEEDED_TIMES_COUNT));
        totalFlushFailedTimes =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                COUNTER_TOTAL_FLUSH_FAILED_TIMES_COUNT));
        totalFlushTimeMs =
                sinkMetricGroup.counter(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                COUNTER_TOTAL_FLUSH_COST_TIME));

        loadTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(METRIC_NAME_FORMAT, tableIdentifier, HISTOGRAM_LOAD_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
        streamLoadPutTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                HISTOGRAM_STREAM_LOAD_PUT_DATA_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
        commitAndPublishTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(
                                METRIC_NAME_FORMAT,
                                tableIdentifier,
                                HISTOGRAM_COMMIT_AND_PUBLISH_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
        this.beginTxnTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, HISTOGRAM_BEGIN_TXN_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
        readDataTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, HISTOGRAM_READ_DATA_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
        writeDataTimeHistogramMs =
                sinkMetricGroup.histogram(
                        String.format(
                                METRIC_NAME_FORMAT, tableIdentifier, HISTOGRAM_WRITE_DATA_TIME_MS),
                        new DescriptiveStatisticsHistogram(HISTOGRAM_WINDOW_SIZE));
    }