class_docstr: Mozilla Common Voice Dataset.
class_docstr_tok: ["Mozilla","Common","Voice","Dataset","."]
code: def _clips_pipeline(self, pipeline, name, dl_manager, dl_path):
      beam = tfds.core.lazy_imports.apache_beam
      counter = functools.partial(
          beam.metrics.Metrics.counter, _BEAM_NAMESPACE
      )
  
      def _read_clips(dl_path):
          for filename, fobj in dl_manager.iter_archive(dl_path):
              if not filename.endswith(".mp3"):
                  counter("clips_pipeline_non_mp3").inc()
                  continue
              match = _AUDIO_FILE_REGEX.match(filename)
              if not match:
                  counter("clips_pipeline_no_regex_match").inc()
                  continue
              clip_filename = match.group(1)
              if not clip_filename:
                  counter("clips_pipeline_empty_filename").inc()
                  continue
              counter("clips_pipeline_clips").inc()
              yield clip_filename, io.BytesIO(fobj.read())
  
      return (
          pipeline
          | f"{name} - Collection of clips" >> beam.Create([dl_path])
          | f"{name} - Read clips" >> beam.FlatMap(_read_clips)
      )
  
imports: import csv
  import dataclasses
  import functools
  import io
  import re
  from typing import Any, Mapping, Sequence
  from etils import epath
  import numpy
  import tensorflow_datasets.public_api
label_desc: Use image node_id 3 for calling the CommonVoice obj's underlying member method code with example usage: obj._clips_pipeline(pipeline, name, dl_manager, dl_path) and returns: unknown