'Get a pandas dataframe from a Hive query
>>> hh = HiveServer2Hook()
>>> sql = "SELECT * FROM airflow.static_babynames LIMIT 100"
>>> df = hh.get_pandas_df(sql)
>>> len(df.index)
100'

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

    import pandas as pd
    res = self.get_results(hql, schema=schema)
    df = pd.DataFrame(res['data'])
    df.columns = [c[0] for c in res['header']]
    return df
