from pyhive import hive
创建一个 Hive 连接对象:
conn = hive.Connection(host='your_hive_host', port=10000, username='your_username')
创建一个 Hive 游标对象:
cursor = conn.cursor()
执行一个样例的 Hive 查询:
cursor.execute('SELECT * FROM your_table')
获取样例查询的所有查询结果:
results = cursor.fetchall()
打印查询结果:
for row in results:
print(row)
关闭 Hive 游标对象:
cursor.close()
关闭 Hive 连接对象:
conn.close()