Skip to content

Commit

Permalink
[#410] feat(catalog-lakehouse): integrate HiveCatalog and JDBCCatalog…
Browse files Browse the repository at this point in the history
… to graviton
  • Loading branch information
yunqing-wei committed Sep 27, 2023
1 parent 0b00c8d commit 91101fb
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,49 +14,49 @@ public class IcebergRESTConfig extends Config {
public static final ConfigEntry<Integer> 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<String> 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<Integer> 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<Integer> 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<Integer> 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<String> 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<Boolean> 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);
}
2 changes: 1 addition & 1 deletion core/src/main/java/com/datastrato/graviton/Config.java
Original file line number Diff line number Diff line change
Expand Up @@ -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.";

Expand Down

0 comments on commit 91101fb

Please sign in to comment.