Skip to main content
Version: 1.3.0

Java Client

Introduction

Use Gravitino Java client library with Spark, Spring and other Java environment or use Gravitino Python client library with Spark, PyTorch, Tensorflow, Ray and Python environment.

First of all, you must have a Gravitino server set up and run, you can refer document of how to install Gravitino to build Gravitino server from source code and install it in your local.

Java Client

Customize the Gravitino Java client by using withClientConfig like this:

 Map<String, String> properties =
ImmutableMap.of(
"gravitino.client.connectionTimeoutMs", "10",
"gravitino.client.socketTimeoutMs", "10"
);

GravitinoClient gravitinoClient = GravitinoClient.builder("http://localhost:8090")
.withMetalake("metalake")
.withClientConfig(properties) // add custom client config (optional)
.builder();

GravitinoAdminClient gravitinoAdminClient = GravitinoAdminClient.builder("http://localhost:8090")
.withClientConfig(properties) // add custom client config (optional)
.builder();
// ...

Java Client Configuration

Configuration itemDescriptionDefault valueRequiredSince version
gravitino.client.connectionTimeoutMsAn optional http connection timeout in milliseconds.180000(3 minutes)No1.0.0
gravitino.client.socketTimeoutMsAn optional http socket timeout in milliseconds.180000(3 minutes)No1.0.0

Note: Invalid configuration properties will result in exceptions.

Python Client

Customize the Gravitino Python client with config properties like this:

gravitino_admin_client = GravitinoAdminClient(
uri="http://localhost:8090",
client_config={"gravitino_client_request_timeout": 60},
)
# ...

gravitino_client = GravitinoClient(
uri="http://localhost:8090",
metalake_name="test",
client_config={"gravitino_client_request_timeout": 60},
)
# ...

Python Client Configuration

Configuration itemDescriptionDefault valueRequiredSince version
gravitino_client_request_timeoutAn optional client timeout in seconds.10No1.0.0

Note: Invalid configuration properties will result in exceptions.