From 91101fbb94be71fed93422b5463d8f5e1cc373c5 Mon Sep 17 00:00:00 2001 From: yunqing-wei Date: Wed, 27 Sep 2023 23:56:14 +0800 Subject: [PATCH] [#410] feat(catalog-lakehouse): integrate HiveCatalog and JDBCCatalog to graviton --- .../lakehouse/iceberg/IcebergRESTConfig.java | 14 +++++++------- .../main/java/com/datastrato/graviton/Config.java | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/catalogs/catalog-lakehouse-iceberg/src/main/java/com/datastrato/graviton/catalog/lakehouse/iceberg/IcebergRESTConfig.java b/catalogs/catalog-lakehouse-iceberg/src/main/java/com/datastrato/graviton/catalog/lakehouse/iceberg/IcebergRESTConfig.java index 60f43a7ab7d..cd963d03058 100644 --- a/catalogs/catalog-lakehouse-iceberg/src/main/java/com/datastrato/graviton/catalog/lakehouse/iceberg/IcebergRESTConfig.java +++ b/catalogs/catalog-lakehouse-iceberg/src/main/java/com/datastrato/graviton/catalog/lakehouse/iceberg/IcebergRESTConfig.java @@ -14,49 +14,49 @@ public class IcebergRESTConfig extends Config { public static final ConfigEntry ICEBERG_REST_SERVER_HTTP_PORT = new ConfigBuilder("serverPort") .doc("The http port number of the Iceberg REST server") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .intConf() .createWithDefault(9001); public static final ConfigEntry ICEBERG_REST_SERVER_HOST = new ConfigBuilder("serverHost") .doc("The host name of the Iceberg REST server") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .stringConf() .createWithDefault("0.0.0.0"); public static final ConfigEntry ICEBERG_REST_SERVER_CORE_THREADS = new ConfigBuilder("coreThreads") .doc("The core thread size of the Iceberg REST server") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .intConf() .createWithDefault(Math.min(Runtime.getRuntime().availableProcessors() * 2, 100)); public static final ConfigEntry ICEBERG_REST_SERVER_MAX_THREADS = new ConfigBuilder("maxThreads") .doc("The max thread size of the Iceberg REST server") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .intConf() .createWithDefault(Math.max(Runtime.getRuntime().availableProcessors() * 4, 400)); public static final ConfigEntry ICEBERG_REST_SERVER_THREAD_POOL_WORK_QUEUE_SIZE = new ConfigBuilder("threadPoolWorkQueueSize") .doc("The executor thread pool work queue size of the Iceberg REST server") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .intConf() .createWithDefault(100); public static final ConfigEntry CATALOG_TYPE = new ConfigBuilder("catalogType") .doc("Choose the implementation of the Iceberg catalog") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .stringConf() .createWithDefault("memory"); public static final ConfigEntry INITIALIZE_JDBC_CATALOG_TABLES = new ConfigBuilder("initializeJdbcCatalogTables") .doc("Whether to load the configuration of the jdbc catalog table during initialization") - .version(DEFAULT_VERSION) + .version(VERSION_0_2_0) .booleanConf() .createWithDefault(true); } diff --git a/core/src/main/java/com/datastrato/graviton/Config.java b/core/src/main/java/com/datastrato/graviton/Config.java index 1eb6e9b6040..93e20816a85 100644 --- a/core/src/main/java/com/datastrato/graviton/Config.java +++ b/core/src/main/java/com/datastrato/graviton/Config.java @@ -27,7 +27,7 @@ public abstract class Config { private static final Logger LOG = LoggerFactory.getLogger(Config.class); - protected static final String DEFAULT_VERSION = "0.2.0"; + protected static final String VERSION_0_2_0 = "0.2.0"; private static final String CONFIG_PREPEND = "graviton.";