public void createTable()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/catalog/KuduCatalog.java [220:239]

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

    public void createTable(KuduTableInfo tableInfo, boolean ignoreIfExists)
            throws CatalogException, TableAlreadyExistException {
        checkNotNull(tableInfo);

        ObjectPath path = getObjectPath(tableInfo.getName());
        if (tableExists(path)) {
            if (ignoreIfExists) {
                return;
            } else {
                throw new TableAlreadyExistException(getName(), path);
            }
        }

        try {
            kuduClient.createTable(
                    tableInfo.getName(), tableInfo.getSchema(), tableInfo.getCreateTableOptions());
        } catch (KuduException e) {
            throw new CatalogException("Could not create table " + tableInfo.getName(), e);
        }
    }