HiveClient - Apache Hive - Apache Software Foundation
Python
Operates only on a standalone server. Set (and export) PYTHONPATH to build/dist/lib/py.
The python modules imported in the code below are generated by building hive.
Please note that the generated python module names have changed in hive trunk.
#!/usr/bin/env python import sys from hive import ThriftHive from hive.ttypes import HiveServerException from thrift import Thrift from thrift.transport import TSocket from thrift.transport import TTransport from thrift.protocol import TBinaryProtocol try : transport = TSocket.TSocket('localhost', 10000) transport = TTransport.TBufferedTransport(transport) protocol = TBinaryProtocol.TBinaryProtocol(transport) client = ThriftHive.Client(protocol) transport.open() client.execute( "CREATE TABLE r(a STRING, b INT, c DOUBLE)" ) client.execute( "LOAD TABLE LOCAL INPATH '/path' INTO TABLE r" ) client.execute( "SELECT * FROM r" ) while (1): row = client.fetchOne() if (row == None): break print row client.execute( "SELECT * FROM r" ) print client.fetchAll() transport.close() except Thrift.TException, tx: print '%s' % (tx.message)
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
