'Get a set of records from a Hive query.
>>> hh = HiveServer2Hook()
>>> sql = "SELECT * FROM airflow.static_babynames LIMIT 100"
>>> len(hh.get_records(sql))
100'

def get_records(self, hql, schema='default'):

    return self.get_results(hql, schema=schema)['data']
