FAQ
Repository: hive
Updated Branches:
   refs/heads/master 815499af9 -> 6a4e0806a


http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py b/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py
deleted file mode 100644
index 978c2a3..0000000
--- a/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py
+++ /dev/null
@@ -1,1674 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-import hive_metastore.ThriftHiveMetastore
-import logging
-from ttypes import *
-from thrift.Thrift import TProcessor
-from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class Iface(hive_metastore.ThriftHiveMetastore.Iface):
- def execute(self, query):
- """
- Parameters:
- - query
- """
- pass
-
- def fetchOne(self):
- pass
-
- def fetchN(self, numRows):
- """
- Parameters:
- - numRows
- """
- pass
-
- def fetchAll(self):
- pass
-
- def getSchema(self):
- pass
-
- def getThriftSchema(self):
- pass
-
- def getClusterStatus(self):
- pass
-
- def getQueryPlan(self):
- pass
-
- def clean(self):
- pass
-
-
-class Client(hive_metastore.ThriftHiveMetastore.Client, Iface):
- def __init__(self, iprot, oprot=None):
- hive_metastore.ThriftHiveMetastore.Client.__init__(self, iprot, oprot)
-
- def execute(self, query):
- """
- Parameters:
- - query
- """
- self.send_execute(query)
- self.recv_execute()
-
- def send_execute(self, query):
- self._oprot.writeMessageBegin('execute', TMessageType.CALL, self._seqid)
- args = execute_args()
- args.query = query
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_execute(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = execute_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.ex is not None:
- raise result.ex
- return
-
- def fetchOne(self):
- self.send_fetchOne()
- return self.recv_fetchOne()
-
- def send_fetchOne(self):
- self._oprot.writeMessageBegin('fetchOne', TMessageType.CALL, self._seqid)
- args = fetchOne_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_fetchOne(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = fetchOne_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchOne failed: unknown result")
-
- def fetchN(self, numRows):
- """
- Parameters:
- - numRows
- """
- self.send_fetchN(numRows)
- return self.recv_fetchN()
-
- def send_fetchN(self, numRows):
- self._oprot.writeMessageBegin('fetchN', TMessageType.CALL, self._seqid)
- args = fetchN_args()
- args.numRows = numRows
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_fetchN(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = fetchN_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchN failed: unknown result")
-
- def fetchAll(self):
- self.send_fetchAll()
- return self.recv_fetchAll()
-
- def send_fetchAll(self):
- self._oprot.writeMessageBegin('fetchAll', TMessageType.CALL, self._seqid)
- args = fetchAll_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_fetchAll(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = fetchAll_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchAll failed: unknown result")
-
- def getSchema(self):
- self.send_getSchema()
- return self.recv_getSchema()
-
- def send_getSchema(self):
- self._oprot.writeMessageBegin('getSchema', TMessageType.CALL, self._seqid)
- args = getSchema_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getSchema(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = getSchema_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getSchema failed: unknown result")
-
- def getThriftSchema(self):
- self.send_getThriftSchema()
- return self.recv_getThriftSchema()
-
- def send_getThriftSchema(self):
- self._oprot.writeMessageBegin('getThriftSchema', TMessageType.CALL, self._seqid)
- args = getThriftSchema_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getThriftSchema(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = getThriftSchema_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getThriftSchema failed: unknown result")
-
- def getClusterStatus(self):
- self.send_getClusterStatus()
- return self.recv_getClusterStatus()
-
- def send_getClusterStatus(self):
- self._oprot.writeMessageBegin('getClusterStatus', TMessageType.CALL, self._seqid)
- args = getClusterStatus_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getClusterStatus(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = getClusterStatus_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterStatus failed: unknown result")
-
- def getQueryPlan(self):
- self.send_getQueryPlan()
- return self.recv_getQueryPlan()
-
- def send_getQueryPlan(self):
- self._oprot.writeMessageBegin('getQueryPlan', TMessageType.CALL, self._seqid)
- args = getQueryPlan_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getQueryPlan(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = getQueryPlan_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.ex is not None:
- raise result.ex
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueryPlan failed: unknown result")
-
- def clean(self):
- self.send_clean()
- self.recv_clean()
-
- def send_clean(self):
- self._oprot.writeMessageBegin('clean', TMessageType.CALL, self._seqid)
- args = clean_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_clean(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = clean_result()
- result.read(iprot)
- iprot.readMessageEnd()
- return
-
-
-class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor):
- def __init__(self, handler):
- hive_metastore.ThriftHiveMetastore.Processor.__init__(self, handler)
- self._processMap["execute"] = Processor.process_execute
- self._processMap["fetchOne"] = Processor.process_fetchOne
- self._processMap["fetchN"] = Processor.process_fetchN
- self._processMap["fetchAll"] = Processor.process_fetchAll
- self._processMap["getSchema"] = Processor.process_getSchema
- self._processMap["getThriftSchema"] = Processor.process_getThriftSchema
- self._processMap["getClusterStatus"] = Processor.process_getClusterStatus
- self._processMap["getQueryPlan"] = Processor.process_getQueryPlan
- self._processMap["clean"] = Processor.process_clean
-
- def process(self, iprot, oprot):
- (name, type, seqid) = iprot.readMessageBegin()
- if name not in self._processMap:
- iprot.skip(TType.STRUCT)
- iprot.readMessageEnd()
- x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
- oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
- x.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
- return
- else:
- self._processMap[name](self, seqid, iprot, oprot)
- return True
-
- def process_execute(self, seqid, iprot, oprot):
- args = execute_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = execute_result()
- try:
- self._handler.execute(args.query)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("execute", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_fetchOne(self, seqid, iprot, oprot):
- args = fetchOne_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = fetchOne_result()
- try:
- result.success = self._handler.fetchOne()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("fetchOne", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_fetchN(self, seqid, iprot, oprot):
- args = fetchN_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = fetchN_result()
- try:
- result.success = self._handler.fetchN(args.numRows)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("fetchN", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_fetchAll(self, seqid, iprot, oprot):
- args = fetchAll_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = fetchAll_result()
- try:
- result.success = self._handler.fetchAll()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("fetchAll", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getSchema(self, seqid, iprot, oprot):
- args = getSchema_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getSchema_result()
- try:
- result.success = self._handler.getSchema()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("getSchema", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getThriftSchema(self, seqid, iprot, oprot):
- args = getThriftSchema_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getThriftSchema_result()
- try:
- result.success = self._handler.getThriftSchema()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("getThriftSchema", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getClusterStatus(self, seqid, iprot, oprot):
- args = getClusterStatus_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getClusterStatus_result()
- try:
- result.success = self._handler.getClusterStatus()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("getClusterStatus", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getQueryPlan(self, seqid, iprot, oprot):
- args = getQueryPlan_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getQueryPlan_result()
- try:
- result.success = self._handler.getQueryPlan()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except HiveServerException as ex:
- msg_type = TMessageType.REPLY
- result.ex = ex
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("getQueryPlan", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_clean(self, seqid, iprot, oprot):
- args = clean_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = clean_result()
- try:
- self._handler.clean()
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("clean", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
-
-# HELPER FUNCTIONS AND STRUCTURES
-
-class execute_args:
- """
- Attributes:
- - query
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'query', None, None, ), # 1
- )
-
- def __init__(self, query=None,):
- self.query = query
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.query = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('execute_args')
- if self.query is not None:
- oprot.writeFieldBegin('query', TType.STRING, 1)
- oprot.writeString(self.query)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.query)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class execute_result:
- """
- Attributes:
- - ex
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, ex=None,):
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('execute_result')
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchOne_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchOne_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchOne_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.STRING, 'success', None, None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRING:
- self.success = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchOne_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRING, 0)
- oprot.writeString(self.success)
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchN_args:
- """
- Attributes:
- - numRows
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'numRows', None, None, ), # 1
- )
-
- def __init__(self, numRows=None,):
- self.numRows = numRows
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.numRows = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchN_args')
- if self.numRows is not None:
- oprot.writeFieldBegin('numRows', TType.I32, 1)
- oprot.writeI32(self.numRows)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.numRows)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchN_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in xrange(_size0):
- _elem5 = iprot.readString()
- self.success.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchN_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter6 in self.success:
- oprot.writeString(iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchAll_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchAll_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class fetchAll_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype10, _size7) = iprot.readListBegin()
- for _i11 in xrange(_size7):
- _elem12 = iprot.readString()
- self.success.append(_elem12)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('fetchAll_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
- for iter13 in self.success:
- oprot.writeString(iter13)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getSchema_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getSchema_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getSchema_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (hive_metastore.ttypes.Schema, hive_metastore.ttypes.Schema.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRUCT:
- self.success = hive_metastore.ttypes.Schema()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getSchema_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getThriftSchema_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getThriftSchema_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getThriftSchema_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (hive_metastore.ttypes.Schema, hive_metastore.ttypes.Schema.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRUCT:
- self.success = hive_metastore.ttypes.Schema()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getThriftSchema_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getClusterStatus_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getClusterStatus_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getClusterStatus_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (HiveClusterStatus, HiveClusterStatus.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRUCT:
- self.success = HiveClusterStatus()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getClusterStatus_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getQueryPlan_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getQueryPlan_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class getQueryPlan_result:
- """
- Attributes:
- - success
- - ex
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (queryplan.ttypes.QueryPlan, queryplan.ttypes.QueryPlan.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'ex', (HiveServerException, HiveServerException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, ex=None,):
- self.success = success
- self.ex = ex
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRUCT:
- self.success = queryplan.ttypes.QueryPlan()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.ex = HiveServerException()
- self.ex.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('getQueryPlan_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
- if self.ex is not None:
- oprot.writeFieldBegin('ex', TType.STRUCT, 1)
- self.ex.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.ex)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class clean_args:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('clean_args')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class clean_result:
-
- thrift_spec = (
- )
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('clean_result')
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-py/hive_service/__init__.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/hive_service/__init__.py b/service/src/gen/thrift/gen-py/hive_service/__init__.py
deleted file mode 100644
index 6a0dcc9..0000000
--- a/service/src/gen/thrift/gen-py/hive_service/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants', 'ThriftHive']

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-py/hive_service/constants.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/hive_service/constants.py b/service/src/gen/thrift/gen-py/hive_service/constants.py
deleted file mode 100644
index 4a6492b..0000000
--- a/service/src/gen/thrift/gen-py/hive_service/constants.py
+++ /dev/null
@@ -1,11 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
-

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-py/hive_service/ttypes.py
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-py/hive_service/ttypes.py b/service/src/gen/thrift/gen-py/hive_service/ttypes.py
deleted file mode 100644
index e19fe2a..0000000
--- a/service/src/gen/thrift/gen-py/hive_service/ttypes.py
+++ /dev/null
@@ -1,260 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-import fb303.ttypes
-import hive_metastore.ttypes
-import queryplan.ttypes
-
-
-from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
- from thrift.protocol import fastbinary
-except:
- fastbinary = None
-
-
-class JobTrackerState:
- INITIALIZING = 1
- RUNNING = 2
-
- _VALUES_TO_NAMES = {
- 1: "INITIALIZING",
- 2: "RUNNING",
- }
-
- _NAMES_TO_VALUES = {
- "INITIALIZING": 1,
- "RUNNING": 2,
- }
-
-
-class HiveClusterStatus:
- """
- Attributes:
- - taskTrackers
- - mapTasks
- - reduceTasks
- - maxMapTasks
- - maxReduceTasks
- - state
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'taskTrackers', None, None, ), # 1
- (2, TType.I32, 'mapTasks', None, None, ), # 2
- (3, TType.I32, 'reduceTasks', None, None, ), # 3
- (4, TType.I32, 'maxMapTasks', None, None, ), # 4
- (5, TType.I32, 'maxReduceTasks', None, None, ), # 5
- (6, TType.I32, 'state', None, None, ), # 6
- )
-
- def __init__(self, taskTrackers=None, mapTasks=None, reduceTasks=None, maxMapTasks=None, maxReduceTasks=None, state=None,):
- self.taskTrackers = taskTrackers
- self.mapTasks = mapTasks
- self.reduceTasks = reduceTasks
- self.maxMapTasks = maxMapTasks
- self.maxReduceTasks = maxReduceTasks
- self.state = state
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.taskTrackers = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.mapTasks = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.reduceTasks = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I32:
- self.maxMapTasks = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I32:
- self.maxReduceTasks = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I32:
- self.state = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('HiveClusterStatus')
- if self.taskTrackers is not None:
- oprot.writeFieldBegin('taskTrackers', TType.I32, 1)
- oprot.writeI32(self.taskTrackers)
- oprot.writeFieldEnd()
- if self.mapTasks is not None:
- oprot.writeFieldBegin('mapTasks', TType.I32, 2)
- oprot.writeI32(self.mapTasks)
- oprot.writeFieldEnd()
- if self.reduceTasks is not None:
- oprot.writeFieldBegin('reduceTasks', TType.I32, 3)
- oprot.writeI32(self.reduceTasks)
- oprot.writeFieldEnd()
- if self.maxMapTasks is not None:
- oprot.writeFieldBegin('maxMapTasks', TType.I32, 4)
- oprot.writeI32(self.maxMapTasks)
- oprot.writeFieldEnd()
- if self.maxReduceTasks is not None:
- oprot.writeFieldBegin('maxReduceTasks', TType.I32, 5)
- oprot.writeI32(self.maxReduceTasks)
- oprot.writeFieldEnd()
- if self.state is not None:
- oprot.writeFieldBegin('state', TType.I32, 6)
- oprot.writeI32(self.state)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.taskTrackers)
- value = (value * 31) ^ hash(self.mapTasks)
- value = (value * 31) ^ hash(self.reduceTasks)
- value = (value * 31) ^ hash(self.maxMapTasks)
- value = (value * 31) ^ hash(self.maxReduceTasks)
- value = (value * 31) ^ hash(self.state)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class HiveServerException(TException):
- """
- Attributes:
- - message
- - errorCode
- - SQLState
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'message', None, None, ), # 1
- (2, TType.I32, 'errorCode', None, None, ), # 2
- (3, TType.STRING, 'SQLState', None, None, ), # 3
- )
-
- def __init__(self, message=None, errorCode=None, SQLState=None,):
- self.message = message
- self.errorCode = errorCode
- self.SQLState = SQLState
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.message = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.errorCode = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.SQLState = iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('HiveServerException')
- if self.message is not None:
- oprot.writeFieldBegin('message', TType.STRING, 1)
- oprot.writeString(self.message)
- oprot.writeFieldEnd()
- if self.errorCode is not None:
- oprot.writeFieldBegin('errorCode', TType.I32, 2)
- oprot.writeI32(self.errorCode)
- oprot.writeFieldEnd()
- if self.SQLState is not None:
- oprot.writeFieldBegin('SQLState', TType.STRING, 3)
- oprot.writeString(self.SQLState)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __str__(self):
- return repr(self)
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.message)
- value = (value * 31) ^ hash(self.errorCode)
- value = (value * 31) ^ hash(self.SQLState)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-rb/hive_service_constants.rb
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-rb/hive_service_constants.rb b/service/src/gen/thrift/gen-rb/hive_service_constants.rb
deleted file mode 100644
index ed7d2d7..0000000
--- a/service/src/gen/thrift/gen-rb/hive_service_constants.rb
+++ /dev/null
@@ -1,9 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-require 'thrift'
-require 'hive_service_types'
-

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-rb/hive_service_types.rb
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-rb/hive_service_types.rb b/service/src/gen/thrift/gen-rb/hive_service_types.rb
deleted file mode 100644
index 9191767..0000000
--- a/service/src/gen/thrift/gen-rb/hive_service_types.rb
+++ /dev/null
@@ -1,68 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-require 'thrift'
-require 'fb303_types'
-require 'hive_metastore_types'
-require 'queryplan_types'
-
-
-module JobTrackerState
- INITIALIZING = 1
- RUNNING = 2
- VALUE_MAP = {1 => "INITIALIZING", 2 => "RUNNING"}
- VALID_VALUES = Set.new([INITIALIZING, RUNNING]).freeze
-end
-
-class HiveClusterStatus
- include ::Thrift::Struct, ::Thrift::Struct_Union
- TASKTRACKERS = 1
- MAPTASKS = 2
- REDUCETASKS = 3
- MAXMAPTASKS = 4
- MAXREDUCETASKS = 5
- STATE = 6
-
- FIELDS = {
- TASKTRACKERS => {:type => ::Thrift::Types::I32, :name => 'taskTrackers'},
- MAPTASKS => {:type => ::Thrift::Types::I32, :name => 'mapTasks'},
- REDUCETASKS => {:type => ::Thrift::Types::I32, :name => 'reduceTasks'},
- MAXMAPTASKS => {:type => ::Thrift::Types::I32, :name => 'maxMapTasks'},
- MAXREDUCETASKS => {:type => ::Thrift::Types::I32, :name => 'maxReduceTasks'},
- STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::JobTrackerState}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- unless @state.nil? || ::JobTrackerState::VALID_VALUES.include?(@state)
- raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!')
- end
- end
-
- ::Thrift::Struct.generate_accessors self
-end
-
-class HiveServerException < ::Thrift::Exception
- include ::Thrift::Struct, ::Thrift::Struct_Union
- MESSAGE = 1
- ERRORCODE = 2
- SQLSTATE = 3
-
- FIELDS = {
- MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'},
- ERRORCODE => {:type => ::Thrift::Types::I32, :name => 'errorCode'},
- SQLSTATE => {:type => ::Thrift::Types::STRING, :name => 'SQLState'}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
-end
-

http://git-wip-us.apache.org/repos/asf/hive/blob/6a4e0806/service/src/gen/thrift/gen-rb/thrift_hive.rb
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-rb/thrift_hive.rb b/service/src/gen/thrift/gen-rb/thrift_hive.rb
deleted file mode 100644
index 2b57cd9..0000000
--- a/service/src/gen/thrift/gen-rb/thrift_hive.rb
+++ /dev/null
@@ -1,555 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.9.3)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-
-require 'thrift'
-require 'thrift_hive_metastore'
-require 'hive_service_types'
-
-module ThriftHive
- class Client < ::ThriftHiveMetastore::Client
- include ::Thrift::Client
-
- def execute(query)
- send_execute(query)
- recv_execute()
- end
-
- def send_execute(query)
- send_message('execute', Execute_args, :query => query)
- end
-
- def recv_execute()
- result = receive_message(Execute_result)
- raise result.ex unless result.ex.nil?
- return
- end
-
- def fetchOne()
- send_fetchOne()
- return recv_fetchOne()
- end
-
- def send_fetchOne()
- send_message('fetchOne', FetchOne_args)
- end
-
- def recv_fetchOne()
- result = receive_message(FetchOne_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchOne failed: unknown result')
- end
-
- def fetchN(numRows)
- send_fetchN(numRows)
- return recv_fetchN()
- end
-
- def send_fetchN(numRows)
- send_message('fetchN', FetchN_args, :numRows => numRows)
- end
-
- def recv_fetchN()
- result = receive_message(FetchN_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchN failed: unknown result')
- end
-
- def fetchAll()
- send_fetchAll()
- return recv_fetchAll()
- end
-
- def send_fetchAll()
- send_message('fetchAll', FetchAll_args)
- end
-
- def recv_fetchAll()
- result = receive_message(FetchAll_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchAll failed: unknown result')
- end
-
- def getSchema()
- send_getSchema()
- return recv_getSchema()
- end
-
- def send_getSchema()
- send_message('getSchema', GetSchema_args)
- end
-
- def recv_getSchema()
- result = receive_message(GetSchema_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSchema failed: unknown result')
- end
-
- def getThriftSchema()
- send_getThriftSchema()
- return recv_getThriftSchema()
- end
-
- def send_getThriftSchema()
- send_message('getThriftSchema', GetThriftSchema_args)
- end
-
- def recv_getThriftSchema()
- result = receive_message(GetThriftSchema_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getThriftSchema failed: unknown result')
- end
-
- def getClusterStatus()
- send_getClusterStatus()
- return recv_getClusterStatus()
- end
-
- def send_getClusterStatus()
- send_message('getClusterStatus', GetClusterStatus_args)
- end
-
- def recv_getClusterStatus()
- result = receive_message(GetClusterStatus_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getClusterStatus failed: unknown result')
- end
-
- def getQueryPlan()
- send_getQueryPlan()
- return recv_getQueryPlan()
- end
-
- def send_getQueryPlan()
- send_message('getQueryPlan', GetQueryPlan_args)
- end
-
- def recv_getQueryPlan()
- result = receive_message(GetQueryPlan_result)
- return result.success unless result.success.nil?
- raise result.ex unless result.ex.nil?
- raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getQueryPlan failed: unknown result')
- end
-
- def clean()
- send_clean()
- recv_clean()
- end
-
- def send_clean()
- send_message('clean', Clean_args)
- end
-
- def recv_clean()
- result = receive_message(Clean_result)
- return
- end
-
- end
-
- class Processor < ::ThriftHiveMetastore::Processor
- include ::Thrift::Processor
-
- def process_execute(seqid, iprot, oprot)
- args = read_args(iprot, Execute_args)
- result = Execute_result.new()
- begin
- @handler.execute(args.query)
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'execute', seqid)
- end
-
- def process_fetchOne(seqid, iprot, oprot)
- args = read_args(iprot, FetchOne_args)
- result = FetchOne_result.new()
- begin
- result.success = @handler.fetchOne()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'fetchOne', seqid)
- end
-
- def process_fetchN(seqid, iprot, oprot)
- args = read_args(iprot, FetchN_args)
- result = FetchN_result.new()
- begin
- result.success = @handler.fetchN(args.numRows)
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'fetchN', seqid)
- end
-
- def process_fetchAll(seqid, iprot, oprot)
- args = read_args(iprot, FetchAll_args)
- result = FetchAll_result.new()
- begin
- result.success = @handler.fetchAll()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'fetchAll', seqid)
- end
-
- def process_getSchema(seqid, iprot, oprot)
- args = read_args(iprot, GetSchema_args)
- result = GetSchema_result.new()
- begin
- result.success = @handler.getSchema()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'getSchema', seqid)
- end
-
- def process_getThriftSchema(seqid, iprot, oprot)
- args = read_args(iprot, GetThriftSchema_args)
- result = GetThriftSchema_result.new()
- begin
- result.success = @handler.getThriftSchema()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'getThriftSchema', seqid)
- end
-
- def process_getClusterStatus(seqid, iprot, oprot)
- args = read_args(iprot, GetClusterStatus_args)
- result = GetClusterStatus_result.new()
- begin
- result.success = @handler.getClusterStatus()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'getClusterStatus', seqid)
- end
-
- def process_getQueryPlan(seqid, iprot, oprot)
- args = read_args(iprot, GetQueryPlan_args)
- result = GetQueryPlan_result.new()
- begin
- result.success = @handler.getQueryPlan()
- rescue ::HiveServerException => ex
- result.ex = ex
- end
- write_result(result, oprot, 'getQueryPlan', seqid)
- end
-
- def process_clean(seqid, iprot, oprot)
- args = read_args(iprot, Clean_args)
- result = Clean_result.new()
- @handler.clean()
- write_result(result, oprot, 'clean', seqid)
- end
-
- end
-
- # HELPER FUNCTIONS AND STRUCTURES
-
- class Execute_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
- QUERY = 1
-
- FIELDS = {
- QUERY => {:type => ::Thrift::Types::STRING, :name => 'query'}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class Execute_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- EX = 1
-
- FIELDS = {
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchOne_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchOne_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::STRING, :name => 'success'},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchN_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
- NUMROWS = 1
-
- FIELDS = {
- NUMROWS => {:type => ::Thrift::Types::I32, :name => 'numRows'}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchN_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchAll_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class FetchAll_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetSchema_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetSchema_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Schema},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetThriftSchema_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetThriftSchema_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Schema},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetClusterStatus_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetClusterStatus_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::HiveClusterStatus},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetQueryPlan_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class GetQueryPlan_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
- SUCCESS = 0
- EX = 1
-
- FIELDS = {
- SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::QueryPlan},
- EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::HiveServerException}
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class Clean_args
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
- class Clean_result
- include ::Thrift::Struct, ::Thrift::Struct_Union
-
- FIELDS = {
-
- }
-
- def struct_fields; FIELDS; end
-
- def validate
- end
-
- ::Thrift::Struct.generate_accessors self
- end
-
-end
-

Search Discussions

Discussion Posts

Previous

Follow ups

Related Discussions

Discussion Navigation
viewthread | post
posts ‹ prev | 4 of 31 | next ›
Discussion Overview
groupcommits @
categorieshive, hadoop
postedApr 26, '16 at 11:16p
activeApr 28, '16 at 10:15p
posts31
users5
websitehive.apache.org

People

Translate

site design / logo © 2021 Grokbase