楼主启动hive是用的Java,应该使用python
下面仅供参考
1 准备连接hive的python代码
在使用Python连接hive之前需要将hive中的文件拷贝到python的sys.path中
[mw_shl_code=bash,true]cp -r $HIVE_PATH/lib/py /usr/local/lib/python2.7/site-packages[/mw_shl_code]
或者将hive中连接代码,设法加入到python的eclipse项目中
总之,目的只有一个,就是用hive自己提供的python客户端代码,来连接hive
关于具体如果将第三方的python代码加入环境变量,可以参照python中添加环境变量
2 启动hive 的thrift
如果hive机器没有thrift请先安装,
确保以下服务开启:
[mw_shl_code=bash,true]hive --service hiveserver [/mw_shl_code]
3 写代码连接hive
hive的ip是机器的ip,端口默认为10000
-------------------------------------------------------------------
[mw_shl_code=python,true]import sys
from hive_service import ThriftHive
from hive_service.ttypes import HiveServerException
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
def hiveExe(sql):
try:
transport = TSocket.TSocket('127.0.0.1', 10000)
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = ThriftHive.Client(protocol)
transport.open()
client.execute(sql)
print "The return value is : "
print client.fetchAll()
print "............"
transport.close()
except Thrift.TException, tx:
print '%s' % (tx.message)
if __name__ == '__main__':
hiveExe("show tables")
--------------------------------[/mw_shl_code]
|