[Kernel-Spark][DSv2] Wireframe for UCManagedSnapshotManager

build.sbt

@@ -462,6 +462,7 @@ lazy val sparkV1Filtered = (project in file("spark-v1-filtered"))
 lazy val sparkV2 = (project in file("kernel-spark"))
   .dependsOn(sparkV1Filtered)
   .dependsOn(kernelDefaults)
+  .dependsOn(kernelUnityCatalog % "compile->compile;test->test")
   .dependsOn(goldenTables % "test")
   .settings(
     name := "delta-spark-v2",

kernel-spark/src/main/java/io/delta/kernel/spark/snapshot/unitycatalog/UCManagedTableSnapshotManager.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright (2025) The Delta Lake Project Authors.
+ *
+ * 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
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.delta.kernel.spark.snapshot.unitycatalog;
+
+import static java.util.Objects.requireNonNull;
+
+import io.delta.kernel.CommitRange;
+import io.delta.kernel.Snapshot;
+import io.delta.kernel.engine.Engine;
+import io.delta.kernel.internal.DeltaHistoryManager;
+import io.delta.kernel.spark.snapshot.DeltaSnapshotManager;
+import io.delta.kernel.unitycatalog.UCCatalogManagedClient;
+import java.util.Optional;
+
+/**
+ * Snapshot manager for Unity Catalog managed tables.
+ *
+ * <p>Used for tables with the catalog-managed commit feature enabled. Unity Catalog serves as the
+ * source of truth for the table's commit history.
+ */
+public class UCManagedTableSnapshotManager implements DeltaSnapshotManager {
+
+  private final UCCatalogManagedClient ucCatalogManagedClient;
+  private final String tableId;
+  private final String tablePath;
+  private final Engine engine;
+
+  /**
+   * Creates a new UCManagedTableSnapshotManager.
+   *
+   * @param ucCatalogManagedClient the UC client for catalog-managed operations
+   * @param tableInfo the UC table information (tableId, tablePath, etc.)
+   * @param engine the Kernel engine for table operations
+   */
+  public UCManagedTableSnapshotManager(
+      UCCatalogManagedClient ucCatalogManagedClient, UCTableInfo tableInfo, Engine engine) {
+    this.ucCatalogManagedClient =
+        requireNonNull(ucCatalogManagedClient, "ucCatalogManagedClient is null");
+    requireNonNull(tableInfo, "tableInfo is null");
+    this.tableId = tableInfo.getTableId();
+    this.tablePath = tableInfo.getTablePath();
+    this.engine = requireNonNull(engine, "engine is null");
+  }
+
+  @Override
+  public Snapshot loadLatestSnapshot() {
+    throw new UnsupportedOperationException(
+        "UCManagedTableSnapshotManager.loadLatestSnapshot is not yet implemented");
+  }
+
+  @Override
+  public Snapshot loadSnapshotAt(long version) {
+    throw new UnsupportedOperationException(
+        "UCManagedTableSnapshotManager.loadSnapshotAt is not yet implemented");
+  }
+
+  @Override
+  public DeltaHistoryManager.Commit getActiveCommitAtTime(
+      long timestampMillis,
+      boolean canReturnLastCommit,
+      boolean mustBeRecreatable,
+      boolean canReturnEarliestCommit) {
+    throw new UnsupportedOperationException(
+        "UCManagedTableSnapshotManager.getActiveCommitAtTime is not yet implemented");
+  }
+
+  @Override
+  public void checkVersionExists(long version, boolean mustBeRecreatable, boolean allowOutOfRange) {
+    throw new UnsupportedOperationException(
+        "UCManagedTableSnapshotManager.checkVersionExists is not yet implemented");
+  }
+
+  @Override
+  public CommitRange getTableChanges(Engine engine, long startVersion, Optional<Long> endVersion) {
+    throw new UnsupportedOperationException(
+        "UCManagedTableSnapshotManager.getTableChanges is not yet implemented");
+  }
+}

kernel-spark/src/main/java/io/delta/kernel/spark/snapshot/unitycatalog/UCUtils.java

@@ -29,7 +29,7 @@
 /**
  * Utility class for extracting Unity Catalog table information from Spark catalog metadata.
  *
- * <p>This class isolates Spark dependencies, allowing {@link UCManagedSnapshotManager} to be
+ * <p>This class isolates Spark dependencies, allowing {@link UCManagedTableSnapshotManager} to be
  * created without Spark if table info is provided directly via {@link UCTableInfo}.
  */
 public final class UCUtils {