:py:mod:`astronomer.providers.google.cloud.extractors.bigquery`
===============================================================

.. py:module:: astronomer.providers.google.cloud.extractors.bigquery


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.google.cloud.extractors.bigquery.SqlContext
   astronomer.providers.google.cloud.extractors.bigquery.BigQueryAsyncExtractor




.. py:class:: SqlContext

   Internal SQL context for holding query parser results

   .. py:attribute:: sql
      :type: str

      

   .. py:attribute:: inputs
      :type: Optional[str]

      

   .. py:attribute:: outputs
      :type: Optional[str]

      

   .. py:attribute:: parser_error
      :type: Optional[str]

      


.. py:class:: BigQueryAsyncExtractor(operator)

   Bases: :py:obj:`openlineage.airflow.extractors.base.BaseExtractor`

   This extractor provides visibility on the metadata of a BigQuery Insert Job
   including ``billedBytes``, ``rowCount``, ``size``, etc. submitted from a
   ``BigQueryInsertJobOperatorAsync`` operator.

   .. py:method:: get_operator_classnames()
      :classmethod:

      Returns the list of operators this extractor works on.


   .. py:method:: extract()

      Empty extract implementation for the abstractmethod of the ``BaseExtractor`` class.


   .. py:method:: extract_on_complete(task_instance)

      Callback on task completion to fetch metadata extraction details that are to be pushed to the Lineage server.

      :param task_instance: Instance of the Airflow task whose metadata needs to be extracted.


   .. py:method:: parse_sql_context()

      Gets SQL from operator and transforms it to `SqlContext` object.