Fix Node 18 CI docs step by including optional dependencies

The "Check docs" step ran `npm ci` without `--include=optional`, which removed @huggingface/transformers. Typedoc then failed because it couldn't resolve the type imports from that package. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Update lance dependency to 5.0.0-rc.1
2026-05-20 21:40:43 +00:00 · 2026-04-13 13:49:45 -05:00 · 2026-04-13 10:50:01 -05:00
49 changed files with 878 additions and 940 deletions
--- a/.bumpversion.toml
+++ b/.bumpversion.toml
@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.28.0-beta.8"
+current_version = "0.28.0-beta.5"
 parse = """(?x)
    (?P<major>0|[1-9]\\d*)\\.
    (?P<minor>0|[1-9]\\d*)\\.
--- a/.github/ISSUE_TEMPLATE/documentation.yml
+++ b/.github/ISSUE_TEMPLATE/documentation.yml
@@ -18,6 +18,6 @@ body:
      label: Link
      description: >
        Provide a link to the existing documentation, if applicable.
-      placeholder: ex. https://docs.lancedb.com/tables/...
+      placeholder: ex. https://lancedb.com/docs/tables/...
    validations:
      required: false
--- a/.github/workflows/nodejs.yml
+++ b/.github/workflows/nodejs.yml
@@ -126,7 +126,7 @@ jobs:
        # We run this as part of the job because the binary needs to be built
        # first to export the types of the native code.
        set -e
-        npm ci
+        npm ci --include=optional
        npm run docs
        if ! git diff --exit-code -- ../ ':(exclude)Cargo.lock'; then
          echo "Docs need to be updated"
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -137,6 +137,15 @@ dependencies = [
 "object",
 ]

+[[package]]
+name = "arc-swap"
+version = "1.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a07d1f37ff60921c83bdfc7407723bdefe89b44b98a9b772f225c8f9d67141a6"
+dependencies = [
+ "rustversion",
+]
+
 [[package]]
 name = "argminmax"
 version = "0.6.3"
@@ -293,7 +302,7 @@ dependencies = [
 "arrow-schema",
 "arrow-select",
 "flatbuffers",
- "lz4_flex",
+ "lz4_flex 0.12.1",
 "zstd",
 ]

@@ -1269,6 +1278,31 @@ dependencies = [
 "generic-array",
 ]

+[[package]]
+name = "bon"
+version = "3.9.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f47dbe92550676ee653353c310dfb9cf6ba17ee70396e1f7cf0a2020ad49b2fe"
+dependencies = [
+ "bon-macros",
+ "rustversion",
+]
+
+[[package]]
+name = "bon-macros"
+version = "3.9.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "519bd3116aeeb42d5372c29d982d16d0170d3d4a5ed85fc7dd91642ffff3c67c"
+dependencies = [
+ "darling 0.20.11",
+ "ident_case",
+ "prettyplease",
+ "proc-macro2",
+ "quote",
+ "rustversion",
+ "syn 2.0.117",
+]
+
 [[package]]
 name = "brotli"
 version = "3.5.0"
@@ -1438,6 +1472,12 @@ dependencies = [
 "shlex",
 ]

+[[package]]
+name = "census"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4f4c707c6a209cbe82d10abd08e1ea8995e9ea937d2550646e02798948992be0"
+
 [[package]]
 name = "cfg-if"
 version = "1.0.4"
@@ -1755,7 +1795,7 @@ dependencies = [
 "crossterm_winapi",
 "document-features",
 "parking_lot",
- "rustix",
+ "rustix 1.1.4",
 "winapi",
 ]

@@ -2674,6 +2714,12 @@ dependencies = [
 "litrs",
 ]

+[[package]]
+name = "downcast-rs"
+version = "2.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "117240f60069e65410b3ae1bb213295bd828f707b5bec6596a1afc8793ce0cbc"
+
 [[package]]
 name = "dtor"
 version = "0.1.1"
@@ -2909,6 +2955,12 @@ version = "0.2.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f8eb564c5c7423d25c886fb561d1e4ee69f72354d16918afa32c08811f6b6a55"

+[[package]]
+name = "fastdivide"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9afc2bd4d5a73106dd53d10d73d3401c2f32730ba2c0b93ddb888a8983680471"
+
 [[package]]
 name = "fastrand"
 version = "2.3.0"
@@ -3002,6 +3054,16 @@ dependencies = [
 "percent-encoding",
 ]

+[[package]]
+name = "fs4"
+version = "0.8.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f7e180ac76c23b45e767bd7ae9579bc0bb458618c4bc71835926e098e61d15f8"
+dependencies = [
+ "rustix 0.38.44",
+ "windows-sys 0.52.0",
+]
+
 [[package]]
 name = "fs_extra"
 version = "1.3.0"
@@ -3010,8 +3072,8 @@ checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c"

 [[package]]
 name = "fsst"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-array",
 "rand 0.9.2",
@@ -3498,6 +3560,12 @@ dependencies = [
 "windows-sys 0.61.2",
 ]

+[[package]]
+name = "htmlescape"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e9025058dae765dee5070ec375f591e2ba14638c63feff74f13805a72e523163"
+
 [[package]]
 name = "http"
 version = "0.2.12"
@@ -4066,14 +4134,13 @@ dependencies = [

 [[package]]
 name = "lance"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-arith",
 "arrow-array",
 "arrow-buffer",
- "arrow-cast",
 "arrow-ipc",
 "arrow-ord",
 "arrow-row",
@@ -4110,14 +4177,12 @@ dependencies = [
 "lance-linalg",
 "lance-namespace",
 "lance-table",
- "lance-tokenizer",
 "log",
 "moka",
 "object_store",
 "permutation",
 "pin-project",
 "prost",
- "prost-build",
 "prost-types",
 "rand 0.9.2",
 "roaring",
@@ -4125,6 +4190,7 @@ dependencies = [
 "serde",
 "serde_json",
 "snafu 0.9.0",
+ "tantivy",
 "tokio",
 "tokio-stream",
 "tokio-util",
@@ -4135,8 +4201,8 @@ dependencies = [

 [[package]]
 name = "lance-arrow"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-array",
 "arrow-buffer",
@@ -4157,8 +4223,8 @@ dependencies = [

 [[package]]
 name = "lance-bitpacking"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrayref",
 "paste",
@@ -4167,8 +4233,8 @@ dependencies = [

 [[package]]
 name = "lance-core"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-array",
 "arrow-buffer",
@@ -4205,13 +4271,12 @@ dependencies = [

 [[package]]
 name = "lance-datafusion"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-array",
 "arrow-buffer",
- "arrow-cast",
 "arrow-ord",
 "arrow-schema",
 "arrow-select",
@@ -4237,8 +4302,8 @@ dependencies = [

 [[package]]
 name = "lance-datagen"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-array",
@@ -4256,8 +4321,8 @@ dependencies = [

 [[package]]
 name = "lance-encoding"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-arith",
 "arrow-array",
@@ -4294,8 +4359,8 @@ dependencies = [

 [[package]]
 name = "lance-file"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-arith",
 "arrow-array",
@@ -4327,8 +4392,8 @@ dependencies = [

 [[package]]
 name = "lance-index"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-arith",
@@ -4365,7 +4430,6 @@ dependencies = [
 "lance-io",
 "lance-linalg",
 "lance-table",
- "lance-tokenizer",
 "libm",
 "log",
 "ndarray",
@@ -4383,6 +4447,7 @@ dependencies = [
 "serde_json",
 "smallvec",
 "snafu 0.9.0",
+ "tantivy",
 "tempfile",
 "tokio",
 "tracing",
@@ -4392,8 +4457,8 @@ dependencies = [

 [[package]]
 name = "lance-io"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-arith",
@@ -4437,8 +4502,8 @@ dependencies = [

 [[package]]
 name = "lance-linalg"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-array",
 "arrow-buffer",
@@ -4454,8 +4519,8 @@ dependencies = [

 [[package]]
 name = "lance-namespace"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "async-trait",
@@ -4468,8 +4533,8 @@ dependencies = [

 [[package]]
 name = "lance-namespace-impls"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-ipc",
@@ -4514,8 +4579,8 @@ dependencies = [

 [[package]]
 name = "lance-table"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow",
 "arrow-array",
@@ -4554,8 +4619,8 @@ dependencies = [

 [[package]]
 name = "lance-testing"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
+version = "5.0.0-rc.1"
+source = "git+https://github.com/lance-format/lance.git?tag=v5.0.0-rc.1#d130b036a62a5d8a904dfbe711d3f7b91b132194"
 dependencies = [
 "arrow-array",
 "arrow-schema",
@@ -4564,19 +4629,9 @@ dependencies = [
 "rand 0.9.2",
 ]

-[[package]]
-name = "lance-tokenizer"
-version = "6.0.0-beta.1"
-source = "git+https://github.com/lance-format/lance.git?tag=v6.0.0-beta.1#c7a7d3a0e944646e793d297d4a2e2cf7e4fb28a3"
-dependencies = [
- "rust-stemmers",
- "serde",
- "unicode-normalization",
-]
-
 [[package]]
 name = "lancedb"
-version = "0.28.0-beta.7"
+version = "0.28.0-beta.5"
 dependencies = [
 "ahash",
 "anyhow",
@@ -4658,7 +4713,7 @@ dependencies = [

 [[package]]
 name = "lancedb-nodejs"
-version = "0.28.0-beta.7"
+version = "0.28.0-beta.5"
 dependencies = [
 "arrow-array",
 "arrow-buffer",
@@ -4680,7 +4735,7 @@ dependencies = [

 [[package]]
 name = "lancedb-python"
-version = "0.31.0-beta.7"
+version = "0.31.0-beta.5"
 dependencies = [
 "arrow",
 "async-trait",
@@ -4718,6 +4773,12 @@ version = "0.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "09edd9e8b54e49e587e4f6295a7d29c3ea94d469cb40ab8ca70b288248a81db2"

+[[package]]
+name = "levenshtein_automata"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0c2cdeb66e45e9f36bfad5bbdb4d2384e70936afbee843c6f6543f0c551ebb25"
+
 [[package]]
 name = "lexical-core"
 version = "1.0.6"
@@ -4806,6 +4867,12 @@ dependencies = [
 "libc",
 ]

+[[package]]
+name = "linux-raw-sys"
+version = "0.4.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d26c52dbd32dccf2d10cac7725f8eae5296885fb5703b261f7d0a0739ec807ab"
+
 [[package]]
 name = "linux-raw-sys"
 version = "0.12.1"
@@ -4886,6 +4953,12 @@ dependencies = [
 "libc",
 ]

+[[package]]
+name = "lz4_flex"
+version = "0.11.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "373f5eceeeab7925e0c1098212f2fbc4d416adec9d35051a6ab251e824c1854a"
+
 [[package]]
 name = "lz4_flex"
 version = "0.12.1"
@@ -4960,6 +5033,15 @@ dependencies = [
 "digest",
 ]

+[[package]]
+name = "measure_time"
+version = "0.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "51c55d61e72fc3ab704396c5fa16f4c184db37978ae4e94ca8959693a235fc0e"
+dependencies = [
+ "log",
+]
+
 [[package]]
 name = "memchr"
 version = "2.8.0"
@@ -5113,6 +5195,12 @@ dependencies = [
 "target-features",
 ]

+[[package]]
+name = "murmurhash32"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2195bf6aa996a481483b29d62a7663eed3fe39600c460e323f8ff41e90bdd89b"
+
 [[package]]
 name = "napi"
 version = "3.8.3"
@@ -5401,6 +5489,12 @@ version = "1.70.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "384b8ab6d37215f3c5301a95a4accb5d64aa607f1fcb26a11b5303878451b4fe"

+[[package]]
+name = "oneshot"
+version = "0.1.13"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "269bca4c2591a28585d6bf10d9ed0332b7d76900a1b02bec41bdc3a2cdcda107"
+
 [[package]]
 name = "onig"
 version = "6.5.1"
@@ -5490,6 +5584,15 @@ version = "0.5.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "1a80800c0488c3a21695ea981a54918fbb37abf04f4d0720c453632255e2ff0e"

+[[package]]
+name = "ownedbytes"
+version = "0.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2fbd56f7631767e61784dc43f8580f403f4475bd4aaa4da003e6295e1bab4a7e"
+dependencies = [
+ "stable_deref_trait",
+]
+
 [[package]]
 name = "p256"
 version = "0.11.1"
@@ -6944,6 +7047,19 @@ dependencies = [
 "semver",
 ]

+[[package]]
+name = "rustix"
+version = "0.38.44"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fdb5bc1ae2baa591800df16c9ca78619bf65c0488b41b96ccec5d11220d8c154"
+dependencies = [
+ "bitflags",
+ "errno",
+ "libc",
+ "linux-raw-sys 0.4.15",
+ "windows-sys 0.59.0",
+]
+
 [[package]]
 name = "rustix"
 version = "1.1.4"
@@ -6953,7 +7069,7 @@ dependencies = [
 "bitflags",
 "errno",
 "libc",
- "linux-raw-sys",
+ "linux-raw-sys 0.12.1",
 "windows-sys 0.59.0",
 ]

@@ -7418,6 +7534,15 @@ version = "1.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b2aa850e253778c88a04c3d7323b043aeda9d3e30d5971937c1855769763678e"

+[[package]]
+name = "sketches-ddsketch"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0c6f73aeb92d671e0cc4dca167e59b2deb6387c375391bc99ee743f326994a2b"
+dependencies = [
+ "serde",
+]
+
 [[package]]
 name = "slab"
 version = "0.4.12"
@@ -7790,6 +7915,152 @@ version = "0.2.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7b2093cf4c8eb1e67749a6762251bc9cd836b6fc171623bd0a9d324d37af2417"

+[[package]]
+name = "tantivy"
+version = "0.24.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "64a966cb0e76e311f09cf18507c9af192f15d34886ee43d7ba7c7e3803660c43"
+dependencies = [
+ "aho-corasick",
+ "arc-swap",
+ "base64 0.22.1",
+ "bitpacking",
+ "bon",
+ "byteorder",
+ "census",
+ "crc32fast",
+ "crossbeam-channel",
+ "downcast-rs",
+ "fastdivide",
+ "fnv",
+ "fs4",
+ "htmlescape",
+ "hyperloglogplus",
+ "itertools 0.14.0",
+ "levenshtein_automata",
+ "log",
+ "lru",
+ "lz4_flex 0.11.6",
+ "measure_time",
+ "memmap2 0.9.10",
+ "once_cell",
+ "oneshot",
+ "rayon",
+ "regex",
+ "rust-stemmers",
+ "rustc-hash",
+ "serde",
+ "serde_json",
+ "sketches-ddsketch",
+ "smallvec",
+ "tantivy-bitpacker",
+ "tantivy-columnar",
+ "tantivy-common",
+ "tantivy-fst",
+ "tantivy-query-grammar",
+ "tantivy-stacker",
+ "tantivy-tokenizer-api",
+ "tempfile",
+ "thiserror 2.0.18",
+ "time",
+ "uuid",
+ "winapi",
+]
+
+[[package]]
+name = "tantivy-bitpacker"
+version = "0.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1adc286a39e089ae9938935cd488d7d34f14502544a36607effd2239ff0e2494"
+dependencies = [
+ "bitpacking",
+]
+
+[[package]]
+name = "tantivy-columnar"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6300428e0c104c4f7db6f95b466a6f5c1b9aece094ec57cdd365337908dc7344"
+dependencies = [
+ "downcast-rs",
+ "fastdivide",
+ "itertools 0.14.0",
+ "serde",
+ "tantivy-bitpacker",
+ "tantivy-common",
+ "tantivy-sstable",
+ "tantivy-stacker",
+]
+
+[[package]]
+name = "tantivy-common"
+version = "0.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e91b6ea6090ce03dc72c27d0619e77185d26cc3b20775966c346c6d4f7e99d7f"
+dependencies = [
+ "async-trait",
+ "byteorder",
+ "ownedbytes",
+ "serde",
+ "time",
+]
+
+[[package]]
+name = "tantivy-fst"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d60769b80ad7953d8a7b2c70cdfe722bbcdcac6bccc8ac934c40c034d866fc18"
+dependencies = [
+ "byteorder",
+ "regex-syntax",
+ "utf8-ranges",
+]
+
+[[package]]
+name = "tantivy-query-grammar"
+version = "0.24.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e810cdeeebca57fc3f7bfec5f85fdbea9031b2ac9b990eb5ff49b371d52bbe6a"
+dependencies = [
+ "nom 7.1.3",
+ "serde",
+ "serde_json",
+]
+
+[[package]]
+name = "tantivy-sstable"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "709f22c08a4c90e1b36711c1c6cad5ae21b20b093e535b69b18783dd2cb99416"
+dependencies = [
+ "futures-util",
+ "itertools 0.14.0",
+ "tantivy-bitpacker",
+ "tantivy-common",
+ "tantivy-fst",
+ "zstd",
+]
+
+[[package]]
+name = "tantivy-stacker"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2bcdebb267671311d1e8891fd9d1301803fdb8ad21ba22e0a30d0cab49ba59c1"
+dependencies = [
+ "murmurhash32",
+ "rand_distr 0.4.3",
+ "tantivy-common",
+]
+
+[[package]]
+name = "tantivy-tokenizer-api"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dfa942fcee81e213e09715bbce8734ae2180070b97b33839a795ba1de201547d"
+dependencies = [
+ "serde",
+]
+
 [[package]]
 name = "tap"
 version = "1.0.1"
@@ -7817,7 +8088,7 @@ dependencies = [
 "fastrand",
 "getrandom 0.4.2",
 "once_cell",
- "rustix",
+ "rustix 1.1.4",
 "windows-sys 0.59.0",
 ]

@@ -8269,15 +8540,6 @@ version = "1.0.24"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e6e4313cd5fcd3dad5cafa179702e2b244f760991f45397d14d4ebf38247da75"

-[[package]]
-name = "unicode-normalization"
-version = "0.1.25"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5fd4f6878c9cb28d874b009da9e8d183b5abc80117c40bbd187a1fde336be6e8"
-dependencies = [
- "tinyvec",
-]
-
 [[package]]
 name = "unicode-normalization-alignments"
 version = "0.1.12"
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -15,20 +15,20 @@ categories = ["database-implementations"]
 rust-version = "1.91.0"

 [workspace.dependencies]
-lance = { "version" = "=6.0.0-beta.1", default-features = false, "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-core = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-datagen = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-file = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-io = { "version" = "=6.0.0-beta.1", default-features = false, "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-index = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-linalg = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace-impls = { "version" = "=6.0.0-beta.1", default-features = false, "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-table = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-testing = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-datafusion = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-encoding = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
-lance-arrow = { "version" = "=6.0.0-beta.1", "tag" = "v6.0.0-beta.1", "git" = "https://github.com/lance-format/lance.git" }
+lance = { "version" = "=5.0.0-rc.1", default-features = false, "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-core = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-datagen = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-file = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-io = { "version" = "=5.0.0-rc.1", default-features = false, "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-index = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-linalg = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-namespace = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-namespace-impls = { "version" = "=5.0.0-rc.1", default-features = false, "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-table = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-testing = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-datafusion = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-encoding = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "git" = "https://github.com/lance-format/lance.git" }
+lance-arrow = { "version" = "=5.0.0-rc.1", "tag" = "v5.0.0-rc.1", "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 }
--- a/README.md
+++ b/README.md
@@ -15,7 +15,7 @@

 # **The Multimodal AI Lakehouse**

-[**How to Install** ](#how-to-install) ✦ [**Detailed Documentation**](https://docs.lancedb.com) ✦ [**Tutorials and Recipes**](https://github.com/lancedb/vectordb-recipes/tree/main) ✦  [**Contributors**](#contributors) 
+[**How to Install** ](#how-to-install) ✦ [**Detailed Documentation**](https://lancedb.com/docs) ✦ [**Tutorials and Recipes**](https://github.com/lancedb/vectordb-recipes/tree/main) ✦  [**Contributors**](#contributors) 

 **The ultimate multimodal data platform for AI/ML applications.** 

@@ -57,7 +57,7 @@ LanceDB is a central location where developers can build, train and analyze thei

 ## **How to Install**:

-Follow the [Quickstart](https://docs.lancedb.com/quickstart) doc to set up LanceDB locally. 
+Follow the [Quickstart](https://lancedb.com/docs/quickstart/) doc to set up LanceDB locally. 

 **API & SDK:** We also support Python, Typescript and Rust SDKs

--- a/docs/README.md
+++ b/docs/README.md
@@ -1,6 +1,6 @@
 # LanceDB Documentation

-LanceDB docs are available at [docs.lancedb.com](https://docs.lancedb.com).
+LanceDB docs are available at [lancedb.com/docs](https://lancedb.com/docs).

 The SDK docs are built and deployed automatically by [Github Actions](../.github/workflows/docs.yml)
 whenever a commit is pushed to the `main` branch. So it is possible for the docs to show
--- a/docs/src/java/java.md
+++ b/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.8</version>
+    <version>0.28.0-beta.5</version>
 </dependency>
 ```

--- a/docs/src/js/README.md
+++ b/docs/src/js/README.md
@@ -34,7 +34,7 @@ const results = await table.vectorSearch([0.1, 0.3]).limit(20).toArray();
 console.log(results);
 ```

-The [quickstart](https://docs.lancedb.com/quickstart/) contains more complete examples.
+The [quickstart](https://lancedb.com/docs/quickstart/basic-usage/) contains more complete examples.

 ## Development

--- a/docs/src/js/interfaces/ConnectionOptions.md
+++ b/docs/src/js/interfaces/ConnectionOptions.md
@@ -89,4 +89,4 @@ optional storageOptions: Record<string, string>;

 (For LanceDB OSS only): configuration for object storage.

-The available options are described at https://docs.lancedb.com/storage/
+The available options are described at https://lancedb.com/docs/storage/
--- a/docs/src/js/interfaces/CreateTableOptions.md
+++ b/docs/src/js/interfaces/CreateTableOptions.md
@@ -97,4 +97,4 @@ Configuration for object storage.
 Options already set on the connection will be inherited by the table,
 but can be overridden here.

-The available options are described at https://docs.lancedb.com/storage/
+The available options are described at https://lancedb.com/docs/storage/
--- a/docs/src/js/interfaces/OpenTableOptions.md
+++ b/docs/src/js/interfaces/OpenTableOptions.md
@@ -42,4 +42,4 @@ Configuration for object storage.
 Options already set on the connection will be inherited by the table,
 but can be overridden here.

-The available options are described at https://docs.lancedb.com/storage/
+The available options are described at https://lancedb.com/docs/storage/
--- a/java/lancedb-core/pom.xml
+++ b/java/lancedb-core/pom.xml
@@ -8,7 +8,7 @@
    <parent>
      <groupId>com.lancedb</groupId>
      <artifactId>lancedb-parent</artifactId>
-      <version>0.28.0-beta.8</version>
+      <version>0.28.0-beta.5</version>
      <relativePath>../pom.xml</relativePath>
    </parent>

--- a/java/pom.xml
+++ b/java/pom.xml
@@ -6,7 +6,7 @@

    <groupId>com.lancedb</groupId>
    <artifactId>lancedb-parent</artifactId>
-    <version>0.28.0-beta.8</version>
+    <version>0.28.0-beta.5</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>6.0.0-beta.1</lance-core.version>
+        <lance-core.version>5.1.0-beta.3</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>
--- a/nodejs/Cargo.toml
+++ b/nodejs/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "lancedb-nodejs"
 edition.workspace = true
-version = "0.28.0-beta.8"
+version = "0.28.0-beta.5"
 license.workspace = true
 description.workspace = true
 repository.workspace = true
--- a/nodejs/README.md
+++ b/nodejs/README.md
@@ -30,7 +30,7 @@ const results = await table.vectorSearch([0.1, 0.3]).limit(20).toArray();
 console.log(results);
 ```

-The [quickstart](https://docs.lancedb.com/quickstart/) contains more complete examples.
+The [quickstart](https://lancedb.com/docs/quickstart/basic-usage/) contains more complete examples.

 ## Development

--- a/nodejs/lancedb/connection.ts
+++ b/nodejs/lancedb/connection.ts
@@ -42,7 +42,7 @@ export interface CreateTableOptions {
   * Options already set on the connection will be inherited by the table,
   * but can be overridden here.
   *
-   * The available options are described at https://docs.lancedb.com/storage/
+   * The available options are described at https://lancedb.com/docs/storage/
   */
  storageOptions?: Record<string, string>;

@@ -78,7 +78,7 @@ export interface OpenTableOptions {
   * Options already set on the connection will be inherited by the table,
   * but can be overridden here.
   *
-   * The available options are described at https://docs.lancedb.com/storage/
+   * The available options are described at https://lancedb.com/docs/storage/
   */
  storageOptions?: Record<string, string>;
  /**
--- a/nodejs/npm/darwin-arm64/package.json
+++ b/nodejs/npm/darwin-arm64/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-darwin-arm64",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["darwin"],
 	"cpu": ["arm64"],
 	"main": "lancedb.darwin-arm64.node",
--- a/nodejs/npm/linux-arm64-gnu/package.json
+++ b/nodejs/npm/linux-arm64-gnu/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-gnu",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-gnu.node",
--- a/nodejs/npm/linux-arm64-musl/package.json
+++ b/nodejs/npm/linux-arm64-musl/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-musl",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-musl.node",
--- a/nodejs/npm/linux-x64-gnu/package.json
+++ b/nodejs/npm/linux-x64-gnu/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-gnu",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-gnu.node",
--- a/nodejs/npm/linux-x64-musl/package.json
+++ b/nodejs/npm/linux-x64-musl/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-musl",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-musl.node",
--- a/nodejs/npm/win32-arm64-msvc/package.json
+++ b/nodejs/npm/win32-arm64-msvc/package.json
@@ -1,6 +1,6 @@
 {
  "name": "@lancedb/lancedb-win32-arm64-msvc",
-  "version": "0.28.0-beta.8",
+  "version": "0.28.0-beta.5",
  "os": [
    "win32"
  ],
--- a/nodejs/npm/win32-x64-msvc/package.json
+++ b/nodejs/npm/win32-x64-msvc/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-win32-x64-msvc",
-	"version": "0.28.0-beta.8",
+	"version": "0.28.0-beta.5",
 	"os": ["win32"],
 	"cpu": ["x64"],
 	"main": "lancedb.win32-x64-msvc.node",
--- a/nodejs/package-lock.json
+++ b/nodejs/package-lock.json
@@ -1,12 +1,12 @@
 {
  "name": "@lancedb/lancedb",
-  "version": "0.28.0-beta.7",
+  "version": "0.28.0-beta.5",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "@lancedb/lancedb",
-      "version": "0.28.0-beta.7",
+      "version": "0.28.0-beta.5",
      "cpu": [
        "x64",
        "arm64"
--- a/nodejs/package.json
+++ b/nodejs/package.json
@@ -11,7 +11,7 @@
    "ann"
  ],
  "private": false,
-  "version": "0.28.0-beta.8",
+  "version": "0.28.0-beta.5",
  "main": "dist/index.js",
  "exports": {
    ".": "./dist/index.js",
--- a/nodejs/src/lib.rs
+++ b/nodejs/src/lib.rs
@@ -35,7 +35,7 @@ pub struct ConnectionOptions {
    pub read_consistency_interval: Option<f64>,
    /// (For LanceDB OSS only): configuration for object storage.
    ///
-    /// The available options are described at https://docs.lancedb.com/storage/
+    /// The available options are described at https://lancedb.com/docs/storage/
    pub storage_options: Option<HashMap<String, String>>,
    /// (For LanceDB OSS only): the session to use for this connection. Holds
    /// shared caches and other session-specific state.
--- a/python/.bumpversion.toml
+++ b/python/.bumpversion.toml
@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.31.0-beta.8"
+current_version = "0.31.0-beta.5"
 parse = """(?x)
    (?P<major>0|[1-9]\\d*)\\.
    (?P<minor>0|[1-9]\\d*)\\.
--- a/python/Cargo.toml
+++ b/python/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "lancedb-python"
-version = "0.31.0-beta.8"
+version = "0.31.0-beta.5"
 edition.workspace = true
 description = "Python bindings for LanceDB"
 license.workspace = true
--- a/python/python/lancedb/init.py
+++ b/python/python/lancedb/init.py
@@ -110,7 +110,7 @@ def connect(
        default configuration is used.
    storage_options: dict, optional
        Additional options for the storage backend. See available options at
-        <https://docs.lancedb.com/storage/>
+        <https://lancedb.com/docs/storage/>
    session: Session, optional
        (For LanceDB OSS only)
        A session to use for this connection. Sessions allow you to configure
@@ -336,7 +336,7 @@ async def connect_async(
        default configuration is used.
    storage_options: dict, optional
        Additional options for the storage backend. See available options at
-        <https://docs.lancedb.com/storage/>
+        <https://lancedb.com/docs/storage/>
    session: Session, optional
        (For LanceDB OSS only)
        A session to use for this connection. Sessions allow you to configure
--- a/python/python/lancedb/common.py
+++ b/python/python/lancedb/common.py
@@ -96,7 +96,7 @@ def data_to_reader(
            f"Unknown data type {type(data)}. "
            "Supported types: list of dicts, pandas DataFrame, polars DataFrame, "
            "pyarrow Table/RecordBatch, or Pydantic models. "
-            "See https://docs.lancedb.com/tables/ for examples."
+            "See https://lancedb.com/docs/tables/ for examples."
        )


--- a/python/python/lancedb/db.py
+++ b/python/python/lancedb/db.py
@@ -282,7 +282,7 @@ class DBConnection(EnforceOverrides):
            Additional options for the storage backend. Options already set on the
            connection will be inherited by the table, but can be overridden here.
            See available options at
-            <https://docs.lancedb.com/storage/>
+            <https://lancedb.com/docs/storage/>

            To enable stable row IDs (row IDs remain stable after compaction,
            update, delete, and merges), set `new_table_enable_stable_row_ids`
@@ -433,7 +433,7 @@ class DBConnection(EnforceOverrides):
            Additional options for the storage backend. Options already set on the
            connection will be inherited by the table, but can be overridden here.
            See available options at
-            <https://docs.lancedb.com/storage/>
+            <https://lancedb.com/docs/storage/>

        Returns
        -------
@@ -1390,7 +1390,6 @@ class AsyncConnection(object):
        namespace_path: Optional[List[str]] = None,
        embedding_functions: Optional[List[EmbeddingFunctionConfig]] = None,
        location: Optional[str] = None,
-        namespace_client: Optional[Any] = None,
    ) -> AsyncTable:
        """Create an [AsyncTable][lancedb.table.AsyncTable] in the database.

@@ -1435,7 +1434,7 @@ class AsyncConnection(object):
            Additional options for the storage backend. Options already set on the
            connection will be inherited by the table, but can be overridden here.
            See available options at
-            <https://docs.lancedb.com/storage/>
+            <https://lancedb.com/docs/storage/>

            To enable stable row IDs (row IDs remain stable after compaction,
            update, delete, and merges), set `new_table_enable_stable_row_ids`
@@ -1588,7 +1587,6 @@ class AsyncConnection(object):
                namespace_path=namespace_path,
                storage_options=storage_options,
                location=location,
-                namespace_client=namespace_client,
            )
        else:
            data = data_to_reader(data, schema)
@@ -1599,7 +1597,6 @@ class AsyncConnection(object):
                namespace_path=namespace_path,
                storage_options=storage_options,
                location=location,
-                namespace_client=namespace_client,
            )

        return AsyncTable(new_table)
@@ -1628,7 +1625,7 @@ class AsyncConnection(object):
            Additional options for the storage backend. Options already set on the
            connection will be inherited by the table, but can be overridden here.
            See available options at
-            <https://docs.lancedb.com/storage/>
+            <https://lancedb.com/docs/storage/>
        index_cache_size: int, default 256
            **Deprecated**: Use session-level cache configuration instead.
            Create a Session with custom cache sizes and pass it to lancedb.connect().
--- a/python/python/lancedb/namespace.py
+++ b/python/python/lancedb/namespace.py
@@ -10,6 +10,7 @@ through a namespace abstraction.

 from __future__ import annotations

+import asyncio
 import sys
 from typing import TYPE_CHECKING, Any, Dict, Iterable, List, Optional, Union

@@ -24,24 +25,7 @@ if TYPE_CHECKING:
 from datetime import timedelta
 import pyarrow as pa

-from lance_namespace_urllib3_client.models.json_arrow_data_type import JsonArrowDataType
-from lance_namespace_urllib3_client.models.json_arrow_field import JsonArrowField
-from lance_namespace_urllib3_client.models.json_arrow_schema import JsonArrowSchema
-from lance_namespace_urllib3_client.models.query_table_request import QueryTableRequest
-from lance_namespace_urllib3_client.models.query_table_request_columns import (
-    QueryTableRequestColumns,
-)
-from lance_namespace_urllib3_client.models.query_table_request_full_text_query import (
-    QueryTableRequestFullTextQuery,
-)
-from lance_namespace_urllib3_client.models.query_table_request_vector import (
-    QueryTableRequestVector,
-)
-from lance_namespace_urllib3_client.models.string_fts_query import StringFtsQuery
-from lance_namespace.errors import TableNotFoundError
-from lancedb._lancedb import connect_namespace_client as _connect_namespace_client
-from lancedb.background_loop import LOOP
-from lancedb.db import AsyncConnection, DBConnection
+from lancedb.db import DBConnection, LanceDBConnection
 from lancedb.namespace_utils import (
    _normalize_create_namespace_mode,
    _normalize_drop_namespace_mode,
@@ -56,11 +40,14 @@ from lance_namespace import (
    ListNamespacesResponse,
    ListTablesResponse,
    ListTablesRequest,
+    DescribeTableRequest,
    DescribeNamespaceRequest,
    DropTableRequest,
    ListNamespacesRequest,
    CreateNamespaceRequest,
    DropNamespaceRequest,
+    DeclareTableRequest,
+    CreateTableRequest,
 )
 from lancedb.table import AsyncTable, LanceTable, Table
 from lancedb.util import validate_table_name
@@ -69,6 +56,21 @@ from lancedb.pydantic import LanceModel
 from lancedb.embeddings import EmbeddingFunctionConfig
 from ._lancedb import Session

+from lance_namespace_urllib3_client.models.json_arrow_schema import JsonArrowSchema
+from lance_namespace_urllib3_client.models.json_arrow_field import JsonArrowField
+from lance_namespace_urllib3_client.models.json_arrow_data_type import JsonArrowDataType
+from lance_namespace_urllib3_client.models.query_table_request import QueryTableRequest
+from lance_namespace_urllib3_client.models.query_table_request_vector import (
+    QueryTableRequestVector,
+)
+from lance_namespace_urllib3_client.models.query_table_request_columns import (
+    QueryTableRequestColumns,
+)
+from lance_namespace_urllib3_client.models.query_table_request_full_text_query import (
+    QueryTableRequestFullTextQuery,
+)
+from lance_namespace_urllib3_client.models.string_fts_query import StringFtsQuery
+

 def _query_to_namespace_request(
    table_id: List[str],
@@ -422,23 +424,6 @@ class LanceNamespaceDBConnection(DBConnection):
        )
        self._namespace_client_impl = namespace_client_impl
        self._namespace_client_properties = namespace_client_properties
-        self._inner = AsyncConnection(
-            _connect_namespace_client(
-                namespace_client,
-                read_consistency_interval=(
-                    read_consistency_interval.total_seconds()
-                    if read_consistency_interval is not None
-                    else None
-                ),
-                storage_options=self.storage_options or None,
-                session=session,
-                namespace_client_pushdown_operations=(
-                    list(self._namespace_client_pushdown_operations)
-                ),
-                namespace_client_impl=namespace_client_impl,
-                namespace_client_properties=namespace_client_properties,
-            )
-        )

    @override
    def serialize(self) -> str:
@@ -512,10 +497,13 @@ class LanceNamespaceDBConnection(DBConnection):
        if mode.lower() not in ["create", "overwrite"]:
            raise ValueError("mode must be either 'create' or 'overwrite'")
        validate_table_name(name)
-        async_table = LOOP.run(
-            self._inner.create_table(
-                name,
-                data,
+
+        table_id = namespace_path + [name]
+
+        if "CreateTable" in self._namespace_client_pushdown_operations:
+            return self._create_table_server_side(
+                name=name,
+                data=data,
                schema=schema,
                mode=mode,
                exist_ok=exist_ok,
@@ -525,15 +513,130 @@ class LanceNamespaceDBConnection(DBConnection):
                namespace_path=namespace_path,
                storage_options=storage_options,
            )
+
+        # Local create path: declare_table + local write
+        # Step 1: Get the table location and storage options from namespace
+        # In overwrite mode, if table exists, use describe_table to get
+        # existing location. Otherwise, call create_empty_table to reserve
+        # a new location
+        location = None
+        namespace_storage_options = None
+        if mode.lower() == "overwrite":
+            # Try to describe the table first to see if it exists
+            try:
+                describe_request = DescribeTableRequest(id=table_id)
+                describe_response = self._namespace_client.describe_table(
+                    describe_request
+                )
+                location = describe_response.location
+                namespace_storage_options = describe_response.storage_options
+            except Exception:
+                # Table doesn't exist, will create a new one below
+                pass
+
+        if location is None:
+            # Table doesn't exist or mode is "create", reserve a new location
+            declare_request = DeclareTableRequest(
+                id=table_id,
+                location=None,
+                properties=self.storage_options if self.storage_options else None,
+            )
+            declare_response = self._namespace_client.declare_table(declare_request)
+
+            if not declare_response.location:
+                raise ValueError(
+                    "Table location is missing from declare_table response"
+                )
+
+            location = declare_response.location
+            namespace_storage_options = declare_response.storage_options
+
+        # Merge storage options: self.storage_options < user options < namespace options
+        merged_storage_options = dict(self.storage_options)
+        if storage_options:
+            merged_storage_options.update(storage_options)
+        if namespace_storage_options:
+            merged_storage_options.update(namespace_storage_options)
+
+        # Step 2: Create table using LanceTable.create with the location
+        # We need a temporary connection for the LanceTable.create method
+        temp_conn = LanceDBConnection(
+            location,  # Use the actual location as the connection URI
+            read_consistency_interval=self.read_consistency_interval,
+            storage_options=merged_storage_options,
+            session=self.session,
        )

-        return LanceTable(
-            self,
+        # Note: storage_options_provider is auto-created in Rust from namespace_client
+        tbl = LanceTable.create(
+            temp_conn,
            name,
+            data,
+            schema,
+            mode=mode,
+            exist_ok=exist_ok,
+            on_bad_vectors=on_bad_vectors,
+            fill_value=fill_value,
+            embedding_functions=embedding_functions,
            namespace_path=namespace_path,
+            storage_options=merged_storage_options,
+            location=location,
            namespace_client=self._namespace_client,
            pushdown_operations=self._namespace_client_pushdown_operations,
-            _async=async_table,
+        )
+
+        return tbl
+
+    def _create_table_server_side(
+        self,
+        name: str,
+        data: Optional[DATA],
+        schema: Optional[Union[pa.Schema, LanceModel]],
+        mode: str,
+        exist_ok: bool,
+        on_bad_vectors: str,
+        fill_value: float,
+        embedding_functions: Optional[List[EmbeddingFunctionConfig]],
+        namespace_path: Optional[List[str]],
+        storage_options: Optional[Dict[str, str]],
+    ) -> Table:
+        """Create a table using server-side namespace.create_table()."""
+        if namespace_path is None:
+            namespace_path = []
+        table_id = namespace_path + [name]
+
+        arrow_ipc_bytes = _data_to_arrow_ipc(
+            data=data,
+            schema=schema,
+            embedding_functions=embedding_functions,
+            on_bad_vectors=on_bad_vectors,
+            fill_value=fill_value,
+        )
+
+        merged = dict(self.storage_options or {})
+        if storage_options:
+            merged.update(storage_options)
+        request = CreateTableRequest(
+            id=table_id,
+            mode=_normalize_create_table_mode(mode),
+            properties=merged or None,
+        )
+
+        try:
+            self._namespace_client.create_table(request, arrow_ipc_bytes)
+        except Exception as e:
+            if exist_ok and "already exists" in str(e).lower():
+                return self.open_table(
+                    name,
+                    namespace_path=namespace_path,
+                    storage_options=storage_options,
+                )
+            raise
+
+        return self.open_table(
+            name,
+            namespace_path=namespace_path,
+            storage_options=storage_options,
        )

    @override
@@ -547,28 +650,30 @@ class LanceNamespaceDBConnection(DBConnection):
    ) -> Table:
        if namespace_path is None:
            namespace_path = []
-        try:
-            async_table = LOOP.run(
-                self._inner.open_table(
-                    name,
-                    namespace_path=namespace_path,
-                    storage_options=storage_options,
-                    index_cache_size=index_cache_size,
-                )
-            )
-        except RuntimeError as e:
-            if "Table not found" in str(e):
-                table_id = namespace_path + [name]
-                raise TableNotFoundError(f"Table not found: {'$'.join(table_id)}")
-            raise
+        table_id = namespace_path + [name]
+        request = DescribeTableRequest(id=table_id)
+        response = self._namespace_client.describe_table(request)

-        return LanceTable(
-            self,
+        # Merge storage options: self.storage_options < user options < namespace options
+        merged_storage_options = dict(self.storage_options)
+        if storage_options:
+            merged_storage_options.update(storage_options)
+        if response.storage_options:
+            merged_storage_options.update(response.storage_options)
+
+        # Pass managed_versioning to avoid redundant describe_table call in Rust.
+        # Convert None to False since we already have the answer from describe_table.
+        managed_versioning = response.managed_versioning is True
+
+        # Note: storage_options_provider is auto-created in Rust from namespace_client
+        return self._lance_table_from_uri(
            name,
+            response.location,
            namespace_path=namespace_path,
+            storage_options=merged_storage_options,
+            index_cache_size=index_cache_size,
            namespace_client=self._namespace_client,
-            pushdown_operations=self._namespace_client_pushdown_operations,
-            _async=async_table,
+            managed_versioning=managed_versioning,
        )

    @override
@@ -792,34 +897,33 @@ class LanceNamespaceDBConnection(DBConnection):
        namespace_client: Optional[Any] = None,
        managed_versioning: Optional[bool] = None,
    ) -> LanceTable:
-        # Open a table directly from the namespace-resolved physical location.
-        #
-        # Open the table through the Rust namespace-backed connection.  The Rust
-        # layer keeps the logical namespace path and namespace client intact.
+        # Open a table directly from a URI using the location parameter
+        # Note: storage_options should already be merged by the caller
+        # Note: storage_options_provider is auto-created in Rust from namespace_client
        if namespace_path is None:
            namespace_path = []
-
-        async_table = LOOP.run(
-            self._inner.open_table(
-                name,
-                namespace_path=namespace_path,
-                storage_options=storage_options,
-                index_cache_size=index_cache_size,
-                location=None,
-                namespace_client=namespace_client,
-                managed_versioning=managed_versioning,
-            )
+        temp_conn = LanceDBConnection(
+            table_uri,  # Use the table location as the connection URI
+            read_consistency_interval=self.read_consistency_interval,
+            storage_options=storage_options if storage_options is not None else {},
+            session=self.session,
        )

-        return LanceTable(
-            self,
+        # Open the table using the temporary connection with the location parameter
+        # Pass namespace_client to enable managed versioning support and auto-create
+        # storage options provider
+        # Pass managed_versioning to avoid redundant describe_table call
+        # Pass pushdown_operations if configured on this connection
+        return LanceTable.open(
+            temp_conn,
            name,
            namespace_path=namespace_path,
+            storage_options=storage_options,
+            index_cache_size=index_cache_size,
            location=table_uri,
            namespace_client=namespace_client,
            managed_versioning=managed_versioning,
            pushdown_operations=self._namespace_client_pushdown_operations,
-            _async=async_table,
        )

    @override
@@ -886,23 +990,6 @@ class AsyncLanceNamespaceDBConnection:
        self._namespace_client_pushdown_operations = set(
            namespace_client_pushdown_operations or []
        )
-        self._inner = AsyncConnection(
-            _connect_namespace_client(
-                namespace_client,
-                read_consistency_interval=(
-                    read_consistency_interval.total_seconds()
-                    if read_consistency_interval is not None
-                    else None
-                ),
-                storage_options=self.storage_options or None,
-                session=session,
-                namespace_client_pushdown_operations=(
-                    list(self._namespace_client_pushdown_operations)
-                ),
-                namespace_client_impl=None,
-                namespace_client_properties=None,
-            )
-        )

    async def table_names(
        self,
@@ -954,16 +1041,148 @@ class AsyncLanceNamespaceDBConnection:
        if mode.lower() not in ["create", "overwrite"]:
            raise ValueError("mode must be either 'create' or 'overwrite'")
        validate_table_name(name)
-        return await self._inner.create_table(
+
+        table_id = namespace_path + [name]
+
+        if "CreateTable" in self._namespace_client_pushdown_operations:
+            return await self._create_table_server_side(
+                name=name,
+                data=data,
+                schema=schema,
+                mode=mode,
+                exist_ok=exist_ok,
+                on_bad_vectors=on_bad_vectors,
+                fill_value=fill_value,
+                embedding_functions=embedding_functions,
+                namespace_path=namespace_path,
+                storage_options=storage_options,
+            )
+
+        # Local create path: declare_table + local write
+        # Step 1: Get the table location and storage options from namespace
+        location = None
+        namespace_storage_options = None
+        if mode.lower() == "overwrite":
+            # Try to describe the table first to see if it exists
+            try:
+                describe_request = DescribeTableRequest(id=table_id)
+                describe_response = self._namespace_client.describe_table(
+                    describe_request
+                )
+                location = describe_response.location
+                namespace_storage_options = describe_response.storage_options
+            except Exception:
+                # Table doesn't exist, will create a new one below
+                pass
+
+        if location is None:
+            # Table doesn't exist or mode is "create", reserve a new location
+            declare_request = DeclareTableRequest(
+                id=table_id,
+                location=None,
+                properties=self.storage_options if self.storage_options else None,
+            )
+            declare_response = self._namespace_client.declare_table(declare_request)
+
+            if not declare_response.location:
+                raise ValueError(
+                    "Table location is missing from declare_table response"
+                )
+
+            location = declare_response.location
+            namespace_storage_options = declare_response.storage_options
+
+        # Merge storage options: self.storage_options < user options < namespace options
+        merged_storage_options = dict(self.storage_options)
+        if storage_options:
+            merged_storage_options.update(storage_options)
+        if namespace_storage_options:
+            merged_storage_options.update(namespace_storage_options)
+
+        # Step 2: Create table using LanceTable.create with the location
+        # Run the sync operation in a thread
+        def _create_table():
+            temp_conn = LanceDBConnection(
+                location,
+                read_consistency_interval=self.read_consistency_interval,
+                storage_options=merged_storage_options,
+                session=self.session,
+            )
+
+            # storage_options_provider is auto-created in Rust from namespace_client
+            return LanceTable.create(
+                temp_conn,
+                name,
+                data,
+                schema,
+                mode=mode,
+                exist_ok=exist_ok,
+                on_bad_vectors=on_bad_vectors,
+                fill_value=fill_value,
+                embedding_functions=embedding_functions,
+                namespace_path=namespace_path,
+                storage_options=merged_storage_options,
+                location=location,
+                namespace_client=self._namespace_client,
+                pushdown_operations=self._namespace_client_pushdown_operations,
+            )
+
+        lance_table = await asyncio.to_thread(_create_table)
+        # Get the underlying async table from LanceTable
+        return lance_table._table
+
+    async def _create_table_server_side(
+        self,
+        name: str,
+        data: Optional[DATA],
+        schema: Optional[Union[pa.Schema, LanceModel]],
+        mode: str,
+        exist_ok: bool,
+        on_bad_vectors: str,
+        fill_value: float,
+        embedding_functions: Optional[List[EmbeddingFunctionConfig]],
+        namespace_path: Optional[List[str]],
+        storage_options: Optional[Dict[str, str]],
+    ) -> AsyncTable:
+        """Create a table using server-side namespace.create_table()."""
+        if namespace_path is None:
+            namespace_path = []
+        table_id = namespace_path + [name]
+
+        def _prepare_and_create():
+            arrow_ipc_bytes = _data_to_arrow_ipc(
+                data=data,
+                schema=schema,
+                embedding_functions=embedding_functions,
+                on_bad_vectors=on_bad_vectors,
+                fill_value=fill_value,
+            )
+
+            merged = dict(self.storage_options or {})
+            if storage_options:
+                merged.update(storage_options)
+            request = CreateTableRequest(
+                id=table_id,
+                mode=_normalize_create_table_mode(mode),
+                properties=merged or None,
+            )
+
+            self._namespace_client.create_table(request, arrow_ipc_bytes)
+
+        try:
+            await asyncio.to_thread(_prepare_and_create)
+        except Exception as e:
+            if exist_ok and "already exists" in str(e).lower():
+                return await self.open_table(
+                    name,
+                    namespace_path=namespace_path,
+                    storage_options=storage_options,
+                )
+            raise
+
+        return await self.open_table(
            name,
-            data,
-            schema=schema,
-            mode=mode,
-            exist_ok=exist_ok,
-            on_bad_vectors=on_bad_vectors,
-            fill_value=fill_value,
            namespace_path=namespace_path,
-            embedding_functions=embedding_functions,
            storage_options=storage_options,
        )

@@ -978,18 +1197,45 @@ class AsyncLanceNamespaceDBConnection:
        """Open an existing table from the namespace."""
        if namespace_path is None:
            namespace_path = []
-        try:
-            return await self._inner.open_table(
+        table_id = namespace_path + [name]
+        request = DescribeTableRequest(id=table_id)
+        response = self._namespace_client.describe_table(request)
+
+        # Merge storage options: self.storage_options < user options < namespace options
+        merged_storage_options = dict(self.storage_options)
+        if storage_options:
+            merged_storage_options.update(storage_options)
+        if response.storage_options:
+            merged_storage_options.update(response.storage_options)
+
+        # Capture managed_versioning from describe response.
+        # Convert None to False since we already have the answer from describe_table.
+        managed_versioning = response.managed_versioning is True
+
+        # Open table in a thread
+        # Note: storage_options_provider is auto-created in Rust from namespace_client
+        def _open_table():
+            temp_conn = LanceDBConnection(
+                response.location,
+                read_consistency_interval=self.read_consistency_interval,
+                storage_options=merged_storage_options,
+                session=self.session,
+            )
+
+            return LanceTable.open(
+                temp_conn,
                name,
                namespace_path=namespace_path,
-                storage_options=storage_options,
+                storage_options=merged_storage_options,
                index_cache_size=index_cache_size,
+                location=response.location,
+                namespace_client=self._namespace_client,
+                managed_versioning=managed_versioning,
+                pushdown_operations=self._namespace_client_pushdown_operations,
            )
-        except RuntimeError as e:
-            if "Table not found" in str(e):
-                table_id = namespace_path + [name]
-                raise TableNotFoundError(f"Table not found: {'$'.join(table_id)}")
-            raise
+
+        lance_table = await asyncio.to_thread(_open_table)
+        return lance_table._table

    async def drop_table(self, name: str, namespace_path: Optional[List[str]] = None):
        """Drop a table from the namespace."""
--- a/python/python/lancedb/table.py
+++ b/python/python/lancedb/table.py
@@ -191,7 +191,7 @@ def _into_pyarrow_reader(
            f"Unknown data type {type(data)}. "
            "Supported types: list of dicts, pandas DataFrame, polars DataFrame, "
            "pyarrow Table/RecordBatch, or Pydantic models. "
-            "See https://docs.lancedb.com/tables/ for examples."
+            "See https://lancedb.com/docs/tables/ for examples."
        )


@@ -2929,7 +2929,6 @@ class LanceTable(Table):
                namespace_path=namespace_path,
                storage_options=storage_options,
                location=location,
-                namespace_client=namespace_client,
            )
        )
        return self
--- a/python/python/tests/test_namespace_integration.py
+++ b/python/python/tests/test_namespace_integration.py
@@ -18,9 +18,6 @@ Tests verify:
 """

 import copy
-import shutil
-import sys
-import tempfile
 import time
 import uuid
 from typing import Dict, Optional
@@ -390,66 +387,6 @@ def test_namespace_open_table_with_provider(s3_bucket: str, use_custom: bool):
    assert get_describe_call_count(inner_ns_client) == describe_count_after_open


-@pytest.mark.skipif(
-    sys.platform == "win32",
-    reason="TODO: fix schema-only namespace metrics test on Windows",
-)
-@pytest.mark.parametrize("use_custom", [False, True], ids=["DirectoryNS", "CustomNS"])
-def test_namespace_create_schema_only_with_provider(use_custom: bool):
-    """
-    Test creating a schema-only table through namespace with storage options provider.
-
-    Verifies:
-    - declare_table is called once to reserve the location
-    - describe_table is not needed during create in create mode
-    - the table can be reopened successfully afterward
-    - opening the table triggers exactly one describe_table call
-    """
-    temp_dir = tempfile.mkdtemp()
-    try:
-        ns_client, inner_ns_client = create_tracking_namespace(
-            bucket_name=temp_dir,
-            storage_options={},
-            credential_expires_in_seconds=3600,
-            use_custom=use_custom,
-        )
-
-        db = LanceNamespaceDBConnection(ns_client)
-
-        namespace_name = f"test_ns_{uuid.uuid4().hex[:8]}"
-        db.create_namespace([namespace_name])
-
-        table_name = f"test_table_{uuid.uuid4().hex}"
-        namespace_path = [namespace_name]
-        schema = pa.schema(
-            [
-                pa.field("id", pa.int64()),
-                pa.field("vector", pa.list_(pa.float32(), 2)),
-                pa.field("text", pa.string()),
-            ]
-        )
-
-        assert get_declare_call_count(inner_ns_client) == 0
-        assert get_describe_call_count(inner_ns_client) == 0
-
-        table = db.create_table(
-            table_name, schema=schema, namespace_path=namespace_path
-        )
-
-        assert table.name == table_name
-        assert table.namespace == namespace_path
-        assert get_declare_call_count(inner_ns_client) == 1
-        assert get_describe_call_count(inner_ns_client) == 0
-
-        reopened_table = db.open_table(table_name, namespace_path=namespace_path)
-
-        assert reopened_table.schema == schema
-        assert get_declare_call_count(inner_ns_client) == 1
-        assert get_describe_call_count(inner_ns_client) == 1
-    finally:
-        shutil.rmtree(temp_dir, ignore_errors=True)
-
-
@pytest.mark.s3_test
@pytest.mark.parametrize("use_custom", [False, True], ids=["DirectoryNS", "CustomNS"])
 def test_namespace_credential_refresh_on_read(s3_bucket: str, use_custom: bool):
--- a/python/python/tests/test_table.py
+++ b/python/python/tests/test_table.py
@@ -3,7 +3,6 @@


 import os
-import sys
 from datetime import date, datetime, timedelta
 from time import sleep
 from typing import List
@@ -2041,13 +2040,6 @@ def test_hybrid_search_metric_type(tmp_db: DBConnection):
@pytest.mark.parametrize(
    "consistency_interval", [None, timedelta(seconds=0), timedelta(seconds=0.1)]
 )
-@pytest.mark.skipif(
-    sys.platform == "win32",
-    reason=(
-        "TODO: directory namespace is not supported on Windows yet; "
-        "re-enable after that is fixed."
-    ),
-)
 def test_consistency(tmp_path, consistency_interval):
    db = lancedb.connect(tmp_path)
    table = db.create_table("my_table", data=[{"id": 0}])
@@ -2068,6 +2060,7 @@ def test_consistency(tmp_path, consistency_interval):
    elif consistency_interval == timedelta(seconds=0):
        assert table2.version == table.version
    else:
+        # (consistency_interval == timedelta(seconds=0.1)
        assert table2.version == table.version - 1
        sleep(0.1)
        assert table2.version == table.version
--- a/python/src/connection.rs
+++ b/python/src/connection.rs
@@ -1,17 +1,11 @@
 // SPDX-License-Identifier: Apache-2.0
 // SPDX-FileCopyrightText: Copyright The LanceDB Authors

-use std::{
-    collections::{HashMap, HashSet},
-    sync::Arc,
-    time::Duration,
-};
+use std::{collections::HashMap, sync::Arc, time::Duration};

 use arrow::{datatypes::Schema, ffi_stream::ArrowArrayStreamReader, pyarrow::FromPyArrow};
 use lancedb::{
    connection::Connection as LanceConnection,
-    connection::NamespaceClientPushdownOperation,
-    database::namespace::LanceNamespaceDatabase,
    database::{CreateTableMode, Database, ReadConsistency},
 };
 use pyo3::{
@@ -45,29 +39,6 @@ impl Connection {
    }
 }

-fn parse_namespace_client_pushdown_operations(
-    operations: Option<Vec<String>>,
-) -> PyResult<HashSet<NamespaceClientPushdownOperation>> {
-    let mut parsed = HashSet::new();
-    for operation in operations.unwrap_or_default() {
-        match operation.as_str() {
-            "QueryTable" => {
-                parsed.insert(NamespaceClientPushdownOperation::QueryTable);
-            }
-            "CreateTable" => {
-                parsed.insert(NamespaceClientPushdownOperation::CreateTable);
-            }
-            _ => {
-                return Err(PyValueError::new_err(format!(
-                    "Invalid pushdown operation: {}",
-                    operation
-                )));
-            }
-        }
-    }
-    Ok(parsed)
-}
-
 impl Connection {
    fn parse_create_mode_str(mode: &str) -> PyResult<CreateTableMode> {
        match mode {
@@ -567,52 +538,6 @@ pub fn connect(
    })
 }

-#[pyfunction]
-#[pyo3(signature = (
-    namespace_client,
-    read_consistency_interval=None,
-    storage_options=None,
-    session=None,
-    namespace_client_pushdown_operations=None,
-    namespace_client_impl=None,
-    namespace_client_properties=None,
-))]
-#[allow(clippy::too_many_arguments)]
-pub fn connect_namespace_client(
-    py: Python<'_>,
-    namespace_client: Py<PyAny>,
-    read_consistency_interval: Option<f64>,
-    storage_options: Option<HashMap<String, String>>,
-    session: Option<crate::session::Session>,
-    namespace_client_pushdown_operations: Option<Vec<String>>,
-    namespace_client_impl: Option<String>,
-    namespace_client_properties: Option<HashMap<String, String>>,
-) -> PyResult<Connection> {
-    let namespace_client = extract_namespace_arc(py, namespace_client)?;
-    let read_consistency_interval = read_consistency_interval.map(Duration::from_secs_f64);
-    let namespace_client_pushdown_operations =
-        parse_namespace_client_pushdown_operations(namespace_client_pushdown_operations)?;
-    let ns_impl = namespace_client_impl.unwrap_or_else(|| "python".to_string());
-    let ns_properties = namespace_client_properties.unwrap_or_default();
-    let storage_options = storage_options.unwrap_or_default();
-    let session = session.map(|s| s.inner.clone());
-
-    let database = LanceNamespaceDatabase::from_namespace_client(
-        namespace_client,
-        ns_impl,
-        ns_properties,
-        storage_options,
-        read_consistency_interval,
-        session,
-        namespace_client_pushdown_operations,
-    );
-
-    Ok(Connection::new(LanceConnection::new(
-        Arc::new(database),
-        Arc::new(lancedb::embeddings::MemoryRegistry::new()),
-    )))
-}
-
 #[derive(FromPyObject)]
 pub struct PyClientConfig {
    user_agent: String,
--- a/python/src/lib.rs
+++ b/python/src/lib.rs
@@ -2,7 +2,7 @@
 // SPDX-FileCopyrightText: Copyright The LanceDB Authors

 use arrow::RecordBatchStream;
-use connection::{Connection, connect, connect_namespace_client};
+use connection::{Connection, connect};
 use env_logger::Env;
 use expr::{PyExpr, expr_col, expr_func, expr_lit};
 use index::IndexConfig;
@@ -58,7 +58,6 @@ pub fn _lancedb(_py: Python, m: &Bound<'_, PyModule>) -> PyResult<()> {
    m.add_class::<PyPermutationReader>()?;
    m.add_class::<PyExpr>()?;
    m.add_function(wrap_pyfunction!(connect, m)?)?;
-    m.add_function(wrap_pyfunction!(connect_namespace_client, m)?)?;
    m.add_function(wrap_pyfunction!(permutation::async_permutation_builder, m)?)?;
    m.add_function(wrap_pyfunction!(util::validate_table_name, m)?)?;
    m.add_function(wrap_pyfunction!(query::fts_query_to_json, m)?)?;
--- a/rust/lancedb/Cargo.toml
+++ b/rust/lancedb/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "lancedb"
-version = "0.28.0-beta.8"
+version = "0.28.0-beta.5"
 edition.workspace = true
 description = "LanceDB: A serverless, low-latency vector database for AI applications"
 license.workspace = true
--- a/rust/lancedb/src/connection.rs
+++ b/rust/lancedb/src/connection.rs
@@ -171,7 +171,7 @@ impl OpenTableBuilder {
    /// Options already set on the connection will be inherited by the table,
    /// but can be overridden here.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_option(mut self, key: impl Into<String>, value: impl Into<String>) -> Self {
        let store_params = self
            .request
@@ -188,7 +188,7 @@ impl OpenTableBuilder {
    /// Options already set on the connection will be inherited by the table,
    /// but can be overridden here.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_options(
        mut self,
        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
@@ -582,14 +582,6 @@ pub struct ConnectRequest {
    /// Database specific options
    pub options: HashMap<String, String>,

-    /// Extra properties for the equivalent namespace client.
-    ///
-    /// For a local [`ListingDatabase`], these are merged into the backing
-    /// `DirectoryNamespace` properties. This is useful for namespace-specific
-    /// settings such as `table_version_tracking_enabled` that are distinct from
-    /// storage options.
-    pub namespace_client_properties: HashMap<String, String>,
-
    /// The interval at which to check for updates from other processes.
    ///
    /// If None, then consistency is not checked. For performance
@@ -629,7 +621,6 @@ impl ConnectBuilder {
                client_config: Default::default(),
                read_consistency_interval: None,
                options: HashMap::new(),
-                namespace_client_properties: HashMap::new(),
                session: None,
            },
            embedding_registry: None,
@@ -747,7 +738,7 @@ impl ConnectBuilder {

    /// Set an option for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_option(mut self, key: impl Into<String>, value: impl Into<String>) -> Self {
        self.request.options.insert(key.into(), value.into());
        self
@@ -755,7 +746,7 @@ impl ConnectBuilder {

    /// Set multiple options for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_options(
        mut self,
        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
@@ -766,31 +757,6 @@ impl ConnectBuilder {
        self
    }

-    /// Set an additional property for the equivalent namespace client.
-    pub fn namespace_client_property(
-        mut self,
-        key: impl Into<String>,
-        value: impl Into<String>,
-    ) -> Self {
-        self.request
-            .namespace_client_properties
-            .insert(key.into(), value.into());
-        self
-    }
-
-    /// Set multiple additional properties for the equivalent namespace client.
-    pub fn namespace_client_properties(
-        mut self,
-        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
-    ) -> Self {
-        for (key, value) in pairs {
-            self.request
-                .namespace_client_properties
-                .insert(key.into(), value.into());
-        }
-        self
-    }
-
    /// The interval at which to check for updates from other processes. This
    /// only affects LanceDB OSS.
    ///
@@ -915,7 +881,7 @@ use std::collections::HashSet;
 /// These operations will be executed on the namespace server instead of locally
 /// when enabled via [`ConnectNamespaceBuilder::pushdown_operations`].
 #[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
-pub enum NamespaceClientPushdownOperation {
+pub enum PushdownOperation {
    /// Execute queries on the namespace server via `query_table()` instead of locally.
    QueryTable,
    /// Execute table creation on the namespace server via `create_table()`
@@ -927,11 +893,10 @@ pub struct ConnectNamespaceBuilder {
    ns_impl: String,
    properties: HashMap<String, String>,
    storage_options: HashMap<String, String>,
-    namespace_client_properties: HashMap<String, String>,
    read_consistency_interval: Option<std::time::Duration>,
    embedding_registry: Option<Arc<dyn EmbeddingRegistry>>,
    session: Option<Arc<lance::session::Session>>,
-    pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+    pushdown_operations: HashSet<PushdownOperation>,
 }

 impl ConnectNamespaceBuilder {
@@ -940,7 +905,6 @@ impl ConnectNamespaceBuilder {
            ns_impl: ns_impl.to_string(),
            properties,
            storage_options: HashMap::new(),
-            namespace_client_properties: HashMap::new(),
            read_consistency_interval: None,
            embedding_registry: None,
            session: None,
@@ -950,7 +914,7 @@ impl ConnectNamespaceBuilder {

    /// Set an option for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_option(mut self, key: impl Into<String>, value: impl Into<String>) -> Self {
        self.storage_options.insert(key.into(), value.into());
        self
@@ -958,7 +922,7 @@ impl ConnectNamespaceBuilder {

    /// Set multiple options for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_options(
        mut self,
        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
@@ -969,29 +933,6 @@ impl ConnectNamespaceBuilder {
        self
    }

-    /// Set an additional namespace client property.
-    pub fn namespace_client_property(
-        mut self,
-        key: impl Into<String>,
-        value: impl Into<String>,
-    ) -> Self {
-        self.namespace_client_properties
-            .insert(key.into(), value.into());
-        self
-    }
-
-    /// Set multiple additional namespace client properties.
-    pub fn namespace_client_properties(
-        mut self,
-        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
-    ) -> Self {
-        for (key, value) in pairs {
-            self.namespace_client_properties
-                .insert(key.into(), value.into());
-        }
-        self
-    }
-
    /// The interval at which to check for updates from other processes.
    ///
    /// If left unset, consistency is not checked. For maximum read
@@ -1029,11 +970,11 @@ impl ConnectNamespaceBuilder {
    /// and leveraging server-side compute resources.
    ///
    /// Available operations:
-    /// - [`NamespaceClientPushdownOperation::QueryTable`]: Execute queries via `namespace.query_table()`
-    /// - [`NamespaceClientPushdownOperation::CreateTable`]: Execute table creation via `namespace.create_table()`
+    /// - [`PushdownOperation::QueryTable`]: Execute queries via `namespace.query_table()`
+    /// - [`PushdownOperation::CreateTable`]: Execute table creation via `namespace.create_table()`
    ///
    /// By default, no operations are pushed down (all executed locally).
-    pub fn pushdown_operation(mut self, operation: NamespaceClientPushdownOperation) -> Self {
+    pub fn pushdown_operation(mut self, operation: PushdownOperation) -> Self {
        self.pushdown_operations.insert(operation);
        self
    }
@@ -1043,7 +984,7 @@ impl ConnectNamespaceBuilder {
    /// See [`Self::pushdown_operation`] for details.
    pub fn pushdown_operations(
        mut self,
-        operations: impl IntoIterator<Item = NamespaceClientPushdownOperation>,
+        operations: impl IntoIterator<Item = PushdownOperation>,
    ) -> Self {
        self.pushdown_operations.extend(operations);
        self
@@ -1053,13 +994,10 @@ impl ConnectNamespaceBuilder {
    pub async fn execute(self) -> Result<Connection> {
        use crate::database::namespace::LanceNamespaceDatabase;

-        let mut properties = self.properties;
-        properties.extend(self.namespace_client_properties);
-
        let internal = Arc::new(
            LanceNamespaceDatabase::connect(
                &self.ns_impl,
-                properties,
+                self.properties,
                self.storage_options,
                self.read_consistency_interval,
                self.session,
@@ -1179,31 +1117,6 @@ mod tests {
        assert_eq!(db.uri(), relative_uri.to_str().unwrap().to_string());
    }

-    #[tokio::test]
-    async fn test_connect_with_namespace_client_properties() {
-        let tmp_dir = tempdir().unwrap();
-        let uri = tmp_dir.path().to_str().unwrap();
-
-        let db = connect(uri)
-            .namespace_client_property("table_version_tracking_enabled", "true")
-            .namespace_client_property("manifest_enabled", "true")
-            .execute()
-            .await
-            .unwrap();
-
-        let (ns_impl, properties) = db.namespace_client_config().await.unwrap();
-        assert_eq!(ns_impl, "dir");
-        assert_eq!(properties.get("root"), Some(&uri.to_string()));
-        assert_eq!(
-            properties.get("table_version_tracking_enabled"),
-            Some(&"true".to_string())
-        );
-        assert_eq!(
-            properties.get("manifest_enabled"),
-            Some(&"true".to_string())
-        );
-    }
-
    #[tokio::test]
    async fn test_table_names() {
        let tc = new_test_connection().await.unwrap();
--- a/rust/lancedb/src/connection/create_table.rs
+++ b/rust/lancedb/src/connection/create_table.rs
@@ -55,7 +55,7 @@ impl CreateTableBuilder {
    /// Options already set on the connection will be inherited by the table,
    /// but can be overridden here.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_option(mut self, key: impl Into<String>, value: impl Into<String>) -> Self {
        let store_params = self
            .request
@@ -73,7 +73,7 @@ impl CreateTableBuilder {
    /// Options already set on the connection will be inherited by the table,
    /// but can be overridden here.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_options(
        mut self,
        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
--- a/rust/lancedb/src/database/listing.rs
+++ b/rust/lancedb/src/database/listing.rs
@@ -20,7 +20,6 @@ use snafu::ResultExt;

 use crate::connection::ConnectRequest;
 use crate::database::ReadConsistency;
-use crate::database::namespace::LanceNamespaceDatabase;
 use crate::error::{CreateDirSnafu, Error, Result};
 use crate::io::object_store::MirroringObjectStoreWrapper;
 use crate::table::NativeTable;
@@ -74,7 +73,7 @@ pub struct ListingDatabaseOptions {
    /// These are used to create/list tables and they are inherited by all tables
    /// opened by this database.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub storage_options: HashMap<String, String>,
 }

@@ -186,7 +185,7 @@ impl ListingDatabaseOptionsBuilder {

    /// Set an option for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_option(mut self, key: impl Into<String>, value: impl Into<String>) -> Self {
        self.options
            .storage_options
@@ -196,7 +195,7 @@ impl ListingDatabaseOptionsBuilder {

    /// Set multiple options for the storage layer.
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    pub fn storage_options(
        mut self,
        pairs: impl IntoIterator<Item = (impl Into<String>, impl Into<String>)>,
@@ -256,9 +255,6 @@ pub struct ListingDatabase {

    // Session for object stores and caching
    session: Arc<lance::session::Session>,
-
-    // Namespace-backed database for child namespace operations
-    namespace_database: Arc<LanceNamespaceDatabase>,
 }

 impl std::fmt::Display for ListingDatabase {
@@ -285,44 +281,6 @@ const MIRRORED_STORE: &str = "mirroredStore";

 /// A connection to LanceDB
 impl ListingDatabase {
-    fn build_namespace_client_properties(
-        uri: &str,
-        storage_options: &HashMap<String, String>,
-        namespace_client_properties: HashMap<String, String>,
-    ) -> HashMap<String, String> {
-        let mut properties = namespace_client_properties;
-        properties.insert("root".to_string(), uri.to_string());
-        for (key, value) in storage_options {
-            properties.insert(format!("storage.{}", key), value.clone());
-        }
-        properties
-    }
-
-    async fn connect_namespace_database(
-        uri: &str,
-        storage_options: HashMap<String, String>,
-        namespace_client_properties: HashMap<String, String>,
-        read_consistency_interval: Option<std::time::Duration>,
-        session: Arc<lance::session::Session>,
-    ) -> Result<Arc<LanceNamespaceDatabase>> {
-        let ns_properties = Self::build_namespace_client_properties(
-            uri,
-            &storage_options,
-            namespace_client_properties,
-        );
-        Ok(Arc::new(
-            LanceNamespaceDatabase::connect(
-                "dir",
-                ns_properties,
-                storage_options,
-                read_consistency_interval,
-                Some(session),
-                HashSet::new(),
-            )
-            .await?,
-        ))
-    }
-
    /// Connect to a listing database
    ///
    /// The URI should be a path to a directory where the tables are stored.
@@ -342,7 +300,6 @@ impl ListingDatabase {
                    uri,
                    request.read_consistency_interval,
                    options.new_table_config,
-                    request.namespace_client_properties.clone(),
                    request.session.clone(),
                )
                .await
@@ -430,15 +387,6 @@ impl ListingDatabase {
                    None => None,
                };

-                let namespace_database = Self::connect_namespace_database(
-                    &table_base_uri,
-                    options.storage_options.clone(),
-                    request.namespace_client_properties.clone(),
-                    request.read_consistency_interval,
-                    session.clone(),
-                )
-                .await?;
-
                Ok(Self {
                    uri: table_base_uri,
                    query_string,
@@ -450,7 +398,6 @@ impl ListingDatabase {
                    storage_options_provider: None,
                    new_table_config: options.new_table_config,
                    session,
-                    namespace_database,
                })
            }
            Err(_) => {
@@ -458,7 +405,6 @@ impl ListingDatabase {
                    uri,
                    request.read_consistency_interval,
                    options.new_table_config,
-                    request.namespace_client_properties.clone(),
                    request.session.clone(),
                )
                .await
@@ -470,7 +416,6 @@ impl ListingDatabase {
        path: &str,
        read_consistency_interval: Option<std::time::Duration>,
        new_table_config: NewTableConfig,
-        namespace_client_properties: HashMap<String, String>,
        session: Option<Arc<lance::session::Session>>,
    ) -> Result<Self> {
        let session = session.unwrap_or_else(|| Arc::new(lance::session::Session::default()));
@@ -484,15 +429,6 @@ impl ListingDatabase {
            Self::try_create_dir(path).context(CreateDirSnafu { path })?;
        }

-        let namespace_database = Self::connect_namespace_database(
-            path,
-            HashMap::new(),
-            namespace_client_properties,
-            read_consistency_interval,
-            session.clone(),
-        )
-        .await?;
-
        Ok(Self {
            uri: path.to_string(),
            query_string: None,
@@ -504,7 +440,6 @@ impl ListingDatabase {
            storage_options_provider: None,
            new_table_config,
            session,
-            namespace_database,
        })
    }

@@ -562,10 +497,6 @@ impl ListingDatabase {
        Ok(uri)
    }

-    fn namespace_database(&self) -> Arc<LanceNamespaceDatabase> {
-        self.namespace_database.clone()
-    }
-
    async fn drop_tables(&self, names: Vec<String>) -> Result<()> {
        let object_store_params = ObjectStoreParams {
            storage_options_accessor: if self.storage_options.is_empty() {
@@ -765,7 +696,16 @@ impl Database for ListingDatabase {
        &self,
        request: ListNamespacesRequest,
    ) -> Result<ListNamespacesResponse> {
-        self.namespace_database().list_namespaces(request).await
+        if request.id.as_ref().map(|v| !v.is_empty()).unwrap_or(false) {
+            return Err(Error::NotSupported {
+                message: "Namespace operations are not supported for listing database".into(),
+            });
+        }
+
+        Ok(ListNamespacesResponse {
+            namespaces: Vec::new(),
+            page_token: None,
+        })
    }

    fn uri(&self) -> &str {
@@ -786,26 +726,36 @@ impl Database for ListingDatabase {

    async fn create_namespace(
        &self,
-        request: CreateNamespaceRequest,
+        _request: CreateNamespaceRequest,
    ) -> Result<CreateNamespaceResponse> {
-        self.namespace_database().create_namespace(request).await
+        Err(Error::NotSupported {
+            message: "Namespace operations are not supported for listing database".into(),
+        })
    }

-    async fn drop_namespace(&self, request: DropNamespaceRequest) -> Result<DropNamespaceResponse> {
-        self.namespace_database().drop_namespace(request).await
+    async fn drop_namespace(
+        &self,
+        _request: DropNamespaceRequest,
+    ) -> Result<DropNamespaceResponse> {
+        Err(Error::NotSupported {
+            message: "Namespace operations are not supported for listing database".into(),
+        })
    }

    async fn describe_namespace(
        &self,
-        request: DescribeNamespaceRequest,
+        _request: DescribeNamespaceRequest,
    ) -> Result<DescribeNamespaceResponse> {
-        self.namespace_database().describe_namespace(request).await
+        Err(Error::NotSupported {
+            message: "Namespace operations are not supported for listing database".into(),
+        })
    }

-    #[allow(deprecated)]
    async fn table_names(&self, request: TableNamesRequest) -> Result<Vec<String>> {
        if !request.namespace_path.is_empty() {
-            return self.namespace_database().table_names(request).await;
+            return Err(Error::NotSupported {
+                message: "Namespace parameter is not supported for listing database. Only root namespace is supported.".into(),
+            });
        }
        let mut f = self
            .object_store
@@ -838,7 +788,9 @@ impl Database for ListingDatabase {

    async fn list_tables(&self, request: ListTablesRequest) -> Result<ListTablesResponse> {
        if request.id.as_ref().map(|v| !v.is_empty()).unwrap_or(false) {
-            return self.namespace_database().list_tables(request).await;
+            return Err(Error::NotSupported {
+                message: "Namespace parameter is not supported for listing database. Only root namespace is supported.".into(),
+            });
        }
        let mut f = self
            .object_store
@@ -886,8 +838,11 @@ impl Database for ListingDatabase {
    }

    async fn create_table(&self, request: CreateTableRequest) -> Result<Arc<dyn BaseTable>> {
-        if !request.namespace_path.is_empty() {
-            return self.namespace_database().create_table(request).await;
+        // When namespace is not empty, location must be provided
+        if !request.namespace_path.is_empty() && request.location.is_none() {
+            return Err(Error::InvalidInput {
+                message: "Location must be provided when namespace is not empty".into(),
+            });
        }
        // Use provided location if available, otherwise derive from table name
        let table_uri = request
@@ -1004,8 +959,11 @@ impl Database for ListingDatabase {
    }

    async fn open_table(&self, mut request: OpenTableRequest) -> Result<Arc<dyn BaseTable>> {
-        if !request.namespace_path.is_empty() {
-            return self.namespace_database().open_table(request).await;
+        // When namespace is not empty, location must be provided
+        if !request.namespace_path.is_empty() && request.location.is_none() {
+            return Err(Error::InvalidInput {
+                message: "Location must be provided when namespace is not empty".into(),
+            });
        }
        // Use provided location if available, otherwise derive from table name
        let table_uri = request
@@ -1101,10 +1059,9 @@ impl Database for ListingDatabase {

    async fn drop_table(&self, name: &str, namespace_path: &[String]) -> Result<()> {
        if !namespace_path.is_empty() {
-            return self
-                .namespace_database()
-                .drop_table(name, namespace_path)
-                .await;
+            return Err(Error::NotSupported {
+                message: "Namespace parameter is not supported for listing database.".into(),
+            });
        }
        self.drop_tables(vec![name.to_string()]).await
    }
@@ -1113,10 +1070,9 @@ impl Database for ListingDatabase {
    async fn drop_all_tables(&self, namespace_path: &[String]) -> Result<()> {
        // Check if namespace parameter is provided
        if !namespace_path.is_empty() {
-            return self
-                .namespace_database()
-                .drop_all_tables(namespace_path)
-                .await;
+            return Err(Error::NotSupported {
+                message: "Namespace parameter is not supported for listing database.".into(),
+            });
        }
        let tables = self.table_names(TableNamesRequest::default()).await?;
        self.drop_tables(tables).await
@@ -1127,11 +1083,30 @@ impl Database for ListingDatabase {
    }

    async fn namespace_client(&self) -> Result<Arc<dyn lance_namespace::LanceNamespace>> {
-        self.namespace_database.namespace_client().await
+        // Create a DirectoryNamespace pointing to the same root with the same storage options
+        let mut builder = lance_namespace_impls::DirectoryNamespaceBuilder::new(&self.uri);
+
+        // Add storage options
+        if !self.storage_options.is_empty() {
+            builder = builder.storage_options(self.storage_options.clone());
+        }
+
+        // Use the same session
+        builder = builder.session(self.session.clone());
+
+        let namespace = builder.build().await.map_err(|e| Error::Runtime {
+            message: format!("Failed to create namespace client: {}", e),
+        })?;
+        Ok(Arc::new(namespace) as Arc<dyn lance_namespace::LanceNamespace>)
    }

    async fn namespace_client_config(&self) -> Result<(String, HashMap<String, String>)> {
-        self.namespace_database.namespace_client_config().await
+        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))
    }
 }

@@ -1157,7 +1132,6 @@ mod tests {
            #[cfg(feature = "remote")]
            client_config: Default::default(),
            options: Default::default(),
-            namespace_client_properties: Default::default(),
            read_consistency_interval: None,
            session: None,
        };
@@ -1291,7 +1265,6 @@ mod tests {
            #[cfg(feature = "remote")]
            client_config: Default::default(),
            options: options.clone(),
-            namespace_client_properties: Default::default(),
            read_consistency_interval: None,
            session: None,
        };
@@ -1826,7 +1799,6 @@ mod tests {
            #[cfg(feature = "remote")]
            client_config: Default::default(),
            options,
-            namespace_client_properties: Default::default(),
            read_consistency_interval: None,
            session: None,
        };
@@ -1932,7 +1904,6 @@ mod tests {
            #[cfg(feature = "remote")]
            client_config: Default::default(),
            options,
-            namespace_client_properties: Default::default(),
            read_consistency_interval: None,
            session: None,
        };
@@ -2004,7 +1975,6 @@ mod tests {
            #[cfg(feature = "remote")]
            client_config: Default::default(),
            options,
-            namespace_client_properties: Default::default(),
            read_consistency_interval: None,
            session: None,
        };
@@ -2138,209 +2108,4 @@ mod tests {
        assert!(tables.contains(&"table1".to_string()));
        assert!(tables.contains(&"table2".to_string()));
    }
-
-    #[tokio::test]
-    async fn test_listing_database_namespace_operations() {
-        let (_tempdir, db) = setup_database().await;
-
-        db.create_namespace(CreateNamespaceRequest {
-            id: Some(vec!["parent".to_string()]),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-
-        db.create_namespace(CreateNamespaceRequest {
-            id: Some(vec!["parent".to_string(), "child".to_string()]),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-
-        let root_namespaces = db
-            .list_namespaces(ListNamespacesRequest {
-                id: Some(vec![]),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-        assert!(root_namespaces.namespaces.contains(&"parent".to_string()));
-
-        let child_namespaces = db
-            .list_namespaces(ListNamespacesRequest {
-                id: Some(vec!["parent".to_string()]),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-        assert!(child_namespaces.namespaces.contains(&"child".to_string()));
-
-        db.describe_namespace(DescribeNamespaceRequest {
-            id: Some(vec!["parent".to_string(), "child".to_string()]),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-    }
-
-    #[tokio::test]
-    #[cfg(not(windows))] // TODO: support Windows once directory namespace-backed listing DB tests are supported.
-    async fn test_listing_database_with_namespace_client_properties() {
-        let tempdir = tempdir().unwrap();
-        let uri = tempdir.path().to_str().unwrap();
-
-        let mut namespace_client_properties = HashMap::new();
-        namespace_client_properties.insert(
-            "table_version_tracking_enabled".to_string(),
-            "true".to_string(),
-        );
-        namespace_client_properties.insert("manifest_enabled".to_string(), "true".to_string());
-
-        let request = ConnectRequest {
-            uri: uri.to_string(),
-            #[cfg(feature = "remote")]
-            client_config: Default::default(),
-            options: Default::default(),
-            namespace_client_properties,
-            read_consistency_interval: None,
-            session: None,
-        };
-
-        let db = ListingDatabase::connect_with_options(&request)
-            .await
-            .unwrap();
-        let namespace_path = vec!["test_ns".to_string()];
-
-        db.create_namespace(CreateNamespaceRequest {
-            id: Some(namespace_path.clone()),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-
-        let schema = Arc::new(Schema::new(vec![
-            Field::new("id", DataType::Int32, false),
-            Field::new("name", DataType::Utf8, false),
-        ]));
-
-        db.create_table(CreateTableRequest {
-            name: "managed_table".to_string(),
-            namespace_path: namespace_path.clone(),
-            data: Box::new(RecordBatch::new_empty(schema)) as Box<dyn Scannable>,
-            mode: CreateTableMode::Create,
-            write_options: Default::default(),
-            location: None,
-            namespace_client: None,
-        })
-        .await
-        .unwrap();
-
-        let namespace_client = db.namespace_client().await.unwrap();
-        let describe = namespace_client
-            .describe_table(lance_namespace::models::DescribeTableRequest {
-                id: Some(vec!["test_ns".to_string(), "managed_table".to_string()]),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-
-        assert_eq!(describe.managed_versioning, Some(true));
-    }
-
-    #[tokio::test]
-    async fn test_listing_database_nested_namespace_table_ops() {
-        let (_tempdir, db) = setup_database().await;
-        let namespace_path = vec!["parent".to_string(), "child".to_string()];
-
-        db.create_namespace(CreateNamespaceRequest {
-            id: Some(vec!["parent".to_string()]),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-        db.create_namespace(CreateNamespaceRequest {
-            id: Some(namespace_path.clone()),
-            ..Default::default()
-        })
-        .await
-        .unwrap();
-
-        let schema = Arc::new(Schema::new(vec![
-            Field::new("id", DataType::Int32, false),
-            Field::new("name", DataType::Utf8, false),
-        ]));
-
-        db.create_table(CreateTableRequest {
-            name: "nested_table".to_string(),
-            namespace_path: namespace_path.clone(),
-            data: Box::new(RecordBatch::new_empty(schema)) as Box<dyn Scannable>,
-            mode: CreateTableMode::Create,
-            write_options: Default::default(),
-            location: None,
-            namespace_client: None,
-        })
-        .await
-        .unwrap();
-
-        let namespace_client = db.namespace_client().await.unwrap();
-        let describe = namespace_client
-            .describe_table(lance_namespace::models::DescribeTableRequest {
-                id: Some(vec![
-                    "parent".to_string(),
-                    "child".to_string(),
-                    "nested_table".to_string(),
-                ]),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-        assert!(describe.location.is_some());
-
-        let table = db
-            .open_table(OpenTableRequest {
-                name: "nested_table".to_string(),
-                namespace_path: namespace_path.clone(),
-                index_cache_size: None,
-                lance_read_params: None,
-                location: None,
-                namespace_client: None,
-                managed_versioning: None,
-            })
-            .await
-            .unwrap();
-        assert_eq!(table.name(), "nested_table");
-
-        #[allow(deprecated)]
-        let table_names = db
-            .table_names(TableNamesRequest {
-                namespace_path: namespace_path.clone(),
-                start_after: None,
-                limit: None,
-            })
-            .await
-            .unwrap();
-        assert_eq!(table_names, vec!["nested_table".to_string()]);
-
-        let list_tables = db
-            .list_tables(ListTablesRequest {
-                id: Some(namespace_path.clone()),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-        assert_eq!(list_tables.tables, vec!["nested_table".to_string()]);
-
-        db.drop_table("nested_table", &namespace_path)
-            .await
-            .unwrap();
-
-        let post_drop = db
-            .list_tables(ListTablesRequest {
-                id: Some(namespace_path),
-                ..Default::default()
-            })
-            .await
-            .unwrap();
-        assert!(post_drop.tables.is_empty());
-    }
 }
--- a/rust/lancedb/src/database/namespace.rs
+++ b/rust/lancedb/src/database/namespace.rs
@@ -22,11 +22,10 @@ use lance_namespace_impls::ConnectBuilder;
 use lance_table::io::commit::CommitHandler;
 use lance_table::io::commit::external_manifest::ExternalManifestCommitHandler;

-use crate::connection::NamespaceClientPushdownOperation;
+use crate::connection::PushdownOperation;
 use crate::database::ReadConsistency;
 use crate::error::{Error, Result};
 use crate::table::NativeTable;
-use lance::dataset::WriteMode;

 use super::{
    BaseTable, CloneTableRequest, CreateTableMode, CreateTableRequest as DbCreateTableRequest,
@@ -45,7 +44,7 @@ pub struct LanceNamespaceDatabase {
    // database URI
    uri: String,
    // Operations to push down to the namespace server
-    pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+    pushdown_operations: HashSet<PushdownOperation>,
    // Namespace implementation type (e.g., "dir", "rest")
    ns_impl: String,
    // Namespace properties used to construct the namespace client
@@ -53,34 +52,13 @@ pub struct LanceNamespaceDatabase {
 }

 impl LanceNamespaceDatabase {
-    pub fn from_namespace_client(
-        namespace_client: Arc<dyn LanceNamespace>,
-        namespace_client_impl: String,
-        namespace_client_properties: HashMap<String, String>,
-        storage_options: HashMap<String, String>,
-        read_consistency_interval: Option<std::time::Duration>,
-        session: Option<Arc<lance::session::Session>>,
-        namespace_client_pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
-    ) -> Self {
-        Self {
-            namespace: namespace_client,
-            storage_options,
-            read_consistency_interval,
-            session,
-            uri: format!("namespace://{}", namespace_client_impl),
-            pushdown_operations: namespace_client_pushdown_operations,
-            ns_impl: namespace_client_impl,
-            ns_properties: namespace_client_properties,
-        }
-    }
-
    pub async fn connect(
        ns_impl: &str,
        ns_properties: HashMap<String, String>,
        storage_options: HashMap<String, String>,
        read_consistency_interval: Option<std::time::Duration>,
        session: Option<Arc<lance::session::Session>>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
    ) -> Result<Self> {
        let mut builder = ConnectBuilder::new(ns_impl);
        for (key, value) in ns_properties.clone() {
@@ -185,23 +163,37 @@ impl Database for LanceNamespaceDatabase {
    async fn create_table(&self, request: DbCreateTableRequest) -> Result<Arc<dyn BaseTable>> {
        let mut table_id = request.namespace_path.clone();
        table_id.push(request.name.clone());
-        let mut existing_table = None;
+        let describe_request = DescribeTableRequest {
+            id: Some(table_id.clone()),
+            ..Default::default()
+        };
+
+        let describe_result = self.namespace.describe_table(describe_request).await;

        match request.mode {
-            CreateTableMode::Create => {}
+            CreateTableMode::Create => {
+                if describe_result.is_ok() {
+                    return Err(Error::TableAlreadyExists {
+                        name: request.name.clone(),
+                    });
+                }
+            }
            CreateTableMode::Overwrite => {
-                let describe_request = DescribeTableRequest {
-                    id: Some(table_id.clone()),
-                    ..Default::default()
-                };
-                existing_table = self.namespace.describe_table(describe_request).await.ok();
+                if describe_result.is_ok() {
+                    // Drop the existing table - must succeed
+                    let drop_request = DropTableRequest {
+                        id: Some(table_id.clone()),
+                        ..Default::default()
+                    };
+                    self.namespace
+                        .drop_table(drop_request)
+                        .await
+                        .map_err(|e| Error::Runtime {
+                            message: format!("Failed to drop existing table for overwrite: {}", e),
+                        })?;
+                }
            }
            CreateTableMode::ExistOk(_) => {
-                let describe_request = DescribeTableRequest {
-                    id: Some(table_id.clone()),
-                    ..Default::default()
-                };
-                let describe_result = self.namespace.describe_table(describe_request).await;
                if describe_result.is_ok() {
                    let native_table = NativeTable::open_from_namespace(
                        self.namespace.clone(),
@@ -229,55 +221,21 @@ impl Database for LanceNamespaceDatabase {
        };

        let (location, initial_storage_options, managed_versioning) = {
-            if let Some(response) = existing_table {
-                let loc = response.location.ok_or_else(|| Error::Runtime {
-                    message: "Table location is missing from describe_table response".to_string(),
-                })?;
-                let opts = response
-                    .storage_options
-                    .or_else(|| Some(self.storage_options.clone()))
-                    .filter(|o| !o.is_empty());
-                (loc, opts, response.managed_versioning)
-            } else {
-                let response = self
-                    .namespace
-                    .declare_table(declare_request)
-                    .await
-                    .map_err(|e| {
-                        let err_str = e.to_string();
-                        if matches!(request.mode, CreateTableMode::Create)
-                            && (err_str.contains("already exists")
-                                || err_str.contains("TableAlreadyExists")
-                                || err_str.contains("table already exists"))
-                        {
-                            Error::TableAlreadyExists {
-                                name: request.name.clone(),
-                            }
-                        } else {
-                            Error::Runtime {
-                                message: format!("Failed to declare table: {}", e),
-                            }
-                        }
-                    })?;
-                let loc = response.location.ok_or_else(|| Error::Runtime {
-                    message: "Table location is missing from declare_table response".to_string(),
-                })?;
-                // Use storage options from response, fall back to self.storage_options
-                let opts = response
-                    .storage_options
-                    .or_else(|| Some(self.storage_options.clone()))
-                    .filter(|o| !o.is_empty());
-                (loc, opts, response.managed_versioning)
-            }
+            let response = self.namespace.declare_table(declare_request).await?;
+            let loc = response.location.ok_or_else(|| Error::Runtime {
+                message: "Table location is missing from declare_table response".to_string(),
+            })?;
+            // Use storage options from response, fall back to self.storage_options
+            let opts = response
+                .storage_options
+                .or_else(|| Some(self.storage_options.clone()))
+                .filter(|o| !o.is_empty());
+            (loc, opts, response.managed_versioning)
        };

        // Build write params with storage options and commit handler
        let mut params = request.write_options.lance_write_params.unwrap_or_default();

-        if matches!(request.mode, CreateTableMode::Overwrite) {
-            params.mode = WriteMode::Overwrite;
-        }
-
        // Set up storage options if provided
        if let Some(storage_opts) = initial_storage_options {
            let store_params = params
@@ -492,47 +450,6 @@ mod tests {
        ));
    }

-    #[tokio::test]
-    async fn test_namespace_connection_with_namespace_client_properties() {
-        let tmp_dir = tempdir().unwrap();
-        let root_path = tmp_dir.path().to_str().unwrap().to_string();
-
-        let mut properties = HashMap::new();
-        properties.insert("root".to_string(), root_path);
-
-        let conn = connect_namespace("dir", properties)
-            .namespace_client_property("table_version_tracking_enabled", "true")
-            .namespace_client_property("manifest_enabled", "true")
-            .execute()
-            .await
-            .expect("Failed to connect to namespace");
-
-        conn.create_namespace(CreateNamespaceRequest {
-            id: Some(vec!["test_ns".into()]),
-            ..Default::default()
-        })
-        .await
-        .expect("Failed to create namespace");
-
-        let test_data = create_test_data();
-        conn.create_table("test_table", test_data)
-            .namespace(vec!["test_ns".into()])
-            .execute()
-            .await
-            .expect("Failed to create table");
-
-        let namespace_client = conn.namespace_client().await.unwrap();
-        let describe = namespace_client
-            .describe_table(DescribeTableRequest {
-                id: Some(vec!["test_ns".into(), "test_table".into()]),
-                ..Default::default()
-            })
-            .await
-            .expect("Failed to describe table");
-
-        assert_eq!(describe.managed_versioning, Some(true));
-    }
-
    #[tokio::test]
    async fn test_namespace_create_table_basic() {
        // Setup: Create a temporary directory for the namespace
--- a/rust/lancedb/src/lib.rs
+++ b/rust/lancedb/src/lib.rs
@@ -69,7 +69,7 @@
 //! It treats [`FixedSizeList<Float16/Float32>`](https://docs.rs/arrow/latest/arrow/array/struct.FixedSizeListArray.html)
 //! columns as vector columns.
 //!
-//! For more details, please refer to the [LanceDB documentation](https://docs.lancedb.com).
+//! For more details, please refer to the [LanceDB documentation](https://lancedb.com/docs).
 //!
 //! #### Create a table
 //!
--- a/rust/lancedb/src/remote/db.rs
+++ b/rust/lancedb/src/remote/db.rs
@@ -97,7 +97,7 @@ pub struct RemoteDatabaseOptions {
    pub host_override: Option<String>,
    /// Storage options configure the storage layer (e.g. S3, GCS, Azure, etc.)
    ///
-    /// See available options at <https://docs.lancedb.com/storage/>
+    /// See available options at <https://lancedb.com/docs/storage/>
    ///
    /// These options are only used for LanceDB Enterprise and only a subset of options
    /// are supported.
--- a/rust/lancedb/src/table.rs
+++ b/rust/lancedb/src/table.rs
@@ -47,7 +47,7 @@ use std::format;
 use std::path::Path;
 use std::sync::Arc;

-use crate::connection::NamespaceClientPushdownOperation;
+use crate::connection::PushdownOperation;

 use crate::data::scannable::{PeekedScannable, Scannable, estimate_write_partitions};
 use crate::database::Database;
@@ -1272,7 +1272,7 @@ pub struct NativeTable {
    pub(crate) namespace_client: Option<Arc<dyn LanceNamespace>>,
    // Operations to push down to the namespace server.
    // pub(crate) so query.rs can access the field for server-side query execution.
-    pub(crate) pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+    pub(crate) pushdown_operations: HashSet<PushdownOperation>,
 }

 impl std::fmt::Debug for NativeTable {
@@ -1359,7 +1359,7 @@ impl NativeTable {
        params: Option<ReadParams>,
        read_consistency_interval: Option<std::time::Duration>,
        namespace_client: Option<Arc<dyn LanceNamespace>>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
        managed_versioning: Option<bool>,
    ) -> Result<Self> {
        let params = params.unwrap_or_default();
@@ -1470,7 +1470,7 @@ impl NativeTable {
        write_store_wrapper: Option<Arc<dyn WrappingObjectStore>>,
        params: Option<ReadParams>,
        read_consistency_interval: Option<std::time::Duration>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
        session: Option<Arc<lance::session::Session>>,
    ) -> Result<Self> {
        let mut params = params.unwrap_or_default();
@@ -1518,7 +1518,7 @@ impl NativeTable {
        let id = Self::build_id(&namespace, name);

        let stored_namespace_client =
-            if pushdown_operations.contains(&NamespaceClientPushdownOperation::QueryTable) {
+            if pushdown_operations.contains(&PushdownOperation::QueryTable) {
                Some(namespace_client)
            } else {
                None
@@ -1588,7 +1588,7 @@ impl NativeTable {
        params: Option<WriteParams>,
        read_consistency_interval: Option<std::time::Duration>,
        namespace_client: Option<Arc<dyn LanceNamespace>>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
    ) -> Result<Self> {
        // Default params uses format v1.
        let params = params.unwrap_or(WriteParams {
@@ -1635,7 +1635,7 @@ impl NativeTable {
        params: Option<WriteParams>,
        read_consistency_interval: Option<std::time::Duration>,
        namespace_client: Option<Arc<dyn LanceNamespace>>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
    ) -> Result<Self> {
        let data: Box<dyn Scannable> = Box::new(RecordBatch::new_empty(schema));
        Self::create(
@@ -1685,7 +1685,7 @@ impl NativeTable {
        write_store_wrapper: Option<Arc<dyn WrappingObjectStore>>,
        params: Option<WriteParams>,
        read_consistency_interval: Option<std::time::Duration>,
-        pushdown_operations: HashSet<NamespaceClientPushdownOperation>,
+        pushdown_operations: HashSet<PushdownOperation>,
        session: Option<Arc<lance::session::Session>>,
    ) -> Result<Self> {
        // Build table_id from namespace + name for the storage options provider
@@ -1738,7 +1738,7 @@ impl NativeTable {
        let id = Self::build_id(&namespace, name);

        let stored_namespace_client =
-            if pushdown_operations.contains(&NamespaceClientPushdownOperation::QueryTable) {
+            if pushdown_operations.contains(&PushdownOperation::QueryTable) {
                Some(namespace_client)
            } else {
                None
--- a/rust/lancedb/src/table/dataset.rs
+++ b/rust/lancedb/src/table/dataset.rs
@@ -285,10 +285,7 @@ mod tests {

    use super::*;

-    use crate::{
-        connect, io::object_store::io_tracking::IoStatsHolder, table::WriteOptions,
-        utils::background_cache::clock,
-    };
+    use crate::{connect, io::object_store::io_tracking::IoStatsHolder, table::WriteOptions};

    async fn create_test_dataset(uri: &str) -> Dataset {
        let schema = Arc::new(Schema::new(vec![Field::new("id", DataType::Int32, false)]));
@@ -466,10 +463,6 @@ mod tests {
        let uri = dir.path().to_str().unwrap();
        let ds = create_test_dataset(uri).await;

-        // Other tests use a thread-local mock clock. Simulate leaked state from a
-        // previous test to ensure this wrapper starts from real time.
-        clock::advance_by(Duration::from_secs(60));
-
        let wrapper = DatasetConsistencyWrapper::new_latest(ds, Some(Duration::from_millis(200)));

        // Populate the cache
--- a/rust/lancedb/src/table/query.rs
+++ b/rust/lancedb/src/table/query.rs
@@ -4,7 +4,7 @@
 use std::sync::Arc;

 use super::NativeTable;
-use crate::connection::NamespaceClientPushdownOperation;
+use crate::connection::PushdownOperation;
 use crate::error::{Error, Result};
 use crate::expr::expr_to_sql_string;
 use crate::query::{
@@ -44,7 +44,7 @@ pub async fn execute_query(
    // If QueryTable pushdown is enabled and namespace client is configured, use server-side query execution
    if table
        .pushdown_operations
-        .contains(&NamespaceClientPushdownOperation::QueryTable)
+        .contains(&PushdownOperation::QueryTable)
        && let Some(ref namespace_client) = table.namespace_client
    {
        return execute_namespace_query(table, namespace_client.clone(), query, options).await;
--- a/rust/lancedb/src/utils/background_cache.rs
+++ b/rust/lancedb/src/utils/background_cache.rs
@@ -107,14 +107,6 @@ where
            refresh_window < ttl,
            "refresh_window ({refresh_window:?}) must be less than ttl ({ttl:?})"
        );
-        #[cfg(test)]
-        {
-            // Tests may advance the thread-local mock clock and leave it behind for
-            // the next test that happens to run on the same worker thread. Each new
-            // cache should start from a clean clock state instead of inheriting
-            // unrelated mock time from a previous test.
-            clock::clear_mock();
-        }
        Self {
            inner: Arc::new(Mutex::new(CacheInner {
                state: State::Empty,