public CatalogTable getTable()

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

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

    public CatalogTable getTable(ObjectPath tablePath) throws TableNotExistException {
        checkNotNull(tablePath);

        if (!tableExists(tablePath)) {
            throw new TableNotExistException(getName(), tablePath);
        }

        String tableName = tablePath.getObjectName();

        try {
            KuduTable kuduTable = kuduClient.openTable(tableName);
            return CatalogTable.of(
                    KuduTableUtils.kuduToFlinkSchema(kuduTable.getSchema()),
                    null,
                    Collections.emptyList(),
                    createTableProperties(kuduTable));
        } catch (KuduException e) {
            throw new CatalogException(e);
        }
    }