From 0f021a8f1a3d48ab7a741f6bae01506cb01e8b4e Mon Sep 17 00:00:00 2001 From: luren <879893931@qq.com> Date: Tue, 28 Jul 2020 20:04:37 +0800 Subject: [PATCH] add a property named "hetu.dc.catalogs.update.threshold" into dc configuration file, this property is used in method CatalogConnectorStore.getDCCatalogUpdateThreshold. --- .../core/plugin/datacenter/DataCenterConfig.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/DataCenterConfig.java b/hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/DataCenterConfig.java index 175271ecf..2930527ff 100644 --- a/hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/DataCenterConfig.java +++ b/hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/DataCenterConfig.java @@ -117,12 +117,26 @@ public class DataCenterConfig private int maxIdleConnections = DEFAULT_MAX_IDLE_CONNECTIONS; + private String updateThreshold = "1m"; + @NotNull public URI getConnectionUrl() { return connectionUrl; } + public String getUpdateThreshold() + { + return updateThreshold; + } + + @Config("hetu.dc.catalog.update.threshold") + public DataCenterConfig setUpdateThreshold(String updateThreshold) + { + this.updateThreshold = updateThreshold; + return this; + } + /** * Set connection url, it is remote data center url. *