Retour au classement

deepseek-ai/smallpond

Python

A lightweight data processing framework built on DuckDB and 3FS.

data-processingduckdb
Croissance des étoiles
Étoiles
5k
Forks
451
Croissance hebdomadaire
Issues
23
2k3k4k
févr. 2025juil. 2025janv. 2026juil. 2026
ArtefactsPyPIpip install smallpond
README

smallpond

CI PyPI Docs License

A lightweight data processing framework built on DuckDB and 3FS.

Features

  • 🚀 High-performance data processing powered by DuckDB
  • 🌍 Scalable to handle PB-scale datasets
  • 🛠️ Easy operations with no long-running services

Installation

Python 3.8 to 3.12 is supported.

pip install smallpond

Quick Start

# Download example data
wget https://duckdb.org/data/prices.parquet
import smallpond

# Initialize session
sp = smallpond.init()

# Load data
df = sp.read_parquet("prices.parquet")

# Process data
df = df.repartition(3, hash_by="ticker")
df = sp.partial_sql("SELECT ticker, min(price), max(price) FROM {0} GROUP BY ticker", df)

# Save results
df.write_parquet("output/")
# Show results
print(df.to_pandas())

Documentation

For detailed guides and API reference:

Performance

We evaluated smallpond using the GraySort benchmark (script) on a cluster comprising 50 compute nodes and 25 storage nodes running 3FS. The benchmark sorted 110.5TiB of data in 30 minutes and 14 seconds, achieving an average throughput of 3.66TiB/min.

Details can be found in 3FS - Gray Sort.

Development

pip install .[dev]

# run unit tests
pytest -v tests/test*.py

# build documentation
pip install .[docs]
cd docs
make html
python -m http.server --directory build/html

License

This project is licensed under the MIT License.

Dépôts similaires
pathwaycom/pathway

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

PythonPyPIOtherbatch-processingkafka
pathway.com
62.6k1.7k
cocoindex-io/cocoindex

Incremental engine for long horizon agents 🌟 Star if you like it!

Rustcrates.ioApache License 2.0aichange-data-capture
cocoindex.io
11k841
onceupon/Bash-Oneliner

A collection of handy Bash One-Liners and terminal tricks for data processing and Linux system maintenance.

MIT Licenseoneliner-commandsbash
onceupon.github.io/Bash-Oneliner/
10.8k647
johnkerl/miller

Miller is like awk, sed, cut, join, and sort for name-indexed data such as CSV, TSV, and tabular JSON

GoGo ModulesOtherdata-processingdata-cleaning
miller.readthedocs.io
10k238
TomWright/dasel

Unified querying, transformation, and modification of JSON, TOML, YAML, XML, INI, HCL, KDL and CSV.

GoGo ModulesMIT Licensejsonyaml
daseldocs.tomwright.me
8k170
datajuicer/data-juicer

Data processing for and with foundation models! 🍎 🍋 🌽 ➡️ ➡️🍸 🍹 🍷

PythonPyPIApache License 2.0data-analysisdata-science
datajuicer.github.io/data-juicer/
6.8k396
OpenDCAI/DataFlow

Easy Data Preparation with latest LLMs-based Operators and Pipelines.

PythonPyPIApache License 2.0datadata-cleaning
opendcai.github.io/DataFlow-Doc/
6.7k826
NVIDIA/DALI

A GPU-accelerated library containing highly optimized building blocks and an execution engine for data processing to accelerate deep learning training and inference applications.

C++Apache License 2.0fast-data-pipelineimage-augmentation
docs.nvidia.com/deeplearning/dali/user-guide/docs/index.html
5.7k669
rocketride-org/rocketride-server

High-performance AI pipeline engine with a C++ core and 50+ Python-extensible nodes. Build, debug, and scale LLM workflows with 13+ model providers, 8+ vector databases, and agent orchestration, all from your IDE. Includes VS Code extension, TypeScript/Python SDKs, and Docker deployment.

PythonPyPIMIT Licenseaicpp
5.4k1.8k
unionai-oss/pandera

A light-weight, flexible, and expressive statistical data testing library

PythonPyPIMIT Licensepandasvalidation
union.ai/pandera
4.4k421
numaproj/numaflow

Kubernetes-native platform to run massively parallel data/streaming jobs

Rustcrates.ioApache License 2.0kubernetesstream-processing
numaflow.numaproj.io
2.8k163
datachain-ai/datachain

The Context Layer for unstructured data: typed, versioned datasets over S3, GCS, Azure

PythonPyPIApache License 2.0claude-codecodex
docs.datachain.ai
2.8k151