Repository: hive Updated Branches: refs/heads/master 6f44fc810 -> ccb30e3ec
http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index 978c2a3..177531d 100644 --- a/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py +++ b/service/src/gen/thrift/gen-py/hive_service/ThriftHive.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -8,7 +8,6 @@ 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 @@ -117,7 +116,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchOne failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchOne failed: unknown result"); def fetchN(self, numRows): """ @@ -150,7 +149,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchN failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchN failed: unknown result"); def fetchAll(self): self.send_fetchAll() @@ -178,7 +177,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchAll failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "fetchAll failed: unknown result"); def getSchema(self): self.send_getSchema() @@ -206,7 +205,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "getSchema failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSchema failed: unknown result"); def getThriftSchema(self): self.send_getThriftSchema() @@ -234,7 +233,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "getThriftSchema failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "getThriftSchema failed: unknown result"); def getClusterStatus(self): self.send_getClusterStatus() @@ -262,7 +261,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterStatus failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "getClusterStatus failed: unknown result"); def getQueryPlan(self): self.send_getQueryPlan() @@ -290,7 +289,7 @@ class Client(hive_metastore.ThriftHiveMetastore.Client, Iface): return result.success if result.ex is not None: raise result.ex - raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueryPlan failed: unknown result") + raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueryPlan failed: unknown result"); def clean(self): self.send_clean() @@ -352,17 +351,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("execute", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -374,17 +365,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("fetchOne", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -396,17 +379,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("fetchN", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -418,17 +393,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("fetchAll", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -440,17 +407,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("getSchema", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -462,17 +421,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("getThriftSchema", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -484,17 +435,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("getClusterStatus", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -506,17 +449,9 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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 + except HiveServerException, ex: 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) + oprot.writeMessageBegin("getQueryPlan", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -526,16 +461,8 @@ class Processor(hive_metastore.ThriftHiveMetastore.Processor, Iface, TProcessor) 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) + self._handler.clean() + oprot.writeMessageBegin("clean", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -568,7 +495,7 @@ class execute_args: break if fid == 1: if ftype == TType.STRING: - self.query = iprot.readString() + self.query = iprot.readString(); else: iprot.skip(ftype) else: @@ -747,7 +674,7 @@ class fetchOne_result: break if fid == 0: if ftype == TType.STRING: - self.success = iprot.readString() + self.success = iprot.readString(); else: iprot.skip(ftype) elif fid == 1: @@ -823,7 +750,7 @@ class fetchN_args: break if fid == 1: if ftype == TType.I32: - self.numRows = iprot.readI32() + self.numRows = iprot.readI32(); else: iprot.skip(ftype) else: @@ -893,7 +820,7 @@ class fetchN_result: self.success = [] (_etype3, _size0) = iprot.readListBegin() for _i4 in xrange(_size0): - _elem5 = iprot.readString() + _elem5 = iprot.readString(); self.success.append(_elem5) iprot.readListEnd() else: @@ -1025,7 +952,7 @@ class fetchAll_result: self.success = [] (_etype10, _size7) = iprot.readListBegin() for _i11 in xrange(_size7): - _elem12 = iprot.readString() + _elem12 = iprot.readString(); self.success.append(_elem12) iprot.readListEnd() else: http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index 4a6492b..99717a9 100644 --- a/service/src/gen/thrift/gen-py/hive_service/constants.py +++ b/service/src/gen/thrift/gen-py/hive_service/constants.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index e19fe2a..29eb916 100644 --- a/service/src/gen/thrift/gen-py/hive_service/ttypes.py +++ b/service/src/gen/thrift/gen-py/hive_service/ttypes.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -75,32 +75,32 @@ class HiveClusterStatus: break if fid == 1: if ftype == TType.I32: - self.taskTrackers = iprot.readI32() + self.taskTrackers = iprot.readI32(); else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.mapTasks = iprot.readI32() + self.mapTasks = iprot.readI32(); else: iprot.skip(ftype) elif fid == 3: if ftype == TType.I32: - self.reduceTasks = iprot.readI32() + self.reduceTasks = iprot.readI32(); else: iprot.skip(ftype) elif fid == 4: if ftype == TType.I32: - self.maxMapTasks = iprot.readI32() + self.maxMapTasks = iprot.readI32(); else: iprot.skip(ftype) elif fid == 5: if ftype == TType.I32: - self.maxReduceTasks = iprot.readI32() + self.maxReduceTasks = iprot.readI32(); else: iprot.skip(ftype) elif fid == 6: if ftype == TType.I32: - self.state = iprot.readI32() + self.state = iprot.readI32(); else: iprot.skip(ftype) else: @@ -196,17 +196,17 @@ class HiveServerException(TException): break if fid == 1: if ftype == TType.STRING: - self.message = iprot.readString() + self.message = iprot.readString(); else: iprot.skip(ftype) elif fid == 2: if ftype == TType.I32: - self.errorCode = iprot.readI32() + self.errorCode = iprot.readI32(); else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.SQLState = iprot.readString() + self.SQLState = iprot.readString(); else: iprot.skip(ftype) else: http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index ed7d2d7..73f4d7b 100644 --- a/service/src/gen/thrift/gen-rb/hive_service_constants.rb +++ b/service/src/gen/thrift/gen-rb/hive_service_constants.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index 9191767..f97a6fb 100644 --- a/service/src/gen/thrift/gen-rb/hive_service_types.rb +++ b/service/src/gen/thrift/gen-rb/hive_service_types.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-rb/t_c_l_i_service.rb ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-rb/t_c_l_i_service.rb b/service/src/gen/thrift/gen-rb/t_c_l_i_service.rb index 7d7f7a7..f754d7d 100644 --- a/service/src/gen/thrift/gen-rb/t_c_l_i_service.rb +++ b/service/src/gen/thrift/gen-rb/t_c_l_i_service.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb b/service/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb index 25adbb4..3f72769 100644 --- a/service/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb +++ b/service/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb ---------------------------------------------------------------------- diff --git a/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb b/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb index f004ec4..bfb2b69 100644 --- a/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb +++ b/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/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 index 2b57cd9..6859ceb 100644 --- a/service/src/gen/thrift/gen-rb/thrift_hive.rb +++ b/service/src/gen/thrift/gen-rb/thrift_hive.rb @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING #
