Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 6 additions & 3 deletions conf/gravitino-lance-rest-server.conf.template
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,9 @@ gravitino.lance-rest.requestHeaderSize = 131072
# The response header size of the built-in web server
gravitino.lance-rest.responseHeaderSize = 131072

# THE CONFIGURATION FOR Lance CATALOG
# The logical Lance catalog served by this REST endpoint
gravitino.lance-rest.catalog-name = default
# THE CONFIGURATION FOR Lance namespace backend
# The backend Lance namespace for Lance REST service, it's recommended to use Gravitino
gravitino.lance-rest.namespace-backend = gravitino
gravitino.lance-rest.uri = http://localhost:8090
# replace metalake with your metalake name in Gravitino
# gravitino.lance-rest.metalake-name = metalake
17 changes: 16 additions & 1 deletion conf/gravitino.conf.template
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,9 @@ gravitino.authorization.enable = false
gravitino.authorization.serviceAdmins = anonymous

# THE CONFIGURATION FOR AUXILIARY SERVICE
# Auxiliary service names, separate by ','
# Auxiliary service names, separate by ',' such as iceberg-rest,lance-rest
gravitino.auxService.names = iceberg-rest

# Iceberg REST service classpath
gravitino.iceberg-rest.classpath = iceberg-rest-server/libs, iceberg-rest-server/conf
# Iceberg REST service host
Expand All @@ -93,3 +94,17 @@ gravitino.iceberg-rest.httpPort = 9001
gravitino.iceberg-rest.catalog-backend = memory
# The warehouse directory of Iceberg catalog for Iceberg REST service
gravitino.iceberg-rest.warehouse = /tmp/

# Lance REST service classpath
gravitino.lance-rest.classpath = lance-rest-server/libs
# Lance REST service host
gravitino.lance-rest.host = 0.0.0.0
# Lance REST service http port
gravitino.lance-rest.httpPort = 9101

# THE CONFIGURATION FOR Lance namespace backend
# The backend Lance namespace for Lance REST service, it's recommended to use Gravitino
gravitino.lance-rest.namespace-backend = gravitino
gravitino.lance-rest.uri = http://localhost:8090
# replace metalake with your metalake name in Gravitino
# gravitino.lance-rest.metalake-name = metalake
Original file line number Diff line number Diff line change
Expand Up @@ -39,29 +39,22 @@ public class LanceConfig extends Config implements OverwriteDefaultConfig {
public static final String DEFAULT_NAMESPACE_BACKEND = "gravitino";
public static final String DEFAULT_URI = "http://localhost:8090";

public static final ConfigEntry<String> CATALOG_NAME =
new ConfigBuilder(LANCE_CONFIG_PREFIX + "catalog-name")
.doc("Logical Lance catalog served by the REST endpoint")
.version(ConfigConstants.VERSION_0_1_0)
.stringConf()
.createWithDefault("default");

public static final ConfigEntry<String> NAMESPACE_BACKEND =
new ConfigBuilder(LANCE_CONFIG_PREFIX + CONFIG_NAMESPACE_BACKEND)
new ConfigBuilder(CONFIG_NAMESPACE_BACKEND)
.doc("The backend implementation for namespace operations")
.version(ConfigConstants.VERSION_0_1_0)
.stringConf()
.createWithDefault(DEFAULT_NAMESPACE_BACKEND);

public static final ConfigEntry<String> METALAKE_NAME =
new ConfigBuilder(LANCE_CONFIG_PREFIX + CONFIG_METALAKE)
new ConfigBuilder(CONFIG_METALAKE)
.doc("The Metalake name for Gravitino namespace backend")
.version(ConfigConstants.VERSION_0_1_0)
.stringConf()
.create();

public static final ConfigEntry<String> NAMESPACE_URI =
new ConfigBuilder(LANCE_CONFIG_PREFIX + CONFIG_URI)
new ConfigBuilder(CONFIG_URI)
.doc("The URI for the namespace backend, e.g., Gravitino server URI")
.version(ConfigConstants.VERSION_0_1_0)
.stringConf()
Expand All @@ -76,8 +69,8 @@ public LanceConfig() {
super(false);
}

public String getCatalogName() {
return get(CATALOG_NAME);
public String getNamespaceBackend() {
return get(NAMESPACE_BACKEND);
}

public String getNamespaceUri() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,19 +32,19 @@ public interface LanceNamespaceOperations {
ListNamespacesResponse listNamespaces(
String namespaceId, String delimiter, String pageToken, Integer limit);

DescribeNamespaceResponse describeNamespace(String id, String delimiter);
DescribeNamespaceResponse describeNamespace(String namespaceId, String delimiter);

CreateNamespaceResponse createNamespace(
String id,
String namespaceId,
String delimiter,
CreateNamespaceRequest.ModeEnum mode,
Map<String, String> properties);

DropNamespaceResponse dropNamespace(
String id,
String namespaceId,
String delimiter,
DropNamespaceRequest.ModeEnum mode,
DropNamespaceRequest.BehaviorEnum behavior);

void namespaceExists(String id, String delimiter) throws LanceNamespaceException;
void namespaceExists(String namespaceId, String delimiter) throws LanceNamespaceException;
}
Loading