:mod:`airflow.contrib.hooks.pinot_hook`
=======================================

.. py:module:: airflow.contrib.hooks.pinot_hook







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






.. py:class:: PinotDbApiHook(*args, **kwargs)

   Bases::class:`airflow.hooks.dbapi_hook.DbApiHook`

   

   Connect to pinot db(https://github.com/linkedin/pinot) to issue pql


   

   

   .. attribute:: conn_name_attr
      :annotation: = pinot_broker_conn_id 

      



   

   

   .. attribute:: default_conn_name
      :annotation: = pinot_broker_default 

      



   

   

   .. attribute:: supports_autocommit
      :annotation: = False 

      



   

   

   

   .. method:: get_conn(self)

      
      Establish a connection to pinot broker through pinot dbqpi.

      



   

   .. method:: get_uri(self)

      
      Get the connection uri for pinot broker.

      e.g: http://localhost:9000/pql

      



   

   .. method:: get_records(self, sql)

      
      Executes the sql and returns a set of records.

      :param sql: the sql statement to be executed (str) or a list of
          sql statements to execute
      :type sql: str

      



   

   .. method:: get_first(self, sql)

      
      Executes the sql and returns the first resulting row.

      :param sql: the sql statement to be executed (str) or a list of
          sql statements to execute
      :type sql: str or list

      



   

   .. method:: set_autocommit(self, conn, autocommit)

      



   

   .. method:: get_pandas_df(self, sql, parameters=None)

      



   

   .. method:: insert_rows(self, table, rows, target_fields=None, commit_every=1000)