code: def _BigQueryToExample(
      pipeline: beam.Pipeline,
      exec_properties: Dict[str, Any],
      split_pattern: str,
  ) -> beam.pvalue.PCollection:
      """Read from BigQuery and transform to TF examples.
  
      Args:
        pipeline: beam pipeline.
        exec_properties: A dict of execution properties.
        split_pattern: Split.pattern in Input config, a BigQuery sql string.
  
      Returns:
        PCollection of TF examples.
      """
      project = utils.parse_gcp_project(
          exec_properties["_beam_pipeline_args"]
      )
      converter = _BigQueryConverter(split_pattern, project)
      big_query_custom_config = (
          json.loads(exec_properties["custom_config"])
          if "custom_config" in exec_properties
          else None
      )
  
      return (
          pipeline
          | "QueryTable"
          >> utils.ReadFromBigQuery(
              query=split_pattern,
              big_query_custom_config=big_query_custom_config,
          )
          | "ToTFExample" >> beam.Map(converter.RowToExample)
      )
  
file_path: tfx/tfx/extensions/google_cloud_big_query/example_gen/executor.py
imports: import json
  from typing import Any, Dict, Optional
  import apache_beam
  from google.cloud import bigquery
  import tensorflow
  from tfx.components.example_gen import base_example_gen_executor
  from tfx.extensions.google_cloud_big_query import utils
label_desc: Use image node_id 1 for calling a global function with example usage: _BigQueryToExample(pipeline, exec_properties, split_pattern) and returns: unknown