Voltar ao ranking

deepseek-ai/smallpond

Python

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

data-processingduckdb
Crescimento de estrelas
Estrelas
5k
Forks
451
Crescimento semanal
Issues
23
2k3k4k
fev. de 2025jul. de 2025jan. de 2026jul. de 2026
ArtefatosPyPIpip 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.

Repositórios relacionados
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