Bump version: 0.21.4-beta.1 → 0.22.0-beta.0

2025-12-25 06:19:57 +00:00 · 2025-08-29 21:20:19 +00:00
39 changed files with 683 additions and 1453 deletions
--- a/.bumpversion.toml
+++ b/.bumpversion.toml
@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.22.0"
+current_version = "0.22.0-beta.0"
 parse = """(?x)
    (?P<major>0|[1-9]\\d*)\\.
    (?P<minor>0|[1-9]\\d*)\\.
--- a/Cargo.lock
+++ b/Cargo.lock
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -15,14 +15,14 @@ categories = ["database-implementations"]
 rust-version = "1.78.0"

 [workspace.dependencies]
-lance = { "version" = "=0.35.0", default-features = false, "features" = ["dynamodb"], "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-io = { "version" = "=0.35.0", default-features = false, "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-index = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-linalg = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-table = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-testing = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-datafusion = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
-lance-encoding = { "version" = "=0.35.0", "tag" = "v0.35.0-beta.4", "git" = "https://github.com/lancedb/lance.git" }
+lance = { "version" = "=0.34.0", default-features = false, "features" = ["dynamodb"], "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-io = { "version" = "=0.34.0", default-features = false, "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-index = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-linalg = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-table = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-testing = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-datafusion = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
+lance-encoding = { "version" = "=0.34.0", "tag" = "v0.34.0-beta.3", "git" = "https://github.com/lancedb/lance.git" }
 # Note that this one does not include pyarrow
 arrow = { version = "55.1", optional = false }
 arrow-array = "55.1"
@@ -33,12 +33,12 @@ arrow-schema = "55.1"
 arrow-arith = "55.1"
 arrow-cast = "55.1"
 async-trait = "0"
-datafusion = { version = "49.0", default-features = false }
-datafusion-catalog = "49.0"
-datafusion-common = { version = "49.0", default-features = false }
-datafusion-execution = "49.0"
-datafusion-expr = "49.0"
-datafusion-physical-plan = "49.0"
+datafusion = { version = "48.0", default-features = false }
+datafusion-catalog = "48.0"
+datafusion-common = { version = "48.0", default-features = false }
+datafusion-execution = "48.0"
+datafusion-expr = "48.0"
+datafusion-physical-plan = "48.0"
 env_logger = "0.11"
 half = { "version" = "2.6.0", default-features = false, features = [
    "num-traits",
--- a/java/core/pom.xml
+++ b/java/core/pom.xml
@@ -8,7 +8,7 @@
    <parent>
        <groupId>com.lancedb</groupId>
        <artifactId>lancedb-parent</artifactId>
-        <version>0.22.0-final.0</version>
+        <version>0.22.0-beta.0</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

--- a/java/lance-namespace/pom.xml
+++ b/java/lance-namespace/pom.xml
@@ -8,7 +8,7 @@
    <parent>
        <groupId>com.lancedb</groupId>
        <artifactId>lancedb-parent</artifactId>
-        <version>0.22.0-final.0</version>
+        <version>0.22.0-beta.0</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

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

    <groupId>com.lancedb</groupId>
    <artifactId>lancedb-parent</artifactId>
-    <version>0.22.0-final.0</version>
+    <version>0.22.0-beta.0</version>
    <packaging>pom</packaging>
    <name>${project.artifactId}</name>
    <description>LanceDB Java SDK Parent POM</description>
--- a/nodejs/Cargo.toml
+++ b/nodejs/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "lancedb-nodejs"
 edition.workspace = true
-version = "0.22.0"
+version = "0.22.0-beta.0"
 license.workspace = true
 description.workspace = true
 repository.workspace = true
--- a/nodejs/test/remote.test.ts
+++ b/nodejs/test/remote.test.ts
@@ -3,13 +3,7 @@

 import * as http from "http";
 import { RequestListener } from "http";
-import {
-  ClientConfig,
-  Connection,
-  ConnectionOptions,
-  TlsConfig,
-  connect,
-} from "../lancedb";
+import { Connection, ConnectionOptions, connect } from "../lancedb";

 async function withMockDatabase(
  listener: RequestListener,
@@ -154,88 +148,4 @@ describe("remote connection", () => {
      },
    );
  });
-
-  describe("TlsConfig", () => {
-    it("should create TlsConfig with all fields", () => {
-      const tlsConfig: TlsConfig = {
-        certFile: "/path/to/cert.pem",
-        keyFile: "/path/to/key.pem",
-        sslCaCert: "/path/to/ca.pem",
-        assertHostname: false,
-      };
-
-      expect(tlsConfig.certFile).toBe("/path/to/cert.pem");
-      expect(tlsConfig.keyFile).toBe("/path/to/key.pem");
-      expect(tlsConfig.sslCaCert).toBe("/path/to/ca.pem");
-      expect(tlsConfig.assertHostname).toBe(false);
-    });
-
-    it("should create TlsConfig with partial fields", () => {
-      const tlsConfig: TlsConfig = {
-        certFile: "/path/to/cert.pem",
-        keyFile: "/path/to/key.pem",
-      };
-
-      expect(tlsConfig.certFile).toBe("/path/to/cert.pem");
-      expect(tlsConfig.keyFile).toBe("/path/to/key.pem");
-      expect(tlsConfig.sslCaCert).toBeUndefined();
-      expect(tlsConfig.assertHostname).toBeUndefined();
-    });
-
-    it("should create ClientConfig with TlsConfig", () => {
-      const tlsConfig: TlsConfig = {
-        certFile: "/path/to/cert.pem",
-        keyFile: "/path/to/key.pem",
-        sslCaCert: "/path/to/ca.pem",
-        assertHostname: true,
-      };
-
-      const clientConfig: ClientConfig = {
-        userAgent: "test-agent",
-        tlsConfig: tlsConfig,
-      };
-
-      expect(clientConfig.userAgent).toBe("test-agent");
-      expect(clientConfig.tlsConfig).toBeDefined();
-      expect(clientConfig.tlsConfig?.certFile).toBe("/path/to/cert.pem");
-      expect(clientConfig.tlsConfig?.keyFile).toBe("/path/to/key.pem");
-      expect(clientConfig.tlsConfig?.sslCaCert).toBe("/path/to/ca.pem");
-      expect(clientConfig.tlsConfig?.assertHostname).toBe(true);
-    });
-
-    it("should handle empty TlsConfig", () => {
-      const tlsConfig: TlsConfig = {};
-
-      expect(tlsConfig.certFile).toBeUndefined();
-      expect(tlsConfig.keyFile).toBeUndefined();
-      expect(tlsConfig.sslCaCert).toBeUndefined();
-      expect(tlsConfig.assertHostname).toBeUndefined();
-    });
-
-    it("should accept TlsConfig in connection options", () => {
-      const tlsConfig: TlsConfig = {
-        certFile: "/path/to/cert.pem",
-        keyFile: "/path/to/key.pem",
-        sslCaCert: "/path/to/ca.pem",
-        assertHostname: false,
-      };
-
-      // Just verify that the ClientConfig accepts the TlsConfig
-      const clientConfig: ClientConfig = {
-        tlsConfig: tlsConfig,
-      };
-
-      const connectionOptions: ConnectionOptions = {
-        apiKey: "fake",
-        clientConfig: clientConfig,
-      };
-
-      // Verify the configuration structure is correct
-      expect(connectionOptions.clientConfig).toBeDefined();
-      expect(connectionOptions.clientConfig?.tlsConfig).toBeDefined();
-      expect(connectionOptions.clientConfig?.tlsConfig?.certFile).toBe(
-        "/path/to/cert.pem",
-      );
-    });
-  });
 });
--- a/nodejs/lancedb/index.ts
+++ b/nodejs/lancedb/index.ts
@@ -21,7 +21,6 @@ export {
  ClientConfig,
  TimeoutConfig,
  RetryConfig,
-  TlsConfig,
  OptimizeStats,
  CompactionStats,
  RemovalStats,
--- a/nodejs/npm/darwin-arm64/package.json
+++ b/nodejs/npm/darwin-arm64/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-darwin-arm64",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["darwin"],
 	"cpu": ["arm64"],
 	"main": "lancedb.darwin-arm64.node",
--- a/nodejs/npm/darwin-x64/package.json
+++ b/nodejs/npm/darwin-x64/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-darwin-x64",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["darwin"],
 	"cpu": ["x64"],
 	"main": "lancedb.darwin-x64.node",
--- a/nodejs/npm/linux-arm64-gnu/package.json
+++ b/nodejs/npm/linux-arm64-gnu/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-gnu",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-gnu.node",
--- a/nodejs/npm/linux-arm64-musl/package.json
+++ b/nodejs/npm/linux-arm64-musl/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-arm64-musl",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["arm64"],
 	"main": "lancedb.linux-arm64-musl.node",
--- a/nodejs/npm/linux-x64-gnu/package.json
+++ b/nodejs/npm/linux-x64-gnu/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-gnu",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-gnu.node",
--- a/nodejs/npm/linux-x64-musl/package.json
+++ b/nodejs/npm/linux-x64-musl/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-linux-x64-musl",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["linux"],
 	"cpu": ["x64"],
 	"main": "lancedb.linux-x64-musl.node",
--- a/nodejs/npm/win32-arm64-msvc/package.json
+++ b/nodejs/npm/win32-arm64-msvc/package.json
@@ -1,6 +1,6 @@
 {
  "name": "@lancedb/lancedb-win32-arm64-msvc",
-  "version": "0.22.0",
+  "version": "0.22.0-beta.0",
  "os": [
    "win32"
  ],
--- a/nodejs/npm/win32-x64-msvc/package.json
+++ b/nodejs/npm/win32-x64-msvc/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "@lancedb/lancedb-win32-x64-msvc",
-	"version": "0.22.0",
+	"version": "0.22.0-beta.0",
 	"os": ["win32"],
 	"cpu": ["x64"],
 	"main": "lancedb.win32-x64-msvc.node",
--- a/nodejs/package-lock.json
+++ b/nodejs/package-lock.json
@@ -1,12 +1,12 @@
 {
  "name": "@lancedb/lancedb",
-  "version": "0.22.0",
+  "version": "0.21.4-beta.1",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "@lancedb/lancedb",
-      "version": "0.22.0",
+      "version": "0.21.4-beta.1",
      "cpu": [
        "x64",
        "arm64"
--- a/nodejs/package.json
+++ b/nodejs/package.json
@@ -11,7 +11,7 @@
    "ann"
  ],
  "private": false,
-  "version": "0.22.0",
+  "version": "0.22.0-beta.0",
  "main": "dist/index.js",
  "exports": {
    ".": "./dist/index.js",
--- a/nodejs/src/query.rs
+++ b/nodejs/src/query.rs
@@ -480,7 +480,6 @@ impl JsFullTextQuery {
    }

    #[napi(factory)]
-    #[allow(clippy::use_self)] // NAPI doesn't allow Self here but clippy reports it
    pub fn boolean_query(queries: Vec<(String, &JsFullTextQuery)>) -> napi::Result<Self> {
        let mut sub_queries = Vec::with_capacity(queries.len());
        for (occur, q) in queries {
--- a/nodejs/src/remote.rs
+++ b/nodejs/src/remote.rs
@@ -69,20 +69,6 @@ pub struct RetryConfig {
    pub statuses: Option<Vec<u16>>,
 }

-/// TLS/mTLS configuration for the remote HTTP client.
-#[napi(object)]
-#[derive(Debug, Default)]
-pub struct TlsConfig {
-    /// Path to the client certificate file (PEM format) for mTLS authentication.
-    pub cert_file: Option<String>,
-    /// Path to the client private key file (PEM format) for mTLS authentication.
-    pub key_file: Option<String>,
-    /// Path to the CA certificate file (PEM format) for server verification.
-    pub ssl_ca_cert: Option<String>,
-    /// Whether to verify the hostname in the server's certificate.
-    pub assert_hostname: Option<bool>,
-}
-
 #[napi(object)]
 #[derive(Debug, Default)]
 pub struct ClientConfig {
@@ -91,7 +77,6 @@ pub struct ClientConfig {
    pub timeout_config: Option<TimeoutConfig>,
    pub extra_headers: Option<HashMap<String, String>>,
    pub id_delimiter: Option<String>,
-    pub tls_config: Option<TlsConfig>,
 }

 impl From<TimeoutConfig> for lancedb::remote::TimeoutConfig {
@@ -122,17 +107,6 @@ impl From<RetryConfig> for lancedb::remote::RetryConfig {
    }
 }

-impl From<TlsConfig> for lancedb::remote::TlsConfig {
-    fn from(config: TlsConfig) -> Self {
-        Self {
-            cert_file: config.cert_file,
-            key_file: config.key_file,
-            ssl_ca_cert: config.ssl_ca_cert,
-            assert_hostname: config.assert_hostname.unwrap_or(true),
-        }
-    }
-}
-
 impl From<ClientConfig> for lancedb::remote::ClientConfig {
    fn from(config: ClientConfig) -> Self {
        Self {
@@ -143,7 +117,6 @@ impl From<ClientConfig> for lancedb::remote::ClientConfig {
            timeout_config: config.timeout_config.map(Into::into).unwrap_or_default(),
            extra_headers: config.extra_headers.unwrap_or_default(),
            id_delimiter: config.id_delimiter,
-            tls_config: config.tls_config.map(Into::into),
        }
    }
 }
--- a/python/.bumpversion.toml
+++ b/python/.bumpversion.toml
@@ -1,5 +1,5 @@
 [tool.bumpversion]
-current_version = "0.25.1-beta.0"
+current_version = "0.25.0-beta.0"
 parse = """(?x)
    (?P<major>0|[1-9]\\d*)\\.
    (?P<minor>0|[1-9]\\d*)\\.
--- a/python/Cargo.toml
+++ b/python/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "lancedb-python"
-version = "0.25.1-beta.0"
+version = "0.25.0-beta.0"
 edition.workspace = true
 description = "Python bindings for LanceDB"
 license.workspace = true
--- a/python/python/lancedb/db.py
+++ b/python/python/lancedb/db.py
@@ -95,10 +95,9 @@ class DBConnection(EnforceOverrides):
    @abstractmethod
    def table_names(
        self,
+        namespace: List[str] = [],
        page_token: Optional[str] = None,
        limit: int = 10,
-        *,
-        namespace: List[str] = [],
    ) -> Iterable[str]:
        """List all tables in this database, in sorted order

@@ -544,10 +543,9 @@ class LanceDBConnection(DBConnection):
    @override
    def table_names(
        self,
+        namespace: List[str] = [],
        page_token: Optional[str] = None,
        limit: int = 10,
-        *,
-        namespace: List[str] = [],
    ) -> Iterable[str]:
        """Get the names of all tables in the database. The names are sorted.

--- a/python/python/lancedb/namespace.py
+++ b/python/python/lancedb/namespace.py
@@ -138,10 +138,9 @@ class LanceNamespaceDBConnection(DBConnection):
    @override
    def table_names(
        self,
+        namespace: List[str] = [],
        page_token: Optional[str] = None,
        limit: int = 10,
-        *,
-        namespace: List[str] = [],
    ) -> Iterable[str]:
        request = ListTablesRequest(id=namespace, page_token=page_token, limit=limit)
        response = self._ns.list_tables(request)
@@ -191,7 +190,7 @@ class LanceNamespaceDBConnection(DBConnection):
        json_schema = _convert_pyarrow_schema_to_json(schema)

        # Create table request with namespace
-        table_id = namespace + [name]
+        table_id = (namespace or []) + [name]
        request = CreateTableRequest(id=table_id, var_schema=json_schema)

        # Create empty Arrow IPC stream bytes
@@ -220,7 +219,7 @@ class LanceNamespaceDBConnection(DBConnection):
        storage_options: Optional[Dict[str, str]] = None,
        index_cache_size: Optional[int] = None,
    ) -> Table:
-        table_id = namespace + [name]
+        table_id = (namespace or []) + [name]
        request = DescribeTableRequest(id=table_id)
        response = self._ns.describe_table(request)

@@ -237,9 +236,9 @@ class LanceNamespaceDBConnection(DBConnection):
        )

    @override
-    def drop_table(self, name: str, namespace: List[str] = []):
+    def drop_table(self, name: str, namespace: Optional[List[str]] = None):
        # Use namespace drop_table directly
-        table_id = namespace + [name]
+        table_id = (namespace or []) + [name]
        request = DropTableRequest(id=table_id)
        self._ns.drop_table(request)

@@ -248,8 +247,8 @@ class LanceNamespaceDBConnection(DBConnection):
        self,
        cur_name: str,
        new_name: str,
-        cur_namespace: List[str] = [],
-        new_namespace: List[str] = [],
+        cur_namespace: Optional[List[str]] = None,
+        new_namespace: Optional[List[str]] = None,
    ):
        raise NotImplementedError(
            "rename_table is not supported for namespace connections"
@@ -262,7 +261,7 @@ class LanceNamespaceDBConnection(DBConnection):
        )

    @override
-    def drop_all_tables(self, namespace: List[str] = []):
+    def drop_all_tables(self, namespace: Optional[List[str]] = None):
        for table_name in self.table_names(namespace=namespace):
            self.drop_table(table_name, namespace=namespace)

--- a/python/python/lancedb/query.py
+++ b/python/python/lancedb/query.py
@@ -943,22 +943,20 @@ class LanceQueryBuilder(ABC):
        >>> query = [100, 100]
        >>> plan = table.search(query).analyze_plan()
        >>> print(plan)  # doctest: +ELLIPSIS, +NORMALIZE_WHITESPACE
-        AnalyzeExec verbose=true, metrics=[], cumulative_cpu=...
-          TracedExec, metrics=[], cumulative_cpu=...
-            ProjectionExec: expr=[...], metrics=[...], cumulative_cpu=...
-              GlobalLimitExec: skip=0, fetch=10, metrics=[...], cumulative_cpu=...
+        AnalyzeExec verbose=true, metrics=[]
+          TracedExec, metrics=[]
+            ProjectionExec: expr=[...], metrics=[...]
+              GlobalLimitExec: skip=0, fetch=10, metrics=[...]
                FilterExec: _distance@2 IS NOT NULL,
-                metrics=[output_rows=..., elapsed_compute=...], cumulative_cpu=...
+                metrics=[output_rows=..., elapsed_compute=...]
                  SortExec: TopK(fetch=10), expr=[...],
                  preserve_partitioning=[...],
-                  metrics=[output_rows=..., elapsed_compute=..., row_replacements=...],
-                  cumulative_cpu=...
+                  metrics=[output_rows=..., elapsed_compute=..., row_replacements=...]
                    KNNVectorDistance: metric=l2,
-                    metrics=[output_rows=..., elapsed_compute=..., output_batches=...],
-                    cumulative_cpu=...
+                    metrics=[output_rows=..., elapsed_compute=..., output_batches=...]
                      LanceRead: uri=..., projection=[vector], ...
                      metrics=[output_rows=..., elapsed_compute=...,
-                      bytes_read=..., iops=..., requests=...], cumulative_cpu=...
+                      bytes_read=..., iops=..., requests=...]

        Returns
        -------
--- a/python/python/lancedb/remote/init.py
+++ b/python/python/lancedb/remote/init.py
@@ -8,7 +8,7 @@ from typing import List, Optional

 from lancedb import __version__

-__all__ = ["TimeoutConfig", "RetryConfig", "TlsConfig", "ClientConfig"]
+__all__ = ["TimeoutConfig", "RetryConfig", "ClientConfig"]


@dataclass
@@ -112,29 +112,6 @@ class RetryConfig:
    statuses: Optional[List[int]] = None


-@dataclass
-class TlsConfig:
-    """TLS/mTLS configuration for the remote HTTP client.
-
-    Attributes
-    ----------
-    cert_file: Optional[str]
-        Path to the client certificate file (PEM format) for mTLS authentication.
-    key_file: Optional[str]
-        Path to the client private key file (PEM format) for mTLS authentication.
-    ssl_ca_cert: Optional[str]
-        Path to the CA certificate file (PEM format) for server verification.
-    assert_hostname: bool
-        Whether to verify the hostname in the server's certificate. Default is True.
-        Set to False to disable hostname verification (use with caution).
-    """
-
-    cert_file: Optional[str] = None
-    key_file: Optional[str] = None
-    ssl_ca_cert: Optional[str] = None
-    assert_hostname: bool = True
-
-
@dataclass
 class ClientConfig:
    user_agent: str = f"LanceDB-Python-Client/{__version__}"
@@ -142,12 +119,9 @@ class ClientConfig:
    timeout_config: Optional[TimeoutConfig] = field(default_factory=TimeoutConfig)
    extra_headers: Optional[dict] = None
    id_delimiter: Optional[str] = None
-    tls_config: Optional[TlsConfig] = None

    def __post_init__(self):
        if isinstance(self.retry_config, dict):
            self.retry_config = RetryConfig(**self.retry_config)
        if isinstance(self.timeout_config, dict):
            self.timeout_config = TimeoutConfig(**self.timeout_config)
-        if isinstance(self.tls_config, dict):
-            self.tls_config = TlsConfig(**self.tls_config)
--- a/python/python/lancedb/remote/db.py
+++ b/python/python/lancedb/remote/db.py
@@ -151,10 +151,9 @@ class RemoteDBConnection(DBConnection):
    @override
    def table_names(
        self,
+        namespace: List[str] = [],
        page_token: Optional[str] = None,
        limit: int = 10,
-        *,
-        namespace: List[str] = [],
    ) -> Iterable[str]:
        """List the names of all tables in the database.

@@ -344,7 +343,7 @@ class RemoteDBConnection(DBConnection):
        return RemoteTable(table, self.db_name)

    @override
-    def drop_table(self, name: str, namespace: List[str] = []):
+    def drop_table(self, name: str, namespace: Optional[List[str]] = None):
        """Drop a table from the database.

        Parameters
@@ -362,8 +361,8 @@ class RemoteDBConnection(DBConnection):
        self,
        cur_name: str,
        new_name: str,
-        cur_namespace: List[str] = [],
-        new_namespace: List[str] = [],
+        cur_namespace: Optional[List[str]] = None,
+        new_namespace: Optional[List[str]] = None,
    ):
        """Rename a table in the database.

--- a/python/python/tests/test_db.py
+++ b/python/python/tests/test_db.py
@@ -175,18 +175,6 @@ def test_table_names(tmp_db: lancedb.DBConnection):
    tmp_db.create_table("test3", data=data)
    assert tmp_db.table_names() == ["test1", "test2", "test3"]

-    # Test that positional arguments for page_token and limit
-    result = list(tmp_db.table_names("test1", 1))  # page_token="test1", limit=1
-    assert result == ["test2"], f"Expected ['test2'], got {result}"
-
-    # Test mixed positional and keyword arguments
-    result = list(tmp_db.table_names("test2", limit=2))
-    assert result == ["test3"], f"Expected ['test3'], got {result}"
-
-    # Test that namespace parameter can be passed as keyword
-    result = list(tmp_db.table_names(namespace=[]))
-    assert len(result) == 3
-

@pytest.mark.asyncio
 async def test_table_names_async(tmp_path):
--- a/python/python/tests/test_namespace.py
+++ b/python/python/tests/test_namespace.py
@@ -420,10 +420,6 @@ class TestNamespaceConnection:
        assert "table2" in table_names
        assert len(table_names) == 1

-        # Test that drop_table works without explicit namespace parameter
-        db.drop_table("table2")
-        assert len(list(db.table_names())) == 0
-
        # Should not be able to open dropped table
        with pytest.raises(RuntimeError):
            db.open_table("table1")
@@ -491,11 +487,6 @@ class TestNamespaceConnection:
        # Verify all tables are gone
        assert len(list(db.table_names())) == 0

-        # Test that table_names works with keyword-only namespace parameter
-        db.create_table("test_table", schema=schema)
-        result = list(db.table_names(namespace=[]))
-        assert "test_table" in result
-
    def test_table_operations(self):
        """Test various table operations through namespace."""
        db = lancedb.connect_namespace("temp", {"root": self.temp_dir})
--- a/python/src/connection.rs
+++ b/python/src/connection.rs
@@ -301,7 +301,6 @@ pub struct PyClientConfig {
    timeout_config: Option<PyClientTimeoutConfig>,
    extra_headers: Option<HashMap<String, String>>,
    id_delimiter: Option<String>,
-    tls_config: Option<PyClientTlsConfig>,
 }

 #[derive(FromPyObject)]
@@ -322,14 +321,6 @@ pub struct PyClientTimeoutConfig {
    pool_idle_timeout: Option<Duration>,
 }

-#[derive(FromPyObject)]
-pub struct PyClientTlsConfig {
-    cert_file: Option<String>,
-    key_file: Option<String>,
-    ssl_ca_cert: Option<String>,
-    assert_hostname: bool,
-}
-
 #[cfg(feature = "remote")]
 impl From<PyClientRetryConfig> for lancedb::remote::RetryConfig {
    fn from(value: PyClientRetryConfig) -> Self {
@@ -356,18 +347,6 @@ impl From<PyClientTimeoutConfig> for lancedb::remote::TimeoutConfig {
    }
 }

-#[cfg(feature = "remote")]
-impl From<PyClientTlsConfig> for lancedb::remote::TlsConfig {
-    fn from(value: PyClientTlsConfig) -> Self {
-        Self {
-            cert_file: value.cert_file,
-            key_file: value.key_file,
-            ssl_ca_cert: value.ssl_ca_cert,
-            assert_hostname: value.assert_hostname,
-        }
-    }
-}
-
 #[cfg(feature = "remote")]
 impl From<PyClientConfig> for lancedb::remote::ClientConfig {
    fn from(value: PyClientConfig) -> Self {
@@ -377,7 +356,6 @@ impl From<PyClientConfig> for lancedb::remote::ClientConfig {
            timeout_config: value.timeout_config.map(Into::into).unwrap_or_default(),
            extra_headers: value.extra_headers.unwrap_or_default(),
            id_delimiter: value.id_delimiter,
-            tls_config: value.tls_config.map(Into::into),
        }
    }
 }
--- a/rust/lancedb/Cargo.toml
+++ b/rust/lancedb/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "lancedb"
-version = "0.22.0"
+version = "0.22.0-beta.0"
 edition.workspace = true
 description = "LanceDB: A serverless, low-latency vector database for AI applications"
 license.workspace = true
--- a/rust/lancedb/examples/hybrid_search.rs
+++ b/rust/lancedb/examples/hybrid_search.rs
@@ -62,8 +62,10 @@ async fn main() -> Result<()> {
            .as_any()
            .downcast_ref::<StringArray>()
            .unwrap();
-        for text in out.iter().flatten() {
-            println!("Result: {}", text);
+        for text in out.iter() {
+            if let Some(text) = text {
+                println!("Result: {}", text);
+            }
        }
    }

--- a/rust/lancedb/src/io/object_store.rs
+++ b/rust/lancedb/src/io/object_store.rs
@@ -9,7 +9,7 @@ use futures::{stream::BoxStream, TryFutureExt};
 use lance::io::WrappingObjectStore;
 use object_store::{
    path::Path, Error, GetOptions, GetResult, ListResult, MultipartUpload, ObjectMeta, ObjectStore,
-    PutMultipartOptions, PutOptions, PutPayload, PutResult, Result, UploadPart,
+    PutMultipartOpts, PutOptions, PutPayload, PutResult, Result, UploadPart,
 };

 use async_trait::async_trait;
@@ -73,7 +73,7 @@ impl ObjectStore for MirroringObjectStore {
    async fn put_multipart_opts(
        &self,
        location: &Path,
-        opts: PutMultipartOptions,
+        opts: PutMultipartOpts,
    ) -> Result<Box<dyn MultipartUpload>> {
        if location.primary_only() {
            return self.primary.put_multipart_opts(location, opts).await;
--- a/rust/lancedb/src/io/object_store/io_tracking.rs
+++ b/rust/lancedb/src/io/object_store/io_tracking.rs
@@ -11,7 +11,7 @@ use futures::stream::BoxStream;
 use lance::io::WrappingObjectStore;
 use object_store::{
    path::Path, GetOptions, GetResult, ListResult, MultipartUpload, ObjectMeta, ObjectStore,
-    PutMultipartOptions, PutOptions, PutPayload, PutResult, Result as OSResult, UploadPart,
+    PutMultipartOpts, PutOptions, PutPayload, PutResult, Result as OSResult, UploadPart,
 };

 #[derive(Debug, Default)]
@@ -110,7 +110,7 @@ impl ObjectStore for IoTrackingStore {
    async fn put_multipart_opts(
        &self,
        location: &Path,
-        opts: PutMultipartOptions,
+        opts: PutMultipartOpts,
    ) -> OSResult<Box<dyn MultipartUpload>> {
        let target = self.target.put_multipart_opts(location, opts).await?;
        Ok(Box::new(IoTrackingMultipartUpload {
--- a/rust/lancedb/src/remote.rs
+++ b/rust/lancedb/src/remote.rs
@@ -18,5 +18,5 @@ const ARROW_FILE_CONTENT_TYPE: &str = "application/vnd.apache.arrow.file";
 #[cfg(test)]
 const JSON_CONTENT_TYPE: &str = "application/json";

-pub use client::{ClientConfig, RetryConfig, TimeoutConfig, TlsConfig};
+pub use client::{ClientConfig, RetryConfig, TimeoutConfig};
 pub use db::{RemoteDatabaseOptions, RemoteDatabaseOptionsBuilder};
--- a/rust/lancedb/src/remote/client.rs
+++ b/rust/lancedb/src/remote/client.rs
@@ -15,19 +15,6 @@ use crate::remote::retry::{ResolvedRetryConfig, RetryCounter};

 const REQUEST_ID_HEADER: HeaderName = HeaderName::from_static("x-request-id");

-/// Configuration for TLS/mTLS settings.
-#[derive(Clone, Debug, Default)]
-pub struct TlsConfig {
-    /// Path to the client certificate file (PEM format)
-    pub cert_file: Option<String>,
-    /// Path to the client private key file (PEM format)
-    pub key_file: Option<String>,
-    /// Path to the CA certificate file for server verification (PEM format)
-    pub ssl_ca_cert: Option<String>,
-    /// Whether to verify the hostname in the server's certificate
-    pub assert_hostname: bool,
-}
-
 /// Configuration for the LanceDB Cloud HTTP client.
 #[derive(Clone, Debug)]
 pub struct ClientConfig {
@@ -41,8 +28,6 @@ pub struct ClientConfig {
    /// The delimiter to use when constructing object identifiers.
    /// If not default, passes as query parameter.
    pub id_delimiter: Option<String>,
-    /// TLS configuration for mTLS support
-    pub tls_config: Option<TlsConfig>,
 }

 impl Default for ClientConfig {
@@ -53,7 +38,6 @@ impl Default for ClientConfig {
            user_agent: concat!("LanceDB-Rust-Client/", env!("CARGO_PKG_VERSION")).into(),
            extra_headers: HashMap::new(),
            id_delimiter: None,
-            tls_config: None,
        }
    }
 }
@@ -261,49 +245,6 @@ impl RestfulLanceDbClient<Sender> {
        if let Some(timeout) = timeout {
            client_builder = client_builder.timeout(timeout);
        }
-
-        // Configure mTLS if TlsConfig is provided
-        if let Some(tls_config) = &client_config.tls_config {
-            // Load client certificate and key for mTLS
-            if let (Some(cert_file), Some(key_file)) = (&tls_config.cert_file, &tls_config.key_file)
-            {
-                let cert = std::fs::read(cert_file).map_err(|err| Error::Other {
-                    message: format!("Failed to read certificate file: {}", cert_file),
-                    source: Some(Box::new(err)),
-                })?;
-                let key = std::fs::read(key_file).map_err(|err| Error::Other {
-                    message: format!("Failed to read key file: {}", key_file),
-                    source: Some(Box::new(err)),
-                })?;
-
-                let identity = reqwest::Identity::from_pem(&[&cert[..], &key[..]].concat())
-                    .map_err(|err| Error::Other {
-                        message: "Failed to create client identity from certificate and key".into(),
-                        source: Some(Box::new(err)),
-                    })?;
-                client_builder = client_builder.identity(identity);
-            }
-
-            // Load CA certificate for server verification
-            if let Some(ca_cert_file) = &tls_config.ssl_ca_cert {
-                let ca_cert = std::fs::read(ca_cert_file).map_err(|err| Error::Other {
-                    message: format!("Failed to read CA certificate file: {}", ca_cert_file),
-                    source: Some(Box::new(err)),
-                })?;
-
-                let ca_cert =
-                    reqwest::Certificate::from_pem(&ca_cert).map_err(|err| Error::Other {
-                        message: "Failed to create CA certificate from PEM".into(),
-                        source: Some(Box::new(err)),
-                    })?;
-                client_builder = client_builder.add_root_certificate(ca_cert);
-            }
-
-            // Configure hostname verification
-            client_builder =
-                client_builder.danger_accept_invalid_hostnames(!tls_config.assert_hostname);
-        }
-
        let client = client_builder
            .default_headers(Self::default_headers(
                api_key,
@@ -720,50 +661,4 @@ mod tests {
            Some(Duration::from_secs(120))
        );
    }
-
-    #[test]
-    fn test_tls_config_default() {
-        let config = TlsConfig::default();
-        assert!(config.cert_file.is_none());
-        assert!(config.key_file.is_none());
-        assert!(config.ssl_ca_cert.is_none());
-        assert!(!config.assert_hostname);
-    }
-
-    #[test]
-    fn test_tls_config_with_mtls() {
-        let tls_config = TlsConfig {
-            cert_file: Some("/path/to/cert.pem".to_string()),
-            key_file: Some("/path/to/key.pem".to_string()),
-            ssl_ca_cert: Some("/path/to/ca.pem".to_string()),
-            assert_hostname: true,
-        };
-
-        assert_eq!(tls_config.cert_file, Some("/path/to/cert.pem".to_string()));
-        assert_eq!(tls_config.key_file, Some("/path/to/key.pem".to_string()));
-        assert_eq!(tls_config.ssl_ca_cert, Some("/path/to/ca.pem".to_string()));
-        assert!(tls_config.assert_hostname);
-    }
-
-    #[test]
-    fn test_client_config_with_tls() {
-        let tls_config = TlsConfig {
-            cert_file: Some("/path/to/cert.pem".to_string()),
-            key_file: Some("/path/to/key.pem".to_string()),
-            ssl_ca_cert: None,
-            assert_hostname: false,
-        };
-
-        let client_config = ClientConfig {
-            tls_config: Some(tls_config.clone()),
-            ..Default::default()
-        };
-
-        assert!(client_config.tls_config.is_some());
-        let config_tls = client_config.tls_config.unwrap();
-        assert_eq!(config_tls.cert_file, Some("/path/to/cert.pem".to_string()));
-        assert_eq!(config_tls.key_file, Some("/path/to/key.pem".to_string()));
-        assert!(config_tls.ssl_ca_cert.is_none());
-        assert!(!config_tls.assert_hostname);
-    }
 }
--- a/rust/lancedb/src/table.rs
+++ b/rust/lancedb/src/table.rs
@@ -32,7 +32,7 @@ use lance::index::vector::VectorIndexParams;
 use lance::io::WrappingObjectStore;
 use lance_datafusion::exec::{analyze_plan as lance_analyze_plan, execute_plan};
 use lance_datafusion::utils::StreamingWriteSource;
-use lance_index::scalar::{BuiltinIndexType, ScalarIndexParams};
+use lance_index::scalar::{ScalarIndexParams, ScalarIndexType};
 use lance_index::vector::hnsw::builder::HnswBuildParams;
 use lance_index::vector::ivf::IvfBuildParams;
 use lance_index::vector::pq::PQBuildParams;
@@ -1778,9 +1778,7 @@ impl NativeTable {
                    );
                    Ok(Box::new(lance_idx_params))
                } else if supported_btree_data_type(field.data_type()) {
-                    Ok(Box::new(ScalarIndexParams::for_builtin(
-                        BuiltinIndexType::BTree,
-                    )))
+                    Ok(Box::new(ScalarIndexParams::new(ScalarIndexType::BTree)))
                } else {
                    return Err(Error::InvalidInput {
                        message: format!(
@@ -1793,21 +1791,15 @@ impl NativeTable {
            }
            Index::BTree(_) => {
                Self::validate_index_type(field, "BTree", supported_btree_data_type)?;
-                Ok(Box::new(ScalarIndexParams::for_builtin(
-                    BuiltinIndexType::BTree,
-                )))
+                Ok(Box::new(ScalarIndexParams::new(ScalarIndexType::BTree)))
            }
            Index::Bitmap(_) => {
                Self::validate_index_type(field, "Bitmap", supported_bitmap_data_type)?;
-                Ok(Box::new(ScalarIndexParams::for_builtin(
-                    BuiltinIndexType::Bitmap,
-                )))
+                Ok(Box::new(ScalarIndexParams::new(ScalarIndexType::Bitmap)))
            }
            Index::LabelList(_) => {
                Self::validate_index_type(field, "LabelList", supported_label_list_data_type)?;
-                Ok(Box::new(ScalarIndexParams::for_builtin(
-                    BuiltinIndexType::LabelList,
-                )))
+                Ok(Box::new(ScalarIndexParams::new(ScalarIndexType::LabelList)))
            }
            Index::FTS(fts_opts) => {
                Self::validate_index_type(field, "FTS", supported_fts_data_type)?;
--- a/rust/lancedb/src/table/datafusion.rs
+++ b/rust/lancedb/src/table/datafusion.rs
@@ -121,10 +121,6 @@ impl ExecutionPlan for MetadataEraserExec {
                as SendableRecordBatchStream,
        )
    }
-
-    fn partition_statistics(&self, partition: Option<usize>) -> DataFusionResult<Statistics> {
-        self.input.partition_statistics(partition)
-    }
 }

 #[derive(Debug)]
@@ -231,7 +227,6 @@ pub mod tests {
        prelude::{SessionConfig, SessionContext},
    };
    use datafusion_catalog::TableProvider;
-    use datafusion_common::stats::Precision;
    use datafusion_execution::SendableRecordBatchStream;
    use datafusion_expr::{col, lit, LogicalPlan, LogicalPlanBuilder};
    use futures::{StreamExt, TryStreamExt};
@@ -500,7 +495,6 @@ pub mod tests {
            plan,
            "MetadataEraserExec
             ProjectionExec:...
-             CooperativeExec...
             LanceRead:...",
        )
        .await;
@@ -515,24 +509,4 @@ pub mod tests {

        TestFixture::check_plan(plan, "").await;
    }
-
-    #[tokio::test]
-    async fn test_metadata_eraser_propagates_statistics() {
-        let fixture = TestFixture::new().await;
-
-        let plan =
-            LogicalPlanBuilder::scan("foo", provider_as_source(fixture.adapter.clone()), None)
-                .unwrap()
-                .build()
-                .unwrap();
-
-        let ctx = SessionContext::new();
-        let physical_plan = ctx.state().create_physical_plan(&plan).await.unwrap();
-
-        assert_eq!(physical_plan.name(), "MetadataEraserExec");
-
-        let partition_stats = physical_plan.partition_statistics(None).unwrap();
-
-        assert!(matches!(partition_stats.num_rows, Precision::Exact(10)));
-    }
 }