code: def testBigQueryToExample(self, mock_client):
      # Mock query result schema for _BigQueryConverter.
      mock_client.return_value.query.return_value.result.return_value.schema = (
          self._schema
      )
  
      with beam.Pipeline() as pipeline:
          examples = pipeline | "ToTFExample" >> executor._BigQueryToExample(
              exec_properties={
                  "_beam_pipeline_args": [],
                  "custom_config": json.dumps(
                      {"query_key": "query_value"}
                  ),
              },
              split_pattern="SELECT i, i2, b, f, f2, s, s2 FROM `fake`",
          )
  
          feature = {}
          feature["i"] = tf.train.Feature(
              int64_list=tf.train.Int64List(value=[1])
          )
          feature["i2"] = tf.train.Feature(
              int64_list=tf.train.Int64List(value=[2, 3])
          )
          feature["b"] = tf.train.Feature(
              int64_list=tf.train.Int64List(value=[1])
          )
          feature["f"] = tf.train.Feature(
              float_list=tf.train.FloatList(value=[2.0])
          )
          feature["f2"] = tf.train.Feature(
              float_list=tf.train.FloatList(value=[2.7, 3.8])
          )
          feature["s"] = tf.train.Feature(
              bytes_list=tf.train.BytesList(
                  value=[tf.compat.as_bytes("abc")]
              )
          )
          feature["s2"] = tf.train.Feature(
              bytes_list=tf.train.BytesList(
                  value=[
                      tf.compat.as_bytes("abc"),
                      tf.compat.as_bytes("def"),
                  ]
              )
          )
          example_proto = tf.train.Example(
              features=tf.train.Features(feature=feature)
          )
          util.assert_that(examples, util.equal_to([example_proto]))
  
imports: import json
  import os
  import random
  from unittest import mock
  import apache_beam
  from apache_beam.testing import util
  from google.cloud import bigquery
  import tensorflow
  from tfx.dsl.components.base import base_beam_executor
  from tfx.dsl.io import fileio
  from tfx.extensions.google_cloud_big_query import utils
  from tfx.extensions.google_cloud_big_query.example_gen import executor
  from tfx.proto import example_gen_pb2
  from tfx.types import artifact_utils
  from tfx.types import standard_artifacts
  from tfx.utils import proto_utils
label_desc: Use image node_id 2 for calling the ExecutorTest obj's underlying member method code with example usage: obj.testBigQueryToExample(mock_client) without return types