public void commit()

in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java [58:65]

• 8 lines of code
• 4 McCabe index (conditional complexity)

    public void commit(List<DorisCommittable> dorisCommittables) {
        if (!dorisOptions.enable2PC() || dorisCommittables.isEmpty()) {
            return;
        }
        for (DorisCommittable dorisCommittable : dorisCommittables) {
            commitTransaction(dorisCommittable);
        }
    }