private KuduTable obtainTable()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/reader/KuduReader.java [105:115]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    private KuduTable obtainTable() throws IOException {
        String tableName = tableInfo.getName();
        if (client.tableExists(tableName)) {
            return client.openTable(tableName);
        }
        if (tableInfo.getCreateTableIfNotExists()) {
            return client.createTable(
                    tableName, tableInfo.getSchema(), tableInfo.getCreateTableOptions());
        }
        throw new RuntimeException("Table " + tableName + " does not exist.");
    }