Add storageType field to HouseTable Entity

iceberg/openhouse/internalcatalog/src/main/java/com/linkedin/openhouse/internal/catalog/model/HouseTable.java

@@ -1,5 +1,6 @@
 package com.linkedin.openhouse.internal.catalog.model;
 
+import com.linkedin.openhouse.cluster.storage.StorageType;
 import javax.persistence.Entity;
 import javax.persistence.Id;
 import javax.persistence.IdClass;
@@ -39,4 +40,12 @@ public class HouseTable {
   private long lastModifiedTime;
 
   private long creationTime;
+
+  /**
+   * This column indicates the storage type used by this table. See {@link
+   * com.linkedin.openhouse.cluster.storage.StorageType}. A storage type indicates the {@link
+   * com.linkedin.openhouse.cluster.storage.StorageClient} implementation that is used to interact
+   * with this table.
+   */
+  @Builder.Default private String storageType = StorageType.HDFS.getValue();
 }

iceberg/openhouse/internalcatalog/src/test/java/com/linkedin/openhouse/internal/catalog/model/HouseTableTest.java

@@ -0,0 +1,51 @@
+package com.linkedin.openhouse.internal.catalog.model;
+
+import com.linkedin.openhouse.cluster.storage.StorageType;
+import com.linkedin.openhouse.internal.catalog.mapper.HouseTableSerdeUtils;
+import java.beans.BeanInfo;
+import java.beans.Introspector;
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Method;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+public class HouseTableTest {
+
+  @Test
+  public void testHouseTableDefaultValues() {
+    HouseTable ht = HouseTable.builder().build();
+
+    try {
+      BeanInfo beanInfo = Introspector.getBeanInfo(HouseTable.class);
+
+      PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
+
+      for (PropertyDescriptor propertyDescriptor : propertyDescriptors) {
+
+        if (propertyDescriptor.getReadMethod() != null) {
+          Method getter = propertyDescriptor.getReadMethod();
+          Object value = getter.invoke(ht);
+
+          String fieldName =
+              getter.getName().substring(3, 4).toLowerCase() + getter.getName().substring(4);
+          if (!HouseTableSerdeUtils.HTS_FIELD_NAMES.contains(fieldName)) {
+            // not a field getter
+            continue;
+          }
+
+          if (fieldName.equals("storageType")) {
+            Assertions.assertEquals(StorageType.HDFS.getValue(), value);
+          } else if (fieldName.equals("creationTime")) {
+            Assertions.assertEquals(0L, value);
+          } else if (fieldName.equals("lastModifiedTime")) {
+            Assertions.assertEquals(0L, value);
+          } else {
+            Assertions.assertNull(value, getter.getName() + " is not null: " + value);
+          }
+        }
+      }
+    } catch (Exception e) {
+      Assertions.fail(e);
+    }
+  }
+}

iceberg/openhouse/internalcatalog/src/test/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