diff --git a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java index 34e7aa8..eff8179 100644 --- a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java +++ b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java @@ -33,6 +33,10 @@ public interface Constants { * Hudi 删除标记字段 */ String HUDI_DELETE_KEY_NAME = "_hoodie_is_deleted"; + /** + * Hudi存储雪花算法值 + */ + String HUDI_SERIES_NUMBER_KEY_NAME = "hoodie_series_number"; String PULSAR_SUBSCRIPTION_NAME_PREFIX = "Hudi_Sync_Pulsar_Reader";