You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2014/08/22 17:35:21 UTC
svn commit: r1619843 [8/9] - in /hive/trunk: metastore/if/
metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/thrift/gen-php/metastore/
metastore/src/gen/thrift/gen-py/hive_me...
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1619843&r1=1619842&r2=1619843&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Aug 22 15:35:20 2014
@@ -655,6 +655,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def set_aggr_stats_for(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
"""
Parameters:
@@ -3708,6 +3715,44 @@ class Client(fb303.FacebookService.Clien
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result");
+ def set_aggr_stats_for(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_set_aggr_stats_for(request)
+ return self.recv_set_aggr_stats_for()
+
+ def send_set_aggr_stats_for(self, request):
+ self._oprot.writeMessageBegin('set_aggr_stats_for', TMessageType.CALL, self._seqid)
+ args = set_aggr_stats_for_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_set_aggr_stats_for(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = set_aggr_stats_for_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
+ if result.o4 is not None:
+ raise result.o4
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result");
+
def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
"""
Parameters:
@@ -5041,6 +5086,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["get_table_statistics_req"] = Processor.process_get_table_statistics_req
self._processMap["get_partitions_statistics_req"] = Processor.process_get_partitions_statistics_req
self._processMap["get_aggr_stats_for"] = Processor.process_get_aggr_stats_for
+ self._processMap["set_aggr_stats_for"] = Processor.process_set_aggr_stats_for
self._processMap["delete_partition_column_statistics"] = Processor.process_delete_partition_column_statistics
self._processMap["delete_table_column_statistics"] = Processor.process_delete_table_column_statistics
self._processMap["create_function"] = Processor.process_create_function
@@ -6329,6 +6375,26 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_set_aggr_stats_for(self, seqid, iprot, oprot):
+ args = set_aggr_stats_for_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = set_aggr_stats_for_result()
+ try:
+ result.success = self._handler.set_aggr_stats_for(args.request)
+ except NoSuchObjectException as o1:
+ result.o1 = o1
+ except InvalidObjectException as o2:
+ result.o2 = o2
+ except MetaException as o3:
+ result.o3 = o3
+ except InvalidInputException as o4:
+ result.o4 = o4
+ oprot.writeMessageBegin("set_aggr_stats_for", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_delete_partition_column_statistics(self, seqid, iprot, oprot):
args = delete_partition_column_statistics_args()
args.read(iprot)
@@ -7699,10 +7765,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype400, _size397) = iprot.readListBegin()
- for _i401 in xrange(_size397):
- _elem402 = iprot.readString();
- self.success.append(_elem402)
+ (_etype407, _size404) = iprot.readListBegin()
+ for _i408 in xrange(_size404):
+ _elem409 = iprot.readString();
+ self.success.append(_elem409)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7725,8 +7791,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 iter403 in self.success:
- oprot.writeString(iter403)
+ for iter410 in self.success:
+ oprot.writeString(iter410)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7821,10 +7887,10 @@ class get_all_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)
+ (_etype414, _size411) = iprot.readListBegin()
+ for _i415 in xrange(_size411):
+ _elem416 = iprot.readString();
+ self.success.append(_elem416)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7847,8 +7913,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 iter410 in self.success:
- oprot.writeString(iter410)
+ for iter417 in self.success:
+ oprot.writeString(iter417)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8558,12 +8624,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype412, _vtype413, _size411 ) = iprot.readMapBegin()
- for _i415 in xrange(_size411):
- _key416 = iprot.readString();
- _val417 = Type()
- _val417.read(iprot)
- self.success[_key416] = _val417
+ (_ktype419, _vtype420, _size418 ) = iprot.readMapBegin()
+ for _i422 in xrange(_size418):
+ _key423 = iprot.readString();
+ _val424 = Type()
+ _val424.read(iprot)
+ self.success[_key423] = _val424
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -8586,9 +8652,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 kiter418,viter419 in self.success.items():
- oprot.writeString(kiter418)
- viter419.write(oprot)
+ for kiter425,viter426 in self.success.items():
+ oprot.writeString(kiter425)
+ viter426.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -8719,11 +8785,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype423, _size420) = iprot.readListBegin()
- for _i424 in xrange(_size420):
- _elem425 = FieldSchema()
- _elem425.read(iprot)
- self.success.append(_elem425)
+ (_etype430, _size427) = iprot.readListBegin()
+ for _i431 in xrange(_size427):
+ _elem432 = FieldSchema()
+ _elem432.read(iprot)
+ self.success.append(_elem432)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8758,8 +8824,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 iter426 in self.success:
- iter426.write(oprot)
+ for iter433 in self.success:
+ iter433.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8898,11 +8964,11 @@ class get_schema_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)
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = FieldSchema()
+ _elem439.read(iprot)
+ self.success.append(_elem439)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8937,8 +9003,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 iter433 in self.success:
- iter433.write(oprot)
+ for iter440 in self.success:
+ iter440.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9735,10 +9801,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype437, _size434) = iprot.readListBegin()
- for _i438 in xrange(_size434):
- _elem439 = iprot.readString();
- self.success.append(_elem439)
+ (_etype444, _size441) = iprot.readListBegin()
+ for _i445 in xrange(_size441):
+ _elem446 = iprot.readString();
+ self.success.append(_elem446)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9761,8 +9827,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 iter440 in self.success:
- oprot.writeString(iter440)
+ for iter447 in self.success:
+ oprot.writeString(iter447)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9875,10 +9941,10 @@ class get_all_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)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = iprot.readString();
+ self.success.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9901,8 +9967,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 iter447 in self.success:
- oprot.writeString(iter447)
+ for iter454 in self.success:
+ oprot.writeString(iter454)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10119,10 +10185,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = iprot.readString();
- self.tbl_names.append(_elem453)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = iprot.readString();
+ self.tbl_names.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10143,8 +10209,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 iter454 in self.tbl_names:
- oprot.writeString(iter454)
+ for iter461 in self.tbl_names:
+ oprot.writeString(iter461)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10199,11 +10265,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = Table()
- _elem460.read(iprot)
- self.success.append(_elem460)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = Table()
+ _elem467.read(iprot)
+ self.success.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10238,8 +10304,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 iter461 in self.success:
- iter461.write(oprot)
+ for iter468 in self.success:
+ iter468.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10390,10 +10456,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString();
- self.success.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = iprot.readString();
+ self.success.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10428,8 +10494,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 iter468 in self.success:
- oprot.writeString(iter468)
+ for iter475 in self.success:
+ oprot.writeString(iter475)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11152,11 +11218,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = Partition()
- _elem474.read(iprot)
- self.new_parts.append(_elem474)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = Partition()
+ _elem481.read(iprot)
+ self.new_parts.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11173,8 +11239,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 iter475 in self.new_parts:
- iter475.write(oprot)
+ for iter482 in self.new_parts:
+ iter482.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11335,10 +11401,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype479, _size476) = iprot.readListBegin()
- for _i480 in xrange(_size476):
- _elem481 = iprot.readString();
- self.part_vals.append(_elem481)
+ (_etype486, _size483) = iprot.readListBegin()
+ for _i487 in xrange(_size483):
+ _elem488 = iprot.readString();
+ self.part_vals.append(_elem488)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11363,8 +11429,8 @@ class append_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 iter482 in self.part_vals:
- oprot.writeString(iter482)
+ for iter489 in self.part_vals:
+ oprot.writeString(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11689,10 +11755,10 @@ class append_partition_with_environment_
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)
+ (_etype493, _size490) = iprot.readListBegin()
+ for _i494 in xrange(_size490):
+ _elem495 = iprot.readString();
+ self.part_vals.append(_elem495)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11723,8 +11789,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 iter489 in self.part_vals:
- oprot.writeString(iter489)
+ for iter496 in self.part_vals:
+ oprot.writeString(iter496)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -12272,10 +12338,10 @@ class drop_partition_args:
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)
+ (_etype500, _size497) = iprot.readListBegin()
+ for _i501 in xrange(_size497):
+ _elem502 = iprot.readString();
+ self.part_vals.append(_elem502)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12305,8 +12371,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 iter496 in self.part_vals:
- oprot.writeString(iter496)
+ for iter503 in self.part_vals:
+ oprot.writeString(iter503)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -12464,10 +12530,10 @@ class drop_partition_with_environment_co
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)
+ (_etype507, _size504) = iprot.readListBegin()
+ for _i508 in xrange(_size504):
+ _elem509 = iprot.readString();
+ self.part_vals.append(_elem509)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12503,8 +12569,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 iter503 in self.part_vals:
- oprot.writeString(iter503)
+ for iter510 in self.part_vals:
+ oprot.writeString(iter510)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -13182,10 +13248,10 @@ class get_partition_args:
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)
+ (_etype514, _size511) = iprot.readListBegin()
+ for _i515 in xrange(_size511):
+ _elem516 = iprot.readString();
+ self.part_vals.append(_elem516)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13210,8 +13276,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 iter510 in self.part_vals:
- oprot.writeString(iter510)
+ for iter517 in self.part_vals:
+ oprot.writeString(iter517)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13356,11 +13422,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype512, _vtype513, _size511 ) = iprot.readMapBegin()
- for _i515 in xrange(_size511):
- _key516 = iprot.readString();
- _val517 = iprot.readString();
- self.partitionSpecs[_key516] = _val517
+ (_ktype519, _vtype520, _size518 ) = iprot.readMapBegin()
+ for _i522 in xrange(_size518):
+ _key523 = iprot.readString();
+ _val524 = iprot.readString();
+ self.partitionSpecs[_key523] = _val524
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13397,9 +13463,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 kiter518,viter519 in self.partitionSpecs.items():
- oprot.writeString(kiter518)
- oprot.writeString(viter519)
+ for kiter525,viter526 in self.partitionSpecs.items():
+ oprot.writeString(kiter525)
+ oprot.writeString(viter526)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -13596,10 +13662,10 @@ class get_partition_with_auth_args:
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)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = iprot.readString();
+ self.part_vals.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13611,10 +13677,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype529, _size526) = iprot.readListBegin()
- for _i530 in xrange(_size526):
- _elem531 = iprot.readString();
- self.group_names.append(_elem531)
+ (_etype536, _size533) = iprot.readListBegin()
+ for _i537 in xrange(_size533):
+ _elem538 = iprot.readString();
+ self.group_names.append(_elem538)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13639,8 +13705,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 iter532 in self.part_vals:
- oprot.writeString(iter532)
+ for iter539 in self.part_vals:
+ oprot.writeString(iter539)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -13650,8 +13716,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 iter533 in self.group_names:
- oprot.writeString(iter533)
+ for iter540 in self.group_names:
+ oprot.writeString(iter540)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14043,11 +14109,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = Partition()
- _elem539.read(iprot)
- self.success.append(_elem539)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = Partition()
+ _elem546.read(iprot)
+ self.success.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14076,8 +14142,8 @@ class get_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter540 in self.success:
- iter540.write(oprot)
+ for iter547 in self.success:
+ iter547.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14164,10 +14230,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = iprot.readString();
- self.group_names.append(_elem546)
+ (_etype551, _size548) = iprot.readListBegin()
+ for _i552 in xrange(_size548):
+ _elem553 = iprot.readString();
+ self.group_names.append(_elem553)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14200,8 +14266,8 @@ class get_partitions_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 iter547 in self.group_names:
- oprot.writeString(iter547)
+ for iter554 in self.group_names:
+ oprot.writeString(iter554)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14253,11 +14319,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = Partition()
- _elem553.read(iprot)
- self.success.append(_elem553)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = Partition()
+ _elem560.read(iprot)
+ self.success.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14286,8 +14352,8 @@ class 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 iter554 in self.success:
- iter554.write(oprot)
+ for iter561 in self.success:
+ iter561.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14428,10 +14494,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = iprot.readString();
- self.success.append(_elem560)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = iprot.readString();
+ self.success.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14454,8 +14520,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 iter561 in self.success:
- oprot.writeString(iter561)
+ for iter568 in self.success:
+ oprot.writeString(iter568)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14525,10 +14591,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = iprot.readString();
- self.part_vals.append(_elem567)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = iprot.readString();
+ self.part_vals.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14558,8 +14624,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 iter568 in self.part_vals:
- oprot.writeString(iter568)
+ for iter575 in self.part_vals:
+ oprot.writeString(iter575)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14615,11 +14681,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = Partition()
- _elem574.read(iprot)
- self.success.append(_elem574)
+ (_etype579, _size576) = iprot.readListBegin()
+ for _i580 in xrange(_size576):
+ _elem581 = Partition()
+ _elem581.read(iprot)
+ self.success.append(_elem581)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14648,8 +14714,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 iter575 in self.success:
- iter575.write(oprot)
+ for iter582 in self.success:
+ iter582.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14729,10 +14795,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype579, _size576) = iprot.readListBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString();
- self.part_vals.append(_elem581)
+ (_etype586, _size583) = iprot.readListBegin()
+ for _i587 in xrange(_size583):
+ _elem588 = iprot.readString();
+ self.part_vals.append(_elem588)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14749,10 +14815,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype585, _size582) = iprot.readListBegin()
- for _i586 in xrange(_size582):
- _elem587 = iprot.readString();
- self.group_names.append(_elem587)
+ (_etype592, _size589) = iprot.readListBegin()
+ for _i593 in xrange(_size589):
+ _elem594 = iprot.readString();
+ self.group_names.append(_elem594)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14777,8 +14843,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 iter588 in self.part_vals:
- oprot.writeString(iter588)
+ for iter595 in self.part_vals:
+ oprot.writeString(iter595)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14792,8 +14858,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 iter589 in self.group_names:
- oprot.writeString(iter589)
+ for iter596 in self.group_names:
+ oprot.writeString(iter596)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14845,11 +14911,11 @@ class get_partitions_ps_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = Partition()
- _elem595.read(iprot)
- self.success.append(_elem595)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = Partition()
+ _elem602.read(iprot)
+ self.success.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14878,8 +14944,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 iter596 in self.success:
- iter596.write(oprot)
+ for iter603 in self.success:
+ iter603.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14953,10 +15019,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype600, _size597) = iprot.readListBegin()
- for _i601 in xrange(_size597):
- _elem602 = iprot.readString();
- self.part_vals.append(_elem602)
+ (_etype607, _size604) = iprot.readListBegin()
+ for _i608 in xrange(_size604):
+ _elem609 = iprot.readString();
+ self.part_vals.append(_elem609)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14986,8 +15052,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 iter603 in self.part_vals:
- oprot.writeString(iter603)
+ for iter610 in self.part_vals:
+ oprot.writeString(iter610)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -15043,10 +15109,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = iprot.readString();
- self.success.append(_elem609)
+ (_etype614, _size611) = iprot.readListBegin()
+ for _i615 in xrange(_size611):
+ _elem616 = iprot.readString();
+ self.success.append(_elem616)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15075,8 +15141,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 iter610 in self.success:
- oprot.writeString(iter610)
+ for iter617 in self.success:
+ oprot.writeString(iter617)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15232,11 +15298,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype614, _size611) = iprot.readListBegin()
- for _i615 in xrange(_size611):
- _elem616 = Partition()
- _elem616.read(iprot)
- self.success.append(_elem616)
+ (_etype621, _size618) = iprot.readListBegin()
+ for _i622 in xrange(_size618):
+ _elem623 = Partition()
+ _elem623.read(iprot)
+ self.success.append(_elem623)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15265,8 +15331,8 @@ 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 iter617 in self.success:
- iter617.write(oprot)
+ for iter624 in self.success:
+ iter624.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15484,10 +15550,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype621, _size618) = iprot.readListBegin()
- for _i622 in xrange(_size618):
- _elem623 = iprot.readString();
- self.names.append(_elem623)
+ (_etype628, _size625) = iprot.readListBegin()
+ for _i629 in xrange(_size625):
+ _elem630 = iprot.readString();
+ self.names.append(_elem630)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15512,8 +15578,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 iter624 in self.names:
- oprot.writeString(iter624)
+ for iter631 in self.names:
+ oprot.writeString(iter631)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15565,11 +15631,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype628, _size625) = iprot.readListBegin()
- for _i629 in xrange(_size625):
- _elem630 = Partition()
- _elem630.read(iprot)
- self.success.append(_elem630)
+ (_etype635, _size632) = iprot.readListBegin()
+ for _i636 in xrange(_size632):
+ _elem637 = Partition()
+ _elem637.read(iprot)
+ self.success.append(_elem637)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15598,8 +15664,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 iter631 in self.success:
- iter631.write(oprot)
+ for iter638 in self.success:
+ iter638.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15829,11 +15895,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype635, _size632) = iprot.readListBegin()
- for _i636 in xrange(_size632):
- _elem637 = Partition()
- _elem637.read(iprot)
- self.new_parts.append(_elem637)
+ (_etype642, _size639) = iprot.readListBegin()
+ for _i643 in xrange(_size639):
+ _elem644 = Partition()
+ _elem644.read(iprot)
+ self.new_parts.append(_elem644)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15858,8 +15924,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 iter638 in self.new_parts:
- iter638.write(oprot)
+ for iter645 in self.new_parts:
+ iter645.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16171,10 +16237,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype642, _size639) = iprot.readListBegin()
- for _i643 in xrange(_size639):
- _elem644 = iprot.readString();
- self.part_vals.append(_elem644)
+ (_etype649, _size646) = iprot.readListBegin()
+ for _i650 in xrange(_size646):
+ _elem651 = iprot.readString();
+ self.part_vals.append(_elem651)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16205,8 +16271,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 iter645 in self.part_vals:
- oprot.writeString(iter645)
+ for iter652 in self.part_vals:
+ oprot.writeString(iter652)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -16334,10 +16400,10 @@ class partition_name_has_valid_character
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype649, _size646) = iprot.readListBegin()
- for _i650 in xrange(_size646):
- _elem651 = iprot.readString();
- self.part_vals.append(_elem651)
+ (_etype656, _size653) = iprot.readListBegin()
+ for _i657 in xrange(_size653):
+ _elem658 = iprot.readString();
+ self.part_vals.append(_elem658)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16359,8 +16425,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 iter652 in self.part_vals:
- oprot.writeString(iter652)
+ for iter659 in self.part_vals:
+ oprot.writeString(iter659)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -16689,10 +16755,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype656, _size653) = iprot.readListBegin()
- for _i657 in xrange(_size653):
- _elem658 = iprot.readString();
- self.success.append(_elem658)
+ (_etype663, _size660) = iprot.readListBegin()
+ for _i664 in xrange(_size660):
+ _elem665 = iprot.readString();
+ self.success.append(_elem665)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16715,8 +16781,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 iter659 in self.success:
- oprot.writeString(iter659)
+ for iter666 in self.success:
+ oprot.writeString(iter666)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16829,11 +16895,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype661, _vtype662, _size660 ) = iprot.readMapBegin()
- for _i664 in xrange(_size660):
- _key665 = iprot.readString();
- _val666 = iprot.readString();
- self.success[_key665] = _val666
+ (_ktype668, _vtype669, _size667 ) = iprot.readMapBegin()
+ for _i671 in xrange(_size667):
+ _key672 = iprot.readString();
+ _val673 = iprot.readString();
+ self.success[_key672] = _val673
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16856,9 +16922,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 kiter667,viter668 in self.success.items():
- oprot.writeString(kiter667)
- oprot.writeString(viter668)
+ for kiter674,viter675 in self.success.items():
+ oprot.writeString(kiter674)
+ oprot.writeString(viter675)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16928,11 +16994,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype670, _vtype671, _size669 ) = iprot.readMapBegin()
- for _i673 in xrange(_size669):
- _key674 = iprot.readString();
- _val675 = iprot.readString();
- self.part_vals[_key674] = _val675
+ (_ktype677, _vtype678, _size676 ) = iprot.readMapBegin()
+ for _i680 in xrange(_size676):
+ _key681 = iprot.readString();
+ _val682 = iprot.readString();
+ self.part_vals[_key681] = _val682
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16962,9 +17028,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 kiter676,viter677 in self.part_vals.items():
- oprot.writeString(kiter676)
- oprot.writeString(viter677)
+ for kiter683,viter684 in self.part_vals.items():
+ oprot.writeString(kiter683)
+ oprot.writeString(viter684)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -17160,11 +17226,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype679, _vtype680, _size678 ) = iprot.readMapBegin()
- for _i682 in xrange(_size678):
- _key683 = iprot.readString();
- _val684 = iprot.readString();
- self.part_vals[_key683] = _val684
+ (_ktype686, _vtype687, _size685 ) = iprot.readMapBegin()
+ for _i689 in xrange(_size685):
+ _key690 = iprot.readString();
+ _val691 = iprot.readString();
+ self.part_vals[_key690] = _val691
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -17194,9 +17260,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 kiter685,viter686 in self.part_vals.items():
- oprot.writeString(kiter685)
- oprot.writeString(viter686)
+ for kiter692,viter693 in self.part_vals.items():
+ oprot.writeString(kiter692)
+ oprot.writeString(viter693)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -18168,11 +18234,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = Index()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = Index()
+ _elem699.read(iprot)
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18201,8 +18267,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 iter693 in self.success:
- iter693.write(oprot)
+ for iter700 in self.success:
+ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18343,10 +18409,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = iprot.readString();
- self.success.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = iprot.readString();
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18369,8 +18435,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 iter700 in self.success:
- oprot.writeString(iter700)
+ for iter707 in self.success:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -19584,6 +19650,178 @@ class get_aggr_stats_for_result:
def __ne__(self, other):
return not (self == other)
+class set_aggr_stats_for_args:
+ """
+ Attributes:
+ - request
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'request', (SetPartitionsStatsRequest, SetPartitionsStatsRequest.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 = SetPartitionsStatsRequest()
+ 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('set_aggr_stats_for_args')
+ if self.request is not None:
+ oprot.writeFieldBegin('request', TType.STRUCT, 1)
+ self.request.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 set_aggr_stats_for_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ - o3
+ - o4
+ """
+
+ thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3
+ (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4
+ )
+
+ def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+ self.o3 = o3
+ self.o4 = o4
+
+ 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.BOOL:
+ self.success = iprot.readBool();
+ 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 = InvalidObjectException()
+ 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)
+ elif fid == 4:
+ if ftype == TType.STRUCT:
+ self.o4 = InvalidInputException()
+ self.o4.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('set_aggr_stats_for_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.BOOL, 0)
+ oprot.writeBool(self.success)
+ 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()
+ if self.o4 is not None:
+ oprot.writeFieldBegin('o4', TType.STRUCT, 4)
+ self.o4.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 delete_partition_column_statistics_args:
"""
Attributes:
@@ -20552,10 +20790,10 @@ class get_functions_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)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString();
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20578,8 +20816,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 iter707 in self.success:
- oprot.writeString(iter707)
+ for iter714 in self.success:
+ oprot.writeString(iter714)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21097,10 +21335,10 @@ class get_role_names_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)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString();
+ self.success.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21123,8 +21361,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 iter714 in self.success:
- oprot.writeString(iter714)
+ for iter721 in self.success:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21597,11 +21835,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = Role()
- _elem720.read(iprot)
- self.success.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = Role()
+ _elem727.read(iprot)
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21624,8 +21862,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter721 in self.success:
- iter721.write(oprot)
+ for iter728 in self.success:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22095,10 +22333,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = iprot.readString();
- self.group_names.append(_elem727)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString();
+ self.group_names.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22123,8 +22361,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter728 in self.group_names:
- oprot.writeString(iter728)
+ for iter735 in self.group_names:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22331,11 +22569,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = HiveObjectPrivilege()
- _elem734.read(iprot)
- self.success.append(_elem734)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = HiveObjectPrivilege()
+ _elem741.read(iprot)
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22358,8 +22596,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter735 in self.success:
- iter735.write(oprot)
+ for iter742 in self.success:
+ iter742.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22818,10 +23056,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString();
- self.group_names.append(_elem741)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = iprot.readString();
+ self.group_names.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22842,8 +23080,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter742 in self.group_names:
- oprot.writeString(iter742)
+ for iter749 in self.group_names:
+ oprot.writeString(iter749)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22892,10 +23130,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString();
- self.success.append(_elem748)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = iprot.readString();
+ self.success.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22918,8 +23156,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter749 in self.success:
- oprot.writeString(iter749)
+ for iter756 in self.success:
+ oprot.writeString(iter756)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: