3434 * <p>This implementation delegates to {@link UCCatalogManagedClient} for all snapshot and commit
3535 * operations, leveraging UC's ratified commits as the source of truth.
3636 */
37- public class UCManagedSnapshotManager implements DeltaSnapshotManager {
37+ public class UCManagedTableSnapshotManager implements DeltaSnapshotManager {
3838
3939 private final UCCatalogManagedClient ucCatalogManagedClient ;
4040 private final String tableId ;
4141 private final String tablePath ;
4242 private final Engine engine ;
4343
4444 /**
45- * Creates a new UCManagedSnapshotManager .
45+ * Creates a new UCManagedTableSnapshotManager .
4646 *
4747 * @param ucCatalogManagedClient the UC client for catalog-managed operations
4848 * @param tableInfo the UC table information (tableId, tablePath, etc.)
4949 * @param hadoopConf Hadoop configuration for filesystem operations
5050 */
51- public UCManagedSnapshotManager (
51+ public UCManagedTableSnapshotManager (
5252 UCCatalogManagedClient ucCatalogManagedClient ,
5353 UCTableInfo tableInfo ,
5454 Configuration hadoopConf ) {
@@ -64,14 +64,14 @@ public UCManagedSnapshotManager(
6464 public Snapshot loadLatestSnapshot () {
6565 // TODO: Implement in snapshotmanager-impl stack
6666 throw new UnsupportedOperationException (
67- "UCManagedSnapshotManager .loadLatestSnapshot not yet implemented" );
67+ "UCManagedTableSnapshotManager .loadLatestSnapshot not yet implemented" );
6868 }
6969
7070 @ Override
7171 public Snapshot loadSnapshotAt (long version ) {
7272 // TODO: Implement in snapshotmanager-impl stack
7373 throw new UnsupportedOperationException (
74- "UCManagedSnapshotManager .loadSnapshotAt not yet implemented" );
74+ "UCManagedTableSnapshotManager .loadSnapshotAt not yet implemented" );
7575 }
7676
7777 @ Override
@@ -82,21 +82,21 @@ public DeltaHistoryManager.Commit getActiveCommitAtTime(
8282 boolean canReturnEarliestCommit ) {
8383 // TODO: Implement in snapshotmanager-impl stack
8484 throw new UnsupportedOperationException (
85- "UCManagedSnapshotManager .getActiveCommitAtTime not yet implemented" );
85+ "UCManagedTableSnapshotManager .getActiveCommitAtTime not yet implemented" );
8686 }
8787
8888 @ Override
8989 public void checkVersionExists (long version , boolean mustBeRecreatable , boolean allowOutOfRange )
9090 throws VersionNotFoundException {
9191 // TODO: Implement in snapshotmanager-impl stack
9292 throw new UnsupportedOperationException (
93- "UCManagedSnapshotManager .checkVersionExists not yet implemented" );
93+ "UCManagedTableSnapshotManager .checkVersionExists not yet implemented" );
9494 }
9595
9696 @ Override
9797 public CommitRange getTableChanges (Engine engine , long startVersion , Optional <Long > endVersion ) {
9898 // TODO: Implement in snapshotmanager-impl stack
9999 throw new UnsupportedOperationException (
100- "UCManagedSnapshotManager .getTableChanges not yet implemented" );
100+ "UCManagedTableSnapshotManager .getTableChanges not yet implemented" );
101101 }
102102}
0 commit comments