A flexible framework for distributed data processing using MapReduce patterns.
pip install dynamic_data_reduction
git clone https://github.com/yourusername/dynamic_data_reduction.git
cd dynamic_data_reduction
pip install -e .
from dynamic_data_reduction import ddr
# Your code here
from dynamic_data_reduction import ddr_coffea
# Your Coffea-specific code here
-- General use example: simple-example.py -- Coffea use in analysis: ddr_cortado.py
from dynamic_data_reduction import ddr_cortado
# Run the example
To set up the development environment:
git clone https://github.com/yourusername/dynamic_data_reduction.git
cd dynamic_data_reduction
pip install -e ".[dev]"
This project is licensed under the MIT License - see the LICENSE file for details.