[ASTS] feat(bucket-assigner): Add underlying physical table (#7299)

palantir · Sep 30, 2024 · d3a7c7d · d3a7c7d
1 parent aadca41
commit d3a7c7d
Show file tree

Hide file tree

Showing 3 changed files with 826 additions and 1 deletion.
diff --git a/atlasdb-client/src/main/java/com/palantir/atlasdb/schema/TargetedSweepSchema.java b/atlasdb-client/src/main/java/com/palantir/atlasdb/schema/TargetedSweepSchema.java
@@ -137,6 +137,26 @@ private static void addSweepStateTables(Schema schema) {
                 conflictHandler(ConflictHandler.IGNORE_ALL);
             }
         });
+
+        schema.addTableDefinition("sweepAssignedBuckets", new TableDefinition() {
+            {
+                javaTableName("SweepAssignedBuckets");
+                allSafeForLoggingByDefault();
+                rowName();
+                hashFirstNRowComponents(3);
+                // All are signed to reserve the negative values for special cells.
+                rowComponent("shard", ValueType.VAR_SIGNED_LONG);
+                rowComponent("major_bucket_identifier", ValueType.VAR_SIGNED_LONG);
+                rowComponent("strategy", ValueType.BLOB);
+                dynamicColumns();
+                columnComponent("minor_bucket_identifier", ValueType.VAR_SIGNED_LONG);
+                value(ValueType.BLOB);
+
+                // we do our own cleanup
+                sweepStrategy(TableMetadataPersistence.SweepStrategy.NOTHING);
+                conflictHandler(ConflictHandler.IGNORE_ALL);
+            }
+        });
     }
 
     private static void addTableIdentifierTables(Schema schema) {