code: def make_private(
      rdd: RDD,
      budget_accountant: budget_accounting.BudgetAccountant,
      privacy_id_extractor: Callable,
  ) -> PrivateRDD:
      """A factory method for creating PrivateRDDs."""
      prdd = PrivateRDD(rdd, budget_accountant, privacy_id_extractor)
      return prdd
  
file_path: pipelinedp/pipeline_dp/private_spark.py
imports: from pyspark import RDD
  from typing import Callable, Optional
  import pipeline_dp
  from pipeline_dp import aggregate_params, budget_accounting
label_desc: Use image node_id 1 for calling a global function with example usage: make_private(rdd, budget_accountant, privacy_id_extractor) and returns: prdd