class_docstr: DatasetBuilder for LAION-400M dataset.
class_docstr_tok: ["DatasetBuilder","for","LAION-400M","dataset","."]
code: def _generate_examples(
      self,
      dl_manager: tfds.download.DownloadManager,
      file_name_to_dl_path: Dict[str, epath.Path],
  ):
      beam = tfds.core.lazy_imports.apache_beam
  
      return (
          "Generate shard indices"
          >> beam.Create(list(range(self.builder_config.num_shards)))
          | "Generate examples from a single shard"
          >> beam.FlatMap(
              functools.partial(
                  self._generate_examples_one_shard,
                  dl_manager,
                  file_name_to_dl_path,
              )
          )
          # `self._generate_examples_one_shard` produces a large number of
          # outputs, so we want to make sure that the next transforms will be
          # run in parallel independently of this step
          | "Prevent fusion of transforms" >> beam.Reshuffle()
      )
  
file_path: datasets/tensorflow_datasets/vision_language/laion400m/laion400m.py
imports: import functools
  from typing import Dict, Tuple
  from etils import epath
  import numpy
  from tensorflow_datasets.core.utils.lazy_imports_utils import tensorflow
  import tensorflow_datasets.public_api
label_desc: Use image node_id 4 for calling the Laion400m obj's underlying member method code with example usage: obj._generate_examples(dl_manager, file_name_to_dl_path) and returns: unknown