NVIDIA NeMo Curator Documentation

repository·main·Indexed 23 days ago

https://github.com/nvidia-nemo/curator

A framework for building repeatable, GPU-accelerated pipelines to load, filter, deduplicate, and transform large-scale text, image, video, and audio datasets for AI training. Includes a scalable data preprocessing tool and a comprehensive benchmarking framework for measuring throughput and memory usage.

Tokens
321.3K
Snippets
630
Records
1.1K
Agent score
81%

What's inside NeMo Curator

  1. Overview of Image Curation in NeMo Curator

    main

    NeMo Curator provides a modular, scalable pipeline for curating high-quality image datasets, specifically designed for training generative AI models like LLMs, VLMs, and WFMs. The system allows for large-scale processing of image-text datasets, including quality filtering, content filtering, and semantic deduplication.

    Key capabilities include:

    • Quality Control: Applying aesthetic filtering and removing low-quality images.
    • Content Filtering: Removing inappropriate or NSFW content.
    • Deduplication: Using semantic similarity to remove duplicate images from large collections.
    • Feature Extraction: Generating embeddings (e.g., via CLIP) for search and retrieval.
    • Scalability: Distributed processing across multiple GPUs and nodes using Ray and GPU-accelerated DALI.
  2. Overview of NeMo Curator Setup & Deployment

    main

    This section provides guidance for running NeMo Curator in production environments, focusing on scaling from a single development workstation to multi-node clusters. It covers deployment topologies, hardware/software requirements, and integrations with external systems.

    Note: If you are looking to install NeMo Curator on a single machine rather than a production cluster, refer to the Install (All Modalities) guide.

  3. Overview of NeMo Curator Text Curation

    main
    NeMo Curator provides a comprehensive toolkit for preparing high-quality text data for Large Language Model (LLM) training. It uses a pipeline-based architecture to handle the entire data lifecycle, including loading, cleaning, quality assessment, and deduplication. The toolkit is designed to scale across CPU and GPU clusters, leveraging Ray and RAPIDS for distributed and GPU-accelerated execution.
  4. Overview of Image Curation workflows

    main

    NeMo Curator provides a modular pipeline architecture for curating high-quality image datasets at scale. The workflow is designed to handle large-scale image-text datasets by applying quality filtering, content filtering, and semantic deduplication.

    Key capabilities include:

    • Data Loading: Efficiently reading JPEG images from tar archives using GPU-accelerated DALI.
    • Feature Extraction: Generating embeddings using CLIP models (e.g., ViT-L/14).
    • Filtering: Applying aesthetic quality scoring and NSFW content filtering.
    • Deduplication: Removing duplicate images via semantic similarity and clustering.
    • Export: Saving metadata to Parquet and exporting datasets with custom resharding into tar archives.

    The architecture is built for scalability using Ray for distributed processing across multiple GPUs and nodes.

  5. Overview of Audio Curation in NeMo Curator

    main

    NeMo Curator provides a suite of capabilities for preparing high-quality speech data for Automatic Speech Recognition (ASR) and multi-modal model training. The toolkit is designed to handle large-scale speech datasets by providing processors for loading audio, performing ASR inference, assessing transcription quality, and integrating audio results with text curation workflows.

    Key Capabilities:

    • ASR Inference: Generate transcriptions using NVIDIA NeMo ASR models.
    • Quality Assessment: Filter datasets based on transcription accuracy metrics like Word Error Rate (WER) and Character Error Rate (CER).
    • Audio Analysis: Extract metadata such as duration and validate audio formats.
    • Data Integration: Combine audio processing results with text curation pipelines for multi-modal workflows.
    • Scalability: Efficiently scale audio processing across GPU clusters.
  6. Overview of NeMo Curator Setup and Deployment

    main

    NeMo Curator provides guidance for transitioning from development workstations to production-scale environments. The setup documentation covers deployment topologies, hardware and software requirements, and integrations with external systems to support multi-node clusters.

    For single-machine installations, users should refer to the Install (All Modalities) guide instead of the production deployment resources.

  7. Overview of NeMo Curator capabilities

    main

    NeMo Curator is an enterprise-grade platform designed for scalable, privacy-aware data curation across multiple modalities: text, image, video, and audio. It is used to prepare high-quality, compliant datasets for LLM and generative AI training.

    Key capabilities include:

    • Scalability: Supports workflows ranging from local laptops to multi-node GPU clusters.
    • Modality Support: Specialized pipelines for Text (cleaning, deduplication, classification), Image (embeddings, aesthetic/NSFW classification), Audio (ASR, WER calculation), and Video (distributed processing).
    • Performance: Proven to handle massive scales, such as deduplicating 1.96 trillion tokens in 0.5 hours using 32 NVIDIA H100 GPUs.
    • Deployment: Supports distributed, cloud-native, and on-premises environments with integration into modern MLOps pipelines.
  8. Scale NeMo Curator from workstation to production clusters

    main

    The Setup & Deployment documentation provides guidance for transitioning NeMo Curator from a single-machine development environment to a multi-node production cluster. This includes information on deployment topologies, hardware/software requirements, and integrations with external systems.

    If you are looking to install NeMo Curator on a single machine rather than a production cluster, refer to the Install (All Modalities) guide instead.

  9. Explore Video Curation Tutorials and Documentation

    main

    NeMo Curator provides several categories of documentation for video curation tasks:

    Concepts

    • Architecture: Understand the system design.
    • Data Flow: Learn how video data moves through the pipeline.
    • Abstractions: Understand the core building blocks used in video processing.

    Processing Tasks

    • Filtering: Remove unwanted video data.
    • Clipping: Segment videos into clips.
    • Frame Extraction: Extract specific frames from video files.
    • Deduplication: Identify and remove duplicate video content.
    • Video Embeddings: Generate embeddings for video data.

    Data Lifecycle

    • Load Data: How to ingest video data into the pipeline.
    • Process Data: How to apply transformations and filters.
    • Export Data: How to save and export the curated results.

    Advanced Topics

    • Pipeline Customization: How to tailor the curation pipeline to specific needs.
    • Production: Information on execution backends for production environments.
  10. Explore interleaved multimodal data curation tutorials

    main

    NeMo Curator provides hands-on tutorials for curating interleaved multimodal data (documents containing text, images, and metadata interlaced in reading order).

    Available tutorial paths:

    1. Getting Started: Focuses on loading, exploring, filtering, and saving interleaved data using MINT-1T PDF shards.
      • Key files: interleaved_data_quickstart.ipynb, interleaved_pipeline.py
    2. PDF Extraction Pipeline (Nemotron-Parse): Demonstrates how to convert PDFs into structured interleaved Parquet files using Nemotron-Parse v1.2.
      • Key file: main.py
  11. Get started with NeMo Curator

    main

    NeMo Curator is a framework designed to streamline the curation and pre-processing of large-scale datasets for training generative AI models. It supports multiple modalities, including text, image, audio, and video.

    Quickstarts are designed for AI/ML engineers and researchers to test capabilities or run initial curation pipelines with minimal setup, typically taking less than 30 minutes. For production-grade deployments, cluster configurations, or detailed system requirements, refer to the Setup & Deployment documentation.

  12. Related Infrastructure Topics for SLURM Deployment

    main

    When deploying NeMo Curator on SLURM, you may need to reference these related infrastructure concepts:

    • Resumable Processing: For handling interruptions and resuming work.
    • Multi-Node Ray on SLURM: For scaling Ray clusters across multiple SLURM nodes.
    • Execution Backends: To understand how different backends handle task execution.
    • Container Environments: For managing dependencies via containers in SLURM.