ray-data

Process large ML datasets with distributed streaming execution across CPU and GPU clusters.

13.0k|930|Updated Nov 3, 2025
One-click install
npx skills add https://github.com/Orchestra-Research/AI-research-SKILLs --skill ray-data-orchestra-research
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: ray-data
Source: https://github.com/Orchestra-Research/AI-research-SKILLs/tree/main/05-data-processing/ray-data
Command: npx skills add https://github.com/Orchestra-Research/AI-research-SKILLs --skill ray-data-orchestra-research

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill requires ray[data], pyarrow, pandas, and includes references (resource) components.

What problem does it solve? Processing datasets larger than memory or scaling data preprocessing and batch inference from a single machine to hundreds of nodes requires distributed infrastructure that is difficult to build manually. ## Core Features & Use Cases - Streaming Distributed Execution: Read and transform Parquet, CSV, JSON, and image data larger than memory across multi-node clusters. - GPU-Accelerated Transforms: Run vectorized map_batches operations with GPU support for image and multi-modal preprocessing. - ML Framework Integration: Feed data directly into Ray Train, PyTorch, and TensorFlow training loops with automatic dataset sharding. - Use Case: Run distributed batch inference by loading a model once per worker, applying it to a Parquet dataset with map_batches, and writing predictions back to cloud storage. ## Quick Start Use the ray-data skill to read a Parquet dataset from S3, apply a preprocessing transformation, and write the results back to cloud storage.

Frequently Asked Questions about ray-data

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I process large datasets with Ray Data in Python?▼

Install ray[data] with pip, then use ray.data.read_parquet or read_csv to load data and apply map_batches for vectorized transformations. Ray Data streams execution, so datasets larger than memory are processed in batches without full loading.

Ray Data vs Pandas vs Spark for data processing?▼

Use Pandas for small data under 1GB on a single machine, Spark for enterprise SQL-based ETL, and Ray Data for ML workloads over 100GB needing distributed preprocessing, GPU acceleration, and direct integration with training frameworks.

Does Ray Data support GPU-accelerated preprocessing?▼

Yes, Ray Data supports GPU transforms by passing num_gpus=1 to map_batches. The documentation shows image preprocessing scaling from 1,000 images per second on CPU to 18,000 per second with four GPUs.

Can I use Ray Data with PyTorch and TensorFlow training?▼

Yes, convert datasets with ds.to_torch or ds.to_tf to feed batches directly into training loops. With Ray Train, use ray.train.get_dataset_shard to automatically shard datasets across training workers.

What data formats does Ray Data support?▼

Ray Data reads and writes Parquet, CSV, JSON, and NumPy, and reads images and Pandas DataFrames. Parquet is the recommended format for ML data due to efficient columnar storage and streaming reads.

When should I not use Ray Data?▼

Avoid Ray Data for small datasets under 1GB where Pandas is simpler, for SQL-heavy tabular analytics where Dask fits better, and for enterprise SQL ETL pipelines where Spark is the standard choice.