class_docstr: DP sum combiner.
  
  It is just for demonstration how custom combiners API work.
class_docstr_tok: ["DP","sum","combiner",".","It","is","just","for","demonstration","how","custom","combiners","API","work","."]
code: def set_aggregate_params(self, aggregate_params):
      self._aggregate_params = aggregate_params
  
imports: from absl import app
  from absl import flags
  from apache_beam.runners.portability import fn_api_runner
  import pyspark
  from examples.movie_view_ratings.common_utils import *
  import pipeline_dp
  import numpy
label_desc: Use image node_id 5 for calling the CountCombiner obj's underlying member method code with example usage: obj.set_aggregate_params(aggregate_params) without return types