From dbfec92c0bf591abd7bee3cd5e28466b3307ea90 Mon Sep 17 00:00:00 2001 From: lance-community Date: Fri, 24 Apr 2026 23:35:53 +0000 Subject: [PATCH] chore: update lance dependency to v6.0.0-beta.3 --- plugin/trino-lance/pom.xml | 6 +++--- .../main/java/io/trino/plugin/lance/LancePageSink.java | 10 ++++------ 2 files changed, 7 insertions(+), 9 deletions(-) diff --git a/plugin/trino-lance/pom.xml b/plugin/trino-lance/pom.xml index 93edc32..f4c6fe8 100755 --- a/plugin/trino-lance/pom.xml +++ b/plugin/trino-lance/pom.xml @@ -116,7 +116,7 @@ org.lance lance-core - 4.0.0 + 6.0.0-beta.3 org.junit.jupiter @@ -128,13 +128,13 @@ org.lance lance-namespace-apache-client - 0.5.2 + 0.6.1 org.lance lance-namespace-core - 0.5.2 + 0.6.1 diff --git a/plugin/trino-lance/src/main/java/io/trino/plugin/lance/LancePageSink.java b/plugin/trino-lance/src/main/java/io/trino/plugin/lance/LancePageSink.java index 586edde..5f36162 100644 --- a/plugin/trino-lance/src/main/java/io/trino/plugin/lance/LancePageSink.java +++ b/plugin/trino-lance/src/main/java/io/trino/plugin/lance/LancePageSink.java @@ -27,7 +27,6 @@ import org.lance.FragmentMetadata; import org.lance.WriteFragmentBuilder; import org.lance.namespace.LanceNamespace; -import org.lance.namespace.LanceNamespaceStorageOptionsProvider; import java.util.ArrayList; import java.util.Collection; @@ -170,7 +169,7 @@ private List writeFragments() log.debug("Using storage options for table %s: %s", tableId, storageOptions); // Write fragments using Lance API - // Use storageOptionsProvider only if credentials have expiration (expires_at_millis) + // Use namespace refresh only if credentials have expiration (expires_at_millis) // Otherwise use static storage_options directly WriteFragmentBuilder fragmentWriter = Fragment.write() .datasetUri(datasetUri) @@ -185,12 +184,11 @@ private List writeFragments() if (storageOptions != null && !storageOptions.isEmpty()) { if (storageOptions.containsKey("expires_at_millis")) { - // Credentials have expiration - use provider for auto-refresh - LanceNamespaceStorageOptionsProvider storageOptionsProvider = - new LanceNamespaceStorageOptionsProvider(namespace, tableId); + // Credentials have expiration - use namespace/table context for auto-refresh fragmentWriter = fragmentWriter .storageOptions(storageOptions) - .storageOptionsProvider(storageOptionsProvider); + .namespaceClient(namespace) + .tableId(tableId); } else { // Static credentials - use storage options directly without provider