code: def compute_on_beam():
      runner = fn_api_runner.FnApiRunner()  # local runner
      with beam.Pipeline(runner=runner) as pipeline:
          movie_views = (
              pipeline
              | beam.io.ReadFromText(FLAGS.input_file)
              | beam.ParDo(ParseFile())
          )
          pipeline_backend = pipeline_dp.BeamBackend()
          dp_result = calculate_private_result(
              movie_views, pipeline_backend
          )
          dp_result | beam.io.WriteToText(FLAGS.output_file)
  
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 4 for calling a global function with example usage: compute_on_beam() without return types