ci: fix pypi publish on mac/windows/arm (#3449)

The python-v0.32.0 publish run failed on every build matrix entry. Three
independent issues:

1. **Mac and Windows**: `pypa/gh-action-pypi-publish` only runs on
Linux, but was being called inline from each build job.
2. **Linux (all arches)**: `pypa/gh-action-pypi-publish` derives its
docker image name from `github.action_repository`, which is empty when
the action is invoked from inside a composite action
(actions/runner#2473 — pypa's own `action.yml` references this bug). It
falls back to `github.repository`, generating
`docker://ghcr.io/lancedb/lancedb:<tag>`, which doesn't exist →
`denied`. Only the ARM matrix entry surfaced this because it failed
first and cancel-cascaded the rest.
3. **Windows**: `upload-artifact` in `build_windows_wheel` pointed at
`python\target\wheels`, but maturin writes to the workspace-root
`target/wheels`. The artifact was always empty. Also, `pypi-publish.yml`
passed a `vcpkg_token` input that the composite doesn't declare.

## Changes

- Build jobs (linux/mac/windows) now upload their wheels as
`actions/upload-artifact` artifacts.
- New Linux `publish` job downloads all wheel artifacts and runs the
Fury or PyPA publish step directly (not via a composite), so
`github.action_repository` resolves correctly.
- Delete the unused `upload_wheel` composite action.
- Drop the broken upload-artifact step inside `build_windows_wheel`.
- Remove the bogus `vcpkg_token` input.
- Fury upload now loops over all wheels instead of just the first.
- Bump `actions/checkout`, `actions/upload-artifact`,
`actions/download-artifact` to current major versions (Node 24) to clear
deprecation warnings.
- Bump Windows job timeout 60 → 90 minutes; previous run was
cancel-timing-out on a 60m cap.
- Use `rust-lld` as the Windows MSVC linker via
`CARGO_TARGET_X86_64_PC_WINDOWS_MSVC_LINKER`. `link.exe` is
single-threaded and the long pole on Windows builds.

Fixes #3445

## Test plan

- [x] Open this PR — `paths` filter triggers a dry-run build on all
three platforms.
- [x] Verify all three builds produce wheels.
- [x] Confirm the `pypa/gh-action-pypi-publish` container actually
starts (the actions/runner#2473 bug) via the `publish-dry-run` job
pointed at TestPyPI.
- [x] **REMOVE BEFORE MERGE**: drop the `publish-dry-run` job and the
now-redundant `actions/upload-artifact` runs on PRs (currently always-on
so the dry-run has wheels to publish).
- [ ] After merge, cherry-pick onto `python-v0.32.0` and force-push the
tag to re-trigger the publish.

.agents/skills/README.md

@@ -1,7 +0,0 @@
-# Agent Skills
-
-This directory contains repo-scoped code agent skills for the LanceDB project.
-
-Each skill is a folder that contains a required `SKILL.md` and optional bundled resources.
-
-Codex discovers skills from `.agents/skills` in the current working directory and parent directories.

.agents/skills/lancedb-column-metadata/SKILL.md

@@ -1,178 +0,0 @@
----
-name: lancedb-column-metadata
-description: Column metadata authoring for LanceDB tables via the REST API. This skill is required for tasks like writing field descriptions, setting tags on columns (field_type, model, project_id, version), classifying columns as embeddings vs labels vs eval metrics, or grouping versioned columns into logical families — because it has the API integration needed to read the schema and persist metadata back. Invoke whenever someone wants to document, annotate, tag, or classify what their table columns ARE. Trigger even without an explicit "LanceDB" mention, as long as the context is column-level documentation or tagging for an ML or vector database table.
-metadata:
-  short-description: Write column descriptions, tags, and logical groupings to a LanceDB table
----
-
-## Overview
-
-This skill authors column-level metadata for a LanceDB table. It connects to a LanceDB deployment over its REST API, inspects the table schema, generates appropriate metadata, and writes it back.
-
-## Step 0: Establish the connection
-
-Use the `lancedb-connect` skill (invoke it via the Skill tool) to resolve the base URL and auth headers (`x-api-key`, `x-lancedb-database`) for whichever deployment the user is working against — enterprise/self-hosted or a local dev server. Skip it only if the connection details are already established in the conversation.
-
-All examples below use `{base_url}` — substitute the resolved endpoint and include the resolved headers on every request.
-
-## Metadata keys
-
-All metadata uses namespaced keys:
-
-| Key | Purpose | Example value |
-|-----|---------|---------------|
-| `lancedb:description` | Human-readable explanation of what the column contains | `"CLIP ViT-L/14 image embedding, L2-normalized (768-dim)"` |
-| `lancedb:tag:<name>` | Flexible key-value tag; the suffix names the tag category | `lancedb:tag:field_type: "embedding"`, `lancedb:tag:model: "clip"`, `lancedb:tag:project_id: "foo"` |
-| `lancedb:logical-column` | Logical group/family this column belongs to | `"clip_features"` |
-
-Tags are open-ended — use whatever key suffix and value make sense given the user's intent. The tag suffix should describe *what is being classified* (e.g., `field_type`, `model`, `project_id`) and the value describes *how*.
-
-## Step 1: Resolve the table identifier
-
-You need:
-- **Table name** (required) — e.g., `my_table` or `my_namespace.my_table`
-- **Database name** — ask if not provided and not inferable from context; it goes in the `x-lancedb-database` header, never in the URL path
-
-The table identifier in the URL path is typically `table_name` for a top-level table, or `namespace$table_name` if the table lives in a namespace. The API accepts a `delimiter` query parameter to parse compound identifiers (default `$`).
-
-## Step 2: Describe the table
-
-```http
-POST {base_url}/v1/table/{table_id}/describe
-Content-Type: application/json
-
-{}
-```
-
-The response contains `schema.fields` — an array of field objects:
-
-```json
-{
-  "schema": {
-    "fields": [
-      {
-        "name": "clip_embedding_v3",
-        "type": { "type": "FixedSizeList", "fields": [...], "listSize": 768 },
-        "nullable": true,
-        "metadata": { "lancedb:description": "..." }
-      }
-    ]
-  }
-}
-```
-
-Each field has:
-- `name` — field name
-- `type` — Arrow data type (check `type.type` for the type string)
-- `nullable` — boolean
-- `metadata` — existing key-value metadata (read this before writing to avoid redundant updates)
-
-For struct/nested fields, recurse into `type.fields` and represent them as dot-notation paths (e.g., `parent.child`).
-
-If the user hasn't specified which columns to update, work with all columns.
-
-## Step 3: Generate metadata
-
-Decide what to generate based on the user's request.
-
-### Writing descriptions (`lancedb:description`)
-
-Base descriptions on:
-- The column name and Arrow type (e.g., `FixedSizeList` of floats → likely an embedding)
-- User-supplied context (upstream pipeline, sample values, domain knowledge)
-- Name patterns: `_embedding`/`_vec`/`_embed` → vector; `_label`/`_class` → label; `_score`/`_eval`/`_metric` → evaluation metric
-
-Be specific and concise. Good: `"Sentence-BERT embedding of the query text (768-dim)."` Not: `"An embedding column."`
-
-### Tagging columns (`lancedb:tag:<name>`)
-
-Choose tag key names that match what the user asked to annotate. Common patterns:
-
-- Semantic field type → `lancedb:tag:field_type: "embedding"` / `"text"` / `"image"` / `"label"` / `"eval"` / `"id"` / `"metadata"`
-- Model or source → `lancedb:tag:model: "clip"` / `"bert"` / `"vit"`
-- Project affiliation → `lancedb:tag:project_id: "<name>"`
-- Version → `lancedb:tag:version: "v3"` (and `lancedb:tag:latest: "true"` for the newest)
-
-Use Arrow type as a hint: `FixedSizeList` + float → embedding; `Utf8`/`LargeUtf8` → text; `Binary` → image or blob.
-
-Multiple tags on the same column are fine — each is a separate key.
-
-### Grouping into logical columns (`lancedb:logical-column`)
-
-Look for naming patterns across columns:
-- `clip_v1`, `clip_v2`, `clip_v3` → logical column `"clip"`, latest is `v3`
-- `text_embed_20240101`, `text_embed_20240601` → logical column `"text_embed"`, latest is the most recent date suffix
-
-Write `lancedb:logical-column` on all members of a group. Mark the newest with `lancedb:tag:latest: "true"` (in addition to its version tag).
-
-## Step 4: Write the metadata
-
-```http
-POST {base_url}/v1/table/{table_id}/update_field_metadata
-Content-Type: application/json
-
-{
-  "updates": [
-    {
-      "path": "clip_v3",
-      "metadata": {
-        "lancedb:description": "CLIP ViT-L/14 image embedding, L2-normalized (1024-dim).",
-        "lancedb:tag:field_type": "embedding",
-        "lancedb:tag:model": "clip",
-        "lancedb:tag:version": "v3",
-        "lancedb:tag:latest": "true",
-        "lancedb:logical-column": "clip"
-      },
-      "replace": false
-    },
-    {
-      "path": "clip_v2",
-      "metadata": {
-        "lancedb:description": "CLIP ViT-B/32 image embedding (768-dim), superseded by v3.",
-        "lancedb:tag:field_type": "embedding",
-        "lancedb:tag:model": "clip",
-        "lancedb:tag:version": "v2",
-        "lancedb:logical-column": "clip"
-      },
-      "replace": false
-    }
-  ]
-}
-```
-
-Rules:
-- **Use `"replace": false`** (merge) by default — this preserves existing metadata the user didn't ask to change
-- Use `"replace": true` only if the user explicitly asks to overwrite all existing metadata on a column
-- Set a value to `null` to delete a specific key
-- Batch all updates in a single request when possible
-
-The response includes `version` (new table version) and `fields` (the updated metadata per field).
-
-## Step 5: Confirm
-
-Report back:
-- Which columns were updated and what was written
-- The new table version number
-- Any columns skipped (e.g., already had up-to-date metadata)
-
----
-
-## Quick examples
-
-**"Write descriptions for all columns in the `product_embeddings` table"**
-1. POST `/v1/table/product_embeddings/describe` → get all fields
-2. Generate a `lancedb:description` for each column based on name + type
-3. POST `update_field_metadata` with descriptions
-4. Report
-
-**"Tag the columns in `model_outputs` with their field type and model"**
-1. Describe `model_outputs`
-2. For each field, classify by name + Arrow type → set `lancedb:tag:field_type` and `lancedb:tag:model` where applicable
-3. POST `update_field_metadata`
-4. Report
-
-**"Group the feature columns in `training_features` into logical families and mark the latest version"**
-1. Describe the table
-2. Find version patterns → assign `lancedb:logical-column` and `lancedb:tag:version`; mark newest with `lancedb:tag:latest: "true"`
-3. POST `update_field_metadata`
-4. Show the grouping

.agents/skills/lancedb-connect/SKILL.md

@@ -1,42 +0,0 @@
----
-name: lancedb-connect
-description: Resolve how to connect to a LanceDB deployment over the REST API — figure out the base URL, API key, and database header. Use this before making any REST requests to a LanceDB table, whenever the endpoint or auth setup is not already known. Also useful on its own when someone asks how to connect, authenticate, or curl their LanceDB instance.
-metadata:
-  short-description: Resolve the base URL and auth headers for a LanceDB deployment
----
-
-## Goal
-
-Produce two things every REST request needs:
-
-1. **Base URL** — the endpoint
-2. **Headers** — `x-api-key`, and usually `x-lancedb-database`
-
-## Resolution steps
-
-1. If the user already gave a URL and API key (or said which environment they're working against), use that.
-2. Otherwise, look for credentials already available in the environment:
-   - Env vars like `LANCEDB_URI` / `LANCEDB_HOST` / `LANCEDB_API_KEY`
-   - A LanceDB endpoint already running or port-forwarded locally (the REST default port is 2333, i.e. `http://localhost:2333`)
-3. If you didn't find both pieces, ask the user directly: **"What's your LanceDB endpoint's URL, and what's your API key?"** Also ask which database to use if it isn't obvious. Don't guess or probe further — the user knows their deployment.
-
-## Validating the connection
-
-Make a cheap authenticated request and check the status:
-
-```bash
-curl -s -w "\n%{http_code}" "{base_url}/v1/table/?limit=1" \
-  -H "x-api-key: <key>" \
-  -H "x-lancedb-database: <database>"
-```
-
-- `200` — connection, key, and database header all good
-- `401` — API key missing or wrong
-- `400` mentioning a database header — this deployment expects `x-lancedb-database`
-
-## Non-REST equivalents
-
-If the caller would rather use the SDK or CLI than raw REST, the same credentials work:
-
-- Python SDK: `lancedb.connect("db://<database>", api_key="<key>", host_override="<base_url>")`
-- `lancedb` CLI: a `[profiles.<name>]` entry in `~/.lancedb/config.toml` with `http_server_url`, `api_key`, `database`

.agents/skills/lancedb-update-lance-dependency/SKILL.md

@@ -1,98 +0,0 @@
----
-name: lancedb-update-lance-dependency
-description: Update LanceDB to a specific Lance release or tag. Use when bumping Lance dependencies in the lancedb repository, including Rust workspace Lance crates, Java lance-core, validation, branch creation, commit, push, and PR creation when requested.
----
-
-# LanceDB Update Lance Dependency
-
-## Scope
-
-Use this skill in the `lancedb/lancedb` repository when updating the Lance dependency to a specific Lance version or tag.
-
-Inputs can be a version (`7.2.0-beta.1`), a tag (`v7.2.0-beta.1`), a tag ref (`refs/tags/v7.2.0-beta.1`), or `latest`.
-
-## Workflow
-
-1. Confirm the worktree status with `git status --short`.
-2. Resolve the target Lance version:
-
-   - If the input is `latest`, empty, or omitted, run:
-
-     ```bash
-     python3 ci/check_lance_release.py
-     ```
-
-     Parse the JSON output. If `needs_update` is not `true`, stop without creating a PR. Otherwise use `latest_tag`.
-
-   - If the input is explicit, use it directly.
-
-3. Compute update metadata without changing files:
-
-   ```bash
-   python3 ci/update_lance_dependency.py "$TAG_OR_VERSION" --metadata-only
-   ```
-
-   Before making changes, check for an existing open PR with the emitted `pr_title`:
-
-   ```bash
-   gh pr list --search "\"$PR_TITLE\" in:title" --state open --limit 1 --json number,url,title
-   ```
-
-   If a matching open PR exists, stop and report it instead of creating a duplicate.
-
-4. Run the deterministic update entrypoint:
-
-   ```bash
-   python3 ci/update_lance_dependency.py "$TAG_OR_VERSION"
-   ```
-
-   This updates the Rust workspace Lance dependencies through `ci/set_lance_version.py`, updates `java/pom.xml`, refreshes Cargo metadata, and prints JSON metadata containing `branch_name`, `commit_message`, and `pr_title`.
-
-5. Run validation:
-
-   ```bash
-   cargo clippy --quiet --workspace --tests --all-features -- -D warnings
-   cargo fmt --all --quiet
-   ```
-
-   Fix real diagnostics and rerun clippy until it succeeds. Do not skip warnings.
-
-6. Inspect `git status --short` and `git diff` to ensure only the Lance dependency update and required compatibility fixes are present.
-
-7. If the task only asks to prepare local changes, stop here and report the changed files and validation result.
-
-8. If the task asks to publish the update, create a branch using the printed `branch_name`, stage all relevant files, and commit using the printed `commit_message`. Do not amend or rewrite existing commits.
-
-9. Push to `origin`. Before creating the PR, check that the current token has push permission:
-
-   ```bash
-   gh api repos/lancedb/lancedb --jq .permissions.push
-   ```
-
-   If the remote branch already exists for the same generated branch name, delete the remote ref with `gh api -X DELETE repos/lancedb/lancedb/git/refs/heads/$BRANCH_NAME`, then push. Do not force-push.
-
-10. Create a PR targeting `main` with the printed `pr_title`. If there is no PR template, keep the body to two or three concise sentences: state the Lance dependency bump, note any required compatibility fixes, and link the triggering Lance tag or release.
-
-11. Read back the remote PR title after creation. If it is not a Conventional Commit title, fix it immediately.
-
-12. When running in GitHub Actions after creating the LanceDB PR, trigger the Sophon dependency update:
-
-    ```bash
-    gh workflow run codex-bump-lancedb-lance.yml \
-      --repo lancedb/sophon \
-      -f lance_ref="$LANCE_TAG" \
-      -f lancedb_ref="$BRANCH_NAME"
-    gh run list --repo lancedb/sophon --workflow codex-bump-lancedb-lance.yml --limit 1 --json databaseId,url,displayTitle
-    ```
-
-    Use the emitted metadata `tag` value as `LANCE_TAG`. Do this only after a new LanceDB PR has been created. If the update was skipped because no update is needed or an open PR already exists, do not trigger Sophon.
-
-## GitHub Actions
-
-When this skill is used from GitHub Actions, `TAG`, `GH_TOKEN`, and `GITHUB_TOKEN` may already be set. Resolve `latest` first when `TAG` is empty. Once an explicit tag or version is known, use:
-
-```bash
-python3 ci/update_lance_dependency.py "$TAG" --github-output "$GITHUB_OUTPUT"
-```
-
-Then use the emitted `branch_name`, `commit_message`, and `pr_title` values for branch, commit, and PR creation.

.bumpversion.toml

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

.github/dependabot.yml

@@ -11,24 +11,8 @@ updates:
     schedule:
       interval: weekly
     open-pull-requests-limit: 10
-    # Only update Cargo.lock, never widen/raise the version requirements in
-    # Cargo.toml. The goal is keeping the lockfile (and the binaries we ship)
-    # current on security fixes, not forcing our library's consumers onto
-    # newer minimum versions.
-    versioning-strategy: lockfile-only
     groups:
       rust-minor-patch:
         update-types:
           - minor
           - patch
-
-  - package-ecosystem: pip
-    directory: /python
-    schedule:
-      interval: weekly
-    # Only update uv.lock, never widen version requirements in pyproject.toml.
-    versioning-strategy: lockfile-only
-    groups:
-      python-deps:
-        patterns:
-          - "*"

.github/workflows/codex-fix-ci.yml

@@ -45,9 +45,7 @@ jobs:
       - name: Set up Node.js
         uses: actions/setup-node@v4
         with:
-          # pnpm 11 (used by the nodejs install step below) requires
-          # Node >= 22.13; use 24 since 22 hits EOL in October.
-          node-version: 24
+          node-version: 20
 
       - name: Install Codex CLI
         run: npm install -g @openai/codex
@@ -81,14 +79,10 @@ jobs:
           java-version: '11'
           cache: maven
 
-      - name: Setup pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 11.1.1
       - name: Install Node.js dependencies for TypeScript bindings
         run: |
           cd nodejs
-          pnpm install --frozen-lockfile
+          npm ci
 
       - name: Configure git user
         run: |
@@ -143,7 +137,7 @@ jobs:
                - For Rust test failures: Run the specific test with "cargo test -p <crate> <test_name>"
                - For Python test failures: Build with "cd python && maturin develop" then run "pytest <specific_test_file>::<test_name>"
                - For Java test failures: Run "cd java && mvn test -Dtest=<TestClass>#<testMethod>"
-               - For TypeScript test failures: Run "cd nodejs && pnpm build && pnpm test -- --testNamePattern='<test_name>'"
+               - For TypeScript test failures: Run "cd nodejs && npm run build && npm test -- --testNamePattern='<test_name>'"
                - Do NOT run the full test suite - only run the tests that were failing
 
           7. If the additional guidelines are provided, follow them as well.

.github/workflows/codex-update-lance-dependency.yml

@@ -4,16 +4,14 @@ on:
   workflow_call:
     inputs:
       tag:
-        description: "Tag name from Lance. If omitted, the skill will use the latest Lance release that needs an update."
-        required: false
-        default: ""
+        description: "Tag name from Lance"
+        required: true
         type: string
   workflow_dispatch:
     inputs:
       tag:
-        description: "Tag name from Lance. Leave empty to use the latest Lance release that needs an update."
-        required: false
-        default: ""
+        description: "Tag name from Lance"
+        required: true
         type: string
 
 permissions:
@@ -27,7 +25,7 @@ jobs:
     steps:
       - name: Show inputs
         run: |
-          echo "tag = ${{ inputs.tag || 'latest' }}"
+          echo "tag = ${{ inputs.tag }}"
 
       - name: Checkout Repo LanceDB
         uses: actions/checkout@v4
@@ -73,21 +71,65 @@ jobs:
           OPENAI_API_KEY: ${{ secrets.CODEX_TOKEN }}
         run: |
           set -euo pipefail
-          TARGET_TAG="${TAG:-latest}"
+          VERSION="${TAG#refs/tags/}"
+          VERSION="${VERSION#v}"
+          BRANCH_NAME="codex/update-lance-${VERSION//[^a-zA-Z0-9]/-}"
+
+          # Use "chore" for beta/rc versions, "feat" for stable releases
+          if [[ "${VERSION}" == *beta* ]] || [[ "${VERSION}" == *rc* ]]; then
+            COMMIT_TYPE="chore"
+          else
+            COMMIT_TYPE="feat"
+          fi
 
           cat <<EOF >/tmp/codex-prompt.txt
-          You are running inside the lancedb repository on a GitHub Actions runner.
+          You are running inside the lancedb repository on a GitHub Actions runner. Update the Lance dependency to version ${VERSION} and prepare a pull request for maintainers to review.
 
-          Use \$lancedb-update-lance-dependency with target "${TARGET_TAG}".
+          Follow these steps exactly:
+          1. Use script "ci/set_lance_version.py" to update Lance Rust dependencies. The script already refreshes Cargo metadata, so allow it to finish even if it takes time.
+          2. Update the Java lance-core dependency version in "java/pom.xml": change the "<lance-core.version>...</lance-core.version>" property to "${VERSION}".
+          3. Run "cargo clippy --workspace --tests --all-features -- -D warnings". If diagnostics appear, fix them yourself and rerun clippy until it exits cleanly. Do not skip any warnings.
+          4. After clippy succeeds, run "cargo fmt --all" to format the workspace.
+          5. Ensure the repository is clean except for intentional changes. Inspect "git status --short" and "git diff" to confirm the dependency update and any required fixes.
+          6. Create and switch to a new branch named "${BRANCH_NAME}" (replace any duplicated hyphens if necessary).
+          7. Stage all relevant files with "git add -A". Commit using the message "${COMMIT_TYPE}: update lance dependency to v${VERSION}".
+          8. Push the branch to origin. If the remote branch already exists, delete it first with "gh api -X DELETE repos/lancedb/lancedb/git/refs/heads/${BRANCH_NAME}" then push with "git push origin ${BRANCH_NAME}". Do NOT use "git push --force" or "git push -f".
+          9. env "GH_TOKEN" is available, use "gh" tools for github related operations like creating pull request.
+          10. Create a pull request targeting "main" with title "${COMMIT_TYPE}: update lance dependency to v${VERSION}". First, write the PR body to /tmp/pr-body.md using a heredoc (cat <<'EOF' > /tmp/pr-body.md). The body should summarize the dependency bump, clippy/fmt verification, and link the triggering tag (${TAG}). Then run "gh pr create --body-file /tmp/pr-body.md".
+          11. After creating the PR, display the PR URL, "git status --short", and a concise summary of the commands run and their results.
 
           Constraints:
-          - Use env "GH_TOKEN" for GitHub operations.
-          - Do not merge the pull request.
-          - Do not force-push.
-          - Do not create a duplicate pull request if an open PR already exists for the target Lance version.
-          - If any command fails, diagnose and fix the root cause instead of aborting.
-          - After creating the PR, display the PR URL, "git status --short", and a concise summary of the commands run and their results.
+          - Use bash commands; avoid modifying GitHub workflow files other than through the scripted task above.
+          - Do not merge the PR.
+          - If any command fails, diagnose and fix the issue instead of aborting.
           EOF
 
           printenv OPENAI_API_KEY | codex login --with-api-key
           codex --config shell_environment_policy.ignore_default_excludes=true exec --dangerously-bypass-approvals-and-sandbox "$(cat /tmp/codex-prompt.txt)"
+
+      - name: Trigger sophon dependency update
+        env:
+          TAG: ${{ inputs.tag }}
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          set -euo pipefail
+          VERSION="${TAG#refs/tags/}"
+          VERSION="${VERSION#v}"
+          LANCEDB_BRANCH="codex/update-lance-${VERSION//[^a-zA-Z0-9]/-}"
+
+          echo "Triggering sophon workflow with:"
+          echo "  lance_ref: ${TAG#refs/tags/}"
+          echo "  lancedb_ref: ${LANCEDB_BRANCH}"
+
+          gh workflow run codex-bump-lancedb-lance.yml \
+            --repo lancedb/sophon \
+            -f lance_ref="${TAG#refs/tags/}" \
+            -f lancedb_ref="${LANCEDB_BRANCH}"
+
+      - name: Show latest sophon workflow run
+        env:
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          set -euo pipefail
+          echo "Latest sophon workflow run:"
+          gh run list --repo lancedb/sophon --workflow codex-bump-lancedb-lance.yml --limit 1 --json databaseId,url,displayTitle

.github/workflows/java.yml

@@ -16,6 +16,7 @@ on:
   push:
     branches:
       - main
+      - release/**
     paths:
       - java/**
       - .github/workflows/java.yml

.github/workflows/lance-release-timer.yml

@@ -0,0 +1,62 @@
+name: Lance Release Timer
+
+on:
+  schedule:
+    - cron: "*/10 * * * *"
+  workflow_dispatch:
+
+permissions:
+  contents: read
+  actions: write
+
+concurrency:
+  group: lance-release-timer
+  cancel-in-progress: false
+
+jobs:
+  trigger-update:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Check for new Lance tag
+        id: check
+        env:
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          python3 ci/check_lance_release.py --github-output "$GITHUB_OUTPUT"
+
+      - name: Look for existing PR
+        if: steps.check.outputs.needs_update == 'true'
+        id: pr
+        env:
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          set -euo pipefail
+          TITLE="chore: update lance dependency to v${{ steps.check.outputs.latest_version }}"
+          COUNT=$(gh pr list --search "\"$TITLE\" in:title" --state open --limit 1 --json number --jq 'length')
+          if [ "$COUNT" -gt 0 ]; then
+            echo "Open PR already exists for $TITLE"
+            echo "pr_exists=true" >> "$GITHUB_OUTPUT"
+          else
+            echo "No existing PR for $TITLE"
+            echo "pr_exists=false" >> "$GITHUB_OUTPUT"
+          fi
+
+      - name: Trigger codex update workflow
+        if: steps.check.outputs.needs_update == 'true' && steps.pr.outputs.pr_exists != 'true'
+        env:
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          set -euo pipefail
+          TAG=${{ steps.check.outputs.latest_tag }}
+          gh workflow run codex-update-lance-dependency.yml -f tag=refs/tags/$TAG
+
+      - name: Show latest codex workflow run
+        if: steps.check.outputs.needs_update == 'true' && steps.pr.outputs.pr_exists != 'true'
+        env:
+          GH_TOKEN: ${{ secrets.ROBOT_TOKEN }}
+        run: |
+          set -euo pipefail
+          gh run list --workflow codex-update-lance-dependency.yml --limit 1 --json databaseId,url,displayTitle

.github/workflows/license-header-check.yml

@@ -3,6 +3,7 @@ on:
   push:
     branches:
       - main
+      - release/**
   pull_request:
     paths:
       - rust/**

.github/workflows/nodejs.yml

@@ -4,6 +4,7 @@ on:
   push:
     branches:
       - main
+      - release/**
   pull_request:
     paths:
       - Cargo.toml
@@ -42,17 +43,11 @@ jobs:
       with:
         fetch-depth: 0
         lfs: true
-    - uses: pnpm/action-setup@v4
-      with:
-        version: 11.1.1
     - uses: actions/setup-node@v4
       with:
-        # pnpm 11 requires Node >= 22.13; use 24 since 22 hits EOL
-        # in October. The library itself still supports Node >= 18
-        # (see test matrix below).
-        node-version: 24
-        cache: 'pnpm'
-        cache-dependency-path: nodejs/pnpm-lock.yaml
+        node-version: 20
+        cache: 'npm'
+        cache-dependency-path: nodejs/package-lock.json
     - uses: actions-rust-lang/setup-rust-toolchain@v1
       with:
         components: rustfmt, clippy
@@ -67,13 +62,11 @@ jobs:
       run: cargo clippy --profile ci --all --all-features -- -D warnings
     - name: Lint Typescript
       run: |
-        pnpm install --frozen-lockfile
-        pnpm lint-ci
+        npm ci
+        npm run lint-ci
     - name: Lint examples
       working-directory: nodejs/examples
-      # The `@lancedb/lancedb` dep points at file:../dist; pnpm errors if
-      # that dir is missing, so create an empty one for lint-only runs.
-      run: mkdir -p ../dist && pnpm install --frozen-lockfile && pnpm lint-ci
+      run: npm ci && npm run lint-ci
   linux:
     name: Linux (NodeJS ${{ matrix.node-version }})
     timeout-minutes: 30
@@ -90,18 +83,14 @@ jobs:
       with:
         fetch-depth: 0
         lfs: true
-    - uses: pnpm/action-setup@v4
-      with:
-        version: 11.1.1
     - uses: actions/setup-node@v4
-      name: Setup Node.js 24 for build
+      name: Setup Node.js 20 for build
       with:
-        # pnpm 11 requires Node >= 22.13; use 24 since 22 hits EOL
-        # in October. Build/install runs on Node 24; tests run on the
-        # matrix version below using direct jest invocation.
-        node-version: 24
-        cache: 'pnpm'
-        cache-dependency-path: nodejs/pnpm-lock.yaml
+        # @napi-rs/cli v3 requires Node >= 20.12 (via @inquirer/prompts@8).
+        # Build always on Node 20; tests run on the matrix version below.
+        node-version: 20
+        cache: 'npm'
+        cache-dependency-path: nodejs/package-lock.json
     - uses: Swatinem/rust-cache@v2
     - name: Install dependencies
       run: |
@@ -109,58 +98,48 @@ jobs:
         sudo apt install -y protobuf-compiler libssl-dev
     - name: Build
       run: |
-        pnpm install --frozen-lockfile
-        # No `--` separator: pnpm forwards it literally, which would
-        # make napi-rs treat `--profile ci` as a cargo passthrough arg.
-        pnpm build:debug --profile ci
-        pnpm tsc
-    - name: Setup examples
-      working-directory: nodejs/examples
-      run: pnpm install --frozen-lockfile
-    - name: Check docs
-      run: |
-        # 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
-        # `pnpm docs` would invoke pnpm's built-in `docs` command, not
-        # the script — use `pnpm run docs`.
-        pnpm run docs
-        if ! git diff --exit-code -- ../ ':(exclude)Cargo.lock'; then
-          echo "Docs need to be updated"
-          echo "Run 'pnpm run docs', fix any warnings, and commit the changes."
-          exit 1
-        fi
+        npm ci --include=optional
+        npm run build:debug -- --profile ci
     - uses: actions/setup-node@v4
       name: Setup Node.js ${{ matrix.node-version }} for test
       with:
         node-version: ${{ matrix.node-version }}
+    - name: Compile TypeScript
+      run: npm run tsc
     - name: Setup localstack
       working-directory: .
       run: docker compose up --detach --wait
     - name: Test
       env:
         S3_TEST: "1"
-        # Newer @smithy/core uses dynamic ESM imports.
-        NODE_OPTIONS: "--experimental-vm-modules"
-      # Invoke jest directly because pnpm 11 itself requires Node 22+
-      # while the matrix tests on older Node versions.
-      run: npx jest --verbose
+      run: npm run test
+    - name: Setup examples
+      working-directory: nodejs/examples
+      run: npm ci
     - name: Test examples
       working-directory: ./
       env:
         OPENAI_API_KEY: test
         OPENAI_BASE_URL: http://0.0.0.0:8000
-        NODE_OPTIONS: "--experimental-vm-modules"
       run: |
         python ci/mock_openai.py &
         cd nodejs/examples
-        npx jest --testEnvironment jest-environment-node-single-context --verbose
+        npm test
+    - name: Check docs
+      run: |
+        # 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 run docs
+        if ! git diff --exit-code -- ../ ':(exclude)Cargo.lock'; then
+          echo "Docs need to be updated"
+          echo "Run 'npm run docs', fix any warnings, and commit the changes."
+          exit 1
+        fi
   macos:
     timeout-minutes: 30
-    # macos-15 ships a newer linker; the older macos-14 linker fails to insert
-    # branch islands when the debug cdylib's __text section exceeds the 128 MB
-    # AArch64 B/BL branch range.
-    runs-on: "macos-15"
+    runs-on: "macos-14"
     defaults:
       run:
         shell: bash
@@ -170,28 +149,20 @@ jobs:
       with:
         fetch-depth: 0
         lfs: true
-    - uses: pnpm/action-setup@v4
-      with:
-        version: 11.1.1
     - uses: actions/setup-node@v4
       with:
-        # pnpm 11 requires Node >= 22.13; use 24 since 22 hits EOL
-        # in October.
-        node-version: 24
-        cache: 'pnpm'
-        cache-dependency-path: nodejs/pnpm-lock.yaml
-    - uses: dtolnay/rust-toolchain@stable
+        node-version: 20
+        cache: 'npm'
+        cache-dependency-path: nodejs/package-lock.json
     - uses: Swatinem/rust-cache@v2
     - name: Install dependencies
       run: |
         brew install protobuf
     - name: Build
       run: |
-        pnpm install --frozen-lockfile
-        # No `--` separator: pnpm forwards it literally, which would
-        # make napi-rs treat `--profile ci` as a cargo passthrough arg.
-        pnpm build:debug --profile ci
-        pnpm tsc
+        npm ci --include=optional
+        npm run build:debug -- --profile ci
+        npm run tsc
     - name: Test
       run: |
-        pnpm test
+        npm run test

.github/workflows/npm-publish.yml

@@ -171,18 +171,13 @@ jobs:
         working-directory: nodejs
     steps:
       - uses: actions/checkout@v4
-      - name: Setup pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 11.1.1
       - name: Setup node
         uses: actions/setup-node@v4
+        if: ${{ !matrix.settings.docker }}
         with:
-          # pnpm 11 requires Node >= 22.13; use 24 since 22 hits EOL
-          # in October.
-          node-version: 24
-          cache: pnpm
-          cache-dependency-path: nodejs/pnpm-lock.yaml
+          node-version: 20
+          cache: npm
+          cache-dependency-path: nodejs/package-lock.json
       - name: Install
         uses: dtolnay/rust-toolchain@stable
         if: ${{ !matrix.settings.docker }}
@@ -200,7 +195,7 @@ jobs:
             target/
           key: nodejs-${{ matrix.settings.target }}-cargo-${{ matrix.settings.host }}
       - name: Install dependencies
-        run: pnpm install --frozen-lockfile
+        run: npm ci
       - name: Install Zig
         uses: mlugg/setup-zig@v2
         if: ${{ contains(matrix.settings.target, 'musl') }}
@@ -253,7 +248,7 @@ jobs:
       # one to do the upload.
       - name: Make generic artifacts
         if: ${{ matrix.settings.target == 'aarch64-apple-darwin' }}
-        run: pnpm tsc
+        run: npm run tsc
       - name: Upload Generic Artifacts
         if: ${{ matrix.settings.target == 'aarch64-apple-darwin' }}
         uses: actions/upload-artifact@v4
@@ -288,24 +283,14 @@ jobs:
         working-directory: nodejs
     steps:
       - uses: actions/checkout@v4
-      - name: Setup pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 11.1.1
-      - name: Setup Node.js 24 for install
-        uses: actions/setup-node@v4
-        with:
-          # pnpm 11 requires Node >= 22.13; use 24 since 22 hits EOL
-          # in October.
-          node-version: 24
-          cache: pnpm
-          cache-dependency-path: nodejs/pnpm-lock.yaml
-      - name: Install dependencies
-        run: pnpm install --frozen-lockfile
-      - name: Setup Node.js ${{ matrix.node }} for test
+      - name: Setup node
         uses: actions/setup-node@v4
         with:
           node-version: ${{ matrix.node }}
+          cache: npm
+          cache-dependency-path: nodejs/package-lock.json
+      - name: Install dependencies
+        run: npm ci
       - name: Download artifacts
         uses: actions/download-artifact@v4
         with:
@@ -326,9 +311,7 @@ jobs:
       - name: Move built files
         run: cp dist/native.d.ts dist/native.js dist/*.node lancedb/
       - name: Test bindings
-        # Invoke jest directly because pnpm 11 itself requires Node 22+
-        # while the matrix tests on older Node versions.
-        run: npx jest --verbose
+        run: npm test
   publish:
     name: Publish
     runs-on: ubuntu-latest
@@ -340,19 +323,15 @@ jobs:
       - test-lancedb
     steps:
       - uses: actions/checkout@v4
-      - name: Setup pnpm
-        uses: pnpm/action-setup@v4
-        with:
-          version: 11.1.1
       - name: Setup node
         uses: actions/setup-node@v4
         with:
           node-version: 24
-          cache: pnpm
-          cache-dependency-path: nodejs/pnpm-lock.yaml
+          cache: npm
+          cache-dependency-path: nodejs/package-lock.json
           registry-url: "https://registry.npmjs.org"
       - name: Install dependencies
-        run: pnpm install --frozen-lockfile
+        run: npm ci
       - uses: actions/download-artifact@v4
         with:
           name: nodejs-dist
@@ -372,7 +351,7 @@ jobs:
       - name: Display structure of downloaded files
         run: find dist && find nodejs-artifacts
       - name: Move artifacts
-        run: pnpm exec napi artifacts -d nodejs-artifacts
+        run: npx napi artifacts -d nodejs-artifacts
       - name: List packages
         run: find npm
       - name: Publish

.github/workflows/pypi-publish.yml

@@ -27,11 +27,19 @@ jobs:
     strategy:
       matrix:
         config:
+          - platform: x86_64
+            manylinux: "2_17"
+            extra_args: ""
+            runner: ubuntu-22.04
           - platform: x86_64
             manylinux: "2_28"
             extra_args: "--features fp16kernels"
             runner: ubuntu-22.04
-          # For successful fat LTO builds, we need a large runner to avoid OOM errors.
+          - platform: aarch64
+            manylinux: "2_17"
+            extra_args: ""
+            # For successful fat LTO builds, we need a large runner to avoid OOM errors.
+            runner: ubuntu-2404-8x-arm64
           - platform: aarch64
             manylinux: "2_28"
             extra_args: "--features fp16kernels"

.github/workflows/python.yml

@@ -4,6 +4,7 @@ on:
   push:
     branches:
       - main
+      - release/**
   pull_request:
     paths:
       - Cargo.toml
@@ -205,7 +206,7 @@ jobs:
       - name: Delete wheels
         run: rm -rf target/wheels
   pydantic1x:
-    timeout-minutes: 60
+    timeout-minutes: 30
     runs-on: "ubuntu-24.04"
     defaults:
       run:

.github/workflows/rust.yml

@@ -4,6 +4,7 @@ on:
   push:
     branches:
       - main
+      - release/**
   pull_request:
     paths:
       - Cargo.toml
@@ -233,26 +234,6 @@ jobs:
           cargo update -p aws-sdk-sso --precise 1.62.0
           cargo update -p aws-sdk-ssooidc --precise 1.63.0
           cargo update -p aws-sdk-sts --precise 1.63.0
-          # aws-runtime/sigv4/credential-types/types and the aws-smithy-*
-          # crates bumped their MSRV to 1.91.1 in late 2026; pin to the last
-          # 1.91.0-compatible versions. The order matters — each downgrade
-          # only succeeds once everything that still pins it at a higher
-          # version has itself been downgraded.
-          cargo update -p aws-runtime --precise 1.5.12
-          cargo update -p aws-types --precise 1.3.9
-          cargo update -p aws-sigv4 --precise 1.3.5
-          cargo update -p aws-credential-types --precise 1.2.8
-          cargo update -p aws-smithy-checksums --precise 0.63.9
-          cargo update -p aws-smithy-runtime --precise 1.9.3
-          cargo update -p aws-smithy-http --precise 0.62.4
-          cargo update -p aws-smithy-eventstream --precise 0.60.12
-          cargo update -p aws-smithy-http-client --precise 1.1.3
-          cargo update -p aws-smithy-observability --precise 0.1.4
-          cargo update -p aws-smithy-query --precise 0.60.8
-          cargo update -p aws-smithy-runtime-api --precise 1.9.1
-          cargo update -p aws-smithy-async --precise 1.2.6
-          cargo update -p aws-smithy-types --precise 1.3.5
-          cargo update -p aws-smithy-xml --precise 0.60.11
           cargo update -p home --precise 0.5.9
       - name: cargo +${{ matrix.msrv }} check
         env:

.gitignore

@@ -27,7 +27,6 @@ python/dist
 *.so
 *.dylib
 *.dll
-*.pdb
 
 ## Javascript
 *.node

AGENTS.md

@@ -17,33 +17,9 @@ Common commands:
 * Run tests: `cargo test --quiet --features remote --tests`
 * Run specific test: `cargo test --quiet --features remote -p <package_name> --test <test_name>`
 * Lint: `cargo clippy --quiet --features remote --tests --examples`
-* Format Rust: `cargo fmt --all`
-* Format Python: `ruff format .`
-* Lint Python: `ruff check .`
-* Bootstrap Python dev env: `cd python && uv run --extra tests --extra dev maturin develop --extras tests,dev`
-* Run Python tests: `cd python && uv run --extra tests pytest python/tests -vv --durations=10 -m "not slow and not s3_test"`
-* Run specific Python test: `cd python && uv run --extra tests pytest python/tests/<test_file>.py::<test_name> -q`
+* Format: `cargo fmt --all`
 
-For Python validation, prefer the uv-managed environment declared by `python/uv.lock`.
-Do not treat system `python`, global `pytest`, or missing editable-install errors as
-final blockers; bootstrap or enter the uv environment instead. If `lancedb._lancedb`
-is missing or stale, or if Rust/PyO3 binding code changed, rebuild the Python
-extension with the bootstrap command above before running tests.
-
-Before committing changes, run formatting for every language you touched. At minimum:
-
-* Rust changes: run `cargo fmt --all`.
-* Python changes: run `ruff format .` and `ruff check .` from the repository root,
-  and run targeted tests through `cd python && uv run ...`.
-* TypeScript changes: run the relevant `npm`/`pnpm` lint, format, build, and docs commands in `nodejs`.
-
-Before creating a PR, the exact value passed to `gh pr create --title` must follow
-Conventional Commits, such as `fix: support nested field paths in native index creation`
-or `feat(python): add dataset multiprocessing support`. Do not use a plain natural
-language summary like `Support nested field paths in native index creation` as the PR
-title. The semantic-release check uses the PR title and body as the merge commit message,
-so a non-conventional PR title will fail CI. After creating a PR, read the remote PR title
-back and fix it immediately if it is not conventional.
+Before committing changes, run formatting.
 
 ## Coding tips
 

Cargo.toml

@@ -13,20 +13,20 @@ categories = ["database-implementations"]
 rust-version = "1.91.0"
 
 [workspace.dependencies]
-lance = { "version" = "=8.0.0-beta.12", default-features = false, "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-core = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-datagen = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-file = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-io = { "version" = "=8.0.0-beta.12", default-features = false, "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-index = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-linalg = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-namespace-impls = { "version" = "=8.0.0-beta.12", default-features = false, "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-table = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-testing = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-datafusion = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-encoding = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
-lance-arrow = { "version" = "=8.0.0-beta.12", "tag" = "v8.0.0-beta.12", "git" = "https://github.com/lance-format/lance.git" }
+lance = { "version" = "=6.0.0", default-features = false }
+lance-core = "=6.0.0"
+lance-datagen = "=6.0.0"
+lance-file = "=6.0.0"
+lance-io = { "version" = "=6.0.0", default-features = false }
+lance-index = "=6.0.0"
+lance-linalg = "=6.0.0"
+lance-namespace = "=6.0.0"
+lance-namespace-impls = { "version" = "=6.0.0", default-features = false }
+lance-table = "=6.0.0"
+lance-testing = "=6.0.0"
+lance-datafusion = "=6.0.0"
+lance-encoding = "=6.0.0"
+lance-arrow = "=6.0.0"
 ahash = "0.8"
 # Note that this one does not include pyarrow
 arrow = { version = "58.0.0", optional = false }
@@ -54,7 +54,7 @@ half = { "version" = "2.7.1", default-features = false, features = [
 futures = "0"
 log = "0.4"
 moka = { version = "0.12", features = ["future"] }
-object_store = "0.13.2"
+object_store = "0.12.0"
 pin-project = "1.0.7"
 rand = "0.9"
 snafu = "0.8"

REVIEW.md

@@ -1,26 +0,0 @@
-# Code review guidelines
-
-Repo-specific guidance for automated PR reviews.
-
-## Cross-SDK parity
-
-LanceDB exposes the same core (`rust/lancedb`) through Python, TypeScript (`nodejs`),
-and Java bindings. Behavioral drift between SDKs is a recurring problem, so watch for
-parity gaps when reviewing — but only flag real ones:
-
-* If the change adds or modifies user-facing API or behavior in the shared core
-  (`rust/lancedb`), check whether each binding that should expose it (`python`,
-  `nodejs`) does. A core change with no corresponding binding update is worth a note.
-* If the change adds or modifies a public API in one SDK but not the other, open the
-  sibling SDK's corresponding module and state whether an equivalent exists. If not,
-  note it as a possible parity gap and suggest a follow-up issue.
-* For bug fixes, first read the sibling SDK's analogous code path to check whether the
-  same bug exists there. Only raise parity if it actually does. Do not ask to "port" a
-  fix for a bug that only ever existed in one binding.
-* Stay silent on internal-only refactors, tests, docs, and changes with no cross-SDK
-  surface.
-* Parity expectations apply to the Python and TypeScript (`nodejs`) SDKs. Java currently
-  implements only the remote table, not the local/embedded backend, so it is expected to
-  be partial — do not flag Java for missing local-only functionality.
-* Keep parity feedback to a short, clearly-labeled note (e.g. "Possible SDK parity
-  gap: …"). It is advisory, not a merge blocker.

ci/check_lance_release.py

@@ -112,25 +112,25 @@ def fetch_remote_tags() -> List[TagInfo]:
             "api",
             "-X",
             "GET",
-            f"repos/{LANCE_REPO}/releases",
+            f"repos/{LANCE_REPO}/git/refs/tags",
+            "--paginate",
             "--jq",
-            ".[].tag_name",
-            "-F",
-            "per_page=20",
+            ".[].ref",
         ]
     )
     tags: List[TagInfo] = []
     for line in output.splitlines():
-        tag = line.strip()
-        if not tag.startswith("v"):
+        ref = line.strip()
+        if not ref.startswith("refs/tags/v"):
             continue
+        tag = ref.split("refs/tags/")[-1]
         version = tag.lstrip("v")
         try:
             tags.append(TagInfo(tag=tag, version=version, semver=parse_semver(version)))
         except ValueError:
             continue
     if not tags:
-        raise RuntimeError("No Lance releases could be parsed from GitHub API output")
+        raise RuntimeError("No Lance tags could be parsed from GitHub API output")
     return tags
 
 

ci/update_lance_dependency.py

@@ -1,126 +0,0 @@
-#!/usr/bin/env python3
-"""Prepare a Lance dependency update for LanceDB."""
-
-from __future__ import annotations
-
-import argparse
-import json
-import re
-import subprocess
-import sys
-from pathlib import Path
-from typing import Sequence
-
-try:
-    from check_lance_release import parse_semver
-except ModuleNotFoundError:
-    # Supports importing as ci.update_lance_dependency from tests or ad hoc checks.
-    from ci.check_lance_release import parse_semver  # type: ignore
-
-
-def normalize_version(raw: str) -> str:
-    value = raw.strip()
-    value = value.removeprefix("refs/tags/")
-    value = value.removeprefix("v")
-    try:
-        parse_semver(value)
-    except ValueError:
-        raise ValueError(f"Unsupported Lance version or tag: {raw}")
-    return value
-
-
-def normalized_tag(version: str) -> str:
-    return f"v{version}"
-
-
-def branch_name(version: str) -> str:
-    suffix = re.sub(r"[^a-zA-Z0-9]+", "-", version).strip("-")
-    suffix = re.sub(r"-+", "-", suffix)
-    return f"codex/update-lance-{suffix}"
-
-
-def commit_type(version: str) -> str:
-    prerelease = version.split("-", maxsplit=1)[1] if "-" in version else ""
-    return "chore" if "beta" in prerelease or "rc" in prerelease else "feat"
-
-
-def metadata_for(version: str) -> dict[str, str]:
-    kind = commit_type(version)
-    message = f"{kind}: update lance dependency to v{version}"
-    return {
-        "version": version,
-        "tag": normalized_tag(version),
-        "branch_name": branch_name(version),
-        "commit_type": kind,
-        "commit_message": message,
-        "pr_title": message,
-    }
-
-
-def run_command(cmd: Sequence[str], *, cwd: Path) -> None:
-    subprocess.run(cmd, cwd=cwd, check=True)
-
-
-def update_java_lance_core_version(repo_root: Path, version: str) -> None:
-    pom_path = repo_root / "java" / "pom.xml"
-    contents = pom_path.read_text(encoding="utf-8")
-    updated, count = re.subn(
-        r"(<lance-core\.version>)[^<]+(</lance-core\.version>)",
-        rf"\g<1>{version}\g<2>",
-        contents,
-        count=1,
-    )
-    if count != 1:
-        raise RuntimeError(
-            "Expected exactly one <lance-core.version> entry in java/pom.xml"
-        )
-    pom_path.write_text(updated, encoding="utf-8")
-
-
-def write_github_outputs(path: str | None, payload: dict[str, str]) -> None:
-    if not path:
-        return
-    with open(path, "a", encoding="utf-8") as output:
-        for key, value in payload.items():
-            output.write(f"{key}={value}\n")
-
-
-def main(argv: Sequence[str] | None = None) -> int:
-    parser = argparse.ArgumentParser(description=__doc__)
-    parser.add_argument(
-        "tag_or_version",
-        help="Lance tag or version, for example refs/tags/v7.2.0-beta.1 or 7.2.0",
-    )
-    parser.add_argument(
-        "--repo-root",
-        type=Path,
-        default=Path(__file__).resolve().parents[1],
-        help="Path to the lancedb repository root",
-    )
-    parser.add_argument(
-        "--github-output",
-        default=None,
-        help="Optional GitHub Actions output file to receive metadata fields",
-    )
-    parser.add_argument(
-        "--metadata-only",
-        action="store_true",
-        help="Only print derived metadata; do not modify dependency files",
-    )
-    args = parser.parse_args(argv)
-
-    repo_root = args.repo_root.resolve()
-    version = normalize_version(args.tag_or_version)
-    payload = metadata_for(version)
-
-    if not args.metadata_only:
-        run_command([sys.executable, "ci/set_lance_version.py", version], cwd=repo_root)
-        update_java_lance_core_version(repo_root, version)
-
-    write_github_outputs(args.github_output, payload)
-    print(json.dumps(payload, sort_keys=True))
-    return 0
-
-
-if __name__ == "__main__":
-    sys.exit(main())

deny.toml

@@ -147,14 +147,6 @@ allow = [
     "CDLA-Permissive-2.0",
 ]
 confidence-threshold = 0.8
-# Per-crate license exceptions: allow a license for a specific crate only,
-# rather than globally via the `allow` list above.
-exceptions = [
-    # CDDL-1.0 (copyleft) is pulled in only as a dev/profiling dependency via
-    # `inferno` -> `pprof` -> `lance-testing`; it is a test dependency that we
-    # do not distribute, so scope the allowance to `inferno` alone.
-    { allow = ["CDDL-1.0"], crate = "inferno" },
-]
 # Crates whose license cannot be determined from Cargo metadata but whose
 # license we've manually confirmed from upstream. Keep this list minimal.
 [[licenses.clarify]]

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.30.1-beta.2</version>
+    <version>0.28.0-beta.11</version>
 </dependency>
 ```
 

docs/src/js/_media/CONTRIBUTING.md

@@ -12,22 +12,20 @@ Typescript.
 * `src/`: Rust bindings source code
 * `lancedb/`: Typescript package source code
 * `__test__/`: Unit tests
-* `examples/`: A pnpm package with the examples shown in the documentation
+* `examples/`: An npm package with the examples shown in the documentation
 
 ## Development environment
 
 To set up your development environment, you will need to install the following:
 
-1. Node.js 22 or later (required by pnpm 11)
-2. [pnpm](https://pnpm.io/installation) 11 or later (or run via `corepack enable`,
-   which uses the `packageManager` field in `package.json`)
-3. Rust's package manager, Cargo. Use [rustup](https://rustup.rs/) to install.
-4. [protoc](https://grpc.io/docs/protoc-installation/) (Protocol Buffers compiler)
+1. Node.js 14 or later
+2. Rust's package manager, Cargo. Use [rustup](https://rustup.rs/) to install.
+3. [protoc](https://grpc.io/docs/protoc-installation/) (Protocol Buffers compiler)
 
 Initial setup:
 
 ```shell
-pnpm install
+npm install
 ```
 
 ### Commit Hooks
@@ -41,38 +39,38 @@ pre-commit install
 
 ## Development
 
-Most common development commands can be run using the pnpm scripts.
+Most common development commands can be run using the npm scripts.
 
 Build the package
 
 ```shell
-pnpm install
-pnpm build
+npm install
+npm run build
 ```
 
 Lint:
 
 ```shell
-pnpm lint
+npm run lint
 ```
 
 Format and fix lints:
 
 ```shell
-pnpm lint-fix
+npm run lint-fix
 ```
 
 Run tests:
 
 ```shell
-pnpm test
+npm test
 ```
 
 To run a single test:
 
 ```shell
 # Single file: table.test.ts
-pnpm test -- table.test.ts
+npm test -- table.test.ts
 # Single test: 'merge insert' in table.test.ts
-pnpm test -- table.test.ts --testNamePattern=merge\ insert
+npm test -- table.test.ts --testNamePattern=merge\ insert
 ```

docs/src/js/classes/BranchContents.md

@@ -1,43 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / BranchContents
-
-# Class: BranchContents
-
-## Constructors
-
-### new BranchContents()
-
-```ts
-new BranchContents(): BranchContents
-```
-
-#### Returns
-
-[`BranchContents`](BranchContents.md)
-
-## Properties
-
-### manifestSize
-
-```ts
-manifestSize: number;
-```
-
-***
-
-### parentBranch?
-
-```ts
-optional parentBranch: string;
-```
-
-***
-
-### parentVersion
-
-```ts
-parentVersion: number;
-```

docs/src/js/classes/Branches.md

@@ -1,96 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / Branches
-
-# Class: Branches
-
-Branch manager for a [Table](Table.md).
-
-Unlike tags, `create` and `checkout` return a new [Table](Table.md) handle scoped
-to the branch; writes on it do not affect `main`.
-
-## Methods
-
-### checkout()
-
-```ts
-checkout(name, version?): Promise<Table>
-```
-
-Check out an existing branch and return a handle scoped to it.
-
-With `version` set, the returned handle is pinned to that version of the
-branch (a read-only, detached view); otherwise it tracks the branch's
-latest and stays writable.
-
-#### Parameters
-
-* **name**: `string`
-
-* **version?**: `number`
-
-#### Returns
-
-`Promise`&lt;[`Table`](Table.md)&gt;
-
-***
-
-### create()
-
-```ts
-create(
-   name,
-   fromRef?,
-   fromVersion?): Promise<Table>
-```
-
-Create a branch and return a handle scoped to it.
-
-#### Parameters
-
-* **name**: `string`
-    Name of the new branch.
-
-* **fromRef?**: `string`
-    Source branch to fork from. Defaults to `main`.
-
-* **fromVersion?**: `number`
-    A specific version on `fromRef`. Defaults to latest.
-
-#### Returns
-
-`Promise`&lt;[`Table`](Table.md)&gt;
-
-***
-
-### delete()
-
-```ts
-delete(name): Promise<void>
-```
-
-Delete a branch.
-
-#### Parameters
-
-* **name**: `string`
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-***
-
-### list()
-
-```ts
-list(): Promise<Record<string, BranchContents>>
-```
-
-List all branches, mapping name to branch metadata.
-
-#### Returns
-
-`Promise`&lt;`Record`&lt;`string`, [`BranchContents`](BranchContents.md)&gt;&gt;

docs/src/js/classes/Connection.md

@@ -148,33 +148,6 @@ Creates a new empty Table
 
 ***
 
-### createNamespace()
-
-```ts
-abstract createNamespace(namespacePath, options?): Promise<CreateNamespaceResponse>
-```
-
-Create a new namespace at the given path.
-
-#### Parameters
-
-* **namespacePath**: `string`[]
-    The namespace path to create.
-
-* **options?**: `Partial`&lt;[`CreateNamespaceOptions`](../interfaces/CreateNamespaceOptions.md)&gt;
-    Creation `mode`
-    ("create" | "exist_ok" | "overwrite") and optional `properties`
-    to attach to the namespace.
-
-#### Returns
-
-`Promise`&lt;[`CreateNamespaceResponse`](../interfaces/CreateNamespaceResponse.md)&gt;
-
-The properties of the
-  created namespace and an optional transaction id.
-
-***
-
 ### createTable()
 
 #### createTable(options, namespacePath)
@@ -257,29 +230,6 @@ Creates a new Table and initialize it with new data.
 
 ***
 
-### describeNamespace()
-
-```ts
-abstract describeNamespace(namespacePath): Promise<DescribeNamespaceResponse>
-```
-
-Describe a namespace, returning its properties.
-
-#### Parameters
-
-* **namespacePath**: `string`[]
-    The namespace path to describe, in
-    parent → child order, e.g. `["analytics", "sales"]`.
-
-#### Returns
-
-`Promise`&lt;[`DescribeNamespaceResponse`](../interfaces/DescribeNamespaceResponse.md)&gt;
-
-The namespace's properties
-  (may be undefined if the namespace has none).
-
-***
-
 ### display()
 
 ```ts
@@ -313,36 +263,6 @@ Drop all tables in the database.
 
 ***
 
-### dropNamespace()
-
-```ts
-abstract dropNamespace(namespacePath, options?): Promise<DropNamespaceResponse>
-```
-
-Drop a namespace.
-
-Use `behavior: "cascade"` to also drop everything contained in the
-namespace (sub-namespaces and tables). The default `"restrict"`
-behavior refuses to drop a non-empty namespace.
-
-#### Parameters
-
-* **namespacePath**: `string`[]
-    The namespace path to drop.
-
-* **options?**: `Partial`&lt;[`DropNamespaceOptions`](../interfaces/DropNamespaceOptions.md)&gt;
-    `mode` ("skip" | "fail"
-    for missing-namespace handling) and `behavior` ("restrict" | "cascade").
-
-#### Returns
-
-`Promise`&lt;[`DropNamespaceResponse`](../interfaces/DropNamespaceResponse.md)&gt;
-
-Any properties returned by
-  the server and an optional transaction id.
-
-***
-
 ### dropTable()
 
 ```ts
@@ -379,36 +299,6 @@ Return true if the connection has not been closed
 
 ***
 
-### listNamespaces()
-
-```ts
-abstract listNamespaces(namespacePath?, options?): Promise<ListNamespacesResponse>
-```
-
-List the immediate child namespaces under the given parent.
-
-Results may be paginated. To retrieve subsequent pages, pass the
-`pageToken` returned by a previous call.
-
-#### Parameters
-
-* **namespacePath?**: `string`[]
-    The parent namespace path. Defaults
-    to the root namespace if omitted.
-
-* **options?**: `Partial`&lt;[`ListNamespacesOptions`](../interfaces/ListNamespacesOptions.md)&gt;
-    Pagination options
-    (`pageToken`, `limit`).
-
-#### Returns
-
-`Promise`&lt;[`ListNamespacesResponse`](../interfaces/ListNamespacesResponse.md)&gt;
-
-Child namespace names and
-  an optional token for fetching the next page.
-
-***
-
 ### openTable()
 
 ```ts
@@ -437,39 +327,6 @@ Open a table in the database.
 
 ***
 
-### renameTable()
-
-```ts
-abstract renameTable(
-   currentName,
-   newName,
-   options?): Promise<void>
-```
-
-Rename a table.
-
-Currently only supported by LanceDB Cloud. Local OSS connections and
-namespace-backed connections (via [connectNamespace](../functions/connectNamespace.md)) reject with
-a "not supported" error.
-
-#### Parameters
-
-* **currentName**: `string`
-    The current name of the table.
-
-* **newName**: `string`
-    The new name for the table.
-
-* **options?**: [`RenameTableOptions`](../interfaces/RenameTableOptions.md)
-    Optional namespace paths. When
-    `newNamespacePath` is omitted the table stays in `namespacePath`.
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-***
-
 ### tableNames()
 
 #### tableNames(options)

docs/src/js/classes/Index.md

@@ -57,24 +57,6 @@ block size may be added in the future.
 
 ***
 
-### fm()
-
-```ts
-static fm(): Index
-```
-
-Create an FM-Index.
-
-An FM-Index is a scalar index on string or binary columns that accelerates
-substring search, i.e. `contains(col, 'needle')`. Unlike the tokenized
-full-text-search index, it matches arbitrary substrings of the raw bytes.
-
-#### Returns
-
-[`Index`](Index.md)
-
-***
-
 ### fts()
 
 ```ts

docs/src/js/classes/MergeInsertBuilder.md

@@ -76,57 +76,6 @@ the query optimizer chooses a suboptimal path.
 
 ***
 
-### useLsmWrite()
-
-```ts
-useLsmWrite(useLsmWrite): MergeInsertBuilder
-```
-
-Controls whether the merge uses the MemWAL LSM write path.
-
-By default (unset), a `mergeInsert` on a table with an LSM write spec is
-routed through Lance's MemWAL shard writer, and a table without one uses
-the standard path. Pass `false` to force the standard path even when a
-spec is set. Pass `true` to require a spec — `mergeInsert` rejects if none
-is installed.
-
-#### Parameters
-
-* **useLsmWrite**: `boolean`
-    Whether to use the LSM write path.
-
-#### Returns
-
-[`MergeInsertBuilder`](MergeInsertBuilder.md)
-
-***
-
-### validateSingleShard()
-
-```ts
-validateSingleShard(validateSingleShard): MergeInsertBuilder
-```
-
-Controls how an LSM merge checks that its input targets a single shard.
-
-When a table has an LSM write spec, every row in a `mergeInsert` call must
-route to the same shard. When `true` (the default), every row is inspected
-to verify this. When `false`, only the first row is inspected and the
-shard it routes to is used for the whole input — a faster path for callers
-that have already pre-sharded their input. Has no effect on tables without
-an LSM write spec.
-
-#### Parameters
-
-* **validateSingleShard**: `boolean`
-    Whether to check every row routes to one shard. Defaults to `true`.
-
-#### Returns
-
-[`MergeInsertBuilder`](MergeInsertBuilder.md)
-
-***
-
 ### whenMatchedUpdateAll()
 
 ```ts

docs/src/js/classes/Query.md

@@ -343,30 +343,6 @@ This is useful for pagination.
 
 ***
 
-### orderBy()
-
-```ts
-orderBy(ordering): this
-```
-
-Sort the results by the specified column(s).
-
-#### Parameters
-
-* **ordering**: [`ColumnOrdering`](../interfaces/ColumnOrdering.md) \| [`ColumnOrdering`](../interfaces/ColumnOrdering.md)[]
-
-#### Returns
-
-`this`
-
-This query builder.
-
-#### Inherited from
-
-`StandardQueryBase.orderBy`
-
-***
-
 ### outputSchema()
 
 ```ts

docs/src/js/classes/Scannable.md

@@ -1,173 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / Scannable
-
-# Class: Scannable
-
-A data source that can be scanned as a stream of Arrow `RecordBatch`es.
-
-`Scannable` wraps the schema + optional row count + rescannable flag and
-a callback that yields batches one at a time. It is passed to consumers
-(e.g. `Table.add`, `createTable`, `mergeInsert` — follow-up work) that
-need to pull data without materializing the full dataset in JS memory.
-
-Batches cross the JS↔Rust boundary as Arrow IPC Stream messages; a fresh
-writer serializes each batch, and the Rust side decodes it with
-`arrow_ipc::reader::StreamReader`. One batch is in flight at a time.
-
-## Properties
-
-### numRows
-
-```ts
-readonly numRows: null | number;
-```
-
-***
-
-### rescannable
-
-```ts
-readonly rescannable: boolean;
-```
-
-***
-
-### schema
-
-```ts
-readonly schema: Schema<any>;
-```
-
-## Methods
-
-### fromFactory()
-
-```ts
-static fromFactory(
-   schema,
-   factory,
-   opts): Promise<Scannable>
-```
-
-Build a Scannable from an explicit schema and a factory that returns a
-fresh batch iterator on each call.
-
-The factory is invoked once per scan. Each iterator yields
-`RecordBatch`es matching the declared schema. Use this when you need
-direct control over the pull loop — for example, to wrap a streaming
-source whose batches are produced lazily.
-
-#### Parameters
-
-* **schema**: `Schema`&lt;`any`&gt;
-    The Arrow schema of the produced batches.
-
-* **factory**
-    Called at the start of each scan to produce a batch
-    iterator. Must be idempotent when `rescannable` is true.
-
-* **opts**: [`ScannableOptions`](../interfaces/ScannableOptions.md) = `{}`
-    Optional hints. `rescannable` defaults to `true`; set to
-    `false` if calling `factory()` twice would not reproduce the same data.
-
-#### Returns
-
-`Promise`&lt;[`Scannable`](Scannable.md)&gt;
-
-***
-
-### fromIterable()
-
-```ts
-static fromIterable(
-   schema,
-   iter,
-   opts): Promise<Scannable>
-```
-
-Build a Scannable from an iterable of `RecordBatch`es. `rescannable`
-defaults to `false`. Pass an explicit schema so the consumer can
-validate before any batch is pulled.
-
-`opts.rescannable: true` is honest for replayable iterables (Arrays,
-Sets, or custom iterables whose `[Symbol.iterator]()` returns a fresh
-iterator each call). It is rejected for one-shot iterables (generators,
-async generators, or already-an-iterator inputs) because their
-`[Symbol.iterator]()` returns the same exhausted object on the second
-scan. For replayable sources outside this shape, use
-`fromFactory(schema, () => createIter(), { rescannable: true })`.
-
-Note: when `opts.rescannable` is `true`, the constructor calls
-`[Symbol.iterator]()` once on the input to perform the structural check.
-
-#### Parameters
-
-* **schema**: `Schema`&lt;`any`&gt;
-
-* **iter**: `Iterable`&lt;`RecordBatch`&lt;`any`&gt;&gt; \| `AsyncIterable`&lt;`RecordBatch`&lt;`any`&gt;&gt;
-
-* **opts**: [`ScannableOptions`](../interfaces/ScannableOptions.md) = `{}`
-
-#### Returns
-
-`Promise`&lt;[`Scannable`](Scannable.md)&gt;
-
-***
-
-### fromRecordBatchReader()
-
-```ts
-static fromRecordBatchReader(reader, opts): Promise<Scannable>
-```
-
-Build a Scannable from an Arrow `RecordBatchReader`. A reader can only
-be consumed once; `rescannable` defaults to `false`.
-
-The reader must already be opened (via `.open()`) so its `.schema` is
-populated. `RecordBatchReader.from(...)` returns an unopened reader.
-
-`opts.rescannable: true` is rejected because `RecordBatchReader` is a
-self-iterator (its `[Symbol.iterator]()` returns itself), and this
-constructor does not call `reader.reset()` between scans, so a second
-scan would always see an exhausted reader. For genuinely replayable
-sources, use
-`fromFactory(schema, () => openReader(), { rescannable: true })`,
-which mints a fresh reader on each scan.
-
-#### Parameters
-
-* **reader**: `RecordBatchReader`&lt;`any`&gt;
-
-* **opts**: [`ScannableOptions`](../interfaces/ScannableOptions.md) = `{}`
-
-#### Returns
-
-`Promise`&lt;[`Scannable`](Scannable.md)&gt;
-
-***
-
-### fromTable()
-
-```ts
-static fromTable(table, opts): Promise<Scannable>
-```
-
-Build a Scannable from an in-memory Arrow `Table`. Always rescannable;
-the table's batches are replayed on each scan.
-
-The table's row count is authoritative: `opts.numRows` must either be
-omitted or equal to `table.numRows`. `opts.rescannable` of `false` is
-rejected because in-memory Tables are always rescannable.
-
-#### Parameters
-
-* **table**: `Table`&lt;`any`&gt;
-
-* **opts**: [`ScannableOptions`](../interfaces/ScannableOptions.md) = `{}`
-
-#### Returns
-
-`Promise`&lt;[`Scannable`](Scannable.md)&gt;

docs/src/js/classes/Table.md

@@ -110,23 +110,6 @@ containing the new version number of the table after altering the columns.
 
 ***
 
-### branches()
-
-```ts
-abstract branches(): Promise<Branches>
-```
-
-Get the branch manager for this table.
-
-Branches are isolated, writable lines of history forked from another
-branch (or version). Writes on a branch do not affect `main`.
-
-#### Returns
-
-`Promise`&lt;[`Branches`](Branches.md)&gt;
-
-***
-
 ### checkout()
 
 ```ts
@@ -204,25 +187,6 @@ Any attempt to use the table after it is closed will result in an error.
 
 ***
 
-### closeLsmWriters()
-
-```ts
-abstract closeLsmWriters(): Promise<void>
-```
-
-Drain and close any cached MemWAL shard writers held for this table.
-
-When an [LsmWriteSpec](../interfaces/LsmWriteSpec.md) is installed, `mergeInsert` opens MemWAL
-shard writers and caches them for reuse across calls. This closes them,
-flushing pending data; writers reopen lazily on the next `mergeInsert`.
-It is a no-op when no writers are cached.
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-***
-
 ### countRows()
 
 ```ts
@@ -726,74 +690,6 @@ of the given query
 
 ***
 
-### setLsmWriteSpec()
-
-```ts
-abstract setLsmWriteSpec(spec): Promise<void>
-```
-
-Install an [LsmWriteSpec](../interfaces/LsmWriteSpec.md) on this table, selecting Lance's MemWAL
-LSM-style write path for future `mergeInsert` calls.
-
-`LsmWriteSpec` chooses one of three sharding strategies via `specType`:
-
-- `"bucket"` — hash-bucket writes by the single-column unenforced primary
-  key (`column` and `numBuckets` required).
-- `"identity"` — shard by the raw value of a scalar `column`.
-- `"unsharded"` — route every write to a single shard.
-
-All variants require the table to have an unenforced primary key
-([Table#setUnenforcedPrimaryKey](Table.md#setunenforcedprimarykey)); bucket sharding additionally
-requires it to be the single column being bucketed.
-
-#### Parameters
-
-* **spec**: [`LsmWriteSpec`](../interfaces/LsmWriteSpec.md)
-    The sharding spec to install.
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-#### Example
-
-```ts
-await table.setUnenforcedPrimaryKey("id");
-await table.setLsmWriteSpec({
-  specType: "bucket",
-  column: "id",
-  numBuckets: 16,
-  maintainedIndexes: ["id_idx"],
-});
-```
-
-***
-
-### setUnenforcedPrimaryKey()
-
-```ts
-abstract setUnenforcedPrimaryKey(columns): Promise<void>
-```
-
-Set the unenforced primary key for this table to a single column.
-
-"Unenforced" means LanceDB does not check uniqueness on writes; the
-column is recorded in the schema as the primary key for use by features
-such as `merge_insert`. Only single-column primary keys are supported,
-and the key cannot be changed once set.
-
-#### Parameters
-
-* **columns**: `string` \| `string`[]
-    The primary key column. A one-element
-    array is also accepted; passing more than one column is rejected.
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-***
-
 ### stats()
 
 ```ts
@@ -897,23 +793,6 @@ Return the table as an arrow table
 
 ***
 
-### unsetLsmWriteSpec()
-
-```ts
-abstract unsetLsmWriteSpec(): Promise<void>
-```
-
-Remove the [LsmWriteSpec](../interfaces/LsmWriteSpec.md) from this table, reverting to the standard
-`mergeInsert` write path.
-
-Errors if no spec is currently set.
-
-#### Returns
-
-`Promise`&lt;`void`&gt;
-
-***
-
 ### update()
 
 #### update(opts)
@@ -1011,29 +890,6 @@ based on the row being updated (e.g. "my_col + 1")
 
 ***
 
-### updateFieldMetadata()
-
-```ts
-abstract updateFieldMetadata(updates): Promise<UpdateFieldMetadataResult>
-```
-
-Update per-field (column) metadata.
-
-#### Parameters
-
-* **updates**: [`FieldMetadataUpdate`](../interfaces/FieldMetadataUpdate.md)[]
-    One or more per-field updates. Each
-    update's metadata is merged into the field's existing metadata by default;
-    a value of `null` deletes that key, and `replace: true` swaps the whole map.
-
-#### Returns
-
-`Promise`&lt;[`UpdateFieldMetadataResult`](../interfaces/UpdateFieldMetadataResult.md)&gt;
-
-resolves to the new table version.
-
-***
-
 ### vectorSearch()
 
 ```ts

docs/src/js/classes/VectorQuery.md

@@ -498,30 +498,6 @@ This is useful for pagination.
 
 ***
 
-### orderBy()
-
-```ts
-orderBy(ordering): this
-```
-
-Sort the results by the specified column(s).
-
-#### Parameters
-
-* **ordering**: [`ColumnOrdering`](../interfaces/ColumnOrdering.md) \| [`ColumnOrdering`](../interfaces/ColumnOrdering.md)[]
-
-#### Returns
-
-`this`
-
-This query builder.
-
-#### Inherited from
-
-`StandardQueryBase.orderBy`
-
-***
-
 ### outputSchema()
 
 ```ts

docs/src/js/functions/connectNamespace.md

@@ -1,131 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / connectNamespace
-
-# Function: connectNamespace()
-
-## connectNamespace(implName, config, options)
-
-```ts
-function connectNamespace(
-   implName,
-   config,
-   options?): Promise<Connection>
-```
-
-Connect to a LanceDB database through a namespace.
-
-Unlike [connect](connect.md), which routes by URI scheme (local path vs.
-`db://` cloud), `connectNamespace` always returns a namespace-backed
-connection. The `implName` selects the namespace implementation:
-
-- `"dir"` — directory namespace, configured with [DirNamespaceConfig](../interfaces/DirNamespaceConfig.md).
-- `"rest"` — remote REST catalog, configured with [RestNamespaceConfig](../interfaces/RestNamespaceConfig.md).
-- Any other string — full module path for a custom implementation,
-  configured with a free-form string-keyed `properties` map.
-
-### Parameters
-
-* **implName**: `"dir"`
-
-* **config**: [`DirNamespaceConfig`](../interfaces/DirNamespaceConfig.md)
-
-* **options?**: `Partial`&lt;[`ConnectNamespaceOptions`](../interfaces/ConnectNamespaceOptions.md)&gt;
-
-### Returns
-
-`Promise`&lt;[`Connection`](../classes/Connection.md)&gt;
-
-### Examples
-
-```ts
-const db = await connectNamespace("dir", { root: "/path/to/db" });
-await db.createTable("users", [{ id: 1 }]);
-```
-
-```ts
-const db = await connectNamespace("rest", {
-  uri: "https://catalog.example.com",
-  headers: { "x-api-key": process.env.CATALOG_KEY ?? "" },
-});
-```
-
-```ts
-const db = await connectNamespace("my.custom.Namespace", {
-  endpoint: "...",
-});
-```
-
-## connectNamespace(implName, config, options)
-
-```ts
-function connectNamespace(
-   implName,
-   config,
-   options?): Promise<Connection>
-```
-
-Connect through the built-in REST namespace.
-
-Configured with [RestNamespaceConfig](../interfaces/RestNamespaceConfig.md). See the function-level
-documentation above for the full surface, examples, and how this
-relates to [connect](connect.md).
-
-### Parameters
-
-* **implName**: `"rest"`
-
-* **config**: [`RestNamespaceConfig`](../interfaces/RestNamespaceConfig.md)
-
-* **options?**: `Partial`&lt;[`ConnectNamespaceOptions`](../interfaces/ConnectNamespaceOptions.md)&gt;
-
-### Returns
-
-`Promise`&lt;[`Connection`](../classes/Connection.md)&gt;
-
-### Example
-
-```ts
-const db = await connectNamespace("rest", {
-  uri: "https://catalog.example.com",
-  headers: { "x-api-key": process.env.CATALOG_KEY ?? "" },
-});
-```
-
-## connectNamespace(implName, properties, options)
-
-```ts
-function connectNamespace(
-   implName,
-   properties,
-   options?): Promise<Connection>
-```
-
-Connect through a custom namespace implementation by full module path,
-configured with a free-form string-keyed `properties` map. Use the
-typed overloads above for the built-in `"dir"` and `"rest"` impls.
-
-See the function-level documentation above for examples and how this
-relates to [connect](connect.md).
-
-### Parameters
-
-* **implName**: `string`
-
-* **properties**: `Record`&lt;`string`, `string`&gt;
-
-* **options?**: `Partial`&lt;[`ConnectNamespaceOptions`](../interfaces/ConnectNamespaceOptions.md)&gt;
-
-### Returns
-
-`Promise`&lt;[`Connection`](../classes/Connection.md)&gt;
-
-### Example
-
-```ts
-const db = await connectNamespace("my.custom.Namespace", {
-  endpoint: "...",
-});
-```

docs/src/js/globals.md

@@ -19,8 +19,6 @@
 
 - [BooleanQuery](classes/BooleanQuery.md)
 - [BoostQuery](classes/BoostQuery.md)
-- [BranchContents](classes/BranchContents.md)
-- [Branches](classes/Branches.md)
 - [Connection](classes/Connection.md)
 - [HeaderProvider](classes/HeaderProvider.md)
 - [Index](classes/Index.md)
@@ -34,7 +32,6 @@
 - [PhraseQuery](classes/PhraseQuery.md)
 - [Query](classes/Query.md)
 - [QueryBase](classes/QueryBase.md)
-- [Scannable](classes/Scannable.md)
 - [Session](classes/Session.md)
 - [StaticHeaderProvider](classes/StaticHeaderProvider.md)
 - [Table](classes/Table.md)
@@ -53,21 +50,12 @@
 - [AlterColumnsResult](interfaces/AlterColumnsResult.md)
 - [ClientConfig](interfaces/ClientConfig.md)
 - [ColumnAlteration](interfaces/ColumnAlteration.md)
-- [ColumnOrdering](interfaces/ColumnOrdering.md)
 - [CompactionStats](interfaces/CompactionStats.md)
-- [ConnectNamespaceOptions](interfaces/ConnectNamespaceOptions.md)
 - [ConnectionOptions](interfaces/ConnectionOptions.md)
-- [CreateNamespaceOptions](interfaces/CreateNamespaceOptions.md)
-- [CreateNamespaceResponse](interfaces/CreateNamespaceResponse.md)
 - [CreateTableOptions](interfaces/CreateTableOptions.md)
 - [DeleteResult](interfaces/DeleteResult.md)
-- [DescribeNamespaceResponse](interfaces/DescribeNamespaceResponse.md)
-- [DirNamespaceConfig](interfaces/DirNamespaceConfig.md)
 - [DropColumnsResult](interfaces/DropColumnsResult.md)
-- [DropNamespaceOptions](interfaces/DropNamespaceOptions.md)
-- [DropNamespaceResponse](interfaces/DropNamespaceResponse.md)
 - [ExecutableQuery](interfaces/ExecutableQuery.md)
-- [FieldMetadataUpdate](interfaces/FieldMetadataUpdate.md)
 - [FragmentStatistics](interfaces/FragmentStatistics.md)
 - [FragmentSummaryStats](interfaces/FragmentSummaryStats.md)
 - [FtsOptions](interfaces/FtsOptions.md)
@@ -81,19 +69,13 @@
 - [IvfFlatOptions](interfaces/IvfFlatOptions.md)
 - [IvfPqOptions](interfaces/IvfPqOptions.md)
 - [IvfRqOptions](interfaces/IvfRqOptions.md)
-- [ListNamespacesOptions](interfaces/ListNamespacesOptions.md)
-- [ListNamespacesResponse](interfaces/ListNamespacesResponse.md)
-- [LsmWriteSpec](interfaces/LsmWriteSpec.md)
 - [MergeResult](interfaces/MergeResult.md)
 - [OpenTableOptions](interfaces/OpenTableOptions.md)
 - [OptimizeOptions](interfaces/OptimizeOptions.md)
 - [OptimizeStats](interfaces/OptimizeStats.md)
 - [QueryExecutionOptions](interfaces/QueryExecutionOptions.md)
 - [RemovalStats](interfaces/RemovalStats.md)
-- [RenameTableOptions](interfaces/RenameTableOptions.md)
-- [RestNamespaceConfig](interfaces/RestNamespaceConfig.md)
 - [RetryConfig](interfaces/RetryConfig.md)
-- [ScannableOptions](interfaces/ScannableOptions.md)
 - [ShuffleOptions](interfaces/ShuffleOptions.md)
 - [SplitCalculatedOptions](interfaces/SplitCalculatedOptions.md)
 - [SplitHashOptions](interfaces/SplitHashOptions.md)
@@ -104,12 +86,10 @@
 - [TimeoutConfig](interfaces/TimeoutConfig.md)
 - [TlsConfig](interfaces/TlsConfig.md)
 - [TokenResponse](interfaces/TokenResponse.md)
-- [UpdateFieldMetadataResult](interfaces/UpdateFieldMetadataResult.md)
 - [UpdateOptions](interfaces/UpdateOptions.md)
 - [UpdateResult](interfaces/UpdateResult.md)
 - [Version](interfaces/Version.md)
 - [WriteExecutionOptions](interfaces/WriteExecutionOptions.md)
-- [WriteProgress](interfaces/WriteProgress.md)
 
 ## Type Aliases
 
@@ -127,7 +107,6 @@
 
 - [RecordBatchIterator](functions/RecordBatchIterator.md)
 - [connect](functions/connect.md)
-- [connectNamespace](functions/connectNamespace.md)
 - [makeArrowTable](functions/makeArrowTable.md)
 - [packBits](functions/packBits.md)
 - [permutationBuilder](functions/permutationBuilder.md)

docs/src/js/interfaces/AddDataOptions.md

@@ -19,39 +19,3 @@ mode: "append" | "overwrite";
 If "append" (the default) then the new data will be added to the table
 
 If "overwrite" then the new data will replace the existing data in the table.
-
-***
-
-### progress()
-
-```ts
-progress: (progress) => void;
-```
-
-Optional callback invoked periodically with write progress.
-
-The callback is fired once per batch written and once more with
-`done: true` when the write completes. Calls are dispatched
-asynchronously to the JS event loop and never block the write — a slow
-callback will queue events rather than back-pressure the writer.
-
-Errors thrown from the callback are logged with `console.warn` and
-swallowed — they do not abort the write.
-
-#### Parameters
-
-* **progress**: [`WriteProgress`](WriteProgress.md)
-
-#### Returns
-
-`void`
-
-#### Example
-
-```ts
-await table.add(data, {
-  progress: (p) => {
-    console.log(`${p.outputRows}/${p.totalRows ?? "?"} rows`);
-  },
-});
-```

docs/src/js/interfaces/ColumnOrdering.md

@@ -1,31 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / ColumnOrdering
-
-# Interface: ColumnOrdering
-
-## Properties
-
-### ascending?
-
-```ts
-optional ascending: boolean;
-```
-
-***
-
-### columnName
-
-```ts
-columnName: string;
-```
-
-***
-
-### nullsFirst?
-
-```ts
-optional nullsFirst: boolean;
-```

docs/src/js/interfaces/ConnectNamespaceOptions.md

@@ -1,54 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / ConnectNamespaceOptions
-
-# Interface: ConnectNamespaceOptions
-
-## Properties
-
-### namespaceClientProperties?
-
-```ts
-optional namespaceClientProperties: Record<string, string>;
-```
-
-Extra properties for the backing namespace client.
-
-***
-
-### readConsistencyInterval?
-
-```ts
-optional readConsistencyInterval: number;
-```
-
-The interval, in seconds, at which to check for updates to the table
-from other processes. If None, then consistency is not checked. For
-performance reasons, this is the default. For strong consistency, set
-this to zero seconds. Then every read will check for updates from other
-processes. As a compromise, you can set this to a non-zero value for
-eventual consistency.
-
-***
-
-### session?
-
-```ts
-optional session: Session;
-```
-
-The session to use for this connection. Holds shared caches and other
-session-specific state.
-
-***
-
-### storageOptions?
-
-```ts
-optional storageOptions: Record<string, string>;
-```
-
-Configuration for object storage. The available options are described
-at https://docs.lancedb.com/storage/

docs/src/js/interfaces/ConnectionOptions.md

@@ -70,20 +70,16 @@ client used by manifest-enabled native connections.
 optional readConsistencyInterval: number;
 ```
 
-The interval, in seconds, at which to check for updates to the table
-from other processes. If None, then consistency is not checked. For
-performance reasons, this is the default. For strong consistency, set
-this to zero seconds. Then every read will check for updates from other
-processes. As a compromise, you can set this to a non-zero value for
-eventual consistency. If more than that interval has passed since the
-last check, then the table will be checked for updates. Note: this
-consistency only applies to read operations. Write operations are
+(For LanceDB OSS only): The interval, in seconds, at which to check for
+updates to the table from other processes. If None, then consistency is not
+checked. For performance reasons, this is the default. For strong
+consistency, set this to zero seconds. Then every read will check for
+updates from other processes. As a compromise, you can set this to a
+non-zero value for eventual consistency. If more than that interval
+has passed since the last check, then the table will be checked for updates.
+Note: this consistency only applies to read operations. Write operations are
 always consistent.
 
-Stronger consistency is not free. The smaller the interval, the more
-often each read pays the cost of checking for updates against object
-storage, raising per-read latency and cost.
-
 ***
 
 ### region?

docs/src/js/interfaces/CreateNamespaceOptions.md

@@ -1,27 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / CreateNamespaceOptions
-
-# Interface: CreateNamespaceOptions
-
-## Properties
-
-### mode?
-
-```ts
-optional mode: "overwrite" | "create" | "exist_ok";
-```
-
-Creation mode.
-
-***
-
-### properties?
-
-```ts
-optional properties: Record<string, string>;
-```
-
-Properties to set on the new namespace.

docs/src/js/interfaces/CreateNamespaceResponse.md

@@ -1,23 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / CreateNamespaceResponse
-
-# Interface: CreateNamespaceResponse
-
-## Properties
-
-### properties?
-
-```ts
-optional properties: Record<string, string>;
-```
-
-***
-
-### transactionId?
-
-```ts
-optional transactionId: string;
-```

docs/src/js/interfaces/DescribeNamespaceResponse.md

@@ -1,15 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / DescribeNamespaceResponse
-
-# Interface: DescribeNamespaceResponse
-
-## Properties
-
-### properties?
-
-```ts
-optional properties: Record<string, string>;
-```

docs/src/js/interfaces/DirNamespaceConfig.md

@@ -1,47 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / DirNamespaceConfig
-
-# Interface: DirNamespaceConfig
-
-Configuration for the built-in directory namespace (`"dir"`).
-
-The directory namespace stores tables under a single root path (local
-filesystem or object storage URI). See
-[https://docs.lancedb.com/namespaces](https://docs.lancedb.com/namespaces) for the documented surface;
-less-common knobs live under [DirNamespaceConfig.extraProperties](DirNamespaceConfig.md#extraproperties).
-
-## Properties
-
-### extraProperties?
-
-```ts
-optional extraProperties: Record<string, string>;
-```
-
-Additional raw properties passed verbatim to the namespace
-implementation (e.g. `storage.*`, `credential_vendor.*`). Typed
-fields above take precedence on key collision.
-
-***
-
-### manifestEnabled?
-
-```ts
-optional manifestEnabled: boolean;
-```
-
-Whether to maintain a namespace manifest at the root. Required for
-child namespaces. Defaults to true on the impl side.
-
-***
-
-### root
-
-```ts
-root: string;
-```
-
-Root path or URI containing the LanceDB tables.

docs/src/js/interfaces/DropNamespaceOptions.md

@@ -1,27 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / DropNamespaceOptions
-
-# Interface: DropNamespaceOptions
-
-## Properties
-
-### behavior?
-
-```ts
-optional behavior: "restrict" | "cascade";
-```
-
-Refuse to drop if non-empty (restrict) or drop recursively (cascade).
-
-***
-
-### mode?
-
-```ts
-optional mode: "fail" | "skip";
-```
-
-Whether to skip if the namespace doesn't exist, or fail.

docs/src/js/interfaces/DropNamespaceResponse.md

@@ -1,23 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / DropNamespaceResponse
-
-# Interface: DropNamespaceResponse
-
-## Properties
-
-### properties?
-
-```ts
-optional properties: Record<string, string>;
-```
-
-***
-
-### transactionId?
-
-```ts
-optional transactionId: string[];
-```

docs/src/js/interfaces/FieldMetadataUpdate.md

@@ -1,41 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / FieldMetadataUpdate
-
-# Interface: FieldMetadataUpdate
-
-A per-field metadata update, addressed by dot-path.
-
-## Properties
-
-### metadata
-
-```ts
-metadata: Record<string, null | string>;
-```
-
-Metadata key/value pairs. Merged into the field's existing metadata by
-default; a value of `null` deletes that key.
-
-***
-
-### path
-
-```ts
-path: string;
-```
-
-Dot-separated path to the field. For a top-level column this is just its
-name; for a nested field it's the path, e.g. "a.b.c".
-
-***
-
-### replace?
-
-```ts
-optional replace: boolean;
-```
-
-If true, replace the field's entire metadata map instead of merging.

docs/src/js/interfaces/IndexConfig.md

@@ -23,31 +23,6 @@ be more columns to represent composite indices.
 
 ***
 
-### createdAt?
-
-```ts
-optional createdAt: Date;
-```
-
-When the index was created.
-
-`undefined` for remote tables or indices created before timestamps were tracked.
-
-***
-
-### indexDetails?
-
-```ts
-optional indexDetails: any;
-```
-
-Index-type-specific details parsed as a JavaScript object.
-
-Falls back to a raw string if JSON parsing fails. `undefined` for
-remote tables or when details are unavailable.
-
-***
-
 ### indexType
 
 ```ts
@@ -58,30 +33,6 @@ The type of the index
 
 ***
 
-### indexUuid?
-
-```ts
-optional indexUuid: string;
-```
-
-The UUID of the first segment of the index.
-
-`undefined` for remote tables, which do not yet surface this.
-
-***
-
-### indexVersion?
-
-```ts
-optional indexVersion: number;
-```
-
-The on-disk index format version.
-
-`undefined` for remote tables.
-
-***
-
 ### name
 
 ```ts
@@ -89,63 +40,3 @@ name: string;
 ```
 
 The name of the index
-
-***
-
-### numIndexedRows?
-
-```ts
-optional numIndexedRows: number;
-```
-
-The number of rows indexed, across all segments.
-
-`undefined` for remote tables.
-
-***
-
-### numSegments?
-
-```ts
-optional numSegments: number;
-```
-
-The number of segments that make up the index.
-
-`undefined` for remote tables.
-
-***
-
-### numUnindexedRows?
-
-```ts
-optional numUnindexedRows: number;
-```
-
-The number of rows not yet covered by this index.
-
-`undefined` for remote tables.
-
-***
-
-### sizeBytes?
-
-```ts
-optional sizeBytes: number;
-```
-
-The total size in bytes of all index files across all segments.
-
-`undefined` for remote tables or indices without size tracking.
-
-***
-
-### typeUrl?
-
-```ts
-optional typeUrl: string;
-```
-
-The protobuf type URL, a precise type identifier for the index.
-
-`undefined` for remote tables.

docs/src/js/interfaces/IndexStatistics.md

@@ -30,6 +30,17 @@ The type of the index
 
 ***
 
+### loss?
+
+```ts
+optional loss: number;
+```
+
+The KMeans loss value of the index,
+it is only present for vector indices.
+
+***
+
 ### numIndexedRows
 
 ```ts

docs/src/js/interfaces/ListNamespacesOptions.md

@@ -1,27 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / ListNamespacesOptions
-
-# Interface: ListNamespacesOptions
-
-## Properties
-
-### limit?
-
-```ts
-optional limit: number;
-```
-
-An optional limit to the number of results to return.
-
-***
-
-### pageToken?
-
-```ts
-optional pageToken: string;
-```
-
-Token from a previous response for pagination.

docs/src/js/interfaces/ListNamespacesResponse.md

@@ -1,23 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / ListNamespacesResponse
-
-# Interface: ListNamespacesResponse
-
-## Properties
-
-### namespaces
-
-```ts
-namespaces: string[];
-```
-
-***
-
-### pageToken?
-
-```ts
-optional pageToken: string;
-```

docs/src/js/interfaces/LsmWriteSpec.md

@@ -1,67 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / LsmWriteSpec
-
-# Interface: LsmWriteSpec
-
-Specification selecting Lance's MemWAL LSM-style write path for
-`mergeInsert`.
-
-`specType` is `"bucket"`, `"identity"`, or `"unsharded"`. For `"bucket"`,
-`column` and `numBuckets` are required; for `"identity"`, `column` is
-required and must be a deterministic function of the unenforced primary
-key (every row with a given primary key must always produce the same
-`column` value, or upserts of that key can land in different shards and a
-stale version can win).
-
-## Properties
-
-### column?
-
-```ts
-optional column: string;
-```
-
-Bucket and identity variants: the sharding column.
-
-***
-
-### maintainedIndexes?
-
-```ts
-optional maintainedIndexes: string[];
-```
-
-Names of indexes the MemWAL should keep up to date during writes.
-
-***
-
-### numBuckets?
-
-```ts
-optional numBuckets: number;
-```
-
-Bucket variant: the number of buckets, in `[1, 1024]`.
-
-***
-
-### specType
-
-```ts
-specType: "bucket" | "identity" | "unsharded";
-```
-
-One of `"bucket"`, `"identity"`, or `"unsharded"`.
-
-***
-
-### writerConfigDefaults?
-
-```ts
-optional writerConfigDefaults: Record<string, string>;
-```
-
-Default `ShardWriter` configuration recorded in the MemWAL index.

docs/src/js/interfaces/MergeResult.md

@@ -32,14 +32,6 @@ numInsertedRows: number;
 
 ***
 
-### numRows
-
-```ts
-numRows: number;
-```
-
-***
-
 ### numUpdatedRows
 
 ```ts

docs/src/js/interfaces/OpenTableOptions.md

@@ -8,18 +8,6 @@
 
 ## Properties
 
-### branch?
-
-```ts
-optional branch: string;
-```
-
-Open the table scoped to this branch instead of the default branch.
-
-Reads and writes on the returned table operate in the branch's context.
-
-***
-
 ### ~~indexCacheSize?~~
 
 ```ts
@@ -55,17 +43,3 @@ 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/
-
-***
-
-### version?
-
-```ts
-optional version: number;
-```
-
-Open the table pinned to this version, producing a read-only view.
-
-Composes with [OpenTableOptions.branch](OpenTableOptions.md#branch): when both are set, opens
-that branch at the version; otherwise opens `main` at the version. Call
-`checkoutLatest` to return to a writable state.

docs/src/js/interfaces/RenameTableOptions.md

@@ -1,29 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / RenameTableOptions
-
-# Interface: RenameTableOptions
-
-## Properties
-
-### namespacePath?
-
-```ts
-optional namespacePath: string[];
-```
-
-The namespace path of the table being renamed. Defaults to the root
-namespace (`[]`) when omitted.
-
-***
-
-### newNamespacePath?
-
-```ts
-optional newNamespacePath: string[];
-```
-
-The namespace path to move the table to as part of the rename. When
-omitted the table stays in `namespacePath`.

docs/src/js/interfaces/RestNamespaceConfig.md

@@ -1,47 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / RestNamespaceConfig
-
-# Interface: RestNamespaceConfig
-
-Configuration for the built-in REST namespace (`"rest"`).
-
-The REST namespace talks to a remote catalog server over HTTP. See
-[https://docs.lancedb.com/namespaces](https://docs.lancedb.com/namespaces) for the documented surface;
-less-common knobs (TLS, metrics) live under
-[RestNamespaceConfig.extraProperties](RestNamespaceConfig.md#extraproperties).
-
-## Properties
-
-### extraProperties?
-
-```ts
-optional extraProperties: Record<string, string>;
-```
-
-Additional raw properties passed verbatim to the namespace
-implementation (e.g. `tls.*`, `ops_metrics_enabled`, `delimiter`).
-Typed fields above take precedence on key collision.
-
-***
-
-### headers?
-
-```ts
-optional headers: Record<string, string>;
-```
-
-HTTP headers forwarded with each request. Keys are passed through
-as-is (e.g. `"x-api-key"`, `"Authorization"`).
-
-***
-
-### uri
-
-```ts
-uri: string;
-```
-
-Catalog endpoint URL.

docs/src/js/interfaces/ScannableOptions.md

@@ -1,29 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / ScannableOptions
-
-# Interface: ScannableOptions
-
-## Properties
-
-### numRows?
-
-```ts
-optional numRows: number;
-```
-
-Hint about the number of rows. Not validated against the stream.
-
-***
-
-### rescannable?
-
-```ts
-optional rescannable: boolean;
-```
-
-Whether the source can be scanned more than once. Defaults to `true` for
-`fromTable` / `fromFactory` and `false` for `fromIterable` /
-`fromRecordBatchReader`.

docs/src/js/interfaces/UpdateFieldMetadataResult.md

@@ -1,15 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / UpdateFieldMetadataResult
-
-# Interface: UpdateFieldMetadataResult
-
-## Properties
-
-### version
-
-```ts
-version: number;
-```

docs/src/js/interfaces/WriteProgress.md

@@ -1,84 +0,0 @@
-[**@lancedb/lancedb**](../README.md) • **Docs**
-
-***
-
-[@lancedb/lancedb](../globals.md) / WriteProgress
-
-# Interface: WriteProgress
-
-Progress snapshot for a write operation, delivered to the `progress`
-callback passed to [Table.add](../classes/Table.md#add).
-
-## Properties
-
-### activeTasks
-
-```ts
-activeTasks: number;
-```
-
-Number of parallel write tasks currently in flight.
-
-***
-
-### done
-
-```ts
-done: boolean;
-```
-
-`true` for the final callback; `false` otherwise.
-
-***
-
-### elapsedSeconds
-
-```ts
-elapsedSeconds: number;
-```
-
-Wall-clock seconds since the write started.
-
-***
-
-### outputBytes
-
-```ts
-outputBytes: number;
-```
-
-Number of bytes written so far.
-
-***
-
-### outputRows
-
-```ts
-outputRows: number;
-```
-
-Number of rows written so far.
-
-***
-
-### totalRows?
-
-```ts
-optional totalRows: number;
-```
-
-Total rows expected, when the input source reports it.
-
-Always set on the final callback (the one with `done: true`), falling
-back to the actual number of rows written when the source could not
-report a row count up front.
-
-***
-
-### totalTasks
-
-```ts
-totalTasks: number;
-```
-
-Total number of parallel write tasks (the write parallelism).

docs/src/python/python.md

@@ -166,12 +166,6 @@ lists the indices that LanceDb supports.
 
 ::: lancedb.index.IvfFlat
 
-::: lancedb.index.IvfSq
-
-::: lancedb.index.IvfRq
-
-::: lancedb.index.HnswFlat
-
 ::: lancedb.table.IndexStatistics
 
 ## Querying (Asynchronous)

java/lancedb-core/pom.xml

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

java/pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.lancedb</groupId>
     <artifactId>lancedb-parent</artifactId>
-    <version>0.30.1-beta.2</version>
+    <version>0.28.0-beta.11</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>8.0.0-beta.12</lance-core.version>
+        <lance-core.version>6.0.0</lance-core.version>
         <spotless.skip>false</spotless.skip>
         <spotless.version>2.30.0</spotless.version>
         <spotless.java.googlejavaformat.version>1.7</spotless.java.googlejavaformat.version>

nodejs/AGENTS.md

@@ -3,11 +3,11 @@ The core Rust library is in the `../rust/lancedb` directory, the rust binding
 code is in the `src/` directory and the typescript bindings are in
 the `lancedb/` directory.
 
-Whenever you change the Rust code, you will need to recompile: `pnpm build`.
+Whenever you change the Rust code, you will need to recompile: `npm run build`.
 
 Common commands:
-* Build: `pnpm build`
-* Lint: `pnpm lint`
-* Fix lints: `pnpm lint-fix`
-* Test: `pnpm test`
-* Run single test file: `pnpm test __test__/arrow.test.ts`
+* Build: `npm run build`
+* Lint: `npm run lint`
+* Fix lints: `npm run lint-fix`
+* Test: `npm test`
+* Run single test file: `npm test __test__/arrow.test.ts`

nodejs/CONTRIBUTING.md

@@ -12,22 +12,20 @@ Typescript.
 * `src/`: Rust bindings source code
 * `lancedb/`: Typescript package source code
 * `__test__/`: Unit tests
-* `examples/`: A pnpm package with the examples shown in the documentation
+* `examples/`: An npm package with the examples shown in the documentation
 
 ## Development environment
 
 To set up your development environment, you will need to install the following:
 
-1. Node.js 22 or later (required by pnpm 11)
-2. [pnpm](https://pnpm.io/installation) 11 or later (or run via `corepack enable`,
-   which uses the `packageManager` field in `package.json`)
-3. Rust's package manager, Cargo. Use [rustup](https://rustup.rs/) to install.
-4. [protoc](https://grpc.io/docs/protoc-installation/) (Protocol Buffers compiler)
+1. Node.js 14 or later
+2. Rust's package manager, Cargo. Use [rustup](https://rustup.rs/) to install.
+3. [protoc](https://grpc.io/docs/protoc-installation/) (Protocol Buffers compiler)
 
 Initial setup:
 
 ```shell
-pnpm install
+npm install
 ```
 
 ### Commit Hooks
@@ -41,38 +39,38 @@ pre-commit install
 
 ## Development
 
-Most common development commands can be run using the pnpm scripts.
+Most common development commands can be run using the npm scripts.
 
 Build the package
 
 ```shell
-pnpm install
-pnpm build
+npm install
+npm run build
 ```
 
 Lint:
 
 ```shell
-pnpm lint
+npm run lint
 ```
 
 Format and fix lints:
 
 ```shell
-pnpm lint-fix
+npm run lint-fix
 ```
 
 Run tests:
 
 ```shell
-pnpm test
+npm test
 ```
 
 To run a single test:
 
 ```shell
 # Single file: table.test.ts
-pnpm test -- table.test.ts
+npm test -- table.test.ts
 # Single test: 'merge insert' in table.test.ts
-pnpm test -- table.test.ts --testNamePattern=merge\ insert
+npm test -- table.test.ts --testNamePattern=merge\ insert
 ```

nodejs/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "lancedb-nodejs"
 edition.workspace = true
-version = "0.30.1-beta.2"
+version = "0.28.0-beta.11"
 publish = false
 license.workspace = true
 description.workspace = true
@@ -22,15 +22,10 @@ arrow-schema.workspace = true
 env_logger.workspace = true
 futures.workspace = true
 lancedb = { path = "../rust/lancedb", default-features = false }
-lance-namespace.workspace = true
 napi = { version = "3.8.3", default-features = false, features = [
     "napi9",
-    "async",
-    "chrono_date",
-    "serde-json",
+    "async"
 ] }
-chrono = { version = "0.4", default-features = false, features = ["clock"] }
-serde_json = "1"
 napi-derive = "3.5.2"
 # Prevent dynamic linking of lzma, which comes from datafusion
 lzma-sys = { version = "0.1", features = ["static"] }

nodejs/__test__/connection.test.ts

@@ -4,7 +4,7 @@
 import { readdirSync } from "fs";
 import { Field, Float64, Schema } from "apache-arrow";
 import * as tmp from "tmp";
-import { Connection, Table, connect, connectNamespace } from "../lancedb";
+import { Connection, Table, connect } from "../lancedb";
 import { LocalTable } from "../lancedb/table";
 
 describe("when connecting", () => {
@@ -47,14 +47,6 @@ describe("given a connection", () => {
     await db.close();
     expect(db.isOpen()).toBe(false);
     await expect(db.tableNames()).rejects.toThrow("Connection is closed");
-    await expect(db.renameTable("a", "b")).rejects.toThrow(
-      "Connection is closed",
-    );
-  });
-
-  it("should report renameTable as unsupported on an OSS connection", async () => {
-    await db.createTable("a", [{ id: 1 }]);
-    await expect(db.renameTable("a", "b")).rejects.toThrow(/not supported/);
   });
   it("should be able to create a table from an object arg `createTable(options)`, or args `createTable(name, data, options)`", async () => {
     let tbl = await db.createTable("test", [{ id: 1 }, { id: 2 }]);
@@ -171,22 +163,18 @@ describe("given a connection", () => {
 
     let manifestDir =
       tmpDir.name + "/test_manifest_paths_v2_empty.lance/_versions";
-    readdirSync(manifestDir)
-      .filter((f) => f.endsWith(".manifest"))
-      .forEach((file) => {
-        expect(file).toMatch(/^\d{20}\.manifest$/);
-      });
+    readdirSync(manifestDir).forEach((file) => {
+      expect(file).toMatch(/^\d{20}\.manifest$/);
+    });
 
     table = (await db.createTable("test_manifest_paths_v2", [{ id: 1 }], {
       enableV2ManifestPaths: true,
     })) as LocalTable;
     expect(await table.usesV2ManifestPaths()).toBe(true);
     manifestDir = tmpDir.name + "/test_manifest_paths_v2.lance/_versions";
-    readdirSync(manifestDir)
-      .filter((f) => f.endsWith(".manifest"))
-      .forEach((file) => {
-        expect(file).toMatch(/^\d{20}\.manifest$/);
-      });
+    readdirSync(manifestDir).forEach((file) => {
+      expect(file).toMatch(/^\d{20}\.manifest$/);
+    });
   });
 
   it("should be able to migrate tables to the V2 manifest paths", async () => {
@@ -203,20 +191,16 @@ describe("given a connection", () => {
 
     const manifestDir =
       tmpDir.name + "/test_manifest_path_migration.lance/_versions";
-    readdirSync(manifestDir)
-      .filter((f) => f.endsWith(".manifest"))
-      .forEach((file) => {
-        expect(file).toMatch(/^\d\.manifest$/);
-      });
+    readdirSync(manifestDir).forEach((file) => {
+      expect(file).toMatch(/^\d\.manifest$/);
+    });
 
     await table.migrateManifestPathsV2();
     expect(await table.usesV2ManifestPaths()).toBe(true);
 
-    readdirSync(manifestDir)
-      .filter((f) => f.endsWith(".manifest"))
-      .forEach((file) => {
-        expect(file).toMatch(/^\d{20}\.manifest$/);
-      });
+    readdirSync(manifestDir).forEach((file) => {
+      expect(file).toMatch(/^\d{20}\.manifest$/);
+    });
   });
 });
 
@@ -322,186 +306,3 @@ describe("clone table functionality", () => {
     ).rejects.toThrow("Deep clone is not yet implemented");
   });
 });
-
-describe("namespaces", () => {
-  let tmpDir: tmp.DirResult;
-  let db: Connection;
-
-  beforeEach(async () => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-    // The local DirectoryNamespace backend only supports child namespaces
-    // when manifest mode is enabled (see lance-namespace-impls/src/dir.rs).
-    db = await connect(tmpDir.name, {
-      // biome-ignore lint/style/useNamingConvention: opaque backend property key, must match Rust
-      namespaceClientProperties: { manifest_enabled: "true" },
-    });
-  });
-  afterEach(() => tmpDir.removeCallback());
-
-  it("should create and describe a namespace", async () => {
-    await db.createNamespace(["myns"]);
-    const desc = await db.describeNamespace(["myns"]);
-    expect(desc).toBeDefined();
-  });
-
-  it("should list namespaces created at the root", async () => {
-    await db.createNamespace(["alpha"]);
-    await db.createNamespace(["beta"]);
-    const list = await db.listNamespaces();
-    expect(list.namespaces).toEqual(expect.arrayContaining(["alpha", "beta"]));
-  });
-
-  it("should list child namespaces under a parent", async () => {
-    await db.createNamespace(["parent"]);
-    await db.createNamespace(["parent", "child"]);
-    const list = await db.listNamespaces(["parent"]);
-    expect(list.namespaces).toContain("child");
-  });
-
-  it("should drop a namespace", async () => {
-    await db.createNamespace(["ephemeral"]);
-    await db.dropNamespace(["ephemeral"]);
-    const list = await db.listNamespaces();
-    expect(list.namespaces).not.toContain("ephemeral");
-  });
-
-  it("should raise an error on any namespace op after close", async () => {
-    await db.close();
-    await expect(db.describeNamespace(["foo"])).rejects.toThrow(
-      "Connection is closed",
-    );
-    await expect(db.listNamespaces()).rejects.toThrow("Connection is closed");
-    await expect(db.createNamespace(["foo"])).rejects.toThrow(
-      "Connection is closed",
-    );
-    await expect(db.dropNamespace(["foo"])).rejects.toThrow(
-      "Connection is closed",
-    );
-  });
-
-  it("should raise an understandable error when describing a non-existent namespace", async () => {
-    await expect(db.describeNamespace(["does-not-exist"])).rejects.toThrow(
-      /not found/i,
-    );
-  });
-
-  it("should raise an error when creating a namespace that already exists", async () => {
-    await db.createNamespace(["dup"]);
-    await expect(db.createNamespace(["dup"])).rejects.toThrow();
-  });
-
-  it("should reject an unrecognized createNamespace mode with a clear error", async () => {
-    await expect(
-      // biome-ignore lint/suspicious/noExplicitAny: deliberately bypass TS to test runtime validation
-      db.createNamespace(["x"], { mode: "frobnicate" as any }),
-    ).rejects.toThrow(/Invalid mode 'frobnicate'/);
-  });
-
-  it("should reject an unrecognized dropNamespace mode with a clear error", async () => {
-    await db.createNamespace(["x"]);
-    await expect(
-      // biome-ignore lint/suspicious/noExplicitAny: deliberately bypass TS to test runtime validation
-      db.dropNamespace(["x"], { mode: "frobnicate" as any }),
-    ).rejects.toThrow(/Invalid mode 'frobnicate'/);
-  });
-
-  it("should reject an unrecognized dropNamespace behavior with a clear error", async () => {
-    await db.createNamespace(["x"]);
-    await expect(
-      // biome-ignore lint/suspicious/noExplicitAny: deliberately bypass TS to test runtime validation
-      db.dropNamespace(["x"], { behavior: "frobnicate" as any }),
-    ).rejects.toThrow(/Invalid behavior 'frobnicate'/);
-  });
-});
-
-describe("connectNamespace", () => {
-  let tmpDir: tmp.DirResult;
-  beforeEach(() => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-  });
-  afterEach(() => tmpDir.removeCallback());
-
-  it("connects via the dir implementation and supports table ops", async () => {
-    const db = await connectNamespace("dir", { root: tmpDir.name });
-    await db.createTable("users", [{ id: 1 }, { id: 2 }]);
-    await expect(db.tableNames()).resolves.toContain("users");
-  });
-
-  it("throws a clear error when implName is empty", async () => {
-    await expect(connectNamespace("", {})).rejects.toThrow(
-      "implName must be a non-empty string",
-    );
-  });
-
-  it("throws when the namespace implementation is unknown", async () => {
-    await expect(connectNamespace("not-a-real-impl", {})).rejects.toThrow();
-  });
-
-  it("passes storage options through to the namespace", async () => {
-    const db = await connectNamespace(
-      "dir",
-      { root: tmpDir.name },
-      { storageOptions: { newTableDataStorageVersion: "stable" } },
-    );
-    await db.createTable("plumbing", [{ id: 1 }]);
-    await expect(db.tableNames()).resolves.toContain("plumbing");
-  });
-
-  it("supports child namespaces when manifestEnabled is true on the dir config", async () => {
-    const writer = await connectNamespace("dir", {
-      root: tmpDir.name,
-      manifestEnabled: true,
-    });
-    await writer.createNamespace(["analytics"]);
-    await writer.createTable("orders", [{ id: 1 }, { id: 2 }], ["analytics"]);
-    await writer.close();
-
-    const reader = await connectNamespace("dir", {
-      root: tmpDir.name,
-      manifestEnabled: true,
-    });
-    await expect(reader.tableNames(["analytics"])).resolves.toContain("orders");
-    const orders = await reader.openTable("orders", ["analytics"]);
-    await expect(orders.countRows()).resolves.toBe(2);
-  });
-
-  it("merges extraProperties into the dir config and is overridden by typed fields", async () => {
-    // Two observable assertions:
-    // - Typed `root` overrides extraProperties.root: createTable would fail
-    //   under the bogus path if the override didn't happen.
-    // - extraProperties.manifest_enabled="false" is honored end-to-end. Child
-    //   namespaces require manifest mode (default true), so explicitly
-    //   disabling it via extraProperties must make createNamespace reject. If
-    //   extraProperties pass-through were silently broken, the default would
-    //   let createNamespace succeed.
-    const db = await connectNamespace("dir", {
-      root: tmpDir.name,
-      extraProperties: {
-        root: "/should/be/overridden",
-        // biome-ignore lint/style/useNamingConvention: backend property key
-        manifest_enabled: "false",
-      },
-    });
-    await db.createTable("base", [{ id: 1 }]);
-    await expect(db.tableNames()).resolves.toContain("base");
-    await expect(db.createNamespace(["analytics"])).rejects.toThrow();
-  });
-
-  it("flows unknown top-level keys through when implName is dynamic (no silent drop)", async () => {
-    // Routes via the third overload because `impl` is `string`, not the
-    // literal `"dir"`. The dispatcher still notices the runtime value is
-    // "dir", but unknown keys like `manifest_enabled` must not be silently
-    // dropped during the conversion.
-    //
-    // Asserting a *negative* outcome (manifest disabled -> createNamespace
-    // rejects) is required for observability, since the backend default for
-    // `manifest_enabled` is true.
-    const impl: string = "dir";
-    const db = await connectNamespace(impl, {
-      root: tmpDir.name,
-      // biome-ignore lint/style/useNamingConvention: backend property key
-      manifest_enabled: "false",
-    });
-    await expect(db.createNamespace(["mixed"])).rejects.toThrow();
-  });
-});

nodejs/__test__/query.test.ts

@@ -109,209 +109,3 @@ describe("Query outputSchema", () => {
     expect(schema.fields.length).toBe(3);
   });
 });
-
-describe("Query orderBy", () => {
-  let tmpDir: tmp.DirResult;
-  let table: Table;
-
-  beforeEach(async () => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-    const db = await connect(tmpDir.name);
-
-    // Create table with numeric data for sorting
-    const schema = new Schema([
-      new Field("id", new Int64(), true),
-      new Field("score", new Float32(), true),
-      new Field("name", new Utf8(), true),
-    ]);
-
-    const data = makeArrowTable(
-      [
-        { id: 1n, score: 3.5, name: "charlie" },
-        { id: 2n, score: 1.2, name: "alice" },
-        { id: 3n, score: 2.8, name: "bob" },
-        { id: 4n, score: 0.5, name: "david" },
-        { id: 5n, score: 4.1, name: "eve" },
-      ],
-      { schema },
-    );
-    table = await db.createTable("test", data);
-  });
-
-  afterEach(() => {
-    tmpDir.removeCallback();
-  });
-
-  it("should sort by single column ascending", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "score", ascending: true, nullsFirst: false })
-      .toArray();
-
-    expect(results.length).toBe(5);
-    // Verify ascending order
-    expect(results[0].score).toBeCloseTo(0.5, 0.001);
-    expect(results[1].score).toBeCloseTo(1.2, 0.001);
-    expect(results[2].score).toBeCloseTo(2.8, 0.001);
-    expect(results[3].score).toBeCloseTo(3.5, 0.001);
-    expect(results[4].score).toBeCloseTo(4.1, 0.001);
-  });
-
-  it("should sort by single column descending", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "score", ascending: false, nullsFirst: false })
-      .toArray();
-
-    expect(results.length).toBe(5);
-    // Verify descending order
-    expect(results[0].score).toBeCloseTo(4.1, 0.001);
-    expect(results[1].score).toBeCloseTo(3.5, 0.001);
-    expect(results[2].score).toBeCloseTo(2.8, 0.001);
-    expect(results[3].score).toBeCloseTo(1.2, 0.001);
-    expect(results[4].score).toBeCloseTo(0.5, 0.001);
-  });
-
-  it("should use ascending as default direction", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "score" })
-      .toArray();
-
-    expect(results.length).toBe(5);
-    // Verify ascending order (default)
-    expect(results[0].score).toBeCloseTo(0.5, 0.001);
-    expect(results[1].score).toBeCloseTo(1.2, 0.001);
-    expect(results[2].score).toBeCloseTo(2.8, 0.001);
-    expect(results[3].score).toBeCloseTo(3.5, 0.001);
-    expect(results[4].score).toBeCloseTo(4.1, 0.001);
-  });
-
-  it("should sort by string column", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "name" })
-      .toArray();
-
-    expect(results.length).toBe(5);
-    // Verify alphabetical order
-    expect(results[0].name).toBe("alice");
-    expect(results[1].name).toBe("bob");
-    expect(results[2].name).toBe("charlie");
-    expect(results[3].name).toBe("david");
-    expect(results[4].name).toBe("eve");
-  });
-
-  it("should support method chaining with where", async () => {
-    const results = await table
-      .query()
-      .where("score > 2.0")
-      .orderBy({ columnName: "score" })
-      .toArray();
-    expect(results.length).toBe(3);
-    // Verify filtered and sorted
-    expect(results[0].score).toBeCloseTo(2.8, 0.001);
-    expect(results[1].score).toBeCloseTo(3.5, 0.001);
-    expect(results[2].score).toBeCloseTo(4.1, 0.001);
-  });
-
-  it("should support method chaining with limit", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "score", ascending: false })
-      .limit(3)
-      .toArray();
-
-    expect(results.length).toBe(3);
-    // Verify top 3 in descending order
-    expect(results[0].score).toBeCloseTo(4.1, 0.001);
-    expect(results[1].score).toBeCloseTo(3.5, 0.001);
-    expect(results[2].score).toBeCloseTo(2.8, 0.001);
-  });
-
-  it("should support method chaining with offset", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "score" })
-      .offset(2)
-      .limit(2)
-      .toArray();
-
-    expect(results.length).toBe(2);
-    // Verify results skip first 2 and take next 2
-    expect(results[0].score).toBeCloseTo(2.8, 0.001);
-    expect(results[1].score).toBeCloseTo(3.5, 0.001);
-  });
-
-  it("should support method chaining with select", async () => {
-    const results = await table
-      .query()
-      .orderBy({ columnName: "name" })
-      .select(["name", "score"])
-      .toArray();
-
-    expect(results.length).toBe(5);
-    // Verify only selected columns are present
-    expect(Object.keys(results[0])).toEqual(["name", "score"]);
-    expect(Object.keys(results[4])).toEqual(["name", "score"]);
-    // Verify sorted by name
-    expect(results[0].name).toBe("alice");
-    expect(results[4].name).toBe("eve");
-  });
-
-  it("should support complex method chaining", async () => {
-    const results = await table
-      .query()
-      .where("score > 1.0")
-      .orderBy({ columnName: "score", ascending: false })
-      .limit(3)
-      .select(["id", "score", "name"])
-      .toArray();
-
-    expect(results.length).toBe(3);
-    // Verify filtered, sorted, limited, and projected
-    expect(results[0].score).toBeCloseTo(4.1, 0.001);
-    expect(results[1].score).toBeCloseTo(3.5, 0.001);
-    expect(results[2].score).toBeCloseTo(2.8, 0.001);
-    expect(Object.keys(results[0])).toEqual(["id", "score", "name"]);
-  });
-
-  it("should support multi-column ordering and null placement", async () => {
-    const schema = new Schema([
-      new Field("group", new Int64(), true),
-      new Field("score", new Float32(), true),
-      new Field("name", new Utf8(), true),
-    ]);
-
-    const data = makeArrowTable(
-      [
-        { group: 1n, score: null, name: "z" },
-        { group: 1n, score: 1.0, name: "b" },
-        { group: 1n, score: 1.0, name: "a" },
-        { group: 2n, score: 0.5, name: "c" },
-      ],
-      { schema },
-    );
-    const nullTable = await (await connect(tmpDir.name)).createTable(
-      "test_multi_order",
-      data,
-      { mode: "overwrite" },
-    );
-
-    const results = await nullTable
-      .query()
-      .orderBy([
-        { columnName: "group", ascending: true, nullsFirst: false },
-        { columnName: "score", ascending: true, nullsFirst: true },
-        { columnName: "name", ascending: true, nullsFirst: false },
-      ])
-      .toArray();
-
-    expect(results.map((r) => [r.group, r.score, r.name])).toEqual([
-      [1n, null, "z"],
-      [1n, 1.0, "a"],
-      [1n, 1.0, "b"],
-      [2n, 0.5, "c"],
-    ]);
-  });
-});

nodejs/__test__/remote.test.ts

@@ -191,34 +191,6 @@ describe("remote connection", () => {
     );
   });
 
-  it("allows version on remote but rejects a non-main branch", async () => {
-    await withMockDatabase(
-      (_req, res) => {
-        // describe (table open + version validation) always succeeds
-        const body = JSON.stringify({
-          name: "t",
-          version: 2,
-          schema: { fields: [] },
-        });
-        res.writeHead(200, { "Content-Type": "application/json" }).end(body);
-      },
-      async (db) => {
-        // version-only (and "main" + version) is allowed: remote supports
-        // version time-travel even though it has no branches
-        await db.openTable("t", undefined, { version: 2 });
-        await db.openTable("t", undefined, { branch: "main", version: 2 });
-
-        // a non-main branch is rejected, with or without a version
-        await expect(
-          db.openTable("t", undefined, { branch: "exp" }),
-        ).rejects.toThrow(/branching/);
-        await expect(
-          db.openTable("t", undefined, { branch: "exp", version: 2 }),
-        ).rejects.toThrow(/branching/);
-      },
-    );
-  });
-
   describe("TlsConfig", () => {
     it("should create TlsConfig with all fields", () => {
       const tlsConfig: TlsConfig = {
@@ -645,68 +617,4 @@ describe("remote connection", () => {
       );
     });
   });
-
-  describe("renameTable", () => {
-    async function captureRenameRequest(
-      call: (db: Connection) => Promise<void>,
-    ): Promise<{ url: string; body: Record<string, unknown> }> {
-      let captured: { url: string; body: Record<string, unknown> } | undefined;
-      await withMockDatabase((req, res) => {
-        let raw = "";
-        req.on("data", (chunk) => {
-          raw += chunk;
-        });
-        req.on("end", () => {
-          captured = {
-            url: req.url ?? "",
-            body: raw ? JSON.parse(raw) : {},
-          };
-          res.writeHead(200, { "Content-Type": "application/json" }).end("");
-        });
-      }, call);
-      if (!captured) {
-        throw new Error("mock server never saw a request");
-      }
-      return captured;
-    }
-
-    it("sends rename request for a table in the root namespace", async () => {
-      const { url, body } = await captureRenameRequest(async (db) => {
-        await db.renameTable("table1", "table2");
-      });
-      expect(url).toBe("/v1/table/table1/rename/");
-      // biome-ignore lint/style/useNamingConvention: snake_case mandated by the server wire format
-      expect(body).toEqual({ new_table_name: "table2" });
-    });
-
-    it("omits new_namespace when only the current namespace is supplied", async () => {
-      // Safe-default check: passing namespacePath alone must not send
-      // `new_namespace`, so the server keeps the table in its current
-      // namespace instead of silently moving it to root.
-      const { url, body } = await captureRenameRequest(async (db) => {
-        await db.renameTable("table1", "table2", {
-          namespacePath: ["ns1"],
-        });
-      });
-      expect(url).toBe("/v1/table/ns1$table1/rename/");
-      // biome-ignore lint/style/useNamingConvention: snake_case mandated by the server wire format
-      expect(body).toEqual({ new_table_name: "table2" });
-    });
-
-    it("includes new_namespace in the body for a cross-namespace rename", async () => {
-      const { url, body } = await captureRenameRequest(async (db) => {
-        await db.renameTable("table1", "table2", {
-          namespacePath: ["ns1"],
-          newNamespacePath: ["ns2"],
-        });
-      });
-      expect(url).toBe("/v1/table/ns1$table1/rename/");
-      expect(body).toEqual({
-        // biome-ignore lint/style/useNamingConvention: snake_case mandated by the server wire format
-        new_table_name: "table2",
-        // biome-ignore lint/style/useNamingConvention: snake_case mandated by the server wire format
-        new_namespace: ["ns2"],
-      });
-    });
-  });
 });

nodejs/__test__/scannable.test.ts

@@ -1,438 +0,0 @@
-// SPDX-License-Identifier: Apache-2.0
-// SPDX-FileCopyrightText: Copyright The LanceDB Authors
-
-import {
-  Field,
-  Float16,
-  Int32,
-  type RecordBatch,
-  RecordBatchReader,
-  Schema,
-  tableToIPC,
-} from "apache-arrow";
-import { makeArrowTable, makeEmptyTable } from "../lancedb/arrow";
-import { Scannable } from "../lancedb/scannable";
-
-function makeTable() {
-  return makeArrowTable(
-    [
-      { id: 1, name: "a" },
-      { id: 2, name: "b" },
-      { id: 3, name: "c" },
-    ],
-    { vectorColumns: {} },
-  );
-}
-
-async function makeReader(): Promise<RecordBatchReader> {
-  // `RecordBatchReader.from()` returns an unopened reader; `.schema` is only
-  // populated after `.open()`. Opening sync readers is synchronous.
-  const reader = RecordBatchReader.from(tableToIPC(makeTable()));
-  return reader.open() as RecordBatchReader;
-}
-
-describe("Scannable", () => {
-  describe("fromTable", () => {
-    test("reflects schema, numRows, and defaults rescannable=true", async () => {
-      const table = makeTable();
-      const scannable = await Scannable.fromTable(table);
-
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.numRows).toBe(table.numRows);
-      expect(scannable.rescannable).toBe(true);
-    });
-
-    test("throws when opts.numRows does not match table.numRows", async () => {
-      await expect(
-        Scannable.fromTable(makeTable(), { numRows: 42 }),
-      ).rejects.toThrow(/does not match table\.numRows/);
-    });
-
-    test("throws when opts.rescannable is false", async () => {
-      await expect(
-        Scannable.fromTable(makeTable(), { rescannable: false }),
-      ).rejects.toThrow(/always rescannable/);
-    });
-  });
-
-  describe("fromRecordBatchReader", () => {
-    test("reflects schema and defaults numRows=null, rescannable=false", async () => {
-      const reader = await makeReader();
-      const scannable = await Scannable.fromRecordBatchReader(reader);
-
-      expect(scannable.schema).toBe(reader.schema);
-      expect(scannable.numRows).toBeNull();
-      expect(scannable.rescannable).toBe(false);
-    });
-
-    test("honors numRows override", async () => {
-      const scannable = await Scannable.fromRecordBatchReader(
-        await makeReader(),
-        { numRows: 3 },
-      );
-
-      expect(scannable.numRows).toBe(3);
-      expect(scannable.rescannable).toBe(false);
-    });
-
-    test("rescannable: false explicit does not throw", async () => {
-      const reader = await makeReader();
-      const scannable = await Scannable.fromRecordBatchReader(reader, {
-        rescannable: false,
-      });
-      expect(scannable.rescannable).toBe(false);
-    });
-
-    test("throws when opts.rescannable is true", async () => {
-      const reader = await makeReader();
-      await expect(
-        Scannable.fromRecordBatchReader(reader, { rescannable: true }),
-      ).rejects.toThrow(/does not accept rescannable/);
-    });
-
-    test("throws when opts.rescannable is true even alongside numRows", async () => {
-      const reader = await makeReader();
-      await expect(
-        Scannable.fromRecordBatchReader(reader, {
-          numRows: 3,
-          rescannable: true,
-        }),
-      ).rejects.toThrow(/does not accept rescannable/);
-    });
-  });
-
-  describe("fromIterable", () => {
-    test("accepts a sync iterable of batches", async () => {
-      const table = makeTable();
-      const scannable = await Scannable.fromIterable(
-        table.schema,
-        table.batches,
-      );
-
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.numRows).toBeNull();
-      expect(scannable.rescannable).toBe(false);
-    });
-
-    test("accepts an async iterable of batches", async () => {
-      const table = makeTable();
-      async function* generator(): AsyncGenerator<RecordBatch> {
-        for (const batch of table.batches) {
-          yield batch;
-        }
-      }
-
-      const scannable = await Scannable.fromIterable(table.schema, generator());
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.rescannable).toBe(false);
-    });
-
-    describe("rescannable: true detection", () => {
-      // Replayable inputs: [Symbol.iterator]() / [Symbol.asyncIterator]()
-      // returns a fresh iterator each call. Must NOT throw.
-
-      test("Array passes (fresh ArrayIterator each call)", async () => {
-        const table = makeTable();
-        const scannable = await Scannable.fromIterable(
-          table.schema,
-          table.batches,
-          { rescannable: true },
-        );
-        expect(scannable.rescannable).toBe(true);
-      });
-
-      test("Set passes (fresh SetIterator each call)", async () => {
-        const table = makeTable();
-        const set = new Set<RecordBatch>(table.batches);
-        const scannable = await Scannable.fromIterable(table.schema, set, {
-          rescannable: true,
-        });
-        expect(scannable.rescannable).toBe(true);
-      });
-
-      test("custom Iterable returning a fresh iterator passes", async () => {
-        const table = makeTable();
-        const replayable: Iterable<RecordBatch> = {
-          [Symbol.iterator]() {
-            return table.batches[Symbol.iterator]();
-          },
-        };
-        const scannable = await Scannable.fromIterable(
-          table.schema,
-          replayable,
-          { rescannable: true },
-        );
-        expect(scannable.rescannable).toBe(true);
-      });
-
-      test("object with generator method passes (fresh generator each call)", async () => {
-        const table = makeTable();
-        const replayable: Iterable<RecordBatch> = {
-          *[Symbol.iterator]() {
-            for (const batch of table.batches) yield batch;
-          },
-        };
-        const scannable = await Scannable.fromIterable(
-          table.schema,
-          replayable,
-          { rescannable: true },
-        );
-        expect(scannable.rescannable).toBe(true);
-      });
-
-      test("empty Array passes (replayable degenerate case)", async () => {
-        const schema = makeTable().schema;
-        const scannable = await Scannable.fromIterable(
-          schema,
-          [] as RecordBatch[],
-          { rescannable: true },
-        );
-        expect(scannable.rescannable).toBe(true);
-      });
-
-      // One-shot inputs: [Symbol.iterator]() / [Symbol.asyncIterator]()
-      // returns the same object, or the input is already-an-iterator.
-      // Must throw with a /one-shot/ message.
-
-      test("sync generator throws", async () => {
-        const table = makeTable();
-        function* generator(): Generator<RecordBatch> {
-          for (const batch of table.batches) yield batch;
-        }
-        await expect(
-          Scannable.fromIterable(table.schema, generator(), {
-            rescannable: true,
-          }),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      test("async generator throws", async () => {
-        const table = makeTable();
-        async function* generator(): AsyncGenerator<RecordBatch> {
-          for (const batch of table.batches) yield batch;
-        }
-        await expect(
-          Scannable.fromIterable(table.schema, generator(), {
-            rescannable: true,
-          }),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      test("empty generator throws (one-shot degenerate case)", async () => {
-        const schema = makeTable().schema;
-        function* generator(): Generator<RecordBatch> {
-          // intentionally empty; yields nothing.
-        }
-        await expect(
-          Scannable.fromIterable(schema, generator(), { rescannable: true }),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      test("custom self-iterator throws", async () => {
-        const table = makeTable();
-        const batches = table.batches;
-        let i = 0;
-        const oneShot: Iterable<RecordBatch> & Iterator<RecordBatch> = {
-          [Symbol.iterator]() {
-            return this;
-          },
-          next() {
-            if (i >= batches.length) {
-              return { done: true, value: undefined };
-            }
-            return { done: false, value: batches[i++] };
-          },
-        };
-        await expect(
-          Scannable.fromIterable(table.schema, oneShot, { rescannable: true }),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      test("Array.values() (IterableIterator) throws", async () => {
-        const table = makeTable();
-        const iter = table.batches.values();
-        await expect(
-          Scannable.fromIterable(table.schema, iter, { rescannable: true }),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      test("raw iterator (only `.next`) throws", async () => {
-        const table = makeTable();
-        const batches = table.batches;
-        let i = 0;
-        const rawIter = {
-          next(): IteratorResult<RecordBatch> {
-            if (i >= batches.length) {
-              return { done: true, value: undefined };
-            }
-            return { done: false, value: batches[i++] };
-          },
-        };
-        await expect(
-          Scannable.fromIterable(
-            table.schema,
-            rawIter as unknown as Iterable<RecordBatch>,
-            { rescannable: true },
-          ),
-        ).rejects.toThrow(/one-shot/);
-      });
-
-      // Edge: null/undefined must not crash the detection helper. The
-      // null check belongs to `normalizeIterator` and only fires when a
-      // scan starts.
-
-      test("null input does not crash detection at construction", async () => {
-        const schema = makeTable().schema;
-        await expect(
-          Scannable.fromIterable(
-            schema,
-            null as unknown as Iterable<RecordBatch>,
-            {
-              rescannable: true,
-            },
-          ),
-        ).resolves.toBeDefined();
-      });
-
-      test("undefined input does not crash detection at construction", async () => {
-        const schema = makeTable().schema;
-        await expect(
-          Scannable.fromIterable(
-            schema,
-            undefined as unknown as Iterable<RecordBatch>,
-            { rescannable: true },
-          ),
-        ).resolves.toBeDefined();
-      });
-
-      // Default (rescannable omitted) skips the check entirely, so even
-      // pathological inputs construct without throwing here.
-
-      test("rescannable omitted skips detection entirely (generator passes)", async () => {
-        const table = makeTable();
-        function* generator(): Generator<RecordBatch> {
-          for (const batch of table.batches) yield batch;
-        }
-        const scannable = await Scannable.fromIterable(
-          table.schema,
-          generator(),
-        );
-        expect(scannable.rescannable).toBe(false);
-      });
-
-      test("rescannable: false explicit skips detection entirely (generator passes)", async () => {
-        const table = makeTable();
-        function* generator(): Generator<RecordBatch> {
-          for (const batch of table.batches) yield batch;
-        }
-        const scannable = await Scannable.fromIterable(
-          table.schema,
-          generator(),
-          { rescannable: false },
-        );
-        expect(scannable.rescannable).toBe(false);
-      });
-    });
-  });
-
-  describe("fromFactory", () => {
-    test("defaults rescannable=true and does not invoke the factory eagerly", async () => {
-      const table = makeTable();
-      const factory = jest.fn(() => table.batches);
-
-      const scannable = await Scannable.fromFactory(table.schema, factory);
-
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.rescannable).toBe(true);
-      expect(factory).not.toHaveBeenCalled();
-    });
-
-    test("honors rescannable and numRows overrides", async () => {
-      const table = makeTable();
-      const scannable = await Scannable.fromFactory(
-        table.schema,
-        () => table.batches,
-        { numRows: 7, rescannable: false },
-      );
-
-      expect(scannable.numRows).toBe(7);
-      expect(scannable.rescannable).toBe(false);
-    });
-  });
-
-  describe("validation", () => {
-    test("throws when numRows is negative", async () => {
-      await expect(
-        Scannable.fromFactory(makeTable().schema, () => [], { numRows: -1 }),
-      ).rejects.toThrow(/non-negative/);
-    });
-
-    test("throws when numRows is not an integer", async () => {
-      await expect(
-        Scannable.fromFactory(makeTable().schema, () => [], { numRows: 3.5 }),
-      ).rejects.toThrow(/integer/);
-    });
-  });
-
-  describe("native handle", () => {
-    test("exposes a native handle via inner", async () => {
-      const scannable = await Scannable.fromTable(makeTable());
-      expect(scannable.inner).toBeDefined();
-      expect(typeof scannable.inner).toBe("object");
-      expect(scannable.inner).not.toBeNull();
-    });
-  });
-
-  // Schema-variety construction tests. Each asserts that construction
-  // succeeds against a richer Arrow schema, which transitively exercises
-  // schema serialization and the Rust-side `ipc_file_to_schema` for types
-  // beyond flat primitives.
-  describe("schema variety", () => {
-    test("accepts an empty table", async () => {
-      const schema = new Schema([new Field("id", new Int32(), true)]);
-      const table = makeEmptyTable(schema);
-      const scannable = await Scannable.fromTable(table);
-
-      expect(scannable.numRows).toBe(0);
-      expect(scannable.schema).toBe(table.schema);
-    });
-
-    test("accepts nested struct and list columns", async () => {
-      const table = makeArrowTable(
-        [
-          { id: 1, point: { x: 0, y: 0 }, tags: ["a", "b"] },
-          { id: 2, point: { x: 1, y: 2 }, tags: ["c"] },
-        ],
-        { vectorColumns: {} },
-      );
-      const scannable = await Scannable.fromTable(table);
-
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.numRows).toBe(2);
-    });
-
-    test("accepts a FixedSizeList (vector) column", async () => {
-      const table = makeArrowTable(
-        [
-          { id: 1, vec: [1, 2, 3] },
-          { id: 2, vec: [4, 5, 6] },
-        ],
-        { vectorColumns: { vec: { type: new Float16() } } },
-      );
-      const scannable = await Scannable.fromTable(table);
-
-      expect(scannable.schema).toBe(table.schema);
-      expect(scannable.numRows).toBe(2);
-    });
-
-    test("accepts a table with many columns", async () => {
-      const row: Record<string, number> = {};
-      for (let i = 0; i < 50; i++) row[`c${i}`] = i;
-      const table = makeArrowTable([row, row], { vectorColumns: {} });
-      const scannable = await Scannable.fromTable(table);
-
-      expect(scannable.schema.fields.length).toBe(50);
-      expect(scannable.numRows).toBe(2);
-    });
-  });
-});

nodejs/__test__/table.test.ts

@@ -28,7 +28,6 @@ import {
   List,
   Schema,
   SchemaLike,
-  Struct,
   Type,
   Uint8,
   Utf8,
@@ -85,136 +84,6 @@ describe.each([arrow15, arrow16, arrow17, arrow18])(
       await expect(table.countRows()).resolves.toBe(3);
     });
 
-    it("should support branches", async () => {
-      await table.add([{ id: 1 }]);
-      expect(await table.countRows()).toBe(1);
-
-      // fork an isolated, writable branch from main
-      const branch = await (await table.branches()).create("exp");
-      expect(await branch.countRows()).toBe(1);
-      await branch.add([{ id: 2 }]);
-      expect(await branch.countRows()).toBe(2);
-      // main is untouched by branch writes
-      expect(await table.countRows()).toBe(1);
-
-      // listed, with main (null) as the parent
-      const list = await (await table.branches()).list();
-      expect(Object.keys(list)).toContain("exp");
-      expect(list["exp"].parentBranch).toBeNull();
-
-      // fromRef="main" is equivalent to the default
-      await (await table.branches()).create("exp2", "main");
-      const list2 = await (await table.branches()).list();
-      expect(list2["exp2"].parentBranch).toBeNull();
-
-      // checkout returns a handle scoped to the branch's latest
-      const checkedOut = await (await table.branches()).checkout("exp");
-      expect(await checkedOut.countRows()).toBe(2);
-
-      // delete removes it
-      await (await table.branches()).delete("exp");
-      await (await table.branches()).delete("exp2");
-      const after = await (await table.branches()).list();
-      expect(Object.keys(after)).not.toContain("exp");
-    });
-
-    it("should open a branch via open_table", async () => {
-      const db = await connect(tmpDir.name);
-      await table.add([{ id: 1 }]);
-      const branch = await (await table.branches()).create("exp");
-      await branch.add([{ id: 2 }]);
-
-      // open_table(..., { branch }) returns a handle scoped to the branch
-      const opened = await db.openTable("some_table", undefined, {
-        branch: "exp",
-      });
-      expect(await opened.countRows()).toBe(2);
-      // opening without branch still tracks main
-      expect(await (await db.openTable("some_table")).countRows()).toBe(1);
-    });
-
-    it("should open a branch at a version isolated from main and HEAD", async () => {
-      const db = await connect(tmpDir.name);
-      // main: a single fork-point row
-      const t = await db.createTable("bv_table", [{ id: 0 }]);
-      const mainV1 = await t.version();
-
-      // fork "exp", then advance exp AND main independently past the fork so
-      // they diverge while sharing version numbers
-      const exp = await (await t.branches()).create("exp");
-      await exp.add([{ id: 1 }]); // exp: {0, 1}
-      const expV2 = await exp.version();
-      await exp.add([{ id: 2 }]); // exp HEAD: {0, 1, 2}
-      await t.add([{ id: 100 }, { id: 101 }, { id: 102 }]); // main HEAD: {0,100,101,102}
-      expect(await t.version()).toBe(expV2);
-
-      // open exp at the shared version: the data must be exp's, not main's.
-      // count alone cannot prove this (main@v2 also exists), so assert
-      // provenance by content.
-      const pinned = await db.openTable("bv_table", undefined, {
-        branch: "exp",
-        version: expV2,
-      });
-      expect(await pinned.countRows()).toBe(2); // not exp HEAD (3), not main@v2 (4)
-      expect(await pinned.countRows("id = 1")).toBe(1); // exp's post-fork row
-      expect(await pinned.countRows("id = 100")).toBe(0); // main's rows invisible
-
-      // the same coordinate is reachable directly via branches().checkout(name, version)
-      const pinnedDirect = await (await t.branches()).checkout("exp", expV2);
-      expect(await pinnedDirect.countRows()).toBe(2);
-
-      // the HEADs are unaffected
-      expect(
-        await (
-          await db.openTable("bv_table", undefined, { branch: "exp" })
-        ).countRows(),
-      ).toBe(3);
-      expect(await (await db.openTable("bv_table")).countRows()).toBe(4);
-
-      // version-only (no branch) time-travels main itself: its fork-point
-      // version holds only main's first row, and the shared version number
-      // resolves to main's data, not the branch's ("opens main at the version")
-      const oldMain = await db.openTable("bv_table", undefined, {
-        version: mainV1,
-      });
-      expect(await oldMain.countRows()).toBe(1);
-      const sharedOnMain = await db.openTable("bv_table", undefined, {
-        version: expV2,
-      });
-      expect(await sharedOnMain.countRows()).toBe(4); // main@v2, not exp@v2 (2)
-
-      // detached head: writing to a pinned version is rejected
-      await expect(pinned.add([{ id: 9 }])).rejects.toThrow(
-        /cannot be modified/,
-      );
-
-      // a nonexistent version is rejected -- on main, and on a branch (a
-      // distinct resolution path, on the branch's manifests)
-      await expect(
-        db.openTable("bv_table", undefined, { version: 9999 }),
-      ).rejects.toThrow();
-      await expect(
-        db.openTable("bv_table", undefined, { branch: "exp", version: 9999 }),
-      ).rejects.toThrow();
-
-      // checkoutLatest re-attaches the pinned handle to the BRANCH's HEAD
-      // (writable again), not main's HEAD (4), and not staying pinned (2)
-      await pinned.checkoutLatest();
-      expect(await pinned.countRows()).toBe(3); // exp HEAD
-      await pinned.add([{ id: 3 }]);
-      expect(await pinned.countRows()).toBe(4); // writable again
-    });
-
-    it("rejects invalid branch inputs", async () => {
-      const branches = await table.branches();
-      await expect(branches.create("")).rejects.toThrow("non-empty");
-      await expect(branches.checkout("")).rejects.toThrow("non-empty");
-      await expect(branches.delete("")).rejects.toThrow("non-empty");
-      await expect(branches.create("bad", "main", -1)).rejects.toThrow(
-        "non-negative",
-      );
-    });
-
     it("should show table stats", async () => {
       await table.add([{ id: 1 }, { id: 2 }]);
       await table.add([{ id: 1 }]);
@@ -246,48 +115,6 @@ describe.each([arrow15, arrow16, arrow17, arrow18])(
       await expect(table.countRows()).resolves.toBe(1);
     });
 
-    it("should invoke the progress callback", async () => {
-      const events: import("../lancedb").WriteProgress[] = [];
-      await table.add([{ id: 1 }, { id: 2 }, { id: 3 }], {
-        progress: (p) => events.push(p),
-      });
-
-      expect(events.length).toBeGreaterThan(0);
-      const last = events[events.length - 1];
-      expect(last.done).toBe(true);
-      // Earlier callbacks must have done=false.
-      for (const ev of events.slice(0, -1)) {
-        expect(ev.done).toBe(false);
-      }
-      // outputRows reflects the rows added in this call, not table size.
-      expect(last.outputRows).toBe(3);
-      // The input source (an array) reports a row count, so totalRows is set.
-      expect(last.totalRows).toBe(3);
-      // outputRows is monotonic.
-      for (let i = 1; i < events.length; i++) {
-        expect(events[i].outputRows).toBeGreaterThanOrEqual(
-          events[i - 1].outputRows,
-        );
-      }
-    });
-
-    it("should swallow errors thrown from the progress callback", async () => {
-      const warn = jest
-        .spyOn(console, "warn")
-        .mockImplementation(() => undefined);
-      try {
-        const res = await table.add([{ id: 1 }, { id: 2 }], {
-          progress: () => {
-            throw new Error("callback bomb");
-          },
-        });
-        expect(res.version).toBeGreaterThan(0);
-        expect(warn).toHaveBeenCalled();
-      } finally {
-        warn.mockRestore();
-      }
-    });
-
     it("should let me close the table", async () => {
       expect(table.isOpen()).toBe(true);
       table.close();
@@ -845,15 +672,13 @@ describe("When creating an index", () => {
     expect(fs.readdirSync(indexDir)).toHaveLength(1);
     const indices = await tbl.listIndices();
     expect(indices.length).toBe(1);
-    expect(indices[0]).toEqual(
-      expect.objectContaining({
-        name: "vec_idx",
-        indexType: "IvfPq",
-        columns: ["vec"],
-      }),
-    );
+    expect(indices[0]).toEqual({
+      name: "vec_idx",
+      indexType: "IvfPq",
+      columns: ["vec"],
+    });
     const stats = await tbl.indexStats("vec_idx");
-    expect(stats).toBeDefined();
+    expect(stats?.loss).toBeDefined();
 
     // Search without specifying the column
     let rst = await tbl
@@ -913,274 +738,6 @@ describe("When creating an index", () => {
     expect(indices2.length).toBe(0);
   });
 
-  it("should preserve canonical nested field paths across index lifecycle", async () => {
-    const db = await connect(tmpDir.name);
-    const nestedSchema = new Schema([
-      new Field("rowId", new Int32(), true),
-      new Field("row-id", new Int32(), true),
-      new Field("userId", new Int32(), true),
-      new Field(
-        "metadata",
-        new Struct([new Field("user_id", new Int32(), true)]),
-        true,
-      ),
-      new Field(
-        "MetaData",
-        new Struct([new Field("userId", new Int32(), true)]),
-        true,
-      ),
-      new Field(
-        "image",
-        new Struct([
-          new Field(
-            "embedding",
-            new FixedSizeList(2, new Field("item", new Float32(), true)),
-            true,
-          ),
-        ]),
-        true,
-      ),
-      new Field(
-        "payload",
-        new Struct([new Field("text", new Utf8(), true)]),
-        true,
-      ),
-      new Field(
-        "meta-data",
-        new Struct([new Field("user-id", new Int32(), true)]),
-        true,
-      ),
-      new Field(
-        "literal",
-        new Struct([new Field("a.b", new Int32(), true)]),
-        true,
-      ),
-    ]);
-    const nestedTable = await db.createTable(
-      "nested_field_index_lifecycle",
-      makeArrowTable(
-        Array.from({ length: 300 }, (_, rowId) => ({
-          rowId,
-          "row-id": rowId,
-          userId: rowId,
-          metadata: { ["user_id"]: rowId },
-          ["MetaData"]: { userId: rowId },
-          image: { embedding: [rowId, rowId + 1] },
-          payload: { text: `document ${rowId}` },
-          "meta-data": { "user-id": rowId },
-          literal: { "a.b": rowId },
-        })),
-        { schema: nestedSchema },
-      ),
-    );
-
-    await nestedTable.createIndex("rowId", {
-      config: Index.btree(),
-      name: "row_id_idx",
-    });
-    await nestedTable.createIndex("`row-id`", {
-      config: Index.btree(),
-      name: "row_dash_id_idx",
-    });
-    await nestedTable.createIndex("userId", {
-      config: Index.btree(),
-      name: "top_user_id_idx",
-    });
-    await nestedTable.createIndex("metadata.user_id", {
-      config: Index.btree(),
-      name: "nested_user_id_idx",
-    });
-    await nestedTable.createIndex("MetaData.userId", {
-      config: Index.btree(),
-      name: "mixed_case_metadata_user_id_idx",
-    });
-    await nestedTable.createIndex("`meta-data`.`user-id`", {
-      config: Index.btree(),
-      name: "escaped_names_idx",
-    });
-    await nestedTable.createIndex("literal.`a.b`", {
-      config: Index.btree(),
-      name: "literal_dot_idx",
-    });
-    await nestedTable.createIndex("image.embedding", {
-      name: "image_embedding_idx",
-    });
-    await nestedTable.createIndex("payload.text", {
-      config: Index.fts({ withPosition: false }),
-      name: "payload_text_idx",
-    });
-
-    const indices = await nestedTable.listIndices();
-    expect(indices).toEqual(
-      expect.arrayContaining([
-        expect.objectContaining({
-          name: "row_id_idx",
-          indexType: "BTree",
-          columns: ["rowId"],
-        }),
-        expect.objectContaining({
-          name: "row_dash_id_idx",
-          indexType: "BTree",
-          columns: ["`row-id`"],
-        }),
-        expect.objectContaining({
-          name: "top_user_id_idx",
-          indexType: "BTree",
-          columns: ["userId"],
-        }),
-        expect.objectContaining({
-          name: "nested_user_id_idx",
-          indexType: "BTree",
-          columns: ["metadata.user_id"],
-        }),
-        expect.objectContaining({
-          name: "mixed_case_metadata_user_id_idx",
-          indexType: "BTree",
-          columns: ["MetaData.userId"],
-        }),
-        expect.objectContaining({
-          name: "escaped_names_idx",
-          indexType: "BTree",
-          columns: ["`meta-data`.`user-id`"],
-        }),
-        expect.objectContaining({
-          name: "literal_dot_idx",
-          indexType: "BTree",
-          columns: ["literal.`a.b`"],
-        }),
-        expect.objectContaining({
-          name: "image_embedding_idx",
-          indexType: "IvfPq",
-          columns: ["image.embedding"],
-        }),
-        expect.objectContaining({
-          name: "payload_text_idx",
-          indexType: "FTS",
-          columns: ["payload.text"],
-        }),
-      ]),
-    );
-
-    const stats = await nestedTable.indexStats(
-      "mixed_case_metadata_user_id_idx",
-    );
-    expect(stats?.numIndexedRows).toEqual(300);
-    expect(stats?.indexType).toEqual("BTREE");
-
-    const filtered = await nestedTable
-      .query()
-      .where("MetaData.userId = 42")
-      .limit(1)
-      .toArray();
-    expect(filtered[0].MetaData.userId).toEqual(42);
-
-    const escapedFiltered = await nestedTable
-      .query()
-      .where("`row-id` = 43")
-      .limit(1)
-      .toArray();
-    expect(escapedFiltered[0]["row-id"]).toEqual(43);
-
-    const explicit = await nestedTable
-      .query()
-      .nearestTo([0.0, 1.0])
-      .column("image.embedding")
-      .limit(1)
-      .toArray();
-    const inferred = await nestedTable
-      .query()
-      .nearestTo([0.0, 1.0])
-      .limit(1)
-      .toArray();
-    expect(inferred[0].rowId).toEqual(explicit[0].rowId);
-
-    await nestedTable.add([
-      {
-        rowId: 300,
-        "row-id": 300,
-        userId: 300,
-        metadata: { ["user_id"]: 300 },
-        ["MetaData"]: { userId: 300 },
-        image: { embedding: [300.0, 301.0] },
-        payload: { text: "document 300" },
-        "meta-data": { "user-id": 300 },
-        literal: { "a.b": 300 },
-      },
-    ]);
-    await nestedTable.optimize();
-    const indicesAfterOptimize = await nestedTable.listIndices();
-    expect(indicesAfterOptimize).toEqual(
-      expect.arrayContaining([
-        expect.objectContaining({
-          name: "mixed_case_metadata_user_id_idx",
-          indexType: "BTree",
-          columns: ["MetaData.userId"],
-        }),
-        expect.objectContaining({
-          name: "image_embedding_idx",
-          indexType: "IvfPq",
-          columns: ["image.embedding"],
-        }),
-      ]),
-    );
-  });
-
-  it("should report multiple nested vector candidates", async () => {
-    const db = await connect(tmpDir.name);
-    const nestedSchema = new Schema([
-      new Field(
-        "image",
-        new Struct([
-          new Field(
-            "embedding",
-            new FixedSizeList(2, new Field("item", new Float32(), true)),
-            true,
-          ),
-        ]),
-        true,
-      ),
-      new Field(
-        "text",
-        new Struct([
-          new Field(
-            "embedding",
-            new FixedSizeList(2, new Field("item", new Float32(), true)),
-            true,
-          ),
-        ]),
-        true,
-      ),
-    ]);
-    const nestedTable = await db.createTable(
-      "multiple_nested_vectors",
-      makeArrowTable(
-        [
-          {
-            image: { embedding: [0.0, 1.0] },
-            text: { embedding: [2.0, 3.0] },
-          },
-        ],
-        { schema: nestedSchema },
-      ),
-    );
-
-    await expect(
-      nestedTable.query().nearestTo([0.0, 1.0]).limit(1).toArray(),
-    ).rejects.toThrow(/image\.embedding.*text\.embedding/);
-  });
-
-  it("should report when no default vector column exists", async () => {
-    const db = await connect(tmpDir.name);
-    const noVectorTable = await db.createTable(
-      "no_vector",
-      makeArrowTable([{ id: 0, label: "cat" }]),
-    );
-
-    await expect(
-      noVectorTable.query().nearestTo([0.0, 1.0]).limit(1).toArray(),
-    ).rejects.toThrow(/No vector column/);
-  });
-
   it("should wait for index readiness", async () => {
     // Create an index and then wait for it to be ready
     await tbl.createIndex("vec");
@@ -1256,13 +813,11 @@ describe("When creating an index", () => {
     expect(fs.readdirSync(indexDir)).toHaveLength(1);
     const indices = await tbl.listIndices();
     expect(indices.length).toBe(1);
-    expect(indices[0]).toEqual(
-      expect.objectContaining({
-        name: "vec_idx",
-        indexType: "IvfHnswSq",
-        columns: ["vec"],
-      }),
-    );
+    expect(indices[0]).toEqual({
+      name: "vec_idx",
+      indexType: "IvfHnswSq",
+      columns: ["vec"],
+    });
 
     // Search without specifying the column
     let rst = await tbl
@@ -1435,20 +990,6 @@ describe("When creating an index", () => {
     expect(fs.readdirSync(indexDir)).toHaveLength(1);
   });
 
-  test("create an FM index", async () => {
-    // FM-Index accelerates substring search on a string/binary column.
-    const db = await connect(tmpDir.name);
-    const fmTbl = await db.createTable("fm_table", [
-      { id: 0, text: "hello world" },
-      { id: 1, text: "foo bar" },
-    ]);
-    await fmTbl.createIndex("text", {
-      config: Index.fm(),
-    });
-    const indexDir = path.join(tmpDir.name, "fm_table.lance", "_indices");
-    expect(fs.readdirSync(indexDir)).toHaveLength(1);
-  });
-
   test("should be able to get index stats", async () => {
     await tbl.createIndex("id");
 
@@ -1459,6 +1000,7 @@ describe("When creating an index", () => {
     expect(stats?.distanceType).toBeUndefined();
     expect(stats?.indexType).toEqual("BTREE");
     expect(stats?.numIndices).toEqual(1);
+    expect(stats?.loss).toBeUndefined();
   });
 
   test("when getting stats on non-existent index", async () => {
@@ -1608,35 +1150,6 @@ describe("When creating an index", () => {
     expect(rst64Query.toString()).toEqual(rst64Search.toString());
     expect(rst64Query.numRows).toBe(2);
   });
-
-  it("should expose rich metadata fields on IndexConfig", async () => {
-    await tbl.createIndex("id", { config: Index.btree() });
-    await tbl.createIndex("vec");
-
-    const indicesByName = Object.fromEntries(
-      (await tbl.listIndices()).map((idx) => [idx.name, idx]),
-    );
-
-    const scalarIdx = indicesByName["id_idx"];
-    expect(scalarIdx).toBeDefined();
-    expect(typeof scalarIdx.indexUuid).toBe("string");
-    expect(scalarIdx.numIndexedRows).toBe(300);
-    expect(scalarIdx.numUnindexedRows).toBe(0);
-    expect(scalarIdx.numSegments).toBeGreaterThanOrEqual(1);
-    expect(scalarIdx.sizeBytes).toBeGreaterThan(0);
-    // Use toString check to avoid cross-realm instanceof failures with native Date objects
-    expect(Object.prototype.toString.call(scalarIdx.createdAt)).toBe(
-      "[object Date]",
-    );
-    expect((scalarIdx.createdAt as Date).getTime()).toBeGreaterThan(0);
-    expect(typeof scalarIdx.indexDetails).toBe("object");
-
-    const vectorIdx = indicesByName["vec_idx"];
-    expect(vectorIdx).toBeDefined();
-    expect(typeof vectorIdx.indexUuid).toBe("string");
-    expect(vectorIdx.numIndexedRows).toBe(300);
-    expect(typeof vectorIdx.indexDetails).toBe("object");
-  });
 });
 
 describe("When querying a table", () => {
@@ -1908,33 +1421,6 @@ describe("schema evolution", function () {
     expect(await table.schema()).toEqual(expectedSchema3);
   });
 
-  it("can update field metadata", async function () {
-    const con = await connect(tmpDir.name);
-    const table = await con.createTable("fm", [
-      { id: 1, category: "a" },
-      { id: 2, category: "b" },
-    ]);
-
-    const res = await table.updateFieldMetadata([
-      { path: "category", metadata: { unit: "label", pii: "false" } },
-    ]);
-    expect(res).toHaveProperty("version");
-    expect(res.version).toBe(2);
-
-    let cat = (await table.schema()).fields.find((f) => f.name === "category");
-    expect(cat?.metadata.get("unit")).toBe("label");
-    expect(cat?.metadata.get("pii")).toBe("false");
-
-    // merge: add a key, delete one via null, keep the rest
-    await table.updateFieldMetadata([
-      { path: "category", metadata: { source: "import", pii: null } },
-    ]);
-    cat = (await table.schema()).fields.find((f) => f.name === "category");
-    expect(cat?.metadata.get("unit")).toBe("label"); // preserved
-    expect(cat?.metadata.get("source")).toBe("import"); // added
-    expect(cat?.metadata.has("pii")).toBe(false); // deleted
-  });
-
   it("can cast to various types", async function () {
     const con = await connect(tmpDir.name);
 
@@ -2862,224 +2348,3 @@ describe("when creating a table with Float32Array vectors", () => {
     expect((fsl.children[0].type as Float32).precision).toBe(1);
   });
 });
-
-describe("setUnenforcedPrimaryKey", () => {
-  let tmpDir: tmp.DirResult;
-
-  beforeEach(() => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-  });
-  afterEach(() => tmpDir.removeCallback());
-
-  it("sets a single-column primary key (string or one-element array)", async () => {
-    const conn = await connect(tmpDir.name);
-    const schema = new arrow.Schema([
-      new arrow.Field("id", new arrow.Int64(), false),
-    ]);
-    const t1 = await conn.createEmptyTable("t1", schema);
-    await t1.setUnenforcedPrimaryKey("id");
-
-    const t2 = await conn.createEmptyTable("t2", schema);
-    await t2.setUnenforcedPrimaryKey(["id"]);
-  });
-
-  it("rejects a compound primary key", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await conn.createEmptyTable(
-      "t",
-      new arrow.Schema([
-        new arrow.Field("id", new arrow.Int64(), false),
-        new arrow.Field("name", new arrow.Utf8(), false),
-      ]),
-    );
-    await expect(
-      table.setUnenforcedPrimaryKey(["id", "name"]),
-    ).rejects.toThrow();
-  });
-
-  it("rejects changing the primary key once set", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await conn.createEmptyTable(
-      "t",
-      new arrow.Schema([
-        new arrow.Field("id", new arrow.Int64(), false),
-        new arrow.Field("name", new arrow.Utf8(), false),
-      ]),
-    );
-    await table.setUnenforcedPrimaryKey("id");
-    await expect(table.setUnenforcedPrimaryKey("name")).rejects.toThrow();
-    await expect(table.setUnenforcedPrimaryKey("id")).rejects.toThrow();
-  });
-});
-
-describe("setLsmWriteSpec / unsetLsmWriteSpec", () => {
-  let tmpDir: tmp.DirResult;
-
-  beforeEach(() => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-  });
-  afterEach(() => tmpDir.removeCallback());
-
-  async function makeTable(conn: Connection): Promise<Table> {
-    return await conn.createEmptyTable(
-      "t",
-      new arrow.Schema([new arrow.Field("id", new arrow.Int64(), false)]),
-    );
-  }
-
-  it("installs and removes a bucket spec", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await makeTable(conn);
-
-    await table.setUnenforcedPrimaryKey("id");
-    await table.setLsmWriteSpec({
-      specType: "bucket",
-      column: "id",
-      numBuckets: 4,
-    });
-    await table.unsetLsmWriteSpec();
-    // A second unset errors — there is no spec left to remove.
-    await expect(table.unsetLsmWriteSpec()).rejects.toThrow();
-    // A fresh spec can be installed after unset.
-    await table.setLsmWriteSpec({
-      specType: "bucket",
-      column: "id",
-      numBuckets: 8,
-    });
-  });
-
-  it("installs an unsharded spec", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await makeTable(conn);
-
-    await table.setUnenforcedPrimaryKey("id");
-    await table.setLsmWriteSpec({ specType: "unsharded" });
-    await table.unsetLsmWriteSpec();
-  });
-
-  it("installs an identity spec", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await makeTable(conn);
-
-    await table.setUnenforcedPrimaryKey("id");
-    await table.setLsmWriteSpec({ specType: "identity", column: "id" });
-    await table.unsetLsmWriteSpec();
-  });
-
-  it("rejects an invalid spec", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await makeTable(conn);
-
-    await table.setUnenforcedPrimaryKey("id");
-    // num_buckets out of range.
-    await expect(
-      table.setLsmWriteSpec({
-        specType: "bucket",
-        column: "id",
-        numBuckets: 0,
-      }),
-    ).rejects.toThrow();
-    // Column mismatch.
-    await expect(
-      table.setLsmWriteSpec({
-        specType: "bucket",
-        column: "missing",
-        numBuckets: 4,
-      }),
-    ).rejects.toThrow();
-  });
-});
-
-describe("LSM merge insert", () => {
-  let tmpDir: tmp.DirResult;
-
-  beforeEach(() => {
-    tmpDir = tmp.dirSync({ unsafeCleanup: true });
-  });
-  afterEach(() => tmpDir.removeCallback());
-
-  async function bucketTable(conn: Connection): Promise<Table> {
-    // The primary key column must be non-nullable.
-    const table = await conn.createEmptyTable(
-      "t",
-      new arrow.Schema([
-        new arrow.Field("id", new arrow.Utf8(), false),
-        new arrow.Field("value", new arrow.Float64(), true),
-      ]),
-    );
-    await table.add([
-      { id: "a", value: 1 },
-      { id: "b", value: 2 },
-    ]);
-    await table.setUnenforcedPrimaryKey("id");
-    // numBuckets = 1: every row routes to the single bucket.
-    await table.setLsmWriteSpec({
-      specType: "bucket",
-      column: "id",
-      numBuckets: 1,
-    });
-    return table;
-  }
-
-  it("routes merge_insert through the shard writer", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await bucketTable(conn);
-
-    const res = await table
-      .mergeInsert("id")
-      .whenMatchedUpdateAll()
-      .whenNotMatchedInsertAll()
-      .execute([
-        { id: "c", value: 3 },
-        { id: "d", value: 4 },
-      ]);
-    // LSM path: rows go to the MemWAL, so only numRows is populated.
-    expect(res.numRows).toBe(2);
-    expect(res.version).toBe(0);
-    expect(res.numInsertedRows).toBe(0);
-
-    await table.closeLsmWriters();
-  });
-
-  it("falls back to the standard path with useLsmWrite(false)", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await bucketTable(conn);
-
-    const res = await table
-      .mergeInsert("id")
-      .whenNotMatchedInsertAll()
-      .useLsmWrite(false)
-      .execute([
-        { id: "b", value: 9 },
-        { id: "e", value: 5 },
-      ]);
-    // Standard path commits: id="e" inserted ("b" already exists).
-    expect(res.numInsertedRows).toBe(1);
-    expect(await table.countRows()).toBe(3);
-  });
-
-  it("supports validateSingleShard(false)", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await bucketTable(conn);
-
-    const res = await table
-      .mergeInsert("id")
-      .whenMatchedUpdateAll()
-      .whenNotMatchedInsertAll()
-      .validateSingleShard(false)
-      .execute([{ id: "f", value: 6 }]);
-    expect(res.numRows).toBe(1);
-  });
-
-  it("rejects a non-upsert merge under an LSM spec", async () => {
-    const conn = await connect(tmpDir.name);
-    const table = await bucketTable(conn);
-
-    await expect(
-      table
-        .mergeInsert("id")
-        .whenNotMatchedInsertAll()
-        .execute([{ id: "g", value: 7 }]),
-    ).rejects.toThrow();
-  });
-});

nodejs/examples/filtering.test.ts

@@ -38,14 +38,5 @@ test("filtering examples", async () => {
     // --8<-- [start:sql_search]
     await tbl.query().where("id = 10").limit(10).toArray();
     // --8<-- [end:sql_search]
-
-    // --8<-- [start:orderby_search]
-    await tbl
-      .query()
-      .where("id > 10")
-      .orderBy({ columnName: "id", ascending: false })
-      .limit(5)
-      .toArray();
-    // --8<-- [end:orderby_search]
   });
 });

nodejs/examples/package.json

@@ -11,17 +11,16 @@
     "test": "node --experimental-vm-modules node_modules/.bin/jest --testEnvironment jest-environment-node-single-context --verbose",
     "lint": "biome check *.ts && biome format *.ts",
     "lint-ci": "biome ci .",
-    "lint-fix": "biome check --write *.ts && pnpm format",
+    "lint-fix": "biome check --write *.ts && npm run format",
     "format": "biome format --write *.ts"
   },
   "author": "Lance Devs",
   "license": "Apache-2.0",
-  "packageManager": "pnpm@11.1.1",
   "dependencies": {
-    "@huggingface/transformers": "3.0.2",
+    "@huggingface/transformers": "^3.0.2",
     "@lancedb/lancedb": "file:../dist",
-    "openai": "4.29.2",
-    "sharp": "0.33.5"
+    "openai": "^4.29.2",
+    "sharp": "^0.33.5"
   },
   "devDependencies": {
     "@biomejs/biome": "^1.7.3",

nodejs/examples/pnpm-workspace.yaml

@@ -1,13 +0,0 @@
-# Block resolution of versions less than 24h old (Shai-Hulud window).
-# This is the pnpm 11 default but pinned here so it's visible to
-# reviewers and survives a future pnpm major flipping the default.
-minimumReleaseAge: 1440
-
-# Fail install if a transitive dep tries to run an unapproved script.
-strictDepBuilds: true
-
-allowBuilds:
-  '@biomejs/biome': true
-  onnxruntime-node: true
-  protobufjs: true
-  sharp: true

nodejs/lancedb/arrow.ts

@@ -1291,18 +1291,6 @@ export async function fromRecordBatchToBuffer(
   return Buffer.from(await writer.toUint8Array());
 }
 
-/**
- * Create a buffer containing a single record batch using the Arrow IPC Stream
- * serialization. Each call produces a self-contained Stream message (schema +
- * batch + EOS) suitable for incremental decode by `arrow_ipc::reader::StreamReader`.
- */
-export async function fromRecordBatchToStreamBuffer(
-  batch: RecordBatch,
-): Promise<Buffer> {
-  const writer = RecordBatchStreamWriter.writeAll([batch]);
-  return Buffer.from(await writer.toUint8Array());
-}
-
 /**
  * Serialize an Arrow Table into a buffer using the Arrow IPC Stream serialization
  *

nodejs/lancedb/connection.ts

@@ -16,18 +16,6 @@ import {
 } from "./arrow";
 import { EmbeddingFunctionConfig, getRegistry } from "./embedding/registry";
 import { Connection as LanceDbConnection } from "./native";
-import type {
-  CreateNamespaceResponse,
-  DescribeNamespaceResponse,
-  DropNamespaceResponse,
-  ListNamespacesResponse,
-} from "./native";
-export type {
-  CreateNamespaceResponse,
-  DescribeNamespaceResponse,
-  DropNamespaceResponse,
-  ListNamespacesResponse,
-};
 import { sanitizeTable } from "./sanitize";
 import { LocalTable, Table } from "./table";
 
@@ -84,20 +72,6 @@ export interface CreateTableOptions {
 }
 
 export interface OpenTableOptions {
-  /**
-   * Open the table scoped to this branch instead of the default branch.
-   *
-   * Reads and writes on the returned table operate in the branch's context.
-   */
-  branch?: string;
-  /**
-   * Open the table pinned to this version, producing a read-only view.
-   *
-   * Composes with {@link OpenTableOptions.branch}: when both are set, opens
-   * that branch at the version; otherwise opens `main` at the version. Call
-   * `checkoutLatest` to return to a writable state.
-   */
-  version?: number;
   /**
    * Configuration for object storage.
    *
@@ -136,41 +110,6 @@ export interface TableNamesOptions {
   /** An optional limit to the number of results to return. */
   limit?: number;
 }
-
-export interface ListNamespacesOptions {
-  /** Token from a previous response for pagination. */
-  pageToken?: string;
-  /** An optional limit to the number of results to return. */
-  limit?: number;
-}
-
-export interface CreateNamespaceOptions {
-  /** Creation mode. */
-  mode?: "create" | "exist_ok" | "overwrite";
-  /** Properties to set on the new namespace. */
-  properties?: Record<string, string>;
-}
-
-export interface DropNamespaceOptions {
-  /** Whether to skip if the namespace doesn't exist, or fail. */
-  mode?: "skip" | "fail";
-  /** Refuse to drop if non-empty (restrict) or drop recursively (cascade). */
-  behavior?: "restrict" | "cascade";
-}
-
-export interface RenameTableOptions {
-  /**
-   * The namespace path of the table being renamed. Defaults to the root
-   * namespace (`[]`) when omitted.
-   */
-  namespacePath?: string[];
-  /**
-   * The namespace path to move the table to as part of the rename. When
-   * omitted the table stays in `namespacePath`.
-   */
-  newNamespacePath?: string[];
-}
-
 /**
  * A LanceDB Connection that allows you to open tables and create new ones.
  *
@@ -329,69 +268,6 @@ export abstract class Connection {
    */
   abstract dropAllTables(namespacePath?: string[]): Promise<void>;
 
-  /**
-   * Describe a namespace, returning its properties.
-   *
-   * @param {string[]} namespacePath - The namespace path to describe, in
-   *   parent → child order, e.g. `["analytics", "sales"]`.
-   * @returns {Promise<DescribeNamespaceResponse>} The namespace's properties
-   *   (may be undefined if the namespace has none).
-   */
-  abstract describeNamespace(
-    namespacePath: string[],
-  ): Promise<DescribeNamespaceResponse>;
-
-  /**
-   * List the immediate child namespaces under the given parent.
-   *
-   * Results may be paginated. To retrieve subsequent pages, pass the
-   * `pageToken` returned by a previous call.
-   *
-   * @param {string[]} namespacePath - The parent namespace path. Defaults
-   *   to the root namespace if omitted.
-   * @param {Partial<ListNamespacesOptions>} options - Pagination options
-   *   (`pageToken`, `limit`).
-   * @returns {Promise<ListNamespacesResponse>} Child namespace names and
-   *   an optional token for fetching the next page.
-   */
-  abstract listNamespaces(
-    namespacePath?: string[],
-    options?: Partial<ListNamespacesOptions>,
-  ): Promise<ListNamespacesResponse>;
-
-  /**
-   * Create a new namespace at the given path.
-   *
-   * @param {string[]} namespacePath - The namespace path to create.
-   * @param {Partial<CreateNamespaceOptions>} options - Creation `mode`
-   *   ("create" | "exist_ok" | "overwrite") and optional `properties`
-   *   to attach to the namespace.
-   * @returns {Promise<CreateNamespaceResponse>} The properties of the
-   *   created namespace and an optional transaction id.
-   */
-  abstract createNamespace(
-    namespacePath: string[],
-    options?: Partial<CreateNamespaceOptions>,
-  ): Promise<CreateNamespaceResponse>;
-
-  /**
-   * Drop a namespace.
-   *
-   * Use `behavior: "cascade"` to also drop everything contained in the
-   * namespace (sub-namespaces and tables). The default `"restrict"`
-   * behavior refuses to drop a non-empty namespace.
-   *
-   * @param {string[]} namespacePath - The namespace path to drop.
-   * @param {Partial<DropNamespaceOptions>} options - `mode` ("skip" | "fail"
-   *   for missing-namespace handling) and `behavior` ("restrict" | "cascade").
-   * @returns {Promise<DropNamespaceResponse>} Any properties returned by
-   *   the server and an optional transaction id.
-   */
-  abstract dropNamespace(
-    namespacePath: string[],
-    options?: Partial<DropNamespaceOptions>,
-  ): Promise<DropNamespaceResponse>;
-
   /**
    * Clone a table from a source table.
    *
@@ -418,24 +294,6 @@ export abstract class Connection {
       isShallow?: boolean;
     },
   ): Promise<Table>;
-
-  /**
-   * Rename a table.
-   *
-   * Currently only supported by LanceDB Cloud. Local OSS connections and
-   * namespace-backed connections (via {@link connectNamespace}) reject with
-   * a "not supported" error.
-   *
-   * @param {string} currentName - The current name of the table.
-   * @param {string} newName - The new name for the table.
-   * @param {RenameTableOptions} options - Optional namespace paths. When
-   *   `newNamespacePath` is omitted the table stays in `namespacePath`.
-   */
-  abstract renameTable(
-    currentName: string,
-    newName: string,
-    options?: RenameTableOptions,
-  ): Promise<void>;
 }
 
 /** @hideconstructor */
@@ -497,20 +355,7 @@ export class LocalConnection extends Connection {
       options?.indexCacheSize,
     );
 
-    let table: Table = new LocalTable(innerTable);
-    // "main" is the default branch, so treat it as no branch. On a real branch,
-    // scope and pin in one step (yielding "version V of branch B"); otherwise
-    // pin the version, if any, against main.
-    const branch =
-      options?.branch != null && options.branch !== "main"
-        ? options.branch
-        : undefined;
-    if (branch != null) {
-      table = await (await table.branches()).checkout(branch, options?.version);
-    } else if (options?.version != null) {
-      await table.checkout(options.version);
-    }
-    return table;
+    return new LocalTable(innerTable);
   }
 
   async cloneTable(
@@ -670,58 +515,6 @@ export class LocalConnection extends Connection {
   async dropAllTables(namespacePath?: string[]): Promise<void> {
     return this.inner.dropAllTables(namespacePath ?? []);
   }
-
-  describeNamespace(
-    namespacePath: string[],
-  ): Promise<DescribeNamespaceResponse> {
-    return this.inner.describeNamespace(namespacePath);
-  }
-
-  listNamespaces(
-    namespacePath?: string[],
-    options?: Partial<ListNamespacesOptions>,
-  ): Promise<ListNamespacesResponse> {
-    return this.inner.listNamespaces(
-      namespacePath ?? [],
-      options?.pageToken,
-      options?.limit,
-    );
-  }
-
-  createNamespace(
-    namespacePath: string[],
-    options?: Partial<CreateNamespaceOptions>,
-  ): Promise<CreateNamespaceResponse> {
-    return this.inner.createNamespace(
-      namespacePath,
-      options?.mode,
-      options?.properties,
-    );
-  }
-
-  dropNamespace(
-    namespacePath: string[],
-    options?: Partial<DropNamespaceOptions>,
-  ): Promise<DropNamespaceResponse> {
-    return this.inner.dropNamespace(
-      namespacePath,
-      options?.mode,
-      options?.behavior,
-    );
-  }
-
-  async renameTable(
-    currentName: string,
-    newName: string,
-    options?: RenameTableOptions,
-  ): Promise<void> {
-    return this.inner.renameTable(
-      currentName,
-      newName,
-      options?.namespacePath ?? [],
-      options?.newNamespacePath,
-    );
-  }
 }
 
 /**

nodejs/lancedb/index.ts

@@ -8,7 +8,6 @@ import {
 } from "./connection";
 
 import {
-  ConnectNamespaceOptions,
   ConnectionOptions,
   Connection as LanceDbConnection,
   JsHeaderProvider as NativeJsHeaderProvider,
@@ -23,7 +22,6 @@ export { JsHeaderProvider as NativeJsHeaderProvider } from "./native.js";
 export {
   AddColumnsSql,
   ConnectionOptions,
-  ConnectNamespaceOptions,
   IndexStatistics,
   IndexConfig,
   ClientConfig,
@@ -38,12 +36,10 @@ export {
   FragmentSummaryStats,
   Tags,
   TagContents,
-  BranchContents,
   MergeResult,
   AddResult,
   AddColumnsResult,
   AlterColumnsResult,
-  UpdateFieldMetadataResult,
   DeleteResult,
   DropColumnsResult,
   UpdateResult,
@@ -66,14 +62,6 @@ export {
   CreateTableOptions,
   TableNamesOptions,
   OpenTableOptions,
-  ListNamespacesOptions,
-  CreateNamespaceOptions,
-  DropNamespaceOptions,
-  ListNamespacesResponse,
-  CreateNamespaceResponse,
-  DropNamespaceResponse,
-  DescribeNamespaceResponse,
-  RenameTableOptions,
 } from "./connection";
 
 export { Session } from "./native.js";
@@ -85,7 +73,6 @@ export {
   VectorQuery,
   TakeQuery,
   QueryExecutionOptions,
-  ColumnOrdering,
   FullTextSearchOptions,
   RecordBatchIterator,
   FullTextQuery,
@@ -112,15 +99,11 @@ export {
 
 export {
   Table,
-  Branches,
   AddDataOptions,
   UpdateOptions,
   OptimizeOptions,
   Version,
-  WriteProgress,
-  LsmWriteSpec,
   ColumnAlteration,
-  FieldMetadataUpdate,
 } from "./table";
 
 export {
@@ -134,7 +117,6 @@ export { MergeInsertBuilder, WriteExecutionOptions } from "./merge";
 
 export * as embedding from "./embedding";
 export { permutationBuilder, PermutationBuilder } from "./permutation";
-export { Scannable, ScannableOptions } from "./scannable";
 export * as rerankers from "./rerankers";
 export {
   SchemaLike,
@@ -311,197 +293,3 @@ export async function connect(
   );
   return new LocalConnection(nativeConn);
 }
-
-/**
- * Configuration for the built-in directory namespace (`"dir"`).
- *
- * The directory namespace stores tables under a single root path (local
- * filesystem or object storage URI). See
- * {@link https://docs.lancedb.com/namespaces} for the documented surface;
- * less-common knobs live under {@link DirNamespaceConfig.extraProperties}.
- */
-export interface DirNamespaceConfig {
-  /** Root path or URI containing the LanceDB tables. */
-  root: string;
-  /**
-   * Whether to maintain a namespace manifest at the root. Required for
-   * child namespaces. Defaults to true on the impl side.
-   */
-  manifestEnabled?: boolean;
-  /**
-   * Additional raw properties passed verbatim to the namespace
-   * implementation (e.g. `storage.*`, `credential_vendor.*`). Typed
-   * fields above take precedence on key collision.
-   */
-  extraProperties?: Record<string, string>;
-}
-
-/**
- * Configuration for the built-in REST namespace (`"rest"`).
- *
- * The REST namespace talks to a remote catalog server over HTTP. See
- * {@link https://docs.lancedb.com/namespaces} for the documented surface;
- * less-common knobs (TLS, metrics) live under
- * {@link RestNamespaceConfig.extraProperties}.
- */
-export interface RestNamespaceConfig {
-  /** Catalog endpoint URL. */
-  uri: string;
-  /**
-   * HTTP headers forwarded with each request. Keys are passed through
-   * as-is (e.g. `"x-api-key"`, `"Authorization"`).
-   */
-  headers?: Record<string, string>;
-  /**
-   * Additional raw properties passed verbatim to the namespace
-   * implementation (e.g. `tls.*`, `ops_metrics_enabled`, `delimiter`).
-   * Typed fields above take precedence on key collision.
-   */
-  extraProperties?: Record<string, string>;
-}
-
-function dirConfigToProperties(
-  config: DirNamespaceConfig,
-): Record<string, string> {
-  // Spread the whole input so that unknown keys (e.g. a raw `manifest_enabled`
-  // passed via the dynamic-impl path) flow through instead of being dropped.
-  // Typed transformations layer on top.
-  const { manifestEnabled, extraProperties, ...rest } = config;
-  const properties: Record<string, string> = {
-    ...(extraProperties ?? {}),
-    ...(rest as Record<string, string>),
-  };
-  if (manifestEnabled !== undefined) {
-    properties.manifest_enabled = String(manifestEnabled);
-  }
-  return properties;
-}
-
-function restConfigToProperties(
-  config: RestNamespaceConfig,
-): Record<string, string> {
-  const { headers, extraProperties, ...rest } = config;
-  const properties: Record<string, string> = {
-    ...(extraProperties ?? {}),
-    ...(rest as Record<string, string>),
-  };
-  if (headers) {
-    for (const [name, value] of Object.entries(headers)) {
-      properties[`headers.${name}`] = value;
-    }
-  }
-  return properties;
-}
-
-/**
- * Connect to a LanceDB database through a namespace.
- *
- * Unlike {@link connect}, which routes by URI scheme (local path vs.
- * `db://` cloud), `connectNamespace` always returns a namespace-backed
- * connection. The `implName` selects the namespace implementation:
- *
- * - `"dir"` — directory namespace, configured with {@link DirNamespaceConfig}.
- * - `"rest"` — remote REST catalog, configured with {@link RestNamespaceConfig}.
- * - Any other string — full module path for a custom implementation,
- *   configured with a free-form string-keyed `properties` map.
- *
- * @example Typed dir namespace
- * ```ts
- * const db = await connectNamespace("dir", { root: "/path/to/db" });
- * await db.createTable("users", [{ id: 1 }]);
- * ```
- *
- * @example Typed REST namespace with auth headers
- * ```ts
- * const db = await connectNamespace("rest", {
- *   uri: "https://catalog.example.com",
- *   headers: { "x-api-key": process.env.CATALOG_KEY ?? "" },
- * });
- * ```
- *
- * @example Custom implementation with raw properties
- * ```ts
- * const db = await connectNamespace("my.custom.Namespace", {
- *   endpoint: "...",
- * });
- * ```
- */
-export function connectNamespace(
-  implName: "dir",
-  config: DirNamespaceConfig,
-  options?: Partial<ConnectNamespaceOptions>,
-): Promise<Connection>;
-/**
- * Connect through the built-in REST namespace.
- *
- * Configured with {@link RestNamespaceConfig}. See the function-level
- * documentation above for the full surface, examples, and how this
- * relates to {@link connect}.
- *
- * @example
- * ```ts
- * const db = await connectNamespace("rest", {
- *   uri: "https://catalog.example.com",
- *   headers: { "x-api-key": process.env.CATALOG_KEY ?? "" },
- * });
- * ```
- */
-export function connectNamespace(
-  implName: "rest",
-  config: RestNamespaceConfig,
-  options?: Partial<ConnectNamespaceOptions>,
-): Promise<Connection>;
-/**
- * Connect through a custom namespace implementation by full module path,
- * configured with a free-form string-keyed `properties` map. Use the
- * typed overloads above for the built-in `"dir"` and `"rest"` impls.
- *
- * See the function-level documentation above for examples and how this
- * relates to {@link connect}.
- *
- * @example
- * ```ts
- * const db = await connectNamespace("my.custom.Namespace", {
- *   endpoint: "...",
- * });
- * ```
- */
-export function connectNamespace(
-  implName: string,
-  properties: Record<string, string>,
-  options?: Partial<ConnectNamespaceOptions>,
-): Promise<Connection>;
-export async function connectNamespace(
-  implName: string,
-  configOrProperties:
-    | DirNamespaceConfig
-    | RestNamespaceConfig
-    | Record<string, string>,
-  options?: Partial<ConnectNamespaceOptions>,
-): Promise<Connection> {
-  let properties: Record<string, string>;
-  if (implName === "dir") {
-    properties = dirConfigToProperties(
-      configOrProperties as DirNamespaceConfig,
-    );
-  } else if (implName === "rest") {
-    properties = restConfigToProperties(
-      configOrProperties as RestNamespaceConfig,
-    );
-  } else {
-    properties = configOrProperties as Record<string, string>;
-  }
-
-  const finalOptions: ConnectNamespaceOptions = (options ??
-    {}) as ConnectNamespaceOptions;
-  finalOptions.storageOptions = cleanseStorageOptions(
-    finalOptions.storageOptions,
-  );
-
-  const nativeConn = await LanceDbConnection.newWithNamespace(
-    implName,
-    properties,
-    finalOptions,
-  );
-  return new LocalConnection(nativeConn);
-}

nodejs/lancedb/indices.ts

@@ -702,17 +702,6 @@ export class Index {
     return new Index(LanceDbIndex.labelList());
   }
 
-  /**
-   * Create an FM-Index.
-   *
-   * An FM-Index is a scalar index on string or binary columns that accelerates
-   * substring search, i.e. `contains(col, 'needle')`. Unlike the tokenized
-   * full-text-search index, it matches arbitrary substrings of the raw bytes.
-   */
-  static fm() {
-    return new Index(LanceDbIndex.fm());
-  }
-
   /**
    * Create a full text search index
    *

nodejs/lancedb/merge.ts

@@ -87,41 +87,6 @@ export class MergeInsertBuilder {
       this.#schema,
     );
   }
-  /**
-   * Controls whether the merge uses the MemWAL LSM write path.
-   *
-   * By default (unset), a `mergeInsert` on a table with an LSM write spec is
-   * routed through Lance's MemWAL shard writer, and a table without one uses
-   * the standard path. Pass `false` to force the standard path even when a
-   * spec is set. Pass `true` to require a spec — `mergeInsert` rejects if none
-   * is installed.
-   *
-   * @param useLsmWrite - Whether to use the LSM write path.
-   */
-  useLsmWrite(useLsmWrite: boolean): MergeInsertBuilder {
-    return new MergeInsertBuilder(
-      this.#native.useLsmWrite(useLsmWrite),
-      this.#schema,
-    );
-  }
-  /**
-   * Controls how an LSM merge checks that its input targets a single shard.
-   *
-   * When a table has an LSM write spec, every row in a `mergeInsert` call must
-   * route to the same shard. When `true` (the default), every row is inspected
-   * to verify this. When `false`, only the first row is inspected and the
-   * shard it routes to is used for the whole input — a faster path for callers
-   * that have already pre-sharded their input. Has no effect on tables without
-   * an LSM write spec.
-   *
-   * @param validateSingleShard - Whether to check every row routes to one shard. Defaults to `true`.
-   */
-  validateSingleShard(validateSingleShard: boolean): MergeInsertBuilder {
-    return new MergeInsertBuilder(
-      this.#native.validateSingleShard(validateSingleShard),
-      this.#schema,
-    );
-  }
   /**
    * Executes the merge insert operation
    *

nodejs/lancedb/query.ts

@@ -79,12 +79,6 @@ export interface QueryExecutionOptions {
   timeoutMs?: number;
 }
 
-export interface ColumnOrdering {
-  columnName: string;
-  ascending?: boolean;
-  nullsFirst?: boolean;
-}
-
 /**
  * Options that control the behavior of a full text search
  */
@@ -423,21 +417,6 @@ export class StandardQueryBase<
     return this;
   }
 
-  /**
-   * Sort the results by the specified column(s).
-   * @returns This query builder.
-   */
-  orderBy(ordering: ColumnOrdering | ColumnOrdering[]): this {
-    const orderings = Array.isArray(ordering) ? ordering : [ordering];
-    const normalized = orderings.map((o) => ({
-      columnName: o.columnName,
-      ascending: o.ascending ?? true,
-      nullsFirst: o.nullsFirst ?? false,
-    }));
-    this.doCall((inner) => inner.orderBy(normalized));
-    return this;
-  }
-
   /**
    * Skip searching un-indexed data. This can make search faster, but will miss
    * any data that is not yet indexed.

nodejs/lancedb/scannable.ts

@@ -1,274 +0,0 @@
-// SPDX-License-Identifier: Apache-2.0
-// SPDX-FileCopyrightText: Copyright The LanceDB Authors
-
-import {
-  Table as ArrowTable,
-  RecordBatch,
-  RecordBatchReader,
-  Schema,
-} from "apache-arrow";
-import {
-  fromRecordBatchToStreamBuffer,
-  fromTableToBuffer,
-  makeEmptyTable,
-} from "./arrow";
-import { NapiScannable } from "./native.js";
-
-export interface ScannableOptions {
-  /** Hint about the number of rows. Not validated against the stream. */
-  numRows?: number;
-  /**
-   * Whether the source can be scanned more than once. Defaults to `true` for
-   * `fromTable` / `fromFactory` and `false` for `fromIterable` /
-   * `fromRecordBatchReader`.
-   */
-  rescannable?: boolean;
-}
-
-/**
- * A data source that can be scanned as a stream of Arrow `RecordBatch`es.
- *
- * `Scannable` wraps the schema + optional row count + rescannable flag and
- * a callback that yields batches one at a time. It is passed to consumers
- * (e.g. `Table.add`, `createTable`, `mergeInsert` — follow-up work) that
- * need to pull data without materializing the full dataset in JS memory.
- *
- * Batches cross the JS↔Rust boundary as Arrow IPC Stream messages; a fresh
- * writer serializes each batch, and the Rust side decodes it with
- * `arrow_ipc::reader::StreamReader`. One batch is in flight at a time.
- */
-export class Scannable {
-  readonly schema: Schema;
-  readonly numRows: number | null;
-  readonly rescannable: boolean;
-
-  /** @hidden */
-  private readonly native: NapiScannable;
-
-  private constructor(
-    native: NapiScannable,
-    schema: Schema,
-    numRows: number | null,
-    rescannable: boolean,
-  ) {
-    this.native = native;
-    this.schema = schema;
-    this.numRows = numRows;
-    this.rescannable = rescannable;
-  }
-
-  /** @hidden Access the native handle for passing through to Rust consumers. */
-  get inner(): NapiScannable {
-    return this.native;
-  }
-
-  /**
-   * Build a Scannable from an explicit schema and a factory that returns a
-   * fresh batch iterator on each call.
-   *
-   * The factory is invoked once per scan. Each iterator yields
-   * `RecordBatch`es matching the declared schema. Use this when you need
-   * direct control over the pull loop — for example, to wrap a streaming
-   * source whose batches are produced lazily.
-   *
-   * @param schema - The Arrow schema of the produced batches.
-   * @param factory - Called at the start of each scan to produce a batch
-   *   iterator. Must be idempotent when `rescannable` is true.
-   * @param opts - Optional hints. `rescannable` defaults to `true`; set to
-   *   `false` if calling `factory()` twice would not reproduce the same data.
-   */
-  static async fromFactory(
-    schema: Schema,
-    factory: () =>
-      | AsyncIterable<RecordBatch>
-      | Iterable<RecordBatch>
-      | AsyncIterator<RecordBatch>
-      | Iterator<RecordBatch>,
-    opts: ScannableOptions = {},
-  ): Promise<Scannable> {
-    const numRows = opts.numRows ?? null;
-    if (numRows != null && !Number.isInteger(numRows)) {
-      throw new TypeError("numRows must be an integer");
-    }
-    const rescannable = opts.rescannable ?? true;
-
-    let iter: AsyncIterator<RecordBatch> | Iterator<RecordBatch> | null = null;
-    const getNextBatch = async (isStart: boolean): Promise<Buffer | null> => {
-      // `isStart` is true on the first pull of every new scan_as_stream.
-      // Drop any cached iterator so factory() is re-invoked for the next scan
-      if (isStart) {
-        iter = null;
-      }
-      if (iter === null) {
-        iter = normalizeIterator(factory());
-      }
-      const result = await iter.next();
-      if (result.done) {
-        iter = null;
-        return null;
-      }
-      return fromRecordBatchToStreamBuffer(result.value);
-    };
-
-    const schemaBuf = await fromTableToBuffer(makeEmptyTable(schema));
-    const native = new NapiScannable(
-      schemaBuf,
-      numRows,
-      rescannable,
-      getNextBatch,
-    );
-    return new Scannable(native, schema, numRows, rescannable);
-  }
-
-  /**
-   * Build a Scannable from an in-memory Arrow `Table`. Always rescannable;
-   * the table's batches are replayed on each scan.
-   *
-   * The table's row count is authoritative: `opts.numRows` must either be
-   * omitted or equal to `table.numRows`. `opts.rescannable` of `false` is
-   * rejected because in-memory Tables are always rescannable.
-   */
-  static async fromTable(
-    table: ArrowTable,
-    opts: ScannableOptions = {},
-  ): Promise<Scannable> {
-    if (opts.numRows != null && opts.numRows !== table.numRows) {
-      throw new TypeError(
-        `opts.numRows (${opts.numRows}) does not match table.numRows (${table.numRows}). ` +
-          `The table's row count is authoritative; omit numRows or pass the matching value.`,
-      );
-    }
-    if (opts.rescannable === false) {
-      throw new TypeError(
-        `fromTable does not accept rescannable: false. ` +
-          `In-memory Arrow Tables are always rescannable; omit the option or pass true.`,
-      );
-    }
-    return Scannable.fromFactory(table.schema, () => table.batches, {
-      numRows: table.numRows,
-      rescannable: true,
-    });
-  }
-
-  /**
-   * Build a Scannable from an iterable of `RecordBatch`es. `rescannable`
-   * defaults to `false`. Pass an explicit schema so the consumer can
-   * validate before any batch is pulled.
-   *
-   * `opts.rescannable: true` is honest for replayable iterables (Arrays,
-   * Sets, or custom iterables whose `[Symbol.iterator]()` returns a fresh
-   * iterator each call). It is rejected for one-shot iterables (generators,
-   * async generators, or already-an-iterator inputs) because their
-   * `[Symbol.iterator]()` returns the same exhausted object on the second
-   * scan. For replayable sources outside this shape, use
-   * `fromFactory(schema, () => createIter(), { rescannable: true })`.
-   *
-   * Note: when `opts.rescannable` is `true`, the constructor calls
-   * `[Symbol.iterator]()` once on the input to perform the structural check.
-   */
-  static async fromIterable(
-    schema: Schema,
-    iter: AsyncIterable<RecordBatch> | Iterable<RecordBatch>,
-    opts: ScannableOptions = {},
-  ): Promise<Scannable> {
-    if (opts.rescannable === true && isOneShotIterable(iter)) {
-      throw new TypeError(
-        `fromIterable: rescannable: true is not honest for one-shot iterables ` +
-          `(generators, async generators, or iterators where [Symbol.iterator]() ` +
-          `returns the same object). The source would be exhausted after the first scan. ` +
-          `Use fromFactory(schema, () => createIter(), { rescannable: true }) for sources ` +
-          `where each call mints a fresh iterator.`,
-      );
-    }
-    return Scannable.fromFactory(schema, () => iter, {
-      numRows: opts.numRows,
-      rescannable: opts.rescannable ?? false,
-    });
-  }
-
-  /**
-   * Build a Scannable from an Arrow `RecordBatchReader`. A reader can only
-   * be consumed once; `rescannable` defaults to `false`.
-   *
-   * The reader must already be opened (via `.open()`) so its `.schema` is
-   * populated. `RecordBatchReader.from(...)` returns an unopened reader.
-   *
-   * `opts.rescannable: true` is rejected because `RecordBatchReader` is a
-   * self-iterator (its `[Symbol.iterator]()` returns itself), and this
-   * constructor does not call `reader.reset()` between scans, so a second
-   * scan would always see an exhausted reader. For genuinely replayable
-   * sources, use
-   * `fromFactory(schema, () => openReader(), { rescannable: true })`,
-   * which mints a fresh reader on each scan.
-   */
-  static async fromRecordBatchReader(
-    reader: RecordBatchReader,
-    opts: ScannableOptions = {},
-  ): Promise<Scannable> {
-    if (opts.rescannable === true) {
-      throw new TypeError(
-        `fromRecordBatchReader does not accept rescannable: true. ` +
-          `RecordBatchReader is a self-iterator (its [Symbol.iterator]() ` +
-          `returns itself) and would be exhausted after the first scan. ` +
-          `Use fromFactory(schema, () => openReader(), { rescannable: true }) ` +
-          `for sources where each call mints a fresh reader.`,
-      );
-    }
-    return Scannable.fromFactory(reader.schema, () => reader, {
-      numRows: opts.numRows,
-      rescannable: false,
-    });
-  }
-}
-
-function normalizeIterator<T>(
-  source: AsyncIterable<T> | Iterable<T> | AsyncIterator<T> | Iterator<T>,
-): AsyncIterator<T> | Iterator<T> {
-  if (source == null) {
-    throw new TypeError("Scannable factory returned null/undefined");
-  }
-  if (
-    typeof (source as AsyncIterable<T>)[Symbol.asyncIterator] === "function"
-  ) {
-    return (source as AsyncIterable<T>)[Symbol.asyncIterator]();
-  }
-  if (typeof (source as Iterable<T>)[Symbol.iterator] === "function") {
-    return (source as Iterable<T>)[Symbol.iterator]();
-  }
-  // Already an iterator (has `.next`).
-  if (typeof (source as Iterator<T>).next === "function") {
-    return source as Iterator<T>;
-  }
-  throw new TypeError("Scannable factory returned a non-iterable value");
-}
-
-// A "self-iterator" returns the same object from `[Symbol.iterator]()` /
-// `[Symbol.asyncIterator]()`. Generators behave this way, so they exhaust
-// after one pass. Replayable iterables (Array, Set, custom) return a fresh
-// iterator each call. Detection mirrors `normalizeIterator`'s ordering so
-// classification matches scan-time behavior.
-function isOneShotIterable(
-  source: AsyncIterable<unknown> | Iterable<unknown>,
-): boolean {
-  // null/undefined are not one-shot in any meaningful sense; let
-  // `normalizeIterator` raise the actual error at scan time.
-  if (source == null) return false;
-  const ref = source as unknown;
-  if (
-    typeof (source as AsyncIterable<unknown>)[Symbol.asyncIterator] ===
-    "function"
-  ) {
-    const it = (source as AsyncIterable<unknown>)[
-      Symbol.asyncIterator
-    ]() as unknown;
-    return it === ref;
-  }
-  if (typeof (source as Iterable<unknown>)[Symbol.iterator] === "function") {
-    const it = (source as Iterable<unknown>)[Symbol.iterator]() as unknown;
-    return it === ref;
-  }
-  // Already-an-iterator (has `.next` but no `Symbol.iterator`) is by
-  // definition one-shot.
-  if (typeof (source as { next?: unknown }).next === "function") return true;
-  return false;
-}

nodejs/lancedb/table.ts

@@ -25,16 +25,13 @@ import {
   AddColumnsSql,
   AddResult,
   AlterColumnsResult,
-  BranchContents,
   DeleteResult,
   DropColumnsResult,
   IndexConfig,
   IndexStatistics,
-  Branches as NativeBranches,
   OptimizeStats,
   TableStatistics,
   Tags,
-  UpdateFieldMetadataResult,
   UpdateResult,
   Table as _NativeTable,
 } from "./native";
@@ -49,33 +46,6 @@ import { sanitizeType } from "./sanitize";
 import { IntoSql, toSQL } from "./util";
 export { IndexConfig } from "./native";
 
-/**
- * Progress snapshot for a write operation, delivered to the `progress`
- * callback passed to {@link Table.add}.
- */
-export interface WriteProgress {
-  /** Number of rows written so far. */
-  outputRows: number;
-  /** Number of bytes written so far. */
-  outputBytes: number;
-  /**
-   * Total rows expected, when the input source reports it.
-   *
-   * Always set on the final callback (the one with `done: true`), falling
-   * back to the actual number of rows written when the source could not
-   * report a row count up front.
-   */
-  totalRows?: number;
-  /** Wall-clock seconds since the write started. */
-  elapsedSeconds: number;
-  /** Number of parallel write tasks currently in flight. */
-  activeTasks: number;
-  /** Total number of parallel write tasks (the write parallelism). */
-  totalTasks: number;
-  /** `true` for the final callback; `false` otherwise. */
-  done: boolean;
-}
-
 /**
  * Options for adding data to a table.
  */
@@ -86,28 +56,6 @@ export interface AddDataOptions {
    * If "overwrite" then the new data will replace the existing data in the table.
    */
   mode: "append" | "overwrite";
-
-  /**
-   * Optional callback invoked periodically with write progress.
-   *
-   * The callback is fired once per batch written and once more with
-   * `done: true` when the write completes. Calls are dispatched
-   * asynchronously to the JS event loop and never block the write — a slow
-   * callback will queue events rather than back-pressure the writer.
-   *
-   * Errors thrown from the callback are logged with `console.warn` and
-   * swallowed — they do not abort the write.
-   *
-   * @example
-   * ```ts
-   * await table.add(data, {
-   *   progress: (p) => {
-   *     console.log(`${p.outputRows}/${p.totalRows ?? "?"} rows`);
-   *   },
-   * });
-   * ```
-   */
-  progress: (progress: WriteProgress) => void;
 }
 
 export interface UpdateOptions {
@@ -158,30 +106,6 @@ export interface Version {
   metadata: Record<string, string>;
 }
 
-/**
- * Specification selecting Lance's MemWAL LSM-style write path for
- * `mergeInsert`.
- *
- * `specType` is `"bucket"`, `"identity"`, or `"unsharded"`. For `"bucket"`,
- * `column` and `numBuckets` are required; for `"identity"`, `column` is
- * required and must be a deterministic function of the unenforced primary
- * key (every row with a given primary key must always produce the same
- * `column` value, or upserts of that key can land in different shards and a
- * stale version can win).
- */
-export interface LsmWriteSpec {
-  /** One of `"bucket"`, `"identity"`, or `"unsharded"`. */
-  specType: "bucket" | "identity" | "unsharded";
-  /** Bucket and identity variants: the sharding column. */
-  column?: string;
-  /** Bucket variant: the number of buckets, in `[1, 1024]`. */
-  numBuckets?: number;
-  /** Names of indexes the MemWAL should keep up to date during writes. */
-  maintainedIndexes?: string[];
-  /** Default `ShardWriter` configuration recorded in the MemWAL index. */
-  writerConfigDefaults?: Record<string, string>;
-}
-
 /**
  * A Table is a collection of Records in a LanceDB Database.
  *
@@ -511,18 +435,6 @@ export abstract class Table {
   abstract alterColumns(
     columnAlterations: ColumnAlteration[],
   ): Promise<AlterColumnsResult>;
-
-  /**
-   * Update per-field (column) metadata.
-   * @param {FieldMetadataUpdate[]} updates One or more per-field updates. Each
-   * update's metadata is merged into the field's existing metadata by default;
-   * a value of `null` deletes that key, and `replace: true` swaps the whole map.
-   * @returns {Promise<UpdateFieldMetadataResult>} resolves to the new table version.
-   */
-  abstract updateFieldMetadata(
-    updates: FieldMetadataUpdate[],
-  ): Promise<UpdateFieldMetadataResult>;
-
   /**
    * Drop one or more columns from the dataset
    *
@@ -537,64 +449,6 @@ export abstract class Table {
    * containing the new version number of the table after dropping the columns.
    */
   abstract dropColumns(columnNames: string[]): Promise<DropColumnsResult>;
-  /**
-   * Set the unenforced primary key for this table to a single column.
-   *
-   * "Unenforced" means LanceDB does not check uniqueness on writes; the
-   * column is recorded in the schema as the primary key for use by features
-   * such as `merge_insert`. Only single-column primary keys are supported,
-   * and the key cannot be changed once set.
-   * @param {string | string[]} columns The primary key column. A one-element
-   * array is also accepted; passing more than one column is rejected.
-   * @returns {Promise<void>}
-   */
-  abstract setUnenforcedPrimaryKey(columns: string | string[]): Promise<void>;
-  /**
-   * Install an {@link LsmWriteSpec} on this table, selecting Lance's MemWAL
-   * LSM-style write path for future `mergeInsert` calls.
-   *
-   * `LsmWriteSpec` chooses one of three sharding strategies via `specType`:
-   *
-   * - `"bucket"` — hash-bucket writes by the single-column unenforced primary
-   *   key (`column` and `numBuckets` required).
-   * - `"identity"` — shard by the raw value of a scalar `column`.
-   * - `"unsharded"` — route every write to a single shard.
-   *
-   * All variants require the table to have an unenforced primary key
-   * ({@link Table#setUnenforcedPrimaryKey}); bucket sharding additionally
-   * requires it to be the single column being bucketed.
-   * @param {LsmWriteSpec} spec The sharding spec to install.
-   * @returns {Promise<void>}
-   * @example
-   * ```ts
-   * await table.setUnenforcedPrimaryKey("id");
-   * await table.setLsmWriteSpec({
-   *   specType: "bucket",
-   *   column: "id",
-   *   numBuckets: 16,
-   *   maintainedIndexes: ["id_idx"],
-   * });
-   * ```
-   */
-  abstract setLsmWriteSpec(spec: LsmWriteSpec): Promise<void>;
-  /**
-   * Remove the {@link LsmWriteSpec} from this table, reverting to the standard
-   * `mergeInsert` write path.
-   *
-   * Errors if no spec is currently set.
-   * @returns {Promise<void>}
-   */
-  abstract unsetLsmWriteSpec(): Promise<void>;
-  /**
-   * Drain and close any cached MemWAL shard writers held for this table.
-   *
-   * When an {@link LsmWriteSpec} is installed, `mergeInsert` opens MemWAL
-   * shard writers and caches them for reuse across calls. This closes them,
-   * flushing pending data; writers reopen lazily on the next `mergeInsert`.
-   * It is a no-op when no writers are cached.
-   * @returns {Promise<void>}
-   */
-  abstract closeLsmWriters(): Promise<void>;
   /** Retrieve the version of the table */
 
   abstract version(): Promise<number>;
@@ -655,14 +509,6 @@ export abstract class Table {
    */
   abstract tags(): Promise<Tags>;
 
-  /**
-   * Get the branch manager for this table.
-   *
-   * Branches are isolated, writable lines of history forked from another
-   * branch (or version). Writes on a branch do not affect `main`.
-   */
-  abstract branches(): Promise<Branches>;
-
   /**
    * Restore the table to the currently checked out version
    *
@@ -790,20 +636,7 @@ export class LocalTable extends Table {
     const schema = await this.schema();
 
     const buffer = await fromDataToBuffer(data, undefined, schema);
-    // Wrap the user callback so a thrown error doesn't surface as an
-    // unhandled exception (the callback fires from a napi threadsafe
-    // function — exceptions there crash the process).
-    const userProgress = options?.progress;
-    const progress = userProgress
-      ? (p: WriteProgress) => {
-          try {
-            userProgress(p);
-          } catch (e) {
-            console.warn("Table.add progress callback threw:", e);
-          }
-        }
-      : undefined;
-    return await this.inner.add(buffer, mode, progress);
+    return await this.inner.add(buffer, mode);
   }
 
   async update(
@@ -1060,33 +893,10 @@ export class LocalTable extends Table {
     return await this.inner.alterColumns(processedAlterations);
   }
 
-  async updateFieldMetadata(
-    updates: FieldMetadataUpdate[],
-  ): Promise<UpdateFieldMetadataResult> {
-    return await this.inner.updateFieldMetadata(updates);
-  }
-
   async dropColumns(columnNames: string[]): Promise<DropColumnsResult> {
     return await this.inner.dropColumns(columnNames);
   }
 
-  async setUnenforcedPrimaryKey(columns: string | string[]): Promise<void> {
-    const cols = typeof columns === "string" ? [columns] : columns;
-    return await this.inner.setUnenforcedPrimaryKey(cols);
-  }
-
-  async setLsmWriteSpec(spec: LsmWriteSpec): Promise<void> {
-    return await this.inner.setLsmWriteSpec(spec);
-  }
-
-  async unsetLsmWriteSpec(): Promise<void> {
-    return await this.inner.unsetLsmWriteSpec();
-  }
-
-  async closeLsmWriters(): Promise<void> {
-    return await this.inner.closeLsmWriters();
-  }
-
   async version(): Promise<number> {
     return await this.inner.version();
   }
@@ -1118,10 +928,6 @@ export class LocalTable extends Table {
     return await this.inner.tags();
   }
 
-  async branches(): Promise<Branches> {
-    return new Branches(await this.inner.branches());
-  }
-
   async optimize(options?: Partial<OptimizeOptions>): Promise<OptimizeStats> {
     let cleanupOlderThanMs;
     if (
@@ -1236,73 +1042,3 @@ export interface ColumnAlteration {
   /** Set the new nullability. Note that a nullable column cannot be made non-nullable. */
   nullable?: boolean;
 }
-
-/** A per-field metadata update, addressed by dot-path. */
-export interface FieldMetadataUpdate {
-  /**
-   * Dot-separated path to the field. For a top-level column this is just its
-   * name; for a nested field it's the path, e.g. "a.b.c".
-   */
-  path: string;
-  /**
-   * Metadata key/value pairs. Merged into the field's existing metadata by
-   * default; a value of `null` deletes that key.
-   */
-  metadata: Record<string, string | null>;
-  /** If true, replace the field's entire metadata map instead of merging. */
-  replace?: boolean;
-}
-
-/**
- * Branch manager for a {@link Table}.
- *
- * Unlike tags, `create` and `checkout` return a new {@link Table} handle scoped
- * to the branch; writes on it do not affect `main`.
- */
-export class Branches {
-  #inner: NativeBranches;
-
-  /**
-   * Construct a Branches manager. Internal use only.
-   * @hidden
-   */
-  constructor(inner: NativeBranches) {
-    this.#inner = inner;
-  }
-
-  /** List all branches, mapping name to branch metadata. */
-  async list(): Promise<Record<string, BranchContents>> {
-    return await this.#inner.list();
-  }
-
-  /**
-   * Create a branch and return a handle scoped to it.
-   *
-   * @param name Name of the new branch.
-   * @param fromRef Source branch to fork from. Defaults to `main`.
-   * @param fromVersion A specific version on `fromRef`. Defaults to latest.
-   */
-  async create(
-    name: string,
-    fromRef?: string,
-    fromVersion?: number,
-  ): Promise<Table> {
-    return new LocalTable(await this.#inner.create(name, fromRef, fromVersion));
-  }
-
-  /**
-   * Check out an existing branch and return a handle scoped to it.
-   *
-   * With `version` set, the returned handle is pinned to that version of the
-   * branch (a read-only, detached view); otherwise it tracks the branch's
-   * latest and stays writable.
-   */
-  async checkout(name: string, version?: number): Promise<Table> {
-    return new LocalTable(await this.#inner.checkout(name, version));
-  }
-
-  /** Delete a branch. */
-  async delete(name: string): Promise<void> {
-    return await this.#inner.delete(name);
-  }
-}

nodejs/npm/darwin-arm64/package.json

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

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

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

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

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

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

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

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

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

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

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

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

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

nodejs/package.json

@@ -11,7 +11,7 @@
     "ann"
   ],
   "private": false,
-  "version": "0.30.1-beta.2",
+  "version": "0.28.0-beta.11",
   "main": "dist/index.js",
   "exports": {
     ".": "./dist/index.js",
@@ -38,15 +38,15 @@
     "url": "https://github.com/lancedb/lancedb"
   },
   "devDependencies": {
-    "@aws-sdk/client-dynamodb": "3.1003.0",
-    "@aws-sdk/client-kms": "3.1003.0",
-    "@aws-sdk/client-s3": "3.1003.0",
+    "@aws-sdk/client-dynamodb": "^3.33.0",
+    "@aws-sdk/client-kms": "^3.33.0",
+    "@aws-sdk/client-s3": "^3.33.0",
     "@biomejs/biome": "^1.7.3",
     "@jest/globals": "^29.7.0",
-    "@napi-rs/cli": "3.7.0",
+    "@napi-rs/cli": "^3.5.1",
     "@types/axios": "^0.14.0",
     "@types/jest": "^29.1.2",
-    "@types/node": "22.7.4",
+    "@types/node": "^22.7.4",
     "@types/tmp": "^0.2.6",
     "apache-arrow-15": "npm:apache-arrow@15.0.0",
     "apache-arrow-16": "npm:apache-arrow@16.0.0",
@@ -57,9 +57,9 @@
     "shx": "^0.3.4",
     "tmp": "^0.2.3",
     "ts-jest": "^29.1.2",
-    "typedoc": "0.26.4",
-    "typedoc-plugin-markdown": "4.2.1",
-    "typescript": "5.5.4",
+    "typedoc": "^0.26.4",
+    "typedoc-plugin-markdown": "^4.2.1",
+    "typescript": "^5.5.4",
     "typescript-eslint": "^7.1.0"
   },
   "ava": {
@@ -68,16 +68,15 @@
   "engines": {
     "node": ">= 18"
   },
-  "packageManager": "pnpm@11.1.1",
   "cpu": ["x64", "arm64"],
   "os": ["darwin", "linux", "win32"],
   "scripts": {
     "artifacts": "napi artifacts",
     "build:debug": "napi build --platform --dts ../lancedb/native.d.ts --js ../lancedb/native.js --output-dir lancedb",
-    "postbuild:debug": "shx mkdir -p dist && shx cp lancedb/*.node dist/ && node -e \"require('fs').writeFileSync('dist/package.json', JSON.stringify({name:'@lancedb/lancedb',type:'commonjs'}))\"",
+    "postbuild:debug": "shx mkdir -p dist && shx cp lancedb/*.node dist/",
     "build:release": "napi build --platform --release --dts ../lancedb/native.d.ts --js ../lancedb/native.js --output-dir dist",
-    "build": "pnpm build:debug && pnpm tsc",
-    "build-release": "pnpm build:release && pnpm tsc",
+    "build": "npm run build:debug && npm run tsc",
+    "build-release": "npm run build:release && npm run tsc",
     "tsc": "tsc -b",
     "posttsc": "shx cp lancedb/native.d.ts dist/native.d.ts",
     "lint-ci": "biome ci .",
@@ -87,7 +86,7 @@
     "lint-fix": "biome check --write . && biome format --write .",
     "prepublishOnly": "napi prepublish -t npm",
     "test": "jest --verbose",
-    "integration": "S3_TEST=1 pnpm test",
+    "integration": "S3_TEST=1 npm run test",
     "universal": "napi universalize",
     "version": "napi version"
   },
@@ -95,8 +94,8 @@
     "reflect-metadata": "^0.2.2"
   },
   "optionalDependencies": {
-    "@huggingface/transformers": "3.0.2",
-    "openai": "4.29.2"
+    "@huggingface/transformers": "^3.0.2",
+    "openai": "^4.29.2"
   },
   "peerDependencies": {
     "apache-arrow": ">=15.0.0 <=18.1.0"

nodejs/pnpm-workspace.yaml

@@ -1,18 +0,0 @@
-# Flat node_modules layout. The @napi-rs/cli build step fails to locate
-# the cdylib artifact under pnpm's isolated layout; the hoisted linker
-# mirrors npm's structure and unblocks the native build.
-nodeLinker: hoisted
-
-# Block resolution of versions less than 24h old (Shai-Hulud window).
-# This is the pnpm 11 default but pinned here so it's visible to
-# reviewers and survives a future pnpm major flipping the default.
-minimumReleaseAge: 1440
-
-# Fail install if a transitive dep tries to run an unapproved script.
-strictDepBuilds: true
-
-allowBuilds:
-  '@biomejs/biome': true
-  onnxruntime-node: true
-  protobufjs: true
-  sharp: true

nodejs/src/connection.rs

@@ -8,16 +8,12 @@ use lancedb::database::{CreateTableMode, Database};
 use napi::bindgen_prelude::*;
 use napi_derive::*;
 
-use crate::ConnectNamespaceOptions;
 use crate::ConnectionOptions;
 use crate::error::NapiErrorExt;
 use crate::header::JsHeaderProvider;
 use crate::table::Table;
-use lancedb::connection::{ConnectBuilder, Connection as LanceDBConnection, connect_namespace};
+use lancedb::connection::{ConnectBuilder, Connection as LanceDBConnection};
 
-use lance_namespace::models::{
-    CreateNamespaceRequest, DescribeNamespaceRequest, DropNamespaceRequest, ListNamespacesRequest,
-};
 use lancedb::ipc::{ipc_file_to_batches, ipc_file_to_schema};
 
 #[napi]
@@ -25,29 +21,6 @@ pub struct Connection {
     inner: Option<LanceDBConnection>,
 }
 
-#[napi(object)]
-pub struct DescribeNamespaceResponse {
-    pub properties: Option<HashMap<String, String>>,
-}
-
-#[napi(object)]
-pub struct ListNamespacesResponse {
-    pub namespaces: Vec<String>,
-    pub page_token: Option<String>,
-}
-
-#[napi(object)]
-pub struct CreateNamespaceResponse {
-    pub properties: Option<HashMap<String, String>>,
-    pub transaction_id: Option<String>,
-}
-
-#[napi(object)]
-pub struct DropNamespaceResponse {
-    pub properties: Option<HashMap<String, String>>,
-    pub transaction_id: Option<Vec<String>>,
-}
-
 impl Connection {
     pub(crate) fn inner_new(inner: LanceDBConnection) -> Self {
         Self { inner: Some(inner) }
@@ -133,39 +106,6 @@ impl Connection {
         Ok(Self::inner_new(builder.execute().await.default_error()?))
     }
 
-    /// Create a new Connection instance backed by a namespace implementation.
-    #[napi(factory)]
-    pub async fn new_with_namespace(
-        impl_name: String,
-        properties: HashMap<String, String>,
-        options: ConnectNamespaceOptions,
-    ) -> napi::Result<Self> {
-        if impl_name.is_empty() {
-            return Err(napi::Error::from_reason(
-                "implName must be a non-empty string",
-            ));
-        }
-
-        let mut builder = connect_namespace(&impl_name, properties);
-        if let Some(interval) = options.read_consistency_interval {
-            builder =
-                builder.read_consistency_interval(std::time::Duration::from_secs_f64(interval));
-        }
-        if let Some(storage_options) = options.storage_options {
-            for (key, value) in storage_options {
-                builder = builder.storage_option(key, value);
-            }
-        }
-        if let Some(namespace_client_properties) = options.namespace_client_properties {
-            builder = builder.namespace_client_properties(namespace_client_properties);
-        }
-        if let Some(session) = options.session {
-            builder = builder.session(session.inner.clone());
-        }
-
-        Ok(Self::inner_new(builder.execute().await.default_error()?))
-    }
-
     #[napi]
     pub fn display(&self) -> napi::Result<String> {
         Ok(self.get_inner()?.to_string())
@@ -333,149 +273,4 @@ impl Connection {
         let ns = namespace_path.unwrap_or_default();
         self.get_inner()?.drop_all_tables(&ns).await.default_error()
     }
-
-    #[napi(catch_unwind)]
-    /// Describe a namespace and return its properties.
-    pub async fn describe_namespace(
-        &self,
-        namespace_path: Vec<String>,
-    ) -> napi::Result<DescribeNamespaceResponse> {
-        let req = DescribeNamespaceRequest {
-            id: Some(namespace_path),
-            ..Default::default()
-        };
-        let resp = self
-            .get_inner()?
-            .describe_namespace(req)
-            .await
-            .default_error()?;
-        Ok(DescribeNamespaceResponse {
-            properties: resp.properties,
-        })
-    }
-
-    #[napi(catch_unwind)]
-    /// List child namespaces under the given namespace path
-    pub async fn list_namespaces(
-        &self,
-        namespace_path: Option<Vec<String>>,
-        page_token: Option<String>,
-        limit: Option<u32>,
-    ) -> napi::Result<ListNamespacesResponse> {
-        let req = ListNamespacesRequest {
-            id: namespace_path,
-            page_token,
-            limit: limit.map(|l| l as i32),
-            ..Default::default()
-        };
-        let resp = self
-            .get_inner()?
-            .list_namespaces(req)
-            .await
-            .default_error()?;
-        Ok(ListNamespacesResponse {
-            namespaces: resp.namespaces,
-            page_token: resp.page_token,
-        })
-    }
-
-    #[napi(catch_unwind)]
-    /// Create a new namespace with optional properties.
-    pub async fn create_namespace(
-        &self,
-        namespace_path: Vec<String>,
-        mode: Option<String>,
-        properties: Option<HashMap<String, String>>,
-    ) -> napi::Result<CreateNamespaceResponse> {
-        let mode_str = mode
-            .map(|m| match m.to_lowercase().as_str() {
-                "create" => Ok("Create".to_string()),
-                "exist_ok" => Ok("ExistOk".to_string()),
-                "overwrite" => Ok("Overwrite".to_string()),
-                _ => Err(napi::Error::from_reason(format!(
-                    "Invalid mode '{}': expected one of 'create', 'exist_ok', 'overwrite'",
-                    m
-                ))),
-            })
-            .transpose()?;
-        let req = CreateNamespaceRequest {
-            id: Some(namespace_path),
-            mode: mode_str,
-            properties,
-            ..Default::default()
-        };
-        let resp = self
-            .get_inner()?
-            .create_namespace(req)
-            .await
-            .default_error()?;
-        Ok(CreateNamespaceResponse {
-            properties: resp.properties,
-            transaction_id: resp.transaction_id,
-        })
-    }
-
-    #[napi(catch_unwind)]
-    /// Drop a namespace.
-    pub async fn drop_namespace(
-        &self,
-        namespace_path: Vec<String>,
-        mode: Option<String>,
-        behavior: Option<String>,
-    ) -> napi::Result<DropNamespaceResponse> {
-        let mode_str = mode
-            .map(|m| match m.to_lowercase().as_str() {
-                "skip" => Ok("Skip".to_string()),
-                "fail" => Ok("Fail".to_string()),
-                _ => Err(napi::Error::from_reason(format!(
-                    "Invalid mode '{}': expected one of 'skip', 'fail'",
-                    m
-                ))),
-            })
-            .transpose()?;
-        let behavior_str = behavior
-            .map(|b| match b.to_lowercase().as_str() {
-                "restrict" => Ok("Restrict".to_string()),
-                "cascade" => Ok("Cascade".to_string()),
-                _ => Err(napi::Error::from_reason(format!(
-                    "Invalid behavior '{}': expected one of 'restrict', 'cascade'",
-                    b
-                ))),
-            })
-            .transpose()?;
-        let req = DropNamespaceRequest {
-            id: Some(namespace_path),
-            mode: mode_str,
-            behavior: behavior_str,
-            ..Default::default()
-        };
-        let resp = self
-            .get_inner()?
-            .drop_namespace(req)
-            .await
-            .default_error()?;
-        Ok(DropNamespaceResponse {
-            properties: resp.properties,
-            transaction_id: resp.transaction_id,
-        })
-    }
-
-    /// Rename a table. `current_namespace_path` and `new_namespace_path` default to
-    /// the root namespace when omitted; the caller is expected to either pass both
-    /// or pass neither.
-    #[napi(catch_unwind)]
-    pub async fn rename_table(
-        &self,
-        current_name: String,
-        new_name: String,
-        current_namespace_path: Option<Vec<String>>,
-        new_namespace_path: Option<Vec<String>>,
-    ) -> napi::Result<()> {
-        let cur_ns = current_namespace_path.unwrap_or_default();
-        let new_ns = new_namespace_path.unwrap_or_default();
-        self.get_inner()?
-            .rename_table(&current_name, &new_name, &cur_ns, &new_ns)
-            .await
-            .default_error()
-    }
 }

nodejs/src/index.rs

@@ -4,7 +4,7 @@
 use std::sync::Mutex;
 
 use lancedb::index::Index as LanceDbIndex;
-use lancedb::index::scalar::{BTreeIndexBuilder, FmIndexBuilder, FtsIndexBuilder};
+use lancedb::index::scalar::{BTreeIndexBuilder, FtsIndexBuilder};
 use lancedb::index::vector::{
     IvfFlatIndexBuilder, IvfHnswPqIndexBuilder, IvfHnswSqIndexBuilder, IvfPqIndexBuilder,
     IvfRqIndexBuilder,
@@ -143,13 +143,6 @@ impl Index {
         }
     }
 
-    #[napi(factory)]
-    pub fn fm() -> Self {
-        Self {
-            inner: Mutex::new(Some(LanceDbIndex::Fm(FmIndexBuilder::default()))),
-        }
-    }
-
     #[napi(factory)]
     #[allow(clippy::too_many_arguments)]
     pub fn fts(

nodejs/src/lib.rs

@@ -16,7 +16,6 @@ pub mod permutation;
 mod query;
 pub mod remote;
 mod rerankers;
-mod scannable;
 mod session;
 mod table;
 mod util;
@@ -24,19 +23,15 @@ mod util;
 #[napi(object)]
 #[derive(Debug)]
 pub struct ConnectionOptions {
-    /// The interval, in seconds, at which to check for updates to the table
-    /// from other processes. If None, then consistency is not checked. For
-    /// performance reasons, this is the default. For strong consistency, set
-    /// this to zero seconds. Then every read will check for updates from other
-    /// processes. As a compromise, you can set this to a non-zero value for
-    /// eventual consistency. If more than that interval has passed since the
-    /// last check, then the table will be checked for updates. Note: this
-    /// consistency only applies to read operations. Write operations are
+    /// (For LanceDB OSS only): The interval, in seconds, at which to check for
+    /// updates to the table from other processes. If None, then consistency is not
+    /// checked. For performance reasons, this is the default. For strong
+    /// consistency, set this to zero seconds. Then every read will check for
+    /// updates from other processes. As a compromise, you can set this to a
+    /// non-zero value for eventual consistency. If more than that interval
+    /// has passed since the last check, then the table will be checked for updates.
+    /// Note: this consistency only applies to read operations. Write operations are
     /// always consistent.
-    ///
-    /// Stronger consistency is not free. The smaller the interval, the more
-    /// often each read pays the cost of checking for updates against object
-    /// storage, raising per-read latency and cost.
     pub read_consistency_interval: Option<f64>,
     /// (For LanceDB OSS only): configuration for object storage.
     ///
@@ -72,26 +67,6 @@ pub struct OpenTableOptions {
     pub storage_options: Option<HashMap<String, String>>,
 }
 
-#[napi(object)]
-#[derive(Debug)]
-pub struct ConnectNamespaceOptions {
-    /// The interval, in seconds, at which to check for updates to the table
-    /// from other processes. If None, then consistency is not checked. For
-    /// performance reasons, this is the default. For strong consistency, set
-    /// this to zero seconds. Then every read will check for updates from other
-    /// processes. As a compromise, you can set this to a non-zero value for
-    /// eventual consistency.
-    pub read_consistency_interval: Option<f64>,
-    /// Configuration for object storage. The available options are described
-    /// at https://docs.lancedb.com/storage/
-    pub storage_options: Option<HashMap<String, String>>,
-    /// Extra properties for the backing namespace client.
-    pub namespace_client_properties: Option<HashMap<String, String>>,
-    /// The session to use for this connection. Holds shared caches and other
-    /// session-specific state.
-    pub session: Option<session::Session>,
-}
-
 #[napi_derive::module_init]
 fn init() {
     let env = Env::new()

nodejs/src/merge.rs

@@ -50,20 +50,6 @@ impl NativeMergeInsertBuilder {
         this
     }
 
-    #[napi]
-    pub fn use_lsm_write(&self, use_lsm_write: bool) -> Self {
-        let mut this = self.clone();
-        this.inner.use_lsm_write(use_lsm_write);
-        this
-    }
-
-    #[napi]
-    pub fn validate_single_shard(&self, validate_single_shard: bool) -> Self {
-        let mut this = self.clone();
-        this.inner.validate_single_shard(validate_single_shard);
-        this
-    }
-
     #[napi(catch_unwind)]
     pub async fn execute(&self, buf: Buffer) -> napi::Result<MergeResult> {
         let data = ipc_file_to_batches(buf.to_vec())

nodejs/src/query.rs

@@ -3,12 +3,6 @@
 
 use std::sync::Arc;
 
-use crate::error::NapiErrorExt;
-use crate::error::convert_error;
-use crate::iterator::RecordBatchIterator;
-use crate::rerankers::RerankHybridCallbackArgs;
-use crate::rerankers::Reranker;
-use crate::util::{parse_distance_type, schema_to_buffer};
 use arrow_array::{
     Array, Float16Array as ArrowFloat16Array, Float32Array as ArrowFloat32Array,
     Float64Array as ArrowFloat64Array, UInt8Array as ArrowUInt8Array,
@@ -25,27 +19,16 @@ use lancedb::query::QueryBase;
 use lancedb::query::QueryExecutionOptions;
 use lancedb::query::Select;
 use lancedb::query::TakeQuery as LanceDbTakeQuery;
-use lancedb::query::{ColumnOrdering as LanceDbColumnOrdering, VectorQuery as LanceDbVectorQuery};
+use lancedb::query::VectorQuery as LanceDbVectorQuery;
 use napi::bindgen_prelude::*;
 use napi_derive::napi;
 
-#[napi(object)]
-pub struct ColumnOrdering {
-    pub ascending: bool,
-    pub nulls_first: bool,
-    pub column_name: String,
-}
-
-impl From<ColumnOrdering> for LanceDbColumnOrdering {
-    fn from(value: ColumnOrdering) -> Self {
-        match (value.ascending, value.nulls_first) {
-            (true, true) => Self::asc_nulls_first(value.column_name),
-            (true, false) => Self::asc_nulls_last(value.column_name),
-            (false, true) => Self::desc_nulls_first(value.column_name),
-            (false, false) => Self::desc_nulls_last(value.column_name),
-        }
-    }
-}
+use crate::error::NapiErrorExt;
+use crate::error::convert_error;
+use crate::iterator::RecordBatchIterator;
+use crate::rerankers::RerankHybridCallbackArgs;
+use crate::rerankers::Reranker;
+use crate::util::{parse_distance_type, schema_to_buffer};
 
 fn bytes_to_arrow_array(data: Uint8Array, dtype: String) -> napi::Result<Arc<dyn Array>> {
     let buf = arrow_buffer::Buffer::from(data.to_vec());
@@ -145,18 +128,6 @@ impl Query {
         self.inner = self.inner.clone().with_row_id();
     }
 
-    #[napi]
-    pub fn order_by(&mut self, ordering: Option<Vec<ColumnOrdering>>) -> napi::Result<()> {
-        let ordering = ordering.map(|ordering| {
-            ordering
-                .into_iter()
-                .map(LanceDbColumnOrdering::from)
-                .collect()
-        });
-        self.inner = self.inner.clone().order_by(ordering);
-        Ok(())
-    }
-
     #[napi(catch_unwind)]
     pub async fn output_schema(&self) -> napi::Result<Buffer> {
         let schema = self.inner.output_schema().await.default_error()?;
@@ -357,18 +328,6 @@ impl VectorQuery {
         Ok(())
     }
 
-    #[napi]
-    pub fn order_by(&mut self, ordering: Option<Vec<ColumnOrdering>>) -> napi::Result<()> {
-        let ordering = ordering.map(|ordering| {
-            ordering
-                .into_iter()
-                .map(LanceDbColumnOrdering::from)
-                .collect()
-        });
-        self.inner = self.inner.clone().order_by(ordering);
-        Ok(())
-    }
-
     #[napi(catch_unwind)]
     pub async fn output_schema(&self) -> napi::Result<Buffer> {
         let schema = self.inner.output_schema().await.default_error()?;