code: def read_from_tfrecords_files(pipeline, input_filename_pattern_list):
      """Reads records from TFRecord files.
  
      Args:
        pipeline: Beam pipeline object.
        input_filename_pattern_list: List of filename patterns.
  
      Returns:
        A PCollection of read tf.Examples.
      """
      readers = []
      for i, filepattern in enumerate(input_filename_pattern_list):
          readers.append(
              pipeline
              | "ReadTFRecordFiles_{}[{}]".format(i, filepattern)
              >> beam.io.ReadFromTFRecord(
                  filepattern, coder=coders.BytesCoder()
              )
          )
      return readers | "Flatten" >> beam.Flatten()
  
file_path: deepvariant/tools/shuffle_tfrecords_beam.py
imports: import argparse
  import hashlib
  import logging
  import os
  import textwrap
  import apache_beam
  from apache_beam import coders
  from apache_beam.options.pipeline_options import PipelineOptions
  import tensorflow.compat.v1
label_desc: Use image node_id 2 for calling a global function with example usage: read_from_tfrecords_files(pipeline, input_filename_pattern_list) and returns: unknown