Merge branch 'main' into feature/wal

Add support for routing merge_insert requests to a separate WAL/ingest
host. The WAL host is auto-derived as {db}.{region}.wal.lancedb.com or
can be explicitly overridden via ConnectBuilder::wal_host_override().
Callers opt in per-operation with MergeInsertBuilder::use_wal(true).

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

.bumpversion.toml

@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.28.0-beta.1"
+current_version = "0.28.0-beta.0"
 parse = """(?x)
     (?P<major>0|[1-9]\\d*)\\.
     (?P<minor>0|[1-9]\\d*)\\.

Cargo.lock

@@ -3072,8 +3072,8 @@ checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c"
 
 [[package]]
 name = "fsst"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-array",
  "rand 0.9.2",
@@ -4134,8 +4134,8 @@ dependencies = [
 
 [[package]]
 name = "lance"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-arith",
@@ -4201,8 +4201,8 @@ dependencies = [
 
 [[package]]
 name = "lance-arrow"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -4222,8 +4222,8 @@ dependencies = [
 
 [[package]]
 name = "lance-bitpacking"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrayref",
  "paste",
@@ -4232,8 +4232,8 @@ dependencies = [
 
 [[package]]
 name = "lance-core"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -4270,8 +4270,8 @@ dependencies = [
 
 [[package]]
 name = "lance-datafusion"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-array",
@@ -4301,8 +4301,8 @@ dependencies = [
 
 [[package]]
 name = "lance-datagen"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-array",
@@ -4320,8 +4320,8 @@ dependencies = [
 
 [[package]]
 name = "lance-encoding"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-arith",
  "arrow-array",
@@ -4358,8 +4358,8 @@ dependencies = [
 
 [[package]]
 name = "lance-file"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-arith",
  "arrow-array",
@@ -4391,8 +4391,8 @@ dependencies = [
 
 [[package]]
 name = "lance-index"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-arith",
@@ -4456,8 +4456,8 @@ dependencies = [
 
 [[package]]
 name = "lance-io"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-arith",
@@ -4501,8 +4501,8 @@ dependencies = [
 
 [[package]]
 name = "lance-linalg"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-array",
  "arrow-buffer",
@@ -4518,8 +4518,8 @@ dependencies = [
 
 [[package]]
 name = "lance-namespace"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "async-trait",
@@ -4532,8 +4532,8 @@ dependencies = [
 
 [[package]]
 name = "lance-namespace-impls"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-ipc",
@@ -4578,8 +4578,8 @@ dependencies = [
 
 [[package]]
 name = "lance-table"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow",
  "arrow-array",
@@ -4618,8 +4618,8 @@ dependencies = [
 
 [[package]]
 name = "lance-testing"
-version = "5.0.0-beta.5"
-source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.5#d630106da5a238b3adfb8c5dea3b3921f3519945"
+version = "5.0.0-beta.4"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-beta.4#d9068e76a301df9e21d7282419f24f61a11375ac"
 dependencies = [
  "arrow-array",
  "arrow-schema",

Cargo.toml

@@ -15,20 +15,20 @@ categories = ["database-implementations"]
 rust-version = "1.91.0"
 
 [workspace.dependencies]
-lance = { "version" = "=5.0.0-beta.5", default-features = false, "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-core = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-datagen = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-file = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-io = { "version" = "=5.0.0-beta.5", default-features = false, "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-index = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-linalg = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace-impls = { "version" = "=5.0.0-beta.5", default-features = false, "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-table = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-testing = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-datafusion = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-encoding = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
-lance-arrow = { "version" = "=5.0.0-beta.5", "tag" = "v5.0.0-beta.5", "git" = "https://github.com/lance-format/lance.git" }
+lance = { "version" = "=5.0.0-beta.4", default-features = false, "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-core = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-datagen = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-file = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-io = { "version" = "=5.0.0-beta.4", default-features = false, "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-index = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-linalg = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-namespace = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-namespace-impls = { "version" = "=5.0.0-beta.4", default-features = false, "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-table = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-testing = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-datafusion = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-encoding = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
+lance-arrow = { "version" = "=5.0.0-beta.4", "tag" = "v5.0.0-beta.4", "git" = "https://github.com/lance-format/lance.git" }
 ahash = "0.8"
 # Note that this one does not include pyarrow
 arrow = { version = "57.2", optional = false }

docs/src/java/java.md

@@ -14,7 +14,7 @@ Add the following dependency to your `pom.xml`:
 <dependency>
     <groupId>com.lancedb</groupId>
     <artifactId>lancedb-core</artifactId>
-    <version>0.28.0-beta.1</version>
+    <version>0.28.0-beta.0</version>
 </dependency>
 ```
 

java/lancedb-core/pom.xml

@@ -8,7 +8,7 @@
     <parent>
       <groupId>com.lancedb</groupId>
       <artifactId>lancedb-parent</artifactId>
-      <version>0.28.0-beta.1</version>
+      <version>0.28.0-beta.0</version>
       <relativePath>../pom.xml</relativePath>
     </parent>
 

java/pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.lancedb</groupId>
     <artifactId>lancedb-parent</artifactId>
-    <version>0.28.0-beta.1</version>
+    <version>0.28.0-beta.0</version>
     <packaging>pom</packaging>
     <name>${project.artifactId}</name>
     <description>LanceDB Java SDK Parent POM</description>
@@ -28,7 +28,7 @@
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <arrow.version>15.0.0</arrow.version>
-        <lance-core.version>5.0.0-beta.5</lance-core.version>
+        <lance-core.version>5.0.0-beta.4</lance-core.version>
         <spotless.skip>false</spotless.skip>
         <spotless.version>2.30.0</spotless.version>
         <spotless.java.googlejavaformat.version>1.7</spotless.java.googlejavaformat.version>

nodejs/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "lancedb-nodejs"
 edition.workspace = true
-version = "0.28.0-beta.1"
+version = "0.28.0-beta.0"
 license.workspace = true
 description.workspace = true
 repository.workspace = true

nodejs/npm/darwin-arm64/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-darwin-arm64",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["darwin"],
 	"cpu": ["arm64"],
 	"main": "lancedb.darwin-arm64.node",

nodejs/npm/linux-arm64-gnu/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-gnu",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-gnu.node",

nodejs/npm/linux-arm64-musl/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-musl",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-musl.node",

nodejs/npm/linux-x64-gnu/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-gnu",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-gnu.node",

nodejs/npm/linux-x64-musl/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-musl",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-musl.node",

nodejs/npm/win32-arm64-msvc/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@lancedb/lancedb-win32-arm64-msvc",
-  "version": "0.28.0-beta.1",
+  "version": "0.28.0-beta.0",
   "os": [
     "win32"
   ],

nodejs/npm/win32-x64-msvc/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-win32-x64-msvc",
-	"version": "0.28.0-beta.1",
+	"version": "0.28.0-beta.0",
 	"os": ["win32"],
 	"cpu": ["x64"],
 	"main": "lancedb.win32-x64-msvc.node",

nodejs/package.json

@@ -11,7 +11,7 @@
     "ann"
   ],
   "private": false,
-  "version": "0.28.0-beta.1",
+  "version": "0.28.0-beta.0",
   "main": "dist/index.js",
   "exports": {
     ".": "./dist/index.js",

python/.bumpversion.toml

@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.31.0-beta.1"
+current_version = "0.31.0-beta.0"
 parse = """(?x)
     (?P<major>0|[1-9]\\d*)\\.
     (?P<minor>0|[1-9]\\d*)\\.

python/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "lancedb-python"
-version = "0.31.0-beta.1"
+version = "0.31.0-beta.0"
 edition.workspace = true
 description = "Python bindings for LanceDB"
 license.workspace = true

python/pyproject.toml

@@ -45,7 +45,7 @@ repository = "https://github.com/lancedb/lancedb"
 
 [project.optional-dependencies]
 pylance = [
-    "pylance>=5.0.0b5",
+    "pylance>=5.0.0b3",
 ]
 tests = [
     "aiohttp>=3.9.0",
@@ -59,7 +59,7 @@ tests = [
     "polars>=0.19, <=1.3.0",
     "tantivy>=0.20.0",
     "pyarrow-stubs>=16.0",
-    "pylance>=5.0.0b5",
+    "pylance>=5.0.0b3",
     "requests>=2.31.0",
     "datafusion>=52,<53",
 ]

python/python/lancedb/_lancedb.pyi

@@ -151,9 +151,6 @@ class Connection(object):
     async def drop_all_tables(
         self, namespace_path: Optional[List[str]] = None
     ) -> None: ...
-    async def namespace_client_config(
-        self,
-    ) -> Dict[str, Any]: ...
 
 class Table:
     def name(self) -> str: ...

python/python/lancedb/db.py

@@ -23,13 +23,11 @@ from lancedb.embeddings.registry import EmbeddingFunctionRegistry
 from lancedb.common import data_to_reader, sanitize_uri, validate_schema
 from lancedb.background_loop import LOOP
 from lance_namespace import (
-    LanceNamespace,
     ListNamespacesResponse,
     CreateNamespaceResponse,
     DropNamespaceResponse,
     DescribeNamespaceResponse,
     ListTablesResponse,
-    connect as namespace_connect,
 )
 
 from . import __version__
@@ -509,26 +507,6 @@ class DBConnection(EnforceOverrides):
     def uri(self) -> str:
         return self._uri
 
-    def namespace_client(self) -> LanceNamespace:
-        """Get the equivalent namespace client for this connection.
-
-        For native storage connections, this returns a DirectoryNamespace
-        pointing to the same root with the same storage options.
-
-        For namespace connections, this returns the backing namespace client.
-
-        For enterprise (remote) connections, this returns a RestNamespace
-        with the same URI and authentication headers.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        raise NotImplementedError(
-            "namespace_client is not supported for this connection type"
-        )
-
 
 class LanceDBConnection(DBConnection):
     """
@@ -1066,20 +1044,6 @@ class LanceDBConnection(DBConnection):
             )
         )
 
-    @override
-    def namespace_client(self) -> LanceNamespace:
-        """Get the equivalent namespace client for this connection.
-
-        Returns a DirectoryNamespace pointing to the same root with the
-        same storage options.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        return LOOP.run(self._conn.namespace_client())
-
     @deprecation.deprecated(
         deprecated_in="0.15.1",
         removed_in="0.17",
@@ -1752,25 +1716,6 @@ class AsyncConnection(object):
             namespace_path = []
         await self._inner.drop_all_tables(namespace_path=namespace_path)
 
-    async def namespace_client(self) -> LanceNamespace:
-        """Get the equivalent namespace client for this connection.
-
-        For native storage connections, this returns a DirectoryNamespace
-        pointing to the same root with the same storage options.
-
-        For namespace connections, this returns the backing namespace client.
-
-        For enterprise (remote) connections, this returns a RestNamespace
-        with the same URI and authentication headers.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        config = await self._inner.namespace_client_config()
-        return namespace_connect(config["impl"], config["properties"])
-
     @deprecation.deprecated(
         deprecated_in="0.15.1",
         removed_in="0.17",

python/python/lancedb/namespace.py

@@ -890,20 +890,6 @@ class LanceNamespaceDBConnection(DBConnection):
             pushdown_operations=self._pushdown_operations,
         )
 
-    @override
-    def namespace_client(self) -> LanceNamespace:
-        """Get the namespace client for this connection.
-
-        For namespace connections, this returns the backing namespace client
-        that was provided during construction.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        return self._namespace_client
-
 
 class AsyncLanceNamespaceDBConnection:
     """
@@ -1401,19 +1387,6 @@ class AsyncLanceNamespaceDBConnection:
             page_token=response.page_token,
         )
 
-    async def namespace_client(self) -> LanceNamespace:
-        """Get the namespace client for this connection.
-
-        For namespace connections, this returns the backing namespace client
-        that was provided during construction.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        return self._namespace_client
-
 
 def connect_namespace(
     namespace_client_impl: str,

python/python/lancedb/pydantic.py

@@ -10,7 +10,6 @@ import sys
 import types
 from abc import ABC, abstractmethod
 from datetime import date, datetime
-from enum import Enum
 from typing import (
     TYPE_CHECKING,
     Any,
@@ -315,19 +314,6 @@ def _pydantic_type_to_arrow_type(tp: Any, field: FieldInfo) -> pa.DataType:
                 return pa.list_(pa.list_(tp.value_arrow_type(), tp.dim()))
             # For regular Vector
             return pa.list_(tp.value_arrow_type(), tp.dim())
-        if _safe_issubclass(tp, Enum):
-            # Map Enum to the Arrow type of its value.
-            # For string-valued enums, use dictionary encoding for efficiency.
-            # For integer enums, use the native type.
-            # Fall back to utf8 for mixed-type or empty enums.
-            value_types = {type(m.value) for m in tp}
-            if len(value_types) == 1:
-                value_type = value_types.pop()
-                if value_type is str:
-                    # Use dictionary encoding for string enums
-                    return pa.dictionary(pa.int32(), pa.utf8())
-                return _py_type_to_arrow_type(value_type, field)
-            return pa.utf8()
     return _py_type_to_arrow_type(tp, field)
 
 

python/python/lancedb/remote/db.py

@@ -24,7 +24,6 @@ from ..common import DATA
 from ..db import DBConnection, LOOP
 from ..embeddings import EmbeddingFunctionConfig
 from lance_namespace import (
-    LanceNamespace,
     CreateNamespaceResponse,
     DescribeNamespaceResponse,
     DropNamespaceResponse,
@@ -571,19 +570,6 @@ class RemoteDBConnection(DBConnection):
             )
         )
 
-    @override
-    def namespace_client(self) -> LanceNamespace:
-        """Get the equivalent namespace client for this connection.
-
-        Returns a RestNamespace with the same URI and authentication headers.
-
-        Returns
-        -------
-        LanceNamespace
-            The namespace client for this connection.
-        """
-        return LOOP.run(self._conn.namespace_client())
-
     async def close(self):
         """Close the connection to the database."""
         self._conn.close()

python/python/tests/test_db.py

@@ -3,7 +3,6 @@
 
 
 import re
-import sys
 from datetime import timedelta
 import os
 
@@ -1049,59 +1048,3 @@ def test_clone_table_deep_clone_fails(tmp_path):
     source_uri = os.path.join(tmp_path, "source.lance")
     with pytest.raises(Exception, match="Deep clone is not yet implemented"):
         db.clone_table("cloned", source_uri, is_shallow=False)
-
-
-@pytest.mark.skipif(sys.platform == "win32", reason="Namespace client issues")
-def test_namespace_client_native_storage(tmp_path):
-    """Test namespace_client() returns DirectoryNamespace for native storage."""
-    from lance.namespace import DirectoryNamespace
-
-    db = lancedb.connect(tmp_path)
-    ns_client = db.namespace_client()
-
-    assert isinstance(ns_client, DirectoryNamespace)
-    assert str(tmp_path) in ns_client.namespace_id()
-
-
-@pytest.mark.skipif(sys.platform == "win32", reason="Namespace client issues")
-def test_namespace_client_with_storage_options(tmp_path):
-    """Test namespace_client() preserves storage options."""
-    from lance.namespace import DirectoryNamespace
-
-    storage_options = {"timeout": "10s"}
-    db = lancedb.connect(tmp_path, storage_options=storage_options)
-    ns_client = db.namespace_client()
-
-    assert isinstance(ns_client, DirectoryNamespace)
-
-
-@pytest.mark.skipif(sys.platform == "win32", reason="Namespace client issues")
-def test_namespace_client_operations(tmp_path):
-    """Test that namespace_client() returns a functional namespace client."""
-    db = lancedb.connect(tmp_path)
-    ns_client = db.namespace_client()
-
-    # Create a table through the main db connection
-    data = [{"id": 1, "text": "hello", "vector": [1.0, 2.0]}]
-    db.create_table("test_table", data=data)
-
-    # Verify the namespace client can see the table
-    from lance_namespace import ListTablesRequest
-
-    # id=[] means root namespace
-    response = ns_client.list_tables(ListTablesRequest(id=[]))
-    # Tables can be strings or objects with name attribute
-    table_names = [t.name if hasattr(t, "name") else t for t in response.tables]
-    assert "test_table" in table_names
-
-
-@pytest.mark.skipif(sys.platform == "win32", reason="Namespace client issues")
-def test_namespace_client_namespace_connection(tmp_path):
-    """Test namespace_client() returns the backing client for namespace connections."""
-    from lance.namespace import DirectoryNamespace
-
-    db = lancedb.connect_namespace("dir", {"root": str(tmp_path)})
-    ns_client = db.namespace_client()
-
-    assert isinstance(ns_client, DirectoryNamespace)
-    assert str(tmp_path) in ns_client.namespace_id()

python/python/tests/test_pydantic.py

@@ -3,7 +3,6 @@
 
 import json
 from datetime import date, datetime
-from enum import Enum
 from typing import List, Optional, Tuple
 
 import pyarrow as pa
@@ -674,29 +673,3 @@ async def test_aliases_in_lance_model_async(mem_db_async):
     assert hasattr(model, "name")
     assert hasattr(model, "distance")
     assert model.distance < 0.01
-
-
-def test_enum_types():
-    """Enum fields should map to the Arrow type of their value (issue #1846)."""
-
-    class StrStatus(str, Enum):
-        PENDING = "pending"
-        RUNNING = "running"
-        DONE = "done"
-
-    class IntPriority(int, Enum):
-        LOW = 1
-        MEDIUM = 2
-        HIGH = 3
-
-    class TestModel(pydantic.BaseModel):
-        status: StrStatus
-        priority: IntPriority
-        opt_status: Optional[StrStatus] = None
-
-    schema = pydantic_to_schema(TestModel)
-
-    assert schema.field("status").type == pa.dictionary(pa.int32(), pa.utf8())
-    assert schema.field("priority").type == pa.int64()
-    assert schema.field("opt_status").type == pa.dictionary(pa.int32(), pa.utf8())
-    assert schema.field("opt_status").nullable

python/src/connection.rs

@@ -474,25 +474,6 @@ impl Connection {
             })
         })
     }
-
-    /// Get the configuration for constructing an equivalent namespace client.
-    /// Returns a dict with:
-    /// - "impl": "dir" for DirectoryNamespace, "rest" for RestNamespace
-    /// - "properties": configuration properties for the namespace
-    #[pyo3(signature = ())]
-    pub fn namespace_client_config(self_: PyRef<'_, Self>) -> PyResult<Bound<'_, PyAny>> {
-        let inner = self_.get_inner()?.clone();
-        let py = self_.py();
-        future_into_py(py, async move {
-            let (impl_type, properties) = inner.namespace_client_config().await.infer_error()?;
-            Python::attach(|py| -> PyResult<Py<PyDict>> {
-                let dict = PyDict::new(py);
-                dict.set_item("impl", impl_type)?;
-                dict.set_item("properties", properties)?;
-                Ok(dict.unbind())
-            })
-        })
-    }
 }
 
 #[pyfunction]

rust/lancedb/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "lancedb"
-version = "0.28.0-beta.1"
+version = "0.28.0-beta.0"
 edition.workspace = true
 description = "LanceDB: A serverless, low-latency vector database for AI applications"
 license.workspace = true

rust/lancedb/src/connection.rs

@@ -30,7 +30,10 @@ use crate::error::{Error, Result};
 #[cfg(feature = "remote")]
 use crate::remote::{
     client::ClientConfig,
-    db::{OPT_REMOTE_API_KEY, OPT_REMOTE_HOST_OVERRIDE, OPT_REMOTE_REGION},
+    db::{
+        OPT_REMOTE_API_KEY, OPT_REMOTE_HOST_OVERRIDE, OPT_REMOTE_REGION,
+        OPT_REMOTE_WAL_HOST_OVERRIDE,
+    },
 };
 use lance::io::ObjectStoreParams;
 pub use lance_encoding::version::LanceFileVersion;
@@ -541,16 +544,6 @@ impl Connection {
         self.internal.namespace_client().await
     }
 
-    /// Get the configuration for constructing an equivalent namespace client.
-    /// Returns (impl_type, properties) where:
-    /// - impl_type: "dir" for DirectoryNamespace, "rest" for RestNamespace
-    /// - properties: configuration properties for the namespace
-    pub async fn namespace_client_config(
-        &self,
-    ) -> Result<(String, std::collections::HashMap<String, String>)> {
-        self.internal.namespace_client_config().await
-    }
-
     /// List tables with pagination support
     pub async fn list_tables(&self, request: ListTablesRequest) -> Result<ListTablesResponse> {
         self.internal.list_tables(request).await
@@ -676,6 +669,24 @@ impl ConnectBuilder {
         self
     }
 
+    /// Set the WAL host override for routing merge_insert requests
+    /// to a separate WAL/ingest service.
+    ///
+    /// This option is only used when connecting to LanceDB Cloud (db:// URIs)
+    /// and will be ignored for other URIs.
+    ///
+    /// # Arguments
+    ///
+    /// * `wal_host_override` - The WAL host override to use for the connection
+    #[cfg(feature = "remote")]
+    pub fn wal_host_override(mut self, wal_host_override: &str) -> Self {
+        self.request.options.insert(
+            OPT_REMOTE_WAL_HOST_OVERRIDE.to_string(),
+            wal_host_override.to_string(),
+        );
+        self
+    }
+
     /// Set the database specific options
     ///
     /// See [crate::database::listing::ListingDatabaseOptions] for the options available for
@@ -829,6 +840,7 @@ impl ConnectBuilder {
             &api_key,
             &region,
             options.host_override,
+            options.wal_host_override,
             self.request.client_config,
             storage_options.into(),
         )?);

rust/lancedb/src/database.rs

@@ -265,13 +265,4 @@ pub trait Database:
     /// For ListingDatabase, it is the equivalent DirectoryNamespace.
     /// For RemoteDatabase, it is the equivalent RestNamespace.
     async fn namespace_client(&self) -> Result<Arc<dyn LanceNamespace>>;
-
-    /// Get the configuration for constructing an equivalent namespace client.
-    /// Returns (impl_type, properties) where:
-    /// - impl_type: "dir" for DirectoryNamespace, "rest" for RestNamespace
-    /// - properties: configuration properties for the namespace
-    ///
-    /// This is useful for Python bindings where we want to return a Python
-    /// namespace object rather than a Rust trait object.
-    async fn namespace_client_config(&self) -> Result<(String, HashMap<String, String>)>;
 }

rust/lancedb/src/database/listing.rs

@@ -1099,15 +1099,6 @@ impl Database for ListingDatabase {
         })?;
         Ok(Arc::new(namespace) as Arc<dyn lance_namespace::LanceNamespace>)
     }
-
-    async fn namespace_client_config(&self) -> Result<(String, HashMap<String, String>)> {
-        let mut properties = HashMap::new();
-        properties.insert("root".to_string(), self.uri.clone());
-        for (key, value) in &self.storage_options {
-            properties.insert(format!("storage.{}", key), value.clone());
-        }
-        Ok(("dir".to_string(), properties))
-    }
 }
 
 #[cfg(test)]

rust/lancedb/src/database/namespace.rs

@@ -45,10 +45,6 @@ pub struct LanceNamespaceDatabase {
     uri: String,
     // Operations to push down to the namespace server
     pushdown_operations: HashSet<PushdownOperation>,
-    // Namespace implementation type (e.g., "dir", "rest")
-    ns_impl: String,
-    // Namespace properties used to construct the namespace client
-    ns_properties: HashMap<String, String>,
 }
 
 impl LanceNamespaceDatabase {
@@ -78,8 +74,6 @@ impl LanceNamespaceDatabase {
             session,
             uri: format!("namespace://{}", ns_impl),
             pushdown_operations,
-            ns_impl: ns_impl.to_string(),
-            ns_properties,
         })
     }
 }
@@ -351,10 +345,6 @@ impl Database for LanceNamespaceDatabase {
     async fn namespace_client(&self) -> Result<Arc<dyn LanceNamespace>> {
         Ok(self.namespace.clone())
     }
-
-    async fn namespace_client_config(&self) -> Result<(String, HashMap<String, String>)> {
-        Ok((self.ns_impl.clone(), self.ns_properties.clone()))
-    }
 }
 
 #[cfg(test)]

rust/lancedb/src/remote/client.rs

@@ -190,6 +190,7 @@ pub struct RetryConfig {
 pub struct RestfulLanceDbClient<S: HttpSend = Sender> {
     client: reqwest::Client,
     host: String,
+    wal_host: String,
     pub(crate) retry_config: ResolvedRetryConfig,
     pub(crate) sender: S,
     pub(crate) id_delimiter: String,
@@ -200,6 +201,7 @@ impl<S: HttpSend> std::fmt::Debug for RestfulLanceDbClient<S> {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         f.debug_struct("RestfulLanceDbClient")
             .field("host", &self.host)
+            .field("wal_host", &self.wal_host)
             .field("retry_config", &self.retry_config)
             .field("sender", &self.sender)
             .field("id_delimiter", &self.id_delimiter)
@@ -285,6 +287,7 @@ impl RestfulLanceDbClient<Sender> {
         parsed_url: &ParsedDbUrl,
         region: &str,
         host_override: Option<String>,
+        wal_host_override: Option<String>,
         default_headers: HeaderMap,
         client_config: ClientConfig,
     ) -> Result<Self> {
@@ -372,11 +375,16 @@ impl RestfulLanceDbClient<Sender> {
             Some(host_override) => host_override,
             None => format!("https://{}.{}.api.lancedb.com", parsed_url.db_name, region),
         };
-        debug!("Created client for host: {}", host);
+        let wal_host = match wal_host_override {
+            Some(wal_host_override) => wal_host_override,
+            None => format!("https://{}.{}.wal.lancedb.com", parsed_url.db_name, region),
+        };
+        debug!("Created client for host: {}, wal_host: {}", host, wal_host);
         let retry_config = client_config.retry_config.clone().try_into()?;
         Ok(Self {
             client,
             host,
+            wal_host,
             retry_config,
             sender: Sender,
             id_delimiter: client_config
@@ -479,6 +487,12 @@ impl<S: HttpSend> RestfulLanceDbClient<S> {
         self.add_id_delimiter_query_param(builder)
     }
 
+    pub fn post_wal(&self, uri: &str) -> RequestBuilder {
+        let full_uri = format!("{}{}", self.wal_host, uri);
+        let builder = self.client.post(full_uri);
+        self.add_id_delimiter_query_param(builder)
+    }
+
     fn add_id_delimiter_query_param(&self, req: RequestBuilder) -> RequestBuilder {
         if self.id_delimiter != "$" {
             req.query(&[("delimiter", self.id_delimiter.clone())])
@@ -791,6 +805,7 @@ pub mod test_utils {
         RestfulLanceDbClient {
             client: reqwest::Client::new(),
             host: "http://localhost".to_string(),
+            wal_host: "http://localhost-wal".to_string(),
             retry_config: RetryConfig::default().try_into().unwrap(),
             sender: MockSender {
                 f: Arc::new(wrapper),
@@ -815,6 +830,7 @@ pub mod test_utils {
         RestfulLanceDbClient {
             client: reqwest::Client::new(),
             host: "http://localhost".to_string(),
+            wal_host: "http://localhost-wal".to_string(),
             retry_config: config.retry_config.try_into().unwrap(),
             sender: MockSender {
                 f: Arc::new(wrapper),
@@ -982,6 +998,7 @@ mod tests {
         let client = RestfulLanceDbClient {
             client: reqwest::Client::new(),
             host: "https://example.com".to_string(),
+            wal_host: "https://example.com".to_string(),
             retry_config: RetryConfig::default().try_into().unwrap(),
             sender: Sender,
             id_delimiter: "+".to_string(),
@@ -1017,6 +1034,7 @@ mod tests {
         let client = RestfulLanceDbClient {
             client: reqwest::Client::new(),
             host: "https://example.com".to_string(),
+            wal_host: "https://example.com".to_string(),
             retry_config: RetryConfig::default().try_into().unwrap(),
             sender: Sender,
             id_delimiter: "+".to_string(),
@@ -1054,6 +1072,7 @@ mod tests {
         let client = RestfulLanceDbClient {
             client: reqwest::Client::new(),
             host: "https://example.com".to_string(),
+            wal_host: "https://example.com".to_string(),
             retry_config: RetryConfig::default().try_into().unwrap(),
             sender: Sender,
             id_delimiter: "+".to_string(),

rust/lancedb/src/remote/db.rs

@@ -82,6 +82,7 @@ pub const OPT_REMOTE_PREFIX: &str = "remote_database_";
 pub const OPT_REMOTE_API_KEY: &str = "remote_database_api_key";
 pub const OPT_REMOTE_REGION: &str = "remote_database_region";
 pub const OPT_REMOTE_HOST_OVERRIDE: &str = "remote_database_host_override";
+pub const OPT_REMOTE_WAL_HOST_OVERRIDE: &str = "remote_database_wal_host_override";
 // TODO: add support for configuring client config via key/value options
 
 #[derive(Clone, Debug, Default)]
@@ -95,6 +96,11 @@ pub struct RemoteDatabaseOptions {
     /// This is required when connecting to LanceDB Enterprise and should be
     /// provided if using an on-premises LanceDB Enterprise instance.
     pub host_override: Option<String>,
+    /// The WAL host override
+    ///
+    /// When set, merge_insert operations using WAL routing will be sent to
+    /// this host instead of the auto-derived WAL host.
+    pub wal_host_override: Option<String>,
     /// Storage options configure the storage layer (e.g. S3, GCS, Azure, etc.)
     ///
     /// See available options at <https://lancedb.com/docs/storage/>
@@ -113,6 +119,7 @@ impl RemoteDatabaseOptions {
         let api_key = map.get(OPT_REMOTE_API_KEY).cloned();
         let region = map.get(OPT_REMOTE_REGION).cloned();
         let host_override = map.get(OPT_REMOTE_HOST_OVERRIDE).cloned();
+        let wal_host_override = map.get(OPT_REMOTE_WAL_HOST_OVERRIDE).cloned();
         let storage_options = map
             .iter()
             .filter(|(key, _)| !key.starts_with(OPT_REMOTE_PREFIX))
@@ -122,6 +129,7 @@ impl RemoteDatabaseOptions {
             api_key,
             region,
             host_override,
+            wal_host_override,
             storage_options,
         })
     }
@@ -141,6 +149,12 @@ impl DatabaseOptions for RemoteDatabaseOptions {
         if let Some(host_override) = &self.host_override {
             map.insert(OPT_REMOTE_HOST_OVERRIDE.to_string(), host_override.clone());
         }
+        if let Some(wal_host_override) = &self.wal_host_override {
+            map.insert(
+                OPT_REMOTE_WAL_HOST_OVERRIDE.to_string(),
+                wal_host_override.clone(),
+            );
+        }
     }
 }
 
@@ -185,6 +199,19 @@ impl RemoteDatabaseOptionsBuilder {
         self.options.host_override = Some(host_override);
         self
     }
+
+    /// Set the WAL host override
+    ///
+    /// When set, merge_insert operations using WAL routing will be sent to
+    /// this host instead of the auto-derived WAL host.
+    ///
+    /// # Arguments
+    ///
+    /// * `wal_host_override` - The WAL host override
+    pub fn wal_host_override(mut self, wal_host_override: String) -> Self {
+        self.options.wal_host_override = Some(wal_host_override);
+        self
+    }
 }
 
 #[derive(Debug)]
@@ -204,6 +231,7 @@ impl RemoteDatabase {
         api_key: &str,
         region: &str,
         host_override: Option<String>,
+        wal_host_override: Option<String>,
         client_config: ClientConfig,
         options: RemoteOptions,
     ) -> Result<Self> {
@@ -231,6 +259,7 @@ impl RemoteDatabase {
             &parsed,
             region,
             host_override,
+            wal_host_override,
             header_map,
             client_config.clone(),
         )?;
@@ -777,32 +806,6 @@ impl<S: HttpSend> Database for RemoteDatabase<S> {
         let namespace = builder.build();
         Ok(Arc::new(namespace) as Arc<dyn lance_namespace::LanceNamespace>)
     }
-
-    async fn namespace_client_config(&self) -> Result<(String, HashMap<String, String>)> {
-        let mut properties = HashMap::new();
-        properties.insert("uri".to_string(), self.client.host().to_string());
-        properties.insert("delimiter".to_string(), self.client.id_delimiter.clone());
-        for (key, value) in &self.namespace_headers {
-            properties.insert(format!("header.{}", key), value.clone());
-        }
-        // Add TLS configuration if present
-        if let Some(tls_config) = &self.tls_config {
-            if let Some(cert_file) = &tls_config.cert_file {
-                properties.insert("tls.cert_file".to_string(), cert_file.clone());
-            }
-            if let Some(key_file) = &tls_config.key_file {
-                properties.insert("tls.key_file".to_string(), key_file.clone());
-            }
-            if let Some(ssl_ca_cert) = &tls_config.ssl_ca_cert {
-                properties.insert("tls.ssl_ca_cert".to_string(), ssl_ca_cert.clone());
-            }
-            properties.insert(
-                "tls.assert_hostname".to_string(),
-                tls_config.assert_hostname.to_string(),
-            );
-        }
-        Ok(("rest".to_string(), properties))
-    }
 }
 
 /// RemoteOptions contains a subset of StorageOptions that are compatible with Remote LanceDB connections

rust/lancedb/src/remote/table.rs

@@ -1610,13 +1610,17 @@ impl<S: HttpSend> BaseTable for RemoteTable<S> {
         self.check_mutable().await?;
 
         let timeout = params.timeout;
+        let use_wal = params.use_wal;
 
         let query = MergeInsertRequest::try_from(params)?;
-        let mut request = self
-            .client
-            .post(&format!("/v1/table/{}/merge_insert/", self.identifier))
-            .query(&query)
-            .header(CONTENT_TYPE, ARROW_STREAM_CONTENT_TYPE);
+        let path = format!("/v1/table/{}/merge_insert/", self.identifier);
+        let mut request = if use_wal {
+            self.client.post_wal(&path)
+        } else {
+            self.client.post(&path)
+        }
+        .query(&query)
+        .header(CONTENT_TYPE, ARROW_STREAM_CONTENT_TYPE);
 
         if let Some(timeout) = timeout {
             // (If it doesn't fit into u64, it's not worth sending anyways.)
@@ -2705,6 +2709,43 @@ mod tests {
         }
     }
 
+    #[tokio::test]
+    async fn test_merge_insert_use_wal() {
+        let batch = RecordBatch::try_new(
+            Arc::new(Schema::new(vec![Field::new("a", DataType::Int32, false)])),
+            vec![Arc::new(Int32Array::from(vec![1, 2, 3]))],
+        )
+        .unwrap();
+        let data: Box<dyn RecordBatchReader + Send> = Box::new(RecordBatchIterator::new(
+            [Ok(batch.clone())],
+            batch.schema(),
+        ));
+
+        let table = Table::new_with_handler("my_table", move |request| {
+            if request.url().path() == "/v1/table/my_table/merge_insert/" {
+                // Verify the request was sent to the WAL host
+                assert_eq!(
+                    request.url().host_str().unwrap(),
+                    "localhost-wal",
+                    "merge_insert with use_wal should route to WAL host"
+                );
+
+                http::Response::builder()
+                    .status(200)
+                    .body(r#"{"version": 1, "num_deleted_rows": 0, "num_inserted_rows": 3, "num_updated_rows": 0}"#)
+                    .unwrap()
+            } else {
+                panic!("Unexpected request path: {}", request.url().path());
+            }
+        });
+
+        let mut builder = table.merge_insert(&["some_col"]);
+        builder.use_wal(true);
+        let result = builder.execute(data).await.unwrap();
+
+        assert_eq!(result.num_inserted_rows, 3);
+    }
+
     #[tokio::test]
     async fn test_merge_insert_retries_on_409() {
         let batch = RecordBatch::try_new(

rust/lancedb/src/table/merge.rs

@@ -55,6 +55,7 @@ pub struct MergeInsertBuilder {
     pub(crate) when_not_matched_by_source_delete_filt: Option<String>,
     pub(crate) timeout: Option<Duration>,
     pub(crate) use_index: bool,
+    pub(crate) use_wal: bool,
 }
 
 impl MergeInsertBuilder {
@@ -69,6 +70,7 @@ impl MergeInsertBuilder {
             when_not_matched_by_source_delete_filt: None,
             timeout: None,
             use_index: true,
+            use_wal: false,
         }
     }
 
@@ -148,6 +150,18 @@ impl MergeInsertBuilder {
         self
     }
 
+    /// Controls whether to route the merge insert operation through the WAL host.
+    ///
+    /// When set to `true`, the operation will be sent to the WAL host instead of
+    /// the main API host. The WAL host is auto-derived from the database connection
+    /// or can be explicitly set via [`crate::connection::ConnectBuilder::wal_host_override`].
+    ///
+    /// Defaults to `false`.
+    pub fn use_wal(&mut self, use_wal: bool) -> &mut Self {
+        self.use_wal = use_wal;
+        self
+    }
+
     /// Executes the merge insert operation
     ///
     /// Returns version and statistics about the merge operation including the number of rows