code: def __init__(
      self,
      dataset_name,
      parse_fcn=None,
      key_field="filepath",
      key_fcn=None,
      expand_schema=True,
      **kwargs,
  ):
      self.dataset_name = dataset_name
      self.parse_fcn = parse_fcn
      self.key_field = key_field
      self.key_fcn = key_fcn
      self.expand_schema = expand_schema
      self.kwargs = kwargs
  
      self._dataset = None
      self._id_map = None
      self._key_fcn = None
      self._samples = None
  
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 1 to create a new MergeBatch object from inherited base classes: beam with example: obj = MergeBatch(dataset_name, parse_fcn, key_field, key_fcn, expand_schema)