code: def _compute_split_statistics_beam(
      *,
      split_files: _SplitFilesDict,
      out_dir: epath.PathLike,
      filename_template: naming.ShardedFileTemplate,
  ) -> Sequence[split_lib.SplitInfo]:
      """Compute statistics."""
      out_dir = epath.Path(out_dir)
  
      assert out_dir.exists(), f"{out_dir} does not exist"
  
      # Launch the beam pipeline computation
      runner = None
      # Create the global pipeline object common for all splits
      # Disable type_hint as it doesn't works with typing.Protocol
      beam_options = beam.options.pipeline_options.PipelineOptions()
      beam_options.view_as(
          beam.options.pipeline_options.TypeOptions
      ).pipeline_type_check = False
      with beam.Pipeline(
          runner=runner, options=beam_options
      ) as pipeline:
          for split_name, file_infos in split_files.items():
              _ = (
                  pipeline
                  | split_name
                  >> _process_split(  # pylint: disable=no-value-for-parameter
                      filename_template=filename_template,
                      out_dir=out_dir,
                      file_infos=file_infos,  # pytype: disable=missing-parameter
                  )
              )
  
      # After the files have been computed
      return [
          _split_info_from_path(
              filename_template.replace(data_dir=out_dir, split=split)
          )
          for split in split_files
      ]
  
imports: import collections
  from collections.abc import Mapping, Sequence, Set
  import dataclasses
  import functools
  import itertools
  import os
  import pprint
  from typing import Optional, Type, Union, cast
  from etils import epath
  from tensorflow_datasets.core import file_adapters
  from tensorflow_datasets.core import lazy_imports_lib
  from tensorflow_datasets.core import naming
  from tensorflow_datasets.core import splits
  from tensorflow_datasets.core import utils
  from tensorflow_datasets.core.proto import dataset_info_pb2
  from tensorflow_datasets.core.utils.lazy_imports_utils import apache_beam
  from tensorflow_datasets.core.utils.lazy_imports_utils import array_record_data_source
  from google.protobuf import json_format
label_desc: Use image node_id 7 for calling a global function with example usage: _compute_split_statistics_beam() and returns: unknown