feat: Add list-tables command to show tables for a given namespace (#150)

Author: subkanthi

examples/scratch/.ice-rest-catalog.yaml

@@ -2,7 +2,7 @@ uri: jdbc:sqlite:file:data/ice-rest-catalog/db.sqlite?journal_mode=WAL&synchrono
 
 # To use etcd instead of sqlite, start etcd with `etcd --data-dir=data/etcd`, then uncomment the line below
 #uri: etcd:http://localhost:2379
-
+#uri: etcd:http://127.0.0.1:12379,http://127.0.0.1:12479,http://127.0.0.1:12579
 warehouse: s3://bucket1
 
 s3:

ice-rest-catalog/src/test/resources/scenarios/basic-operations/run.sh.tmpl

@@ -123,6 +123,17 @@ fi
 {{ICE_CLI}} --config {{CLI_CONFIG}} files ${TABLE_SORTED} >> /tmp/basic_ops_files.txt
 echo "OK Listed files in tables"
 
+# List tables in the namespace via list-tables command
+{{ICE_CLI}} --config {{CLI_CONFIG}} list-tables ${NAMESPACE_NAME} > /tmp/basic_ops_list_tables.txt
+for t in ${TABLE_IRIS} ${TABLE_PARTITIONED} ${TABLE_SORTED}; do
+  if ! grep -q "${t}" /tmp/basic_ops_list_tables.txt; then
+    echo "FAIL: list-tables output missing table ${t}"
+    cat /tmp/basic_ops_list_tables.txt
+    exit 1
+  fi
+done
+echo "OK list-tables listed tables in ${NAMESPACE_NAME}"
+
 # Cleanup tables then namespace
 {{ICE_CLI}} --config {{CLI_CONFIG}} delete-table ${TABLE_IRIS}
 {{ICE_CLI}} --config {{CLI_CONFIG}} delete-table ${TABLE_PARTITIONED}

ice-rest-catalog/src/test/resources/scenarios/basic-operations/verify.sh.tmpl

@@ -5,11 +5,11 @@ set -e
 # Exit code 0 = success, non-zero = failure
 # Expects run.sh to have written: basic_ops_list_namespace.txt, basic_ops_describe.txt,
 # basic_ops_scan_iris.txt, basic_ops_scan_partitioned.txt, basic_ops_scan_sorted.txt,
-# basic_ops_files.txt under /tmp
+# basic_ops_files.txt, basic_ops_list_tables.txt under /tmp
 
 echo "Verifying basic operations test..."
 
-for f in /tmp/basic_ops_list_namespace.txt /tmp/basic_ops_describe.txt /tmp/basic_ops_scan_iris.txt /tmp/basic_ops_scan_partitioned.txt /tmp/basic_ops_scan_sorted.txt; do
+for f in /tmp/basic_ops_list_namespace.txt /tmp/basic_ops_describe.txt /tmp/basic_ops_scan_iris.txt /tmp/basic_ops_scan_partitioned.txt /tmp/basic_ops_scan_sorted.txt /tmp/basic_ops_list_tables.txt; do
   if [ ! -f "$f" ]; then
     echo "FAIL Output file not found: $f"
     exit 1
@@ -72,8 +72,16 @@ if ! grep -q "test_ns" /tmp/basic_ops_list_namespace.txt; then
   exit 1
 fi
 
+# Verify list-tables output contains the expected tables in the test namespace
+for t in test_ns.iris test_ns.taxis_p_by_day test_ns.taxis_s_by_day; do
+  if ! grep -q "$t" /tmp/basic_ops_list_tables.txt; then
+    echo "FAIL basic_ops_list_tables.txt does not contain expected table '$t'"
+    exit 1
+  fi
+done
+
 # Cleanup temp files
-rm -f /tmp/basic_ops_list_namespace.txt /tmp/basic_ops_describe.txt /tmp/basic_ops_scan_iris.txt /tmp/basic_ops_scan_partitioned.txt /tmp/basic_ops_scan_sorted.txt /tmp/basic_ops_files.txt
+rm -f /tmp/basic_ops_list_namespace.txt /tmp/basic_ops_describe.txt /tmp/basic_ops_scan_iris.txt /tmp/basic_ops_scan_partitioned.txt /tmp/basic_ops_scan_sorted.txt /tmp/basic_ops_files.txt /tmp/basic_ops_list_tables.txt
 
 echo "OK Verification passed"
 exit 0

ice/README.md

@@ -140,6 +140,7 @@ where `filelist` contains one file path per line. If any file fails, the entire
 ```shell
 ice create-namespace flowers
 ice list-namespaces
+ice list-tables flowers
 ice delete-namespace flowers
 ```
 

ice/src/main/java/com/altinity/ice/cli/Main.java

@@ -24,6 +24,7 @@
 import com.altinity.ice.cli.internal.cmd.InsertWatch;
 import com.altinity.ice.cli.internal.cmd.ListNamespaces;
 import com.altinity.ice.cli.internal.cmd.ListPartitions;
+import com.altinity.ice.cli.internal.cmd.ListTables;
 import com.altinity.ice.cli.internal.cmd.Scan;
 import com.altinity.ice.cli.internal.config.Config;
 import com.altinity.ice.cli.internal.iceberg.rest.RESTCatalogFactory;
@@ -752,6 +753,33 @@ void listNamespaces(
     }
   }
 
+  @CommandLine.Command(name = "list-tables", description = "List tables in a namespace.")
+  void listTables(
+      @CommandLine.Parameters(
+              arity = "1",
+              paramLabel = "<namespace>",
+              description = "Namespace to list tables from (e.g. parent_ns.child_ns)")
+          String namespaceName,
+      @CommandLine.Option(
+              names = {"--json"},
+              description = "Output JSON instead of YAML")
+          boolean json)
+      throws IOException {
+    if (namespaceName == null || namespaceName.isEmpty()) {
+      throw new IllegalArgumentException("Namespace name is required");
+    }
+    String[] split = namespaceName.split("[.]");
+    for (String level : split) {
+      if (level.isEmpty()) {
+        throw new IllegalArgumentException(
+            "Invalid namespace name: '.' cannot separate empty names");
+      }
+    }
+    try (RESTCatalog catalog = loadCatalog()) {
+      ListTables.run(catalog, Namespace.of(split), json);
+    }
+  }
+
   @CommandLine.Command(name = "delete", description = "Delete data from catalog.")
   void delete(
       @CommandLine.Parameters(

ice/src/main/java/com/altinity/ice/cli/internal/cmd/ListTables.java

@@ -0,0 +1,47 @@
+/*
+ * Copyright (c) 2025 Altinity Inc and/or its affiliates. All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ */
+package com.altinity.ice.cli.internal.cmd;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
+import com.fasterxml.jackson.dataformat.yaml.YAMLGenerator;
+import java.io.IOException;
+import java.util.List;
+import java.util.stream.Collectors;
+import org.apache.iceberg.catalog.Namespace;
+import org.apache.iceberg.catalog.TableIdentifier;
+import org.apache.iceberg.rest.RESTCatalog;
+
+public final class ListTables {
+
+  private ListTables() {}
+
+  public static void run(RESTCatalog catalog, Namespace namespace, boolean json)
+      throws IOException {
+    List<TableIdentifier> tables = catalog.listTables(namespace);
+    List<String> names =
+        tables.stream().map(TableIdentifier::toString).sorted().collect(Collectors.toList());
+    var result = new Result(namespace.toString(), names);
+    output(result, json);
+  }
+
+  private static void output(Result result, boolean json) throws IOException {
+    ObjectMapper mapper =
+        json
+            ? new ObjectMapper()
+            : new ObjectMapper(new YAMLFactory().enable(YAMLGenerator.Feature.MINIMIZE_QUOTES));
+    mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+    System.out.println(mapper.writeValueAsString(result));
+  }
+
+  @JsonInclude(JsonInclude.Include.NON_NULL)
+  record Result(String namespace, List<String> tables) {}
+}