PipelineDP is a Python framework for applying differentially private aggregations to large datasets using batch processing systems such as Apache Spark, Apache Beam, and more.
This PRs contains a few small changes related to custom combiner:
1.Copying aggregate_params before sending them to custom combiner (to prevent changes in the original AggregateParams)
Passing AggregateParams in extract_private_output, which simplifies API of custom combiner, now the custom combiner framework would keep AggregateParams instead of the user code.
This PRs contains a few small changes related to custom combiner: 1.Copying aggregate_params before sending them to custom combiner (to prevent changes in the original AggregateParams)
AggregateParams
inextract_private_output
, which simplifies API of custom combiner, now the custom combiner framework would keepAggregateParams
instead of the user code.