airflow/contrib/hooks/pinot_hook.py
def 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
        """
        with self.get_conn() as cur:
            cur.execute(sql)
            return cur.fetchall()
def 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
        """
        with self.get_conn() as cur:
            cur.execute(sql)
            return cur.fetchall()
def get_records ( self , sql ) : with self . get_conn ( ) as cur : cur . execute ( sql ) return cur . fetchall ( )
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
Executes the sql and returns a set of records .