class_docstr: Base class for all benchmarks.
code: def _create_beam_pipeline(self):
      # FLAGS may not be parsed if the benchmark is instantiated directly by a
      # test framework (e.g. PerfZero creates the class and calls the methods
      # directly)
      runner_flag = (
          FLAGS.beam_runner
          if FLAGS.is_parsed()
          else FLAGS["beam_runner"].default
      )
      return beam.Pipeline(
          runner=beam.runners.create_runner(runner_flag)
      )
  
imports: from absl import flags
  import apache_beam
  from tensorflow.python.platform import test
label_desc: Use image node_id 1 for calling the BenchmarkBase obj's underlying member method code with example usage: obj._create_beam_pipeline() and returns: beam