Modified: hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1622763&r1=1622762&r2=1622763&view=diff ============================================================================== --- hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Sep 5 19:15:44 2014 @@ -237,6 +237,13 @@ class Iface(fb303.FacebookService.Iface) """ pass + def add_partitions_pspec(self, new_parts): + """ + Parameters: + - new_parts + """ + pass + def append_partition(self, db_name, tbl_name, part_vals): """ Parameters: @@ -391,6 +398,15 @@ class Iface(fb303.FacebookService.Iface) """ pass + def get_partitions_pspec(self, db_name, tbl_name, max_parts): + """ + Parameters: + - db_name + - tbl_name + - max_parts + """ + pass + def get_partition_names(self, db_name, tbl_name, max_parts): """ Parameters: @@ -442,6 +458,16 @@ class Iface(fb303.FacebookService.Iface) """ pass + def get_part_specs_by_filter(self, db_name, tbl_name, filter, max_parts): + """ + Parameters: + - db_name + - tbl_name + - filter + - max_parts + """ + pass + def get_partitions_by_expr(self, req): """ Parameters: @@ -1935,6 +1961,42 @@ class Client(fb303.FacebookService.Clien raise result.o3 raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions failed: unknown result"); + def add_partitions_pspec(self, new_parts): + """ + Parameters: + - new_parts + """ + self.send_add_partitions_pspec(new_parts) + return self.recv_add_partitions_pspec() + + def send_add_partitions_pspec(self, new_parts): + self._oprot.writeMessageBegin('add_partitions_pspec', TMessageType.CALL, self._seqid) + args = add_partitions_pspec_args() + args.new_parts = new_parts + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_add_partitions_pspec(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = add_partitions_pspec_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + if result.o3 is not None: + raise result.o3 + raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_pspec failed: unknown result"); + def append_partition(self, db_name, tbl_name, part_vals): """ Parameters: @@ -2577,6 +2639,44 @@ class Client(fb303.FacebookService.Clien raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_with_auth failed: unknown result"); + def get_partitions_pspec(self, db_name, tbl_name, max_parts): + """ + Parameters: + - db_name + - tbl_name + - max_parts + """ + self.send_get_partitions_pspec(db_name, tbl_name, max_parts) + return self.recv_get_partitions_pspec() + + def send_get_partitions_pspec(self, db_name, tbl_name, max_parts): + self._oprot.writeMessageBegin('get_partitions_pspec', TMessageType.CALL, self._seqid) + args = get_partitions_pspec_args() + args.db_name = db_name + args.tbl_name = tbl_name + args.max_parts = max_parts + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_partitions_pspec(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = get_partitions_pspec_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_pspec failed: unknown result"); + def get_partition_names(self, db_name, tbl_name, max_parts): """ Parameters: @@ -2777,6 +2877,46 @@ class Client(fb303.FacebookService.Clien raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result"); + def get_part_specs_by_filter(self, db_name, tbl_name, filter, max_parts): + """ + Parameters: + - db_name + - tbl_name + - filter + - max_parts + """ + self.send_get_part_specs_by_filter(db_name, tbl_name, filter, max_parts) + return self.recv_get_part_specs_by_filter() + + def send_get_part_specs_by_filter(self, db_name, tbl_name, filter, max_parts): + self._oprot.writeMessageBegin('get_part_specs_by_filter', TMessageType.CALL, self._seqid) + args = get_part_specs_by_filter_args() + args.db_name = db_name + args.tbl_name = tbl_name + args.filter = filter + args.max_parts = max_parts + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_part_specs_by_filter(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = get_part_specs_by_filter_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_part_specs_by_filter failed: unknown result"); + def get_partitions_by_expr(self, req): """ Parameters: @@ -5040,6 +5180,7 @@ class Processor(fb303.FacebookService.Pr self._processMap["add_partition"] = Processor.process_add_partition self._processMap["add_partition_with_environment_context"] = Processor.process_add_partition_with_environment_context self._processMap["add_partitions"] = Processor.process_add_partitions + self._processMap["add_partitions_pspec"] = Processor.process_add_partitions_pspec self._processMap["append_partition"] = Processor.process_append_partition self._processMap["add_partitions_req"] = Processor.process_add_partitions_req self._processMap["append_partition_with_environment_context"] = Processor.process_append_partition_with_environment_context @@ -5056,11 +5197,13 @@ class Processor(fb303.FacebookService.Pr self._processMap["get_partition_by_name"] = Processor.process_get_partition_by_name self._processMap["get_partitions"] = Processor.process_get_partitions self._processMap["get_partitions_with_auth"] = Processor.process_get_partitions_with_auth + self._processMap["get_partitions_pspec"] = Processor.process_get_partitions_pspec self._processMap["get_partition_names"] = Processor.process_get_partition_names self._processMap["get_partitions_ps"] = Processor.process_get_partitions_ps self._processMap["get_partitions_ps_with_auth"] = Processor.process_get_partitions_ps_with_auth self._processMap["get_partition_names_ps"] = Processor.process_get_partition_names_ps self._processMap["get_partitions_by_filter"] = Processor.process_get_partitions_by_filter + self._processMap["get_part_specs_by_filter"] = Processor.process_get_part_specs_by_filter self._processMap["get_partitions_by_expr"] = Processor.process_get_partitions_by_expr self._processMap["get_partitions_by_names"] = Processor.process_get_partitions_by_names self._processMap["alter_partition"] = Processor.process_alter_partition @@ -5603,6 +5746,24 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_add_partitions_pspec(self, seqid, iprot, oprot): + args = add_partitions_pspec_args() + args.read(iprot) + iprot.readMessageEnd() + result = add_partitions_pspec_result() + try: + result.success = self._handler.add_partitions_pspec(args.new_parts) + except InvalidObjectException as o1: + result.o1 = o1 + except AlreadyExistsException as o2: + result.o2 = o2 + except MetaException as o3: + result.o3 = o3 + oprot.writeMessageBegin("add_partitions_pspec", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_append_partition(self, seqid, iprot, oprot): args = append_partition_args() args.read(iprot) @@ -5873,6 +6034,22 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_get_partitions_pspec(self, seqid, iprot, oprot): + args = get_partitions_pspec_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_partitions_pspec_result() + try: + result.success = self._handler.get_partitions_pspec(args.db_name, args.tbl_name, args.max_parts) + except NoSuchObjectException as o1: + result.o1 = o1 + except MetaException as o2: + result.o2 = o2 + oprot.writeMessageBegin("get_partitions_pspec", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_get_partition_names(self, seqid, iprot, oprot): args = get_partition_names_args() args.read(iprot) @@ -5951,6 +6128,22 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_get_part_specs_by_filter(self, seqid, iprot, oprot): + args = get_part_specs_by_filter_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_part_specs_by_filter_result() + try: + result.success = self._handler.get_part_specs_by_filter(args.db_name, args.tbl_name, args.filter, args.max_parts) + except MetaException as o1: + result.o1 = o1 + except NoSuchObjectException as o2: + result.o2 = o2 + oprot.writeMessageBegin("get_part_specs_by_filter", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_get_partitions_by_expr(self, seqid, iprot, oprot): args = get_partitions_by_expr_args() args.read(iprot) @@ -7765,10 +7958,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype407, _size404) = iprot.readListBegin() - for _i408 in xrange(_size404): - _elem409 = iprot.readString(); - self.success.append(_elem409) + (_etype437, _size434) = iprot.readListBegin() + for _i438 in xrange(_size434): + _elem439 = iprot.readString(); + self.success.append(_elem439) iprot.readListEnd() else: iprot.skip(ftype) @@ -7791,8 +7984,8 @@ class get_databases_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter410 in self.success: - oprot.writeString(iter410) + for iter440 in self.success: + oprot.writeString(iter440) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -7887,10 +8080,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype414, _size411) = iprot.readListBegin() - for _i415 in xrange(_size411): - _elem416 = iprot.readString(); - self.success.append(_elem416) + (_etype444, _size441) = iprot.readListBegin() + for _i445 in xrange(_size441): + _elem446 = iprot.readString(); + self.success.append(_elem446) iprot.readListEnd() else: iprot.skip(ftype) @@ -7913,8 +8106,8 @@ class get_all_databases_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter417 in self.success: - oprot.writeString(iter417) + for iter447 in self.success: + oprot.writeString(iter447) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8624,12 +8817,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype419, _vtype420, _size418 ) = iprot.readMapBegin() - for _i422 in xrange(_size418): - _key423 = iprot.readString(); - _val424 = Type() - _val424.read(iprot) - self.success[_key423] = _val424 + (_ktype449, _vtype450, _size448 ) = iprot.readMapBegin() + for _i452 in xrange(_size448): + _key453 = iprot.readString(); + _val454 = Type() + _val454.read(iprot) + self.success[_key453] = _val454 iprot.readMapEnd() else: iprot.skip(ftype) @@ -8652,9 +8845,9 @@ class get_type_all_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter425,viter426 in self.success.items(): - oprot.writeString(kiter425) - viter426.write(oprot) + for kiter455,viter456 in self.success.items(): + oprot.writeString(kiter455) + viter456.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -8785,11 +8978,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype430, _size427) = iprot.readListBegin() - for _i431 in xrange(_size427): - _elem432 = FieldSchema() - _elem432.read(iprot) - self.success.append(_elem432) + (_etype460, _size457) = iprot.readListBegin() + for _i461 in xrange(_size457): + _elem462 = FieldSchema() + _elem462.read(iprot) + self.success.append(_elem462) iprot.readListEnd() else: iprot.skip(ftype) @@ -8824,8 +9017,8 @@ class get_fields_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter433 in self.success: - iter433.write(oprot) + for iter463 in self.success: + iter463.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8964,11 +9157,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype437, _size434) = iprot.readListBegin() - for _i438 in xrange(_size434): - _elem439 = FieldSchema() - _elem439.read(iprot) - self.success.append(_elem439) + (_etype467, _size464) = iprot.readListBegin() + for _i468 in xrange(_size464): + _elem469 = FieldSchema() + _elem469.read(iprot) + self.success.append(_elem469) iprot.readListEnd() else: iprot.skip(ftype) @@ -9003,8 +9196,8 @@ class get_schema_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter440 in self.success: - iter440.write(oprot) + for iter470 in self.success: + iter470.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9801,10 +9994,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype444, _size441) = iprot.readListBegin() - for _i445 in xrange(_size441): - _elem446 = iprot.readString(); - self.success.append(_elem446) + (_etype474, _size471) = iprot.readListBegin() + for _i475 in xrange(_size471): + _elem476 = iprot.readString(); + self.success.append(_elem476) iprot.readListEnd() else: iprot.skip(ftype) @@ -9827,8 +10020,8 @@ class get_tables_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter447 in self.success: - oprot.writeString(iter447) + for iter477 in self.success: + oprot.writeString(iter477) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9941,10 +10134,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype451, _size448) = iprot.readListBegin() - for _i452 in xrange(_size448): - _elem453 = iprot.readString(); - self.success.append(_elem453) + (_etype481, _size478) = iprot.readListBegin() + for _i482 in xrange(_size478): + _elem483 = iprot.readString(); + self.success.append(_elem483) iprot.readListEnd() else: iprot.skip(ftype) @@ -9967,8 +10160,8 @@ class get_all_tables_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter454 in self.success: - oprot.writeString(iter454) + for iter484 in self.success: + oprot.writeString(iter484) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10185,10 +10378,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype458, _size455) = iprot.readListBegin() - for _i459 in xrange(_size455): - _elem460 = iprot.readString(); - self.tbl_names.append(_elem460) + (_etype488, _size485) = iprot.readListBegin() + for _i489 in xrange(_size485): + _elem490 = iprot.readString(); + self.tbl_names.append(_elem490) iprot.readListEnd() else: iprot.skip(ftype) @@ -10209,8 +10402,8 @@ class get_table_objects_by_name_args: if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) - for iter461 in self.tbl_names: - oprot.writeString(iter461) + for iter491 in self.tbl_names: + oprot.writeString(iter491) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10265,11 +10458,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype465, _size462) = iprot.readListBegin() - for _i466 in xrange(_size462): - _elem467 = Table() - _elem467.read(iprot) - self.success.append(_elem467) + (_etype495, _size492) = iprot.readListBegin() + for _i496 in xrange(_size492): + _elem497 = Table() + _elem497.read(iprot) + self.success.append(_elem497) iprot.readListEnd() else: iprot.skip(ftype) @@ -10304,8 +10497,8 @@ class get_table_objects_by_name_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter468 in self.success: - iter468.write(oprot) + for iter498 in self.success: + iter498.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10456,10 +10649,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype472, _size469) = iprot.readListBegin() - for _i473 in xrange(_size469): - _elem474 = iprot.readString(); - self.success.append(_elem474) + (_etype502, _size499) = iprot.readListBegin() + for _i503 in xrange(_size499): + _elem504 = iprot.readString(); + self.success.append(_elem504) iprot.readListEnd() else: iprot.skip(ftype) @@ -10494,8 +10687,8 @@ class get_table_names_by_filter_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter475 in self.success: - oprot.writeString(iter475) + for iter505 in self.success: + oprot.writeString(iter505) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11218,11 +11411,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype479, _size476) = iprot.readListBegin() - for _i480 in xrange(_size476): - _elem481 = Partition() - _elem481.read(iprot) - self.new_parts.append(_elem481) + (_etype509, _size506) = iprot.readListBegin() + for _i510 in xrange(_size506): + _elem511 = Partition() + _elem511.read(iprot) + self.new_parts.append(_elem511) iprot.readListEnd() else: iprot.skip(ftype) @@ -11239,8 +11432,8 @@ class add_partitions_args: if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) - for iter482 in self.new_parts: - iter482.write(oprot) + for iter512 in self.new_parts: + iter512.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11359,25 +11552,19 @@ class add_partitions_result: def __ne__(self, other): return not (self == other) -class append_partition_args: +class add_partitions_pspec_args: """ Attributes: - - db_name - - tbl_name - - part_vals + - new_parts """ thrift_spec = ( None, # 0 - (1, TType.STRING, 'db_name', None, None, ), # 1 - (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3 + (1, TType.LIST, 'new_parts', (TType.STRUCT,(PartitionSpec, PartitionSpec.thrift_spec)), None, ), # 1 ) - def __init__(self, db_name=None, tbl_name=None, part_vals=None,): - self.db_name = db_name - self.tbl_name = tbl_name - self.part_vals = part_vals + def __init__(self, new_parts=None,): + self.new_parts = new_parts 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: @@ -11389,22 +11576,13 @@ class append_partition_args: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.STRING: - self.db_name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.tbl_name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: if ftype == TType.LIST: - self.part_vals = [] - (_etype486, _size483) = iprot.readListBegin() - for _i487 in xrange(_size483): - _elem488 = iprot.readString(); - self.part_vals.append(_elem488) + self.new_parts = [] + (_etype516, _size513) = iprot.readListBegin() + for _i517 in xrange(_size513): + _elem518 = PartitionSpec() + _elem518.read(iprot) + self.new_parts.append(_elem518) iprot.readListEnd() else: iprot.skip(ftype) @@ -11417,20 +11595,12 @@ class append_partition_args: 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('append_partition_args') - if self.db_name is not None: - oprot.writeFieldBegin('db_name', TType.STRING, 1) - oprot.writeString(self.db_name) - oprot.writeFieldEnd() - if self.tbl_name is not None: - oprot.writeFieldBegin('tbl_name', TType.STRING, 2) - oprot.writeString(self.tbl_name) - oprot.writeFieldEnd() - if self.part_vals is not None: - oprot.writeFieldBegin('part_vals', TType.LIST, 3) - oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter489 in self.part_vals: - oprot.writeString(iter489) + oprot.writeStructBegin('add_partitions_pspec_args') + if self.new_parts is not None: + oprot.writeFieldBegin('new_parts', TType.LIST, 1) + oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) + for iter519 in self.new_parts: + iter519.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11451,7 +11621,7 @@ class append_partition_args: def __ne__(self, other): return not (self == other) -class append_partition_result: +class add_partitions_pspec_result: """ Attributes: - success @@ -11461,7 +11631,7 @@ class append_partition_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 + (0, TType.I32, 'success', None, None, ), # 0 (1, TType.STRUCT, 'o1', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'o2', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 @@ -11483,9 +11653,8 @@ class append_partition_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.STRUCT: - self.success = Partition() - self.success.read(iprot) + if ftype == TType.I32: + self.success = iprot.readI32(); else: iprot.skip(ftype) elif fid == 1: @@ -11515,10 +11684,10 @@ class append_partition_result: 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('append_partition_result') + oprot.writeStructBegin('add_partitions_pspec_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) + oprot.writeFieldBegin('success', TType.I32, 0) + oprot.writeI32(self.success) oprot.writeFieldEnd() if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) @@ -11550,19 +11719,25 @@ class append_partition_result: def __ne__(self, other): return not (self == other) -class add_partitions_req_args: +class append_partition_args: """ Attributes: - - request + - db_name + - tbl_name + - part_vals """ thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'request', (AddPartitionsRequest, AddPartitionsRequest.thrift_spec), None, ), # 1 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3 ) - def __init__(self, request=None,): - self.request = request + def __init__(self, db_name=None, tbl_name=None, part_vals=None,): + self.db_name = db_name + self.tbl_name = tbl_name + self.part_vals = part_vals 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: @@ -11574,9 +11749,23 @@ class add_partitions_req_args: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.STRUCT: - self.request = AddPartitionsRequest() - self.request.read(iprot) + if ftype == TType.STRING: + self.db_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tbl_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.part_vals = [] + (_etype523, _size520) = iprot.readListBegin() + for _i524 in xrange(_size520): + _elem525 = iprot.readString(); + self.part_vals.append(_elem525) + iprot.readListEnd() else: iprot.skip(ftype) else: @@ -11588,9 +11777,180 @@ class add_partitions_req_args: 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('add_partitions_req_args') - if self.request is not None: - oprot.writeFieldBegin('request', TType.STRUCT, 1) + oprot.writeStructBegin('append_partition_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.part_vals is not None: + oprot.writeFieldBegin('part_vals', TType.LIST, 3) + oprot.writeListBegin(TType.STRING, len(self.part_vals)) + for iter526 in self.part_vals: + oprot.writeString(iter526) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 append_partition_result: + """ + Attributes: + - success + - o1 + - o2 + - o3 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'o1', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 + ) + + def __init__(self, success=None, o1=None, o2=None, o3=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + self.o3 = o3 + + 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 = Partition() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = InvalidObjectException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = AlreadyExistsException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = MetaException() + self.o3.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('append_partition_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 add_partitions_req_args: + """ + Attributes: + - request + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'request', (AddPartitionsRequest, AddPartitionsRequest.thrift_spec), None, ), # 1 + ) + + def __init__(self, request=None,): + self.request = request + + 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.request = AddPartitionsRequest() + self.request.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('add_partitions_req_args') + if self.request is not None: + oprot.writeFieldBegin('request', TType.STRUCT, 1) self.request.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11755,10 +12115,10 @@ class append_partition_with_environment_ elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype493, _size490) = iprot.readListBegin() - for _i494 in xrange(_size490): - _elem495 = iprot.readString(); - self.part_vals.append(_elem495) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = iprot.readString(); + self.part_vals.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -11789,8 +12149,8 @@ class append_partition_with_environment_ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter496 in self.part_vals: - oprot.writeString(iter496) + for iter533 in self.part_vals: + oprot.writeString(iter533) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -12338,10 +12698,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype500, _size497) = iprot.readListBegin() - for _i501 in xrange(_size497): - _elem502 = iprot.readString(); - self.part_vals.append(_elem502) + (_etype537, _size534) = iprot.readListBegin() + for _i538 in xrange(_size534): + _elem539 = iprot.readString(); + self.part_vals.append(_elem539) iprot.readListEnd() else: iprot.skip(ftype) @@ -12371,8 +12731,8 @@ class drop_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter503 in self.part_vals: - oprot.writeString(iter503) + for iter540 in self.part_vals: + oprot.writeString(iter540) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -12530,10 +12890,10 @@ class drop_partition_with_environment_co elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype507, _size504) = iprot.readListBegin() - for _i508 in xrange(_size504): - _elem509 = iprot.readString(); - self.part_vals.append(_elem509) + (_etype544, _size541) = iprot.readListBegin() + for _i545 in xrange(_size541): + _elem546 = iprot.readString(); + self.part_vals.append(_elem546) iprot.readListEnd() else: iprot.skip(ftype) @@ -12569,8 +12929,8 @@ class drop_partition_with_environment_co if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter510 in self.part_vals: - oprot.writeString(iter510) + for iter547 in self.part_vals: + oprot.writeString(iter547) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -13248,10 +13608,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype514, _size511) = iprot.readListBegin() - for _i515 in xrange(_size511): - _elem516 = iprot.readString(); - self.part_vals.append(_elem516) + (_etype551, _size548) = iprot.readListBegin() + for _i552 in xrange(_size548): + _elem553 = iprot.readString(); + self.part_vals.append(_elem553) iprot.readListEnd() else: iprot.skip(ftype) @@ -13276,8 +13636,8 @@ class get_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter517 in self.part_vals: - oprot.writeString(iter517) + for iter554 in self.part_vals: + oprot.writeString(iter554) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13422,11 +13782,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype519, _vtype520, _size518 ) = iprot.readMapBegin() - for _i522 in xrange(_size518): - _key523 = iprot.readString(); - _val524 = iprot.readString(); - self.partitionSpecs[_key523] = _val524 + (_ktype556, _vtype557, _size555 ) = iprot.readMapBegin() + for _i559 in xrange(_size555): + _key560 = iprot.readString(); + _val561 = iprot.readString(); + self.partitionSpecs[_key560] = _val561 iprot.readMapEnd() else: iprot.skip(ftype) @@ -13463,9 +13823,9 @@ class exchange_partition_args: if self.partitionSpecs is not None: oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs)) - for kiter525,viter526 in self.partitionSpecs.items(): - oprot.writeString(kiter525) - oprot.writeString(viter526) + for kiter562,viter563 in self.partitionSpecs.items(): + oprot.writeString(kiter562) + oprot.writeString(viter563) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -13662,10 +14022,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype530, _size527) = iprot.readListBegin() - for _i531 in xrange(_size527): - _elem532 = iprot.readString(); - self.part_vals.append(_elem532) + (_etype567, _size564) = iprot.readListBegin() + for _i568 in xrange(_size564): + _elem569 = iprot.readString(); + self.part_vals.append(_elem569) iprot.readListEnd() else: iprot.skip(ftype) @@ -13677,10 +14037,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype536, _size533) = iprot.readListBegin() - for _i537 in xrange(_size533): - _elem538 = iprot.readString(); - self.group_names.append(_elem538) + (_etype573, _size570) = iprot.readListBegin() + for _i574 in xrange(_size570): + _elem575 = iprot.readString(); + self.group_names.append(_elem575) iprot.readListEnd() else: iprot.skip(ftype) @@ -13705,8 +14065,8 @@ class get_partition_with_auth_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter539 in self.part_vals: - oprot.writeString(iter539) + for iter576 in self.part_vals: + oprot.writeString(iter576) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -13716,8 +14076,8 @@ class get_partition_with_auth_args: if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.group_names)) - for iter540 in self.group_names: - oprot.writeString(iter540) + for iter577 in self.group_names: + oprot.writeString(iter577) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14009,10 +14369,194 @@ class get_partitions_args: (3, TType.I16, 'max_parts', None, -1, ), # 3 ) - def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): + self.db_name = db_name + self.tbl_name = tbl_name + self.max_parts = max_parts + + 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.db_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tbl_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I16: + self.max_parts = iprot.readI16(); + 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('get_partitions_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.max_parts is not None: + oprot.writeFieldBegin('max_parts', TType.I16, 3) + oprot.writeI16(self.max_parts) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 get_partitions_result: + """ + Attributes: + - success + - o1 + - o2 + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + ) + + def __init__(self, success=None, o1=None, o2=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + + 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 = [] + (_etype581, _size578) = iprot.readListBegin() + for _i582 in xrange(_size578): + _elem583 = Partition() + _elem583.read(iprot) + self.success.append(_elem583) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = NoSuchObjectException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = MetaException() + self.o2.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('get_partitions_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter584 in self.success: + iter584.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 get_partitions_with_auth_args: + """ + Attributes: + - db_name + - tbl_name + - max_parts + - user_name + - group_names + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.I16, 'max_parts', None, -1, ), # 3 + (4, TType.STRING, 'user_name', None, None, ), # 4 + (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,): self.db_name = db_name self.tbl_name = tbl_name self.max_parts = max_parts + self.user_name = user_name + self.group_names = group_names 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: @@ -14038,6 +14582,21 @@ class get_partitions_args: self.max_parts = iprot.readI16(); else: iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.user_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.group_names = [] + (_etype588, _size585) = iprot.readListBegin() + for _i589 in xrange(_size585): + _elem590 = iprot.readString(); + self.group_names.append(_elem590) + iprot.readListEnd() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -14047,7 +14606,7 @@ class get_partitions_args: 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('get_partitions_args') + oprot.writeStructBegin('get_partitions_with_auth_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -14060,6 +14619,17 @@ class get_partitions_args: oprot.writeFieldBegin('max_parts', TType.I16, 3) oprot.writeI16(self.max_parts) oprot.writeFieldEnd() + if self.user_name is not None: + oprot.writeFieldBegin('user_name', TType.STRING, 4) + oprot.writeString(self.user_name) + oprot.writeFieldEnd() + if self.group_names is not None: + oprot.writeFieldBegin('group_names', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.group_names)) + for iter591 in self.group_names: + oprot.writeString(iter591) + oprot.writeListEnd() + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14078,7 +14648,7 @@ class get_partitions_args: def __ne__(self, other): return not (self == other) -class get_partitions_result: +class get_partitions_with_auth_result: """ Attributes: - success @@ -14109,11 +14679,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype544, _size541) = iprot.readListBegin() - for _i545 in xrange(_size541): - _elem546 = Partition() - _elem546.read(iprot) - self.success.append(_elem546) + (_etype595, _size592) = iprot.readListBegin() + for _i596 in xrange(_size592): + _elem597 = Partition() + _elem597.read(iprot) + self.success.append(_elem597) iprot.readListEnd() else: iprot.skip(ftype) @@ -14138,12 +14708,12 @@ class get_partitions_result: 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('get_partitions_result') + oprot.writeStructBegin('get_partitions_with_auth_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter547 in self.success: - iter547.write(oprot) + for iter598 in self.success: + iter598.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14172,31 +14742,25 @@ class get_partitions_result: def __ne__(self, other): return not (self == other) -class get_partitions_with_auth_args: +class get_partitions_pspec_args: """ Attributes: - db_name - tbl_name - max_parts - - user_name - - group_names """ thrift_spec = ( None, # 0 (1, TType.STRING, 'db_name', None, None, ), # 1 (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.I16, 'max_parts', None, -1, ), # 3 - (4, TType.STRING, 'user_name', None, None, ), # 4 - (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 + (3, TType.I32, 'max_parts', None, -1, ), # 3 ) - def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,): + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): self.db_name = db_name self.tbl_name = tbl_name self.max_parts = max_parts - self.user_name = user_name - self.group_names = group_names 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: @@ -14218,23 +14782,8 @@ class get_partitions_with_auth_args: else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.I16: - self.max_parts = iprot.readI16(); - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.user_name = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.LIST: - self.group_names = [] - (_etype551, _size548) = iprot.readListBegin() - for _i552 in xrange(_size548): - _elem553 = iprot.readString(); - self.group_names.append(_elem553) - iprot.readListEnd() + if ftype == TType.I32: + self.max_parts = iprot.readI32(); else: iprot.skip(ftype) else: @@ -14246,7 +14795,7 @@ class get_partitions_with_auth_args: 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('get_partitions_with_auth_args') + oprot.writeStructBegin('get_partitions_pspec_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -14256,19 +14805,8 @@ class get_partitions_with_auth_args: oprot.writeString(self.tbl_name) oprot.writeFieldEnd() if self.max_parts is not None: - oprot.writeFieldBegin('max_parts', TType.I16, 3) - oprot.writeI16(self.max_parts) - oprot.writeFieldEnd() - if self.user_name is not None: - oprot.writeFieldBegin('user_name', TType.STRING, 4) - oprot.writeString(self.user_name) - oprot.writeFieldEnd() - if self.group_names is not None: - oprot.writeFieldBegin('group_names', TType.LIST, 5) - oprot.writeListBegin(TType.STRING, len(self.group_names)) - for iter554 in self.group_names: - oprot.writeString(iter554) - oprot.writeListEnd() + oprot.writeFieldBegin('max_parts', TType.I32, 3) + oprot.writeI32(self.max_parts) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -14288,7 +14826,7 @@ class get_partitions_with_auth_args: def __ne__(self, other): return not (self == other) -class get_partitions_with_auth_result: +class get_partitions_pspec_result: """ Attributes: - success @@ -14297,7 +14835,7 @@ class get_partitions_with_auth_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(PartitionSpec, PartitionSpec.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 ) @@ -14319,11 +14857,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype558, _size555) = iprot.readListBegin() - for _i559 in xrange(_size555): - _elem560 = Partition() - _elem560.read(iprot) - self.success.append(_elem560) + (_etype602, _size599) = iprot.readListBegin() + for _i603 in xrange(_size599): + _elem604 = PartitionSpec() + _elem604.read(iprot) + self.success.append(_elem604) iprot.readListEnd() else: iprot.skip(ftype) @@ -14348,12 +14886,12 @@ class get_partitions_with_auth_result: 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('get_partitions_with_auth_result') + oprot.writeStructBegin('get_partitions_pspec_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter561 in self.success: - iter561.write(oprot) + for iter605 in self.success: + iter605.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14494,10 +15032,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype565, _size562) = iprot.readListBegin() - for _i566 in xrange(_size562): - _elem567 = iprot.readString(); - self.success.append(_elem567) + (_etype609, _size606) = iprot.readListBegin() + for _i610 in xrange(_size606): + _elem611 = iprot.readString(); + self.success.append(_elem611) iprot.readListEnd() else: iprot.skip(ftype) @@ -14520,8 +15058,8 @@ class get_partition_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter568 in self.success: - oprot.writeString(iter568) + for iter612 in self.success: + oprot.writeString(iter612) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14591,10 +15129,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype572, _size569) = iprot.readListBegin() - for _i573 in xrange(_size569): - _elem574 = iprot.readString(); - self.part_vals.append(_elem574) + (_etype616, _size613) = iprot.readListBegin() + for _i617 in xrange(_size613): + _elem618 = iprot.readString(); + self.part_vals.append(_elem618) iprot.readListEnd() else: iprot.skip(ftype) @@ -14624,8 +15162,8 @@ class get_partitions_ps_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter575 in self.part_vals: - oprot.writeString(iter575) + for iter619 in self.part_vals: + oprot.writeString(iter619) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -14681,11 +15219,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype579, _size576) = iprot.readListBegin() - for _i580 in xrange(_size576): - _elem581 = Partition() - _elem581.read(iprot) - self.success.append(_elem581) + (_etype623, _size620) = iprot.readListBegin() + for _i624 in xrange(_size620): + _elem625 = Partition() + _elem625.read(iprot) + self.success.append(_elem625) iprot.readListEnd() else: iprot.skip(ftype) @@ -14714,8 +15252,8 @@ class get_partitions_ps_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter582 in self.success: - iter582.write(oprot) + for iter626 in self.success: + iter626.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14795,10 +15333,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype586, _size583) = iprot.readListBegin() - for _i587 in xrange(_size583): - _elem588 = iprot.readString(); - self.part_vals.append(_elem588) + (_etype630, _size627) = iprot.readListBegin() + for _i631 in xrange(_size627): + _elem632 = iprot.readString(); + self.part_vals.append(_elem632) iprot.readListEnd() else: iprot.skip(ftype) @@ -14815,10 +15353,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype592, _size589) = iprot.readListBegin() - for _i593 in xrange(_size589): - _elem594 = iprot.readString(); - self.group_names.append(_elem594) + (_etype636, _size633) = iprot.readListBegin() + for _i637 in xrange(_size633): + _elem638 = iprot.readString(); + self.group_names.append(_elem638) iprot.readListEnd() else: iprot.skip(ftype) @@ -14843,8 +15381,8 @@ class get_partitions_ps_with_auth_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter595 in self.part_vals: - oprot.writeString(iter595) + for iter639 in self.part_vals: + oprot.writeString(iter639) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -14858,8 +15396,8 @@ class get_partitions_ps_with_auth_args: if self.group_names is not None: oprot.writeFieldBegin('group_names', TType.LIST, 6) oprot.writeListBegin(TType.STRING, len(self.group_names)) - for iter596 in self.group_names: - oprot.writeString(iter596) + for iter640 in self.group_names: + oprot.writeString(iter640) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14911,11 +15449,11 @@ class get_partitions_ps_with_auth_result if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype600, _size597) = iprot.readListBegin() - for _i601 in xrange(_size597): - _elem602 = Partition() - _elem602.read(iprot) - self.success.append(_elem602) + (_etype644, _size641) = iprot.readListBegin() + for _i645 in xrange(_size641): + _elem646 = Partition() + _elem646.read(iprot) + self.success.append(_elem646) iprot.readListEnd() else: iprot.skip(ftype) @@ -14944,8 +15482,8 @@ class get_partitions_ps_with_auth_result if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter603 in self.success: - iter603.write(oprot) + for iter647 in self.success: + iter647.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15019,10 +15557,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype607, _size604) = iprot.readListBegin() - for _i608 in xrange(_size604): - _elem609 = iprot.readString(); - self.part_vals.append(_elem609) + (_etype651, _size648) = iprot.readListBegin() + for _i652 in xrange(_size648): + _elem653 = iprot.readString(); + self.part_vals.append(_elem653) iprot.readListEnd() else: iprot.skip(ftype) @@ -15052,8 +15590,8 @@ class get_partition_names_ps_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter610 in self.part_vals: - oprot.writeString(iter610) + for iter654 in self.part_vals: + oprot.writeString(iter654) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15109,10 +15647,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype614, _size611) = iprot.readListBegin() - for _i615 in xrange(_size611): - _elem616 = iprot.readString(); - self.success.append(_elem616) + (_etype658, _size655) = iprot.readListBegin() + for _i659 in xrange(_size655): + _elem660 = iprot.readString(); + self.success.append(_elem660) iprot.readListEnd() else: iprot.skip(ftype) @@ -15141,8 +15679,8 @@ class get_partition_names_ps_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter617 in self.success: - oprot.writeString(iter617) + for iter661 in self.success: + oprot.writeString(iter661) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15298,11 +15836,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype621, _size618) = iprot.readListBegin() - for _i622 in xrange(_size618): - _elem623 = Partition() - _elem623.read(iprot) - self.success.append(_elem623) + (_etype665, _size662) = iprot.readListBegin() + for _i666 in xrange(_size662): + _elem667 = Partition() + _elem667.read(iprot) + self.success.append(_elem667) iprot.readListEnd() else: iprot.skip(ftype) @@ -15331,8 +15869,198 @@ class get_partitions_by_filter_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter624 in self.success: - iter624.write(oprot) + for iter668 in self.success: + iter668.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 get_part_specs_by_filter_args: + """ + Attributes: + - db_name + - tbl_name + - filter + - max_parts + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.STRING, 'filter', None, None, ), # 3 + (4, TType.I32, 'max_parts', None, -1, ), # 4 + ) + + def __init__(self, db_name=None, tbl_name=None, filter=None, max_parts=thrift_spec[4][4],): + self.db_name = db_name + self.tbl_name = tbl_name + self.filter = filter + self.max_parts = max_parts + + 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.db_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.tbl_name = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.filter = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.I32: + self.max_parts = 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('get_part_specs_by_filter_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.filter is not None: + oprot.writeFieldBegin('filter', TType.STRING, 3) + oprot.writeString(self.filter) + oprot.writeFieldEnd() + if self.max_parts is not None: + oprot.writeFieldBegin('max_parts', TType.I32, 4) + oprot.writeI32(self.max_parts) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 get_part_specs_by_filter_result: + """ + Attributes: + - success + - o1 + - o2 + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(PartitionSpec, PartitionSpec.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 + ) + + def __init__(self, success=None, o1=None, o2=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + + 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 = [] + (_etype672, _size669) = iprot.readListBegin() + for _i673 in xrange(_size669): + _elem674 = PartitionSpec() + _elem674.read(iprot) + self.success.append(_elem674) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = NoSuchObjectException() + self.o2.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('get_part_specs_by_filter_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter675 in self.success: + iter675.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15550,10 +16278,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype628, _size625) = iprot.readListBegin() - for _i629 in xrange(_size625): - _elem630 = iprot.readString(); - self.names.append(_elem630) + (_etype679, _size676) = iprot.readListBegin() + for _i680 in xrange(_size676): + _elem681 = iprot.readString(); + self.names.append(_elem681) iprot.readListEnd() else: iprot.skip(ftype) @@ -15578,8 +16306,8 @@ class get_partitions_by_names_args: if self.names is not None: oprot.writeFieldBegin('names', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.names)) - for iter631 in self.names: - oprot.writeString(iter631) + for iter682 in self.names: + oprot.writeString(iter682) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15631,11 +16359,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype635, _size632) = iprot.readListBegin() - for _i636 in xrange(_size632): - _elem637 = Partition() - _elem637.read(iprot) - self.success.append(_elem637) + (_etype686, _size683) = iprot.readListBegin() + for _i687 in xrange(_size683): + _elem688 = Partition() + _elem688.read(iprot) + self.success.append(_elem688) iprot.readListEnd() else: iprot.skip(ftype) @@ -15664,8 +16392,8 @@ class get_partitions_by_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter638 in self.success: - iter638.write(oprot) + for iter689 in self.success: + iter689.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15895,11 +16623,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype642, _size639) = iprot.readListBegin() - for _i643 in xrange(_size639): - _elem644 = Partition() - _elem644.read(iprot) - self.new_parts.append(_elem644) + (_etype693, _size690) = iprot.readListBegin() + for _i694 in xrange(_size690): + _elem695 = Partition() + _elem695.read(iprot) + self.new_parts.append(_elem695) iprot.readListEnd() else: iprot.skip(ftype) @@ -15924,8 +16652,8 @@ class alter_partitions_args: if self.new_parts is not None: oprot.writeFieldBegin('new_parts', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.new_parts)) - for iter645 in self.new_parts: - iter645.write(oprot) + for iter696 in self.new_parts: + iter696.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16237,10 +16965,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype649, _size646) = iprot.readListBegin() - for _i650 in xrange(_size646): - _elem651 = iprot.readString(); - self.part_vals.append(_elem651) + (_etype700, _size697) = iprot.readListBegin() + for _i701 in xrange(_size697): + _elem702 = iprot.readString(); + self.part_vals.append(_elem702) iprot.readListEnd() else: iprot.skip(ftype) @@ -16271,8 +16999,8 @@ class rename_partition_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter652 in self.part_vals: - oprot.writeString(iter652) + for iter703 in self.part_vals: + oprot.writeString(iter703) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -16400,10 +17128,10 @@ class partition_name_has_valid_character if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype656, _size653) = iprot.readListBegin() - for _i657 in xrange(_size653): - _elem658 = iprot.readString(); - self.part_vals.append(_elem658) + (_etype707, _size704) = iprot.readListBegin() + for _i708 in xrange(_size704): + _elem709 = iprot.readString(); + self.part_vals.append(_elem709) iprot.readListEnd() else: iprot.skip(ftype) @@ -16425,8 +17153,8 @@ class partition_name_has_valid_character if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter659 in self.part_vals: - oprot.writeString(iter659) + for iter710 in self.part_vals: + oprot.writeString(iter710) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -16755,10 +17483,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype663, _size660) = iprot.readListBegin() - for _i664 in xrange(_size660): - _elem665 = iprot.readString(); - self.success.append(_elem665) + (_etype714, _size711) = iprot.readListBegin() + for _i715 in xrange(_size711): + _elem716 = iprot.readString(); + self.success.append(_elem716) iprot.readListEnd() else: iprot.skip(ftype) @@ -16781,8 +17509,8 @@ class partition_name_to_vals_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter666 in self.success: - oprot.writeString(iter666) + for iter717 in self.success: + oprot.writeString(iter717) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16895,11 +17623,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype668, _vtype669, _size667 ) = iprot.readMapBegin() - for _i671 in xrange(_size667): - _key672 = iprot.readString(); - _val673 = iprot.readString(); - self.success[_key672] = _val673 + (_ktype719, _vtype720, _size718 ) = iprot.readMapBegin() + for _i722 in xrange(_size718): + _key723 = iprot.readString(); + _val724 = iprot.readString(); + self.success[_key723] = _val724 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16922,9 +17650,9 @@ class partition_name_to_spec_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter674,viter675 in self.success.items(): - oprot.writeString(kiter674) - oprot.writeString(viter675) + for kiter725,viter726 in self.success.items(): + oprot.writeString(kiter725) + oprot.writeString(viter726) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16994,11 +17722,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype677, _vtype678, _size676 ) = iprot.readMapBegin() - for _i680 in xrange(_size676): - _key681 = iprot.readString(); - _val682 = iprot.readString(); - self.part_vals[_key681] = _val682 + (_ktype728, _vtype729, _size727 ) = iprot.readMapBegin() + for _i731 in xrange(_size727): + _key732 = iprot.readString(); + _val733 = iprot.readString(); + self.part_vals[_key732] = _val733 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17028,9 +17756,9 @@ class markPartitionForEvent_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.MAP, 3) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals)) - for kiter683,viter684 in self.part_vals.items(): - oprot.writeString(kiter683) - oprot.writeString(viter684) + for kiter734,viter735 in self.part_vals.items(): + oprot.writeString(kiter734) + oprot.writeString(viter735) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -17226,11 +17954,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype686, _vtype687, _size685 ) = iprot.readMapBegin() - for _i689 in xrange(_size685): - _key690 = iprot.readString(); - _val691 = iprot.readString(); - self.part_vals[_key690] = _val691 + (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin() + for _i740 in xrange(_size736): + _key741 = iprot.readString(); + _val742 = iprot.readString(); + self.part_vals[_key741] = _val742 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17260,9 +17988,9 @@ class isPartitionMarkedForEvent_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.MAP, 3) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals)) - for kiter692,viter693 in self.part_vals.items(): - oprot.writeString(kiter692) - oprot.writeString(viter693) + for kiter743,viter744 in self.part_vals.items(): + oprot.writeString(kiter743) + oprot.writeString(viter744) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -18234,11 +18962,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype697, _size694) = iprot.readListBegin() - for _i698 in xrange(_size694): - _elem699 = Index() - _elem699.read(iprot) - self.success.append(_elem699) + (_etype748, _size745) = iprot.readListBegin() + for _i749 in xrange(_size745): + _elem750 = Index() + _elem750.read(iprot) + self.success.append(_elem750) iprot.readListEnd() else: iprot.skip(ftype) @@ -18267,8 +18995,8 @@ class get_indexes_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter700 in self.success: - iter700.write(oprot) + for iter751 in self.success: + iter751.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18409,10 +19137,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype704, _size701) = iprot.readListBegin() - for _i705 in xrange(_size701): - _elem706 = iprot.readString(); - self.success.append(_elem706) + (_etype755, _size752) = iprot.readListBegin() + for _i756 in xrange(_size752): + _elem757 = iprot.readString(); + self.success.append(_elem757) iprot.readListEnd() else: iprot.skip(ftype) @@ -18435,8 +19163,8 @@ class get_index_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter707 in self.success: - oprot.writeString(iter707) + for iter758 in self.success: + oprot.writeString(iter758) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -20790,10 +21518,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype711, _size708) = iprot.readListBegin() - for _i712 in xrange(_size708): - _elem713 = iprot.readString(); - self.success.append(_elem713) + (_etype762, _size759) = iprot.readListBegin() + for _i763 in xrange(_size759): + _elem764 = iprot.readString(); + self.success.append(_elem764) iprot.readListEnd() else: iprot.skip(ftype) @@ -20816,8 +21544,8 @@ class get_functions_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter714 in self.success: - oprot.writeString(iter714) + for iter765 in self.success: + oprot.writeString(iter765) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21335,10 +22063,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype718, _size715) = iprot.readListBegin() - for _i719 in xrange(_size715): - _elem720 = iprot.readString(); - self.success.append(_elem720) + (_etype769, _size766) = iprot.readListBegin() + for _i770 in xrange(_size766): + _elem771 = iprot.readString(); + self.success.append(_elem771) iprot.readListEnd() else: iprot.skip(ftype) @@ -21361,8 +22089,8 @@ class get_role_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter721 in self.success: - oprot.writeString(iter721) + for iter772 in self.success: + oprot.writeString(iter772) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21835,11 +22563,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype725, _size722) = iprot.readListBegin() - for _i726 in xrange(_size722): - _elem727 = Role() - _elem727.read(iprot) - self.success.append(_elem727) + (_etype776, _size773) = iprot.readListBegin() + for _i777 in xrange(_size773): + _elem778 = Role() + _elem778.read(iprot)
[... 122 lines stripped ...]
