code: def ReadFromBigQuery(  # pylint: disable=invalid-name
      pipeline: beam.Pipeline,
      query: str,
      big_query_custom_config: Optional[Dict[str, Any]] = None,
  ) -> beam.pvalue.PCollection:
      """Read data from BigQuery.
  
      Args:
        pipeline: Beam pipeline.
        query: A BigQuery sql string.
        big_query_custom_config: A BigQuery custom configs dict.
      Returns:
        PCollection of dict.
      """
      if big_query_custom_config is None:
          big_query_custom_config = {}
      return pipeline | "ReadFromBigQuery" >> bigquery.ReadFromBigQuery(
          query=query,
          use_standard_sql=True,
          bigquery_job_labels=telemetry_utils.make_labels_dict(),
          **big_query_custom_config,
      )
  
file_path: tfx/tfx/extensions/google_cloud_big_query/utils.py
imports: from typing import Any, Dict, List, Optional
  import apache_beam
  from apache_beam.io.gcp import bigquery
  from apache_beam.options import value_provider
  import tensorflow
  from tfx.utils import telemetry_utils
label_desc: Use image node_id 1 for calling a global function with example usage: ReadFromBigQuery(pipeline, query, big_query_custom_config) and returns: unknown