public static void batchWrite()

in paimon-web-api/src/main/java/org/apache/paimon/web/api/table/TableManager.java [569:598]

25 lines of code
2 McCabe index (conditional complexity)


    public static void batchWrite(
            List<GenericRow> records,
            Catalog catalog,
            String dbName,
            String tableName,
            @Nullable Map<String, String> staticPartition)
            throws Exception {
        checkNotNull(catalog, dbName, tableName);

        BatchWriteBuilder writeBuilder =
                (BatchWriteBuilder)
                        getWriteBuilder(
                                getTable(catalog, dbName, tableName),
                                WriteMode.BATCH.getValue(),
                                staticPartition);

        List<CommitMessage> commitMessages;
        try (BatchTableWrite writer = writeBuilder.newWrite()) {

            for (GenericRow record : records) {
                writer.write(record);
            }

            commitMessages = writer.prepareCommit();
        }

        try (BatchTableCommit commit = writeBuilder.newCommit()) {
            commit.commit(commitMessages);
        }
    }