void check()

in iceberg-catalog-migrator/api/src/main/java/org/apache/polaris/iceberg/catalog/migrator/api/CatalogMigrator.java [63:82]

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

  void check() {
    if (!(targetCatalog() instanceof SupportsNamespaces)) {
      throw new UnsupportedOperationException(
          String.format(
              "target catalog %s doesn't implement SupportsNamespaces to create missing namespaces.",
              targetCatalog().name()));
    }

    if (!(sourceCatalog() instanceof SupportsNamespaces)) {
      throw new UnsupportedOperationException(
          String.format(
              "source catalog %s doesn't implement SupportsNamespaces to list all namespaces.",
              sourceCatalog().name()));
    }

    if (deleteEntriesFromSourceCatalog() && sourceCatalog() instanceof HadoopCatalog) {
      throw new UnsupportedOperationException(
          "Source catalog is a Hadoop catalog and it doesn't support deleting the table entries just from the catalog. Please configure `deleteEntriesFromSourceCatalog` as `false`");
    }
  }