Add storageType field to HouseTable Entity #80

linkedin · Apr 22, 2024 · 8ff7d67 · 8ff7d67
1 parent 24266de
commit 8ff7d67
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/...ternalcatalog/src/main/java/com/linkedin/openhouse/internal/catalog/model/HouseTable.java b/...ternalcatalog/src/main/java/com/linkedin/openhouse/internal/catalog/model/HouseTable.java
@@ -39,4 +39,6 @@ public class HouseTable {
   private long lastModifiedTime;
 
   private long creationTime;
+
+  private String storageType;
 }
diff --git a/...java/com/linkedin/openhouse/internal/catalog/repository/HouseTableRepositoryImplTest.java b/...java/com/linkedin/openhouse/internal/catalog/repository/HouseTableRepositoryImplTest.java
@@ -132,6 +132,7 @@ public void testRepoSave() {
     Assertions.assertEquals(result.getDatabaseId(), HOUSE_TABLE.getDatabaseId());
     Assertions.assertEquals(result.getTableLocation(), HOUSE_TABLE.getTableLocation());
     Assertions.assertEquals(result.getTableVersion(), HOUSE_TABLE.getTableVersion());
+    Assertions.assertEquals(result.getStorageType(), HOUSE_TABLE.getStorageType());
   }
 
   @Test

diff --git a/...c/testFixtures/java/com/linkedin/openhouse/internal/catalog/HouseTableModelConstants.java b/...c/testFixtures/java/com/linkedin/openhouse/internal/catalog/HouseTableModelConstants.java
@@ -25,6 +25,7 @@ public class HouseTableModelConstants {
           .tableLocation("loc1")
           .tableVersion(String.valueOf(new Random().nextLong()))
           .tableUUID(UUID.randomUUID().toString())
+          .storageType("st")
           .build();
 
   public static final HouseTable HOUSE_TABLE_SAME_DB =
@@ -36,6 +37,7 @@ public class HouseTableModelConstants {
           .tableLocation("loc2")
           .tableVersion(String.valueOf(new Random().nextLong()))
           .tableUUID(UUID.randomUUID().toString())
+          .storageType("st")
           .build();
 
   public static final HouseTable HOUSE_TABLE_DIFF_DB =
@@ -47,5 +49,6 @@ public class HouseTableModelConstants {
           .tableLocation("loc3")
           .tableVersion(String.valueOf(new Random().nextLong()))
           .tableUUID(UUID.randomUUID().toString())
+          .storageType("st")
           .build();
 }