code: def process(self, sample):
      import fiftyone as fo
  
      if self.parse_fcn is not None:
          sample = self.parse_fcn(sample)
      else:
          sample = fo.Sample.from_dict(sample)
  
      self._samples.append(sample)
  
imports: import logging
  import numpy
  import fiftyone.core.dataset
  import fiftyone.core.utils
  import fiftyone.core.view
  import apache_beam
  from apache_beam.options.pipeline_options import PipelineOptions
label_desc: Use image node_id 4 for calling the MergeBatch obj's underlying member method code with example usage: obj.process(sample) without return types