import pandas as pd
from connect2hive import Hive

def main():
    
    host  = 'test.direction.com'    # String containing the URL hosting your datanase (use "localhost" for databases running in your own system)
    port  = 10000                   # Integer containing the port in which your database is running
    db    = 'db_test'               #  String containing your database name
    table = 'tb_test'               # String containing your table name

    # Define your SQL query

    query = "SELECT * FROM " + table

    # Connect to Hive server

    hiv = Hive(host, port, db)

    # Execute the required query
       
    hiv.executequery(query)

    # Retrieve query into Pandas dataframe
       
    df = pd.DataFrame(hiv.fetchall())

    return

if __name__ == __main__:

    main()