08-01 05:02 阅读 75

关注

HiveClient Apache Hive Apache Software Foundation

• HiveClient Apache Hive Apache Software Foundation

  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 pythonimport 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 TBinaryProtocoltry:
      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)

•