Skip to content
Merged
Show file tree
Hide file tree
Changes from 6 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 @@ -82,7 +82,8 @@ gravitino.authorization.serviceAdmins = anonymous

# THE CONFIGURATION FOR AUXILIARY SERVICE
# Auxiliary service names, separate by ','
gravitino.auxService.names = iceberg-rest
gravitino.auxService.names = iceberg-rest, lance-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
Loading