python wrapper for Lance columnar format
Project description
Python bindings for Lance Data Format
:warning: Under heavy development
Lance is a new columnar data format for data science and machine learning
Why you should use Lance
- Is order of magnitude faster than parquet for point queries and nested data structures common to DS/ML
- Comes with a fast vector index that delivers sub-millisecond nearest neighbors search performance
- Is automatically versioned and supports lineage and time-travel for full reproducibility
- Integrated with duckdb/pandas/polars already. Easily convert from/to parquet in 2 lines of code
Quick start
Installation
pip install pylance
Make sure you have a recent version of pandas (1.5+), pyarrow (10.0+), and DuckDB (0.7.0+)
Converting to Lance
import lance
import pandas as pd
import pyarrow as pa
import pyarrow.dataset
df = pd.DataFrame({"a": [5], "b": [10]})
uri = "/tmp/test.parquet"
tbl = pa.Table.from_pandas(df)
pa.dataset.write_dataset(tbl, uri, format='parquet')
parquet = pa.dataset.dataset(uri, format='parquet')
lance.write_dataset(parquet, "/tmp/test.lance")
Reading Lance data
dataset = lance.dataset("/tmp/test.lance")
assert isinstance(dataset, pa.dataset.Dataset)
Pandas
df = dataset.to_table().to_pandas()
DuckDB
import duckdb
# If this segfaults, make sure you have duckdb v0.7+ installed
duckdb.query("SELECT * FROM dataset LIMIT 10").to_df()
Vector search
Download the sift1m subset
wget ftp://ftp.irisa.fr/local/texmex/corpus/sift.tar.gz
tar -xzf sift.tar.gz
Convert it to Lance
import lance
from lance.vector import vec_to_table
import numpy as np
import struct
nvecs = 1000000
ndims = 128
with open("sift/sift_base.fvecs", mode="rb") as fobj:
buf = fobj.read()
data = np.array(struct.unpack("<128000000f", buf[4 : 4 + 4 * nvecs * ndims])).reshape((nvecs, ndims))
dd = dict(zip(range(nvecs), data))
table = vec_to_table(dd)
uri = "vec_data.lance"
sift1m = lance.write_dataset(table, uri, max_rows_per_group=8192, max_rows_per_file=1024*1024)
Build the index
sift1m.create_index("vector",
index_type="IVF_PQ",
num_partitions=256, # IVF
num_sub_vectors=16) # PQ
Search the dataset
# Get top 10 similar vectors
import duckdb
dataset = lance.dataset(uri)
# Sample 100 query vectors. If this segfaults, make sure you have duckdb v0.7+ installed
sample = duckdb.query("SELECT vector FROM dataset USING SAMPLE 100").to_df()
query_vectors = np.array([np.array(x) for x in sample.vector])
# Get nearest neighbors for all of them
rs = [dataset.to_table(nearest={"column": "vector", "k": 10, "q": q})
for q in query_vectors]
*More distance metrics, HNSW, and distributed support is on the roadmap
Python package details
Install from PyPI: pip install pylance # >=0.3.0 is the new rust-based implementation
Install from source: maturin develop (under the /python directory)
Run unit tests: make test
Run integration tests: make integtest
Import via: import lance
The python integration is done via pyo3 + custom python code:
- We make wrapper classes in Rust for Dataset/Scanner/RecordBatchReader that's exposed to python.
- These are then used by LanceDataset / LanceScanner implementations that extend pyarrow Dataset/Scanner for duckdb compat.
- Data is delivered via the Arrow C Data Interface
Motivation
Why do we need a new format for data science and machine learning?
1. Reproducibility is a must-have
Versioning and experimentation support should be built into the dataset instead of requiring multiple tools.
It should also be efficient and not require expensive copying everytime you want to create a new version.
We call this "Zero copy versioning" in Lance. It makes versioning data easy without increasing storage costs.
2. Cloud storage is now the default
Remote object storage is the default now for data science and machine learning and the performance characteristics of cloud are fundamentally different.
Lance format is optimized to be cloud native. Common operations like filter-then-take can be order of magnitude faster
using Lance than Parquet, especially for ML data.
3. Vectors must be a first class citizen, not a separate thing
The majority of reasonable scale workflows should not require the added complexity and cost of a specialized database just to compute vector similarity. Lance integrates optimized vector indices into a columnar format so no additional infrastructure is required to get low latency top-K similarity search.
4. Open standards is a requirement
The DS/ML ecosystem is incredibly rich and data must be easily accessible across different languages, tools, and environments. Lance makes Apache Arrow integration its primary interface, which means conversions to/from is 2 lines of code, your code does not need to change after conversion, and nothing is locked-up to force you to pay for vendor compute. We need open-source not fauxpen-source.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distributions
Built Distributions
File details
Details for the file pylance-0.10.1-cp38-abi3-win_amd64.whl.
File metadata
- Download URL: pylance-0.10.1-cp38-abi3-win_amd64.whl
- Upload date:
- Size: 22.0 MB
- Tags: CPython 3.8+, Windows x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.0.0 CPython/3.8.10
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 287078721ba081d4b6b3ddd94eb3f17a01dfeb0f59b7f1ae72ec42faa46c3930 |
|
| MD5 | 578aa17d40efa818915489fca53b912b |
|
| BLAKE2b-256 | a48d59e85fc15f6051ec57d3d9435422be65d4f4f9365e9507ad9d9fd160ab05 |
Provenance
File details
Details for the file pylance-0.10.1-cp38-abi3-manylinux_2_24_aarch64.whl.
File metadata
- Download URL: pylance-0.10.1-cp38-abi3-manylinux_2_24_aarch64.whl
- Upload date:
- Size: 19.9 MB
- Tags: CPython 3.8+, manylinux: glibc 2.24+ ARM64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.0.0 CPython/3.8.18
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 3d9622b8f660db3d1c7ad233547e223437a838f3eced1ca2e59c702bded84139 |
|
| MD5 | 4494718f49ae2c28867d14a156868b75 |
|
| BLAKE2b-256 | dfb9440b4d905bee3a182ffb56c4e4bba67064ec255f038d1aba0e64e0d5e2a4 |
Provenance
File details
Details for the file pylance-0.10.1-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.
File metadata
- Download URL: pylance-0.10.1-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
- Upload date:
- Size: 21.5 MB
- Tags: CPython 3.8+, manylinux: glibc 2.17+ x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.0.0 CPython/3.8.18
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | baae54aa37a1d2c5ef065e92e0805106d53b89f7f1fcd1a457a1bad91e5ff180 |
|
| MD5 | cc4e317e06bf804fa5e24ae42f9740b9 |
|
| BLAKE2b-256 | ecb3b9fbd184b63df59bc8b39e14c89000e7d3dcb18b1ca836e5d2a78ab5cecd |
Provenance
File details
Details for the file pylance-0.10.1-cp38-abi3-macosx_11_0_arm64.whl.
File metadata
- Download URL: pylance-0.10.1-cp38-abi3-macosx_11_0_arm64.whl
- Upload date:
- Size: 18.8 MB
- Tags: CPython 3.8+, macOS 11.0+ ARM64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.0.0 CPython/3.12.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 760581a970e44dd054ad3740eb154df88fc7a016bb35b4adec73b8d229656a29 |
|
| MD5 | a8d18640f74aa56c00f8610b91928fce |
|
| BLAKE2b-256 | 2743882c20debef6d0457291e6614639cb5f2d23b19f25393ea595d54d4c4d8c |
Provenance
File details
Details for the file pylance-0.10.1-cp38-abi3-macosx_10_15_x86_64.whl.
File metadata
- Download URL: pylance-0.10.1-cp38-abi3-macosx_10_15_x86_64.whl
- Upload date:
- Size: 20.4 MB
- Tags: CPython 3.8+, macOS 10.15+ x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/5.0.0 CPython/3.12.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | f7dd2aab0416c0770f626104ab36f729a0268d61249452761711d018c1e7ef9e |
|
| MD5 | 9194fe32e0f164a628f13a85a81e52cf |
|
| BLAKE2b-256 | f1c4c845a8daaaf0749730eaa7523cc24cb662da34d25de633f4ad99a8bf4b88 |
