Python配置单元/hadoop连接

2024-04-25 23:05:28 发布

您现在位置:Python中文网/ 问答频道 /正文

我尝试使用python来使用Hive/Hadoop。在

import pyhs2
with pyhs2.connect(host='localhost',
               port=10000,
               authMechanism="PLAIN",
               user='None',
               password='None',
               database='Default') as conn:
with conn.cursor() as cur:
    #Show databases
    print cur.getDatabases()

    #Execute query
    cur.execute("select * from table")

    #Return column info from query
    print cur.getSchema()

    #Fetch table results
    for i in cur.fetch():
        print i

我得到以下错误。在

^{pr2}$

有人能告诉我怎么做吗?在


Tags: fromimporthadoopnoneasconnectwithtable