ray-data

Scalable data processing for ML workloads. Streaming execution across CPU/GPU, supports Parquet/CSV/JSON/images. Integrates with Ray Train, PyTorch, TensorFlow. Scales from single machine to 100s of nodes. Use for batch inference, data preprocessing, multi-modal data loading, or distributed ETL pipe

By orchestra-research · 780 installs

npx skills add orchestra-research/ai-research-skills --skill ray-data

Source repository · Upstream listing

Ray Data Scalable ML Data Processing Distributed data processing library for ML and AI workloads. When to use Ray Data Use Ray Data when: Processing large datasets ( 100GB) for ML training Need distributed data preprocessing across cluster Building batch inference pipelines Loading multi modal data (images, audio, video) Scaling data processing from laptop to cluster Key features : Streaming execution : Process data larger than memory GPU support : Accelerate transforms with GPUs Framework integration : PyTorch, TensorFlow, HuggingFace Multi modal : Images, Parquet, CSV, JSON, audio, video Use alternatives instead : Pandas : Small data (<1GB) on single machine Dask : Tabular data, SQL like operations Spark : Enterprise ETL, SQL queries Quick start Installation Load and transform data Integration with Ray Train Reading data From cloud storage From Python objects Transformations Map batches (vectorized) Row transformations Filter Group by and aggregate GPU accelerated transforms Writing data Performance optimization Repartition Batch size tuning Streaming execution Common patterns Batch inference Data preprocessing pipeline Integration with ML frameworks PyTorch TensorFlow Supported data formats Format Read Write Use Case Parquet ✅ ✅ ML data (recommended) CSV ✅ ✅ Tabular data JSON ✅ ✅ Semi structured Images ✅ ❌ Computer vision NumPy ✅ ✅ Arrays Pandas ✅ ❌ DataFrames Performance benchmarks Scaling (processing 100GB data): 1 node (16 cores): ~30 minutes 4 nodes (64 cores): ~8 minutes 16 nodes (256 cores): ~2 minutes GPU acceleration (image preprocessing): CPU only: 1,000 images/sec 1 GPU: 5,000 images/sec 4 GPUs: 18,000 images/sec Use cases Production deployments : Pinterest : Last mile data processing for model training ByteDance : Scaling offline inference with multi modal LLMs Spotify : ML platform for batch inference References [Transformations Guide](references/transformations.md) Map, filter, groupby operations [Integration Guide](references/integration.md) Ray Train, PyTorch, TensorFlow Resources Docs : https://docs.ray.io/en/latest/data/data.html GitHub : https://github.com/ray project/ray ⭐ 36,000+ Version : Ray 2.40.0+ Examples : https://docs.ray.io/en/latest/data/examples/overview.html