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/05 07:52:53 UTC
svn commit: r1615865 [9/10] - 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_m...
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=1615865&r1=1615864&r2=1615865&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 Tue Aug 5 05:52:51 2014
@@ -633,6 +633,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def get_aggr_stats_for(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
"""
Parameters:
@@ -3588,6 +3595,40 @@ class Client(fb303.FacebookService.Clien
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_statistics_req failed: unknown result");
+ def get_aggr_stats_for(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_aggr_stats_for(request)
+ return self.recv_get_aggr_stats_for()
+
+ def send_get_aggr_stats_for(self, request):
+ self._oprot.writeMessageBegin('get_aggr_stats_for', TMessageType.CALL, self._seqid)
+ args = get_aggr_stats_for_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_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 = get_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
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result");
+
def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
"""
Parameters:
@@ -4918,6 +4959,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["get_partition_column_statistics"] = Processor.process_get_partition_column_statistics
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["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
@@ -6162,6 +6204,22 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_aggr_stats_for(self, seqid, iprot, oprot):
+ args = get_aggr_stats_for_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_aggr_stats_for_result()
+ try:
+ result.success = self._handler.get_aggr_stats_for(args.request)
+ except NoSuchObjectException as o1:
+ result.o1 = o1
+ except MetaException as o2:
+ result.o2 = o2
+ oprot.writeMessageBegin("get_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)
@@ -7267,10 +7325,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype393, _size390) = iprot.readListBegin()
- for _i394 in xrange(_size390):
- _elem395 = iprot.readString();
- self.success.append(_elem395)
+ (_etype400, _size397) = iprot.readListBegin()
+ for _i401 in xrange(_size397):
+ _elem402 = iprot.readString();
+ self.success.append(_elem402)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7293,8 +7351,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 iter396 in self.success:
- oprot.writeString(iter396)
+ for iter403 in self.success:
+ oprot.writeString(iter403)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7389,10 +7447,10 @@ class get_all_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)
@@ -7415,8 +7473,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 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:
@@ -8126,12 +8184,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype405, _vtype406, _size404 ) = iprot.readMapBegin()
- for _i408 in xrange(_size404):
- _key409 = iprot.readString();
- _val410 = Type()
- _val410.read(iprot)
- self.success[_key409] = _val410
+ (_ktype412, _vtype413, _size411 ) = iprot.readMapBegin()
+ for _i415 in xrange(_size411):
+ _key416 = iprot.readString();
+ _val417 = Type()
+ _val417.read(iprot)
+ self.success[_key416] = _val417
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -8154,9 +8212,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 kiter411,viter412 in self.success.items():
- oprot.writeString(kiter411)
- viter412.write(oprot)
+ for kiter418,viter419 in self.success.items():
+ oprot.writeString(kiter418)
+ viter419.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -8287,11 +8345,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype416, _size413) = iprot.readListBegin()
- for _i417 in xrange(_size413):
- _elem418 = FieldSchema()
- _elem418.read(iprot)
- self.success.append(_elem418)
+ (_etype423, _size420) = iprot.readListBegin()
+ for _i424 in xrange(_size420):
+ _elem425 = FieldSchema()
+ _elem425.read(iprot)
+ self.success.append(_elem425)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8326,8 +8384,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 iter419 in self.success:
- iter419.write(oprot)
+ for iter426 in self.success:
+ iter426.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8466,11 +8524,11 @@ class get_schema_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)
@@ -8505,8 +8563,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 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:
@@ -9303,10 +9361,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype430, _size427) = iprot.readListBegin()
- for _i431 in xrange(_size427):
- _elem432 = iprot.readString();
- self.success.append(_elem432)
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = iprot.readString();
+ self.success.append(_elem439)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9329,8 +9387,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 iter433 in self.success:
- oprot.writeString(iter433)
+ for iter440 in self.success:
+ oprot.writeString(iter440)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9443,10 +9501,10 @@ class get_all_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)
@@ -9469,8 +9527,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 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:
@@ -9687,10 +9745,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString();
- self.tbl_names.append(_elem446)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = iprot.readString();
+ self.tbl_names.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9711,8 +9769,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 iter447 in self.tbl_names:
- oprot.writeString(iter447)
+ for iter454 in self.tbl_names:
+ oprot.writeString(iter454)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9767,11 +9825,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = Table()
- _elem453.read(iprot)
- self.success.append(_elem453)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = Table()
+ _elem460.read(iprot)
+ self.success.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9806,8 +9864,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 iter454 in self.success:
- iter454.write(oprot)
+ for iter461 in self.success:
+ iter461.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9958,10 +10016,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString();
- self.success.append(_elem460)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = iprot.readString();
+ self.success.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9996,8 +10054,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 iter461 in self.success:
- oprot.writeString(iter461)
+ for iter468 in self.success:
+ oprot.writeString(iter468)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10720,11 +10778,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = Partition()
- _elem467.read(iprot)
- self.new_parts.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = Partition()
+ _elem474.read(iprot)
+ self.new_parts.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10741,8 +10799,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 iter468 in self.new_parts:
- iter468.write(oprot)
+ for iter475 in self.new_parts:
+ iter475.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10903,10 +10961,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readString();
- self.part_vals.append(_elem474)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = iprot.readString();
+ self.part_vals.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10931,8 +10989,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 iter475 in self.part_vals:
- oprot.writeString(iter475)
+ for iter482 in self.part_vals:
+ oprot.writeString(iter482)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11257,10 +11315,10 @@ class append_partition_with_environment_
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)
@@ -11291,8 +11349,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 iter482 in self.part_vals:
- oprot.writeString(iter482)
+ for iter489 in self.part_vals:
+ oprot.writeString(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -11840,10 +11898,10 @@ class drop_partition_args:
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)
@@ -11873,8 +11931,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 iter489 in self.part_vals:
- oprot.writeString(iter489)
+ for iter496 in self.part_vals:
+ oprot.writeString(iter496)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -12032,10 +12090,10 @@ class drop_partition_with_environment_co
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)
@@ -12071,8 +12129,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 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:
@@ -12750,10 +12808,10 @@ class get_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)
+ (_etype507, _size504) = iprot.readListBegin()
+ for _i508 in xrange(_size504):
+ _elem509 = iprot.readString();
+ self.part_vals.append(_elem509)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12778,8 +12836,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 iter503 in self.part_vals:
- oprot.writeString(iter503)
+ for iter510 in self.part_vals:
+ oprot.writeString(iter510)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12924,11 +12982,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype505, _vtype506, _size504 ) = iprot.readMapBegin()
- for _i508 in xrange(_size504):
- _key509 = iprot.readString();
- _val510 = iprot.readString();
- self.partitionSpecs[_key509] = _val510
+ (_ktype512, _vtype513, _size511 ) = iprot.readMapBegin()
+ for _i515 in xrange(_size511):
+ _key516 = iprot.readString();
+ _val517 = iprot.readString();
+ self.partitionSpecs[_key516] = _val517
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12965,9 +13023,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 kiter511,viter512 in self.partitionSpecs.items():
- oprot.writeString(kiter511)
- oprot.writeString(viter512)
+ for kiter518,viter519 in self.partitionSpecs.items():
+ oprot.writeString(kiter518)
+ oprot.writeString(viter519)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -13164,10 +13222,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = iprot.readString();
- self.part_vals.append(_elem518)
+ (_etype523, _size520) = iprot.readListBegin()
+ for _i524 in xrange(_size520):
+ _elem525 = iprot.readString();
+ self.part_vals.append(_elem525)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13179,10 +13237,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype522, _size519) = iprot.readListBegin()
- for _i523 in xrange(_size519):
- _elem524 = iprot.readString();
- self.group_names.append(_elem524)
+ (_etype529, _size526) = iprot.readListBegin()
+ for _i530 in xrange(_size526):
+ _elem531 = iprot.readString();
+ self.group_names.append(_elem531)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13207,8 +13265,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 iter525 in self.part_vals:
- oprot.writeString(iter525)
+ for iter532 in self.part_vals:
+ oprot.writeString(iter532)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -13218,8 +13276,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 iter526 in self.group_names:
- oprot.writeString(iter526)
+ for iter533 in self.group_names:
+ oprot.writeString(iter533)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13611,11 +13669,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = Partition()
- _elem532.read(iprot)
- self.success.append(_elem532)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = Partition()
+ _elem539.read(iprot)
+ self.success.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13644,8 +13702,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 iter533 in self.success:
- iter533.write(oprot)
+ for iter540 in self.success:
+ iter540.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13732,10 +13790,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString();
- self.group_names.append(_elem539)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = iprot.readString();
+ self.group_names.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13768,8 +13826,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 iter540 in self.group_names:
- oprot.writeString(iter540)
+ for iter547 in self.group_names:
+ oprot.writeString(iter547)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13821,11 +13879,11 @@ class get_partitions_with_auth_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)
+ (_etype551, _size548) = iprot.readListBegin()
+ for _i552 in xrange(_size548):
+ _elem553 = Partition()
+ _elem553.read(iprot)
+ self.success.append(_elem553)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13854,8 +13912,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 iter547 in self.success:
- iter547.write(oprot)
+ for iter554 in self.success:
+ iter554.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13996,10 +14054,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = iprot.readString();
- self.success.append(_elem553)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = iprot.readString();
+ self.success.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14022,8 +14080,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 iter554 in self.success:
- oprot.writeString(iter554)
+ for iter561 in self.success:
+ oprot.writeString(iter561)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14093,10 +14151,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = iprot.readString();
- self.part_vals.append(_elem560)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = iprot.readString();
+ self.part_vals.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14126,8 +14184,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 iter561 in self.part_vals:
- oprot.writeString(iter561)
+ for iter568 in self.part_vals:
+ oprot.writeString(iter568)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14183,11 +14241,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = Partition()
- _elem567.read(iprot)
- self.success.append(_elem567)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = Partition()
+ _elem574.read(iprot)
+ self.success.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14216,8 +14274,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 iter568 in self.success:
- iter568.write(oprot)
+ for iter575 in self.success:
+ iter575.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14297,10 +14355,10 @@ class get_partitions_ps_with_auth_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)
+ (_etype579, _size576) = iprot.readListBegin()
+ for _i580 in xrange(_size576):
+ _elem581 = iprot.readString();
+ self.part_vals.append(_elem581)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14317,10 +14375,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype578, _size575) = iprot.readListBegin()
- for _i579 in xrange(_size575):
- _elem580 = iprot.readString();
- self.group_names.append(_elem580)
+ (_etype585, _size582) = iprot.readListBegin()
+ for _i586 in xrange(_size582):
+ _elem587 = iprot.readString();
+ self.group_names.append(_elem587)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14345,8 +14403,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 iter581 in self.part_vals:
- oprot.writeString(iter581)
+ for iter588 in self.part_vals:
+ oprot.writeString(iter588)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14360,8 +14418,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 iter582 in self.group_names:
- oprot.writeString(iter582)
+ for iter589 in self.group_names:
+ oprot.writeString(iter589)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14413,11 +14471,11 @@ class get_partitions_ps_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype586, _size583) = iprot.readListBegin()
- for _i587 in xrange(_size583):
- _elem588 = Partition()
- _elem588.read(iprot)
- self.success.append(_elem588)
+ (_etype593, _size590) = iprot.readListBegin()
+ for _i594 in xrange(_size590):
+ _elem595 = Partition()
+ _elem595.read(iprot)
+ self.success.append(_elem595)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14446,8 +14504,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 iter589 in self.success:
- iter589.write(oprot)
+ for iter596 in self.success:
+ iter596.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14521,10 +14579,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = iprot.readString();
- self.part_vals.append(_elem595)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = iprot.readString();
+ self.part_vals.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14554,8 +14612,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 iter596 in self.part_vals:
- oprot.writeString(iter596)
+ for iter603 in self.part_vals:
+ oprot.writeString(iter603)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14611,10 +14669,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype600, _size597) = iprot.readListBegin()
- for _i601 in xrange(_size597):
- _elem602 = iprot.readString();
- self.success.append(_elem602)
+ (_etype607, _size604) = iprot.readListBegin()
+ for _i608 in xrange(_size604):
+ _elem609 = iprot.readString();
+ self.success.append(_elem609)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14643,8 +14701,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 iter603 in self.success:
- oprot.writeString(iter603)
+ for iter610 in self.success:
+ oprot.writeString(iter610)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14800,11 +14858,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = Partition()
- _elem609.read(iprot)
- self.success.append(_elem609)
+ (_etype614, _size611) = iprot.readListBegin()
+ for _i615 in xrange(_size611):
+ _elem616 = Partition()
+ _elem616.read(iprot)
+ self.success.append(_elem616)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14833,8 +14891,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 iter610 in self.success:
- iter610.write(oprot)
+ for iter617 in self.success:
+ iter617.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15052,10 +15110,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype614, _size611) = iprot.readListBegin()
- for _i615 in xrange(_size611):
- _elem616 = iprot.readString();
- self.names.append(_elem616)
+ (_etype621, _size618) = iprot.readListBegin()
+ for _i622 in xrange(_size618):
+ _elem623 = iprot.readString();
+ self.names.append(_elem623)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15080,8 +15138,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 iter617 in self.names:
- oprot.writeString(iter617)
+ for iter624 in self.names:
+ oprot.writeString(iter624)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15133,11 +15191,11 @@ class get_partitions_by_names_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)
+ (_etype628, _size625) = iprot.readListBegin()
+ for _i629 in xrange(_size625):
+ _elem630 = Partition()
+ _elem630.read(iprot)
+ self.success.append(_elem630)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15166,8 +15224,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 iter624 in self.success:
- iter624.write(oprot)
+ for iter631 in self.success:
+ iter631.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15397,11 +15455,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype628, _size625) = iprot.readListBegin()
- for _i629 in xrange(_size625):
- _elem630 = Partition()
- _elem630.read(iprot)
- self.new_parts.append(_elem630)
+ (_etype635, _size632) = iprot.readListBegin()
+ for _i636 in xrange(_size632):
+ _elem637 = Partition()
+ _elem637.read(iprot)
+ self.new_parts.append(_elem637)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15426,8 +15484,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 iter631 in self.new_parts:
- iter631.write(oprot)
+ for iter638 in self.new_parts:
+ iter638.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15739,10 +15797,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype635, _size632) = iprot.readListBegin()
- for _i636 in xrange(_size632):
- _elem637 = iprot.readString();
- self.part_vals.append(_elem637)
+ (_etype642, _size639) = iprot.readListBegin()
+ for _i643 in xrange(_size639):
+ _elem644 = iprot.readString();
+ self.part_vals.append(_elem644)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15773,8 +15831,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 iter638 in self.part_vals:
- oprot.writeString(iter638)
+ for iter645 in self.part_vals:
+ oprot.writeString(iter645)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -15902,10 +15960,10 @@ class partition_name_has_valid_character
if fid == 1:
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)
@@ -15927,8 +15985,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 iter645 in self.part_vals:
- oprot.writeString(iter645)
+ for iter652 in self.part_vals:
+ oprot.writeString(iter652)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -16257,10 +16315,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype649, _size646) = iprot.readListBegin()
- for _i650 in xrange(_size646):
- _elem651 = iprot.readString();
- self.success.append(_elem651)
+ (_etype656, _size653) = iprot.readListBegin()
+ for _i657 in xrange(_size653):
+ _elem658 = iprot.readString();
+ self.success.append(_elem658)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16283,8 +16341,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 iter652 in self.success:
- oprot.writeString(iter652)
+ for iter659 in self.success:
+ oprot.writeString(iter659)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16397,11 +16455,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype654, _vtype655, _size653 ) = iprot.readMapBegin()
- for _i657 in xrange(_size653):
- _key658 = iprot.readString();
- _val659 = iprot.readString();
- self.success[_key658] = _val659
+ (_ktype661, _vtype662, _size660 ) = iprot.readMapBegin()
+ for _i664 in xrange(_size660):
+ _key665 = iprot.readString();
+ _val666 = iprot.readString();
+ self.success[_key665] = _val666
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16424,9 +16482,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 kiter660,viter661 in self.success.items():
- oprot.writeString(kiter660)
- oprot.writeString(viter661)
+ for kiter667,viter668 in self.success.items():
+ oprot.writeString(kiter667)
+ oprot.writeString(viter668)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16496,11 +16554,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype663, _vtype664, _size662 ) = iprot.readMapBegin()
- for _i666 in xrange(_size662):
- _key667 = iprot.readString();
- _val668 = iprot.readString();
- self.part_vals[_key667] = _val668
+ (_ktype670, _vtype671, _size669 ) = iprot.readMapBegin()
+ for _i673 in xrange(_size669):
+ _key674 = iprot.readString();
+ _val675 = iprot.readString();
+ self.part_vals[_key674] = _val675
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16530,9 +16588,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 kiter669,viter670 in self.part_vals.items():
- oprot.writeString(kiter669)
- oprot.writeString(viter670)
+ for kiter676,viter677 in self.part_vals.items():
+ oprot.writeString(kiter676)
+ oprot.writeString(viter677)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -16728,11 +16786,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype672, _vtype673, _size671 ) = iprot.readMapBegin()
- for _i675 in xrange(_size671):
- _key676 = iprot.readString();
- _val677 = iprot.readString();
- self.part_vals[_key676] = _val677
+ (_ktype679, _vtype680, _size678 ) = iprot.readMapBegin()
+ for _i682 in xrange(_size678):
+ _key683 = iprot.readString();
+ _val684 = iprot.readString();
+ self.part_vals[_key683] = _val684
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16762,9 +16820,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 kiter678,viter679 in self.part_vals.items():
- oprot.writeString(kiter678)
- oprot.writeString(viter679)
+ for kiter685,viter686 in self.part_vals.items():
+ oprot.writeString(kiter685)
+ oprot.writeString(viter686)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -17736,11 +17794,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = Index()
- _elem685.read(iprot)
- self.success.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = Index()
+ _elem692.read(iprot)
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17769,8 +17827,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 iter686 in self.success:
- iter686.write(oprot)
+ for iter693 in self.success:
+ iter693.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17911,10 +17969,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = iprot.readString();
- self.success.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = iprot.readString();
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17937,8 +17995,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 iter693 in self.success:
- oprot.writeString(iter693)
+ for iter700 in self.success:
+ oprot.writeString(iter700)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -19005,6 +19063,153 @@ class get_partitions_statistics_req_resu
def __ne__(self, other):
return not (self == other)
+class get_aggr_stats_for_args:
+ """
+ Attributes:
+ - request
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'request', (PartitionsStatsRequest, PartitionsStatsRequest.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 = PartitionsStatsRequest()
+ 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('get_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 get_aggr_stats_for_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (AggrStats, AggrStats.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.STRUCT:
+ self.success = AggrStats()
+ self.success.read(iprot)
+ 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_aggr_stats_for_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()
+ 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:
@@ -19973,10 +20178,10 @@ class get_functions_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)
@@ -19999,8 +20204,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 iter700 in self.success:
- oprot.writeString(iter700)
+ for iter707 in self.success:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20518,10 +20723,10 @@ class get_role_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)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString();
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20544,8 +20749,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 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:
@@ -21018,11 +21223,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = Role()
- _elem713.read(iprot)
- self.success.append(_elem713)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = Role()
+ _elem720.read(iprot)
+ self.success.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21045,8 +21250,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 iter714 in self.success:
- iter714.write(oprot)
+ for iter721 in self.success:
+ iter721.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21516,10 +21721,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = iprot.readString();
- self.group_names.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = iprot.readString();
+ self.group_names.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21544,8 +21749,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 iter721 in self.group_names:
- oprot.writeString(iter721)
+ for iter728 in self.group_names:
+ oprot.writeString(iter728)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21752,11 +21957,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = HiveObjectPrivilege()
- _elem727.read(iprot)
- self.success.append(_elem727)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = HiveObjectPrivilege()
+ _elem734.read(iprot)
+ self.success.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21779,8 +21984,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 iter728 in self.success:
- iter728.write(oprot)
+ for iter735 in self.success:
+ iter735.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22239,10 +22444,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = iprot.readString();
- self.group_names.append(_elem734)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString();
+ self.group_names.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22263,8 +22468,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 iter735 in self.group_names:
- oprot.writeString(iter735)
+ for iter742 in self.group_names:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22313,10 +22518,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString();
- self.success.append(_elem741)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = iprot.readString();
+ self.success.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22339,8 +22544,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 iter742 in self.success:
- oprot.writeString(iter742)
+ for iter749 in self.success:
+ oprot.writeString(iter749)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1615865&r1=1615864&r2=1615865&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Tue Aug 5 05:52:51 2014
@@ -4148,6 +4148,91 @@ class ColumnStatistics:
def __ne__(self, other):
return not (self == other)
+class AggrStats:
+ """
+ Attributes:
+ - colStats
+ - partsFound
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'colStats', (TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec)), None, ), # 1
+ (2, TType.I64, 'partsFound', None, None, ), # 2
+ )
+
+ def __init__(self, colStats=None, partsFound=None,):
+ self.colStats = colStats
+ self.partsFound = partsFound
+
+ 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.LIST:
+ self.colStats = []
+ (_etype219, _size216) = iprot.readListBegin()
+ for _i220 in xrange(_size216):
+ _elem221 = ColumnStatisticsObj()
+ _elem221.read(iprot)
+ self.colStats.append(_elem221)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I64:
+ self.partsFound = iprot.readI64();
+ 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('AggrStats')
+ if self.colStats is not None:
+ oprot.writeFieldBegin('colStats', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.colStats))
+ for iter222 in self.colStats:
+ iter222.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.partsFound is not None:
+ oprot.writeFieldBegin('partsFound', TType.I64, 2)
+ oprot.writeI64(self.partsFound)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.colStats is None:
+ raise TProtocol.TProtocolException(message='Required field colStats is unset!')
+ if self.partsFound is None:
+ raise TProtocol.TProtocolException(message='Required field partsFound is unset!')
+ 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 Schema:
"""
Attributes:
@@ -4177,22 +4262,22 @@ class Schema:
if fid == 1:
if ftype == TType.LIST:
self.fieldSchemas = []
- (_etype219, _size216) = iprot.readListBegin()
- for _i220 in xrange(_size216):
- _elem221 = FieldSchema()
- _elem221.read(iprot)
- self.fieldSchemas.append(_elem221)
+ (_etype226, _size223) = iprot.readListBegin()
+ for _i227 in xrange(_size223):
+ _elem228 = FieldSchema()
+ _elem228.read(iprot)
+ self.fieldSchemas.append(_elem228)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.MAP:
self.properties = {}
- (_ktype223, _vtype224, _size222 ) = iprot.readMapBegin()
- for _i226 in xrange(_size222):
- _key227 = iprot.readString();
- _val228 = iprot.readString();
- self.properties[_key227] = _val228
+ (_ktype230, _vtype231, _size229 ) = iprot.readMapBegin()
+ for _i233 in xrange(_size229):
+ _key234 = iprot.readString();
+ _val235 = iprot.readString();
+ self.properties[_key234] = _val235
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4209,16 +4294,16 @@ class Schema:
if self.fieldSchemas is not None:
oprot.writeFieldBegin('fieldSchemas', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.fieldSchemas))
- for iter229 in self.fieldSchemas:
- iter229.write(oprot)
+ for iter236 in self.fieldSchemas:
+ iter236.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 2)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter230,viter231 in self.properties.items():
- oprot.writeString(kiter230)
- oprot.writeString(viter231)
+ for kiter237,viter238 in self.properties.items():
+ oprot.writeString(kiter237)
+ oprot.writeString(viter238)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4265,11 +4350,11 @@ class EnvironmentContext:
if fid == 1:
if ftype == TType.MAP:
self.properties = {}
- (_ktype233, _vtype234, _size232 ) = iprot.readMapBegin()
- for _i236 in xrange(_size232):
- _key237 = iprot.readString();
- _val238 = iprot.readString();
- self.properties[_key237] = _val238
+ (_ktype240, _vtype241, _size239 ) = iprot.readMapBegin()
+ for _i243 in xrange(_size239):
+ _key244 = iprot.readString();
+ _val245 = iprot.readString();
+ self.properties[_key244] = _val245
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4286,9 +4371,9 @@ class EnvironmentContext:
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter239,viter240 in self.properties.items():
- oprot.writeString(kiter239)
- oprot.writeString(viter240)
+ for kiter246,viter247 in self.properties.items():
+ oprot.writeString(kiter246)
+ oprot.writeString(viter247)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4338,11 +4423,11 @@ class PartitionsByExprResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype244, _size241) = iprot.readListBegin()
- for _i245 in xrange(_size241):
- _elem246 = Partition()
- _elem246.read(iprot)
- self.partitions.append(_elem246)
+ (_etype251, _size248) = iprot.readListBegin()
+ for _i252 in xrange(_size248):
+ _elem253 = Partition()
+ _elem253.read(iprot)
+ self.partitions.append(_elem253)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4364,8 +4449,8 @@ class PartitionsByExprResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter247 in self.partitions:
- iter247.write(oprot)
+ for iter254 in self.partitions:
+ iter254.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.hasUnknownPartitions is not None:
@@ -4534,11 +4619,11 @@ class TableStatsResult:
if fid == 1:
if ftype == TType.LIST:
self.tableStats = []
- (_etype251, _size248) = iprot.readListBegin()
- for _i252 in xrange(_size248):
- _elem253 = ColumnStatisticsObj()
- _elem253.read(iprot)
- self.tableStats.append(_elem253)
+ (_etype258, _size255) = iprot.readListBegin()
+ for _i259 in xrange(_size255):
+ _elem260 = ColumnStatisticsObj()
+ _elem260.read(iprot)
+ self.tableStats.append(_elem260)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4555,8 +4640,8 @@ class TableStatsResult:
if self.tableStats is not None:
oprot.writeFieldBegin('tableStats', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.tableStats))
- for iter254 in self.tableStats:
- iter254.write(oprot)
+ for iter261 in self.tableStats:
+ iter261.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4605,17 +4690,17 @@ class PartitionsStatsResult:
if fid == 1:
if ftype == TType.MAP:
self.partStats = {}
- (_ktype256, _vtype257, _size255 ) = iprot.readMapBegin()
- for _i259 in xrange(_size255):
- _key260 = iprot.readString();
- _val261 = []
- (_etype265, _size262) = iprot.readListBegin()
- for _i266 in xrange(_size262):
- _elem267 = ColumnStatisticsObj()
- _elem267.read(iprot)
- _val261.append(_elem267)
+ (_ktype263, _vtype264, _size262 ) = iprot.readMapBegin()
+ for _i266 in xrange(_size262):
+ _key267 = iprot.readString();
+ _val268 = []
+ (_etype272, _size269) = iprot.readListBegin()
+ for _i273 in xrange(_size269):
+ _elem274 = ColumnStatisticsObj()
+ _elem274.read(iprot)
+ _val268.append(_elem274)
iprot.readListEnd()
- self.partStats[_key260] = _val261
+ self.partStats[_key267] = _val268
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -4632,11 +4717,11 @@ class PartitionsStatsResult:
if self.partStats is not None:
oprot.writeFieldBegin('partStats', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.LIST, len(self.partStats))
- for kiter268,viter269 in self.partStats.items():
- oprot.writeString(kiter268)
- oprot.writeListBegin(TType.STRUCT, len(viter269))
- for iter270 in viter269:
- iter270.write(oprot)
+ for kiter275,viter276 in self.partStats.items():
+ oprot.writeString(kiter275)
+ oprot.writeListBegin(TType.STRUCT, len(viter276))
+ for iter277 in viter276:
+ iter277.write(oprot)
oprot.writeListEnd()
oprot.writeMapEnd()
oprot.writeFieldEnd()
@@ -4702,10 +4787,10 @@ class TableStatsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.colNames = []
- (_etype274, _size271) = iprot.readListBegin()
- for _i275 in xrange(_size271):
- _elem276 = iprot.readString();
- self.colNames.append(_elem276)
+ (_etype281, _size278) = iprot.readListBegin()
+ for _i282 in xrange(_size278):
+ _elem283 = iprot.readString();
+ self.colNames.append(_elem283)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4730,8 +4815,8 @@ class TableStatsRequest:
if self.colNames is not None:
oprot.writeFieldBegin('colNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.colNames))
- for iter277 in self.colNames:
- oprot.writeString(iter277)
+ for iter284 in self.colNames:
+ oprot.writeString(iter284)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4803,20 +4888,20 @@ class PartitionsStatsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.colNames = []
- (_etype281, _size278) = iprot.readListBegin()
- for _i282 in xrange(_size278):
- _elem283 = iprot.readString();
- self.colNames.append(_elem283)
+ (_etype288, _size285) = iprot.readListBegin()
+ for _i289 in xrange(_size285):
+ _elem290 = iprot.readString();
+ self.colNames.append(_elem290)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.partNames = []
- (_etype287, _size284) = iprot.readListBegin()
- for _i288 in xrange(_size284):
- _elem289 = iprot.readString();
- self.partNames.append(_elem289)
+ (_etype294, _size291) = iprot.readListBegin()
+ for _i295 in xrange(_size291):
+ _elem296 = iprot.readString();
+ self.partNames.append(_elem296)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4841,15 +4926,15 @@ class PartitionsStatsRequest:
if self.colNames is not None:
oprot.writeFieldBegin('colNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.colNames))
- for iter290 in self.colNames:
- oprot.writeString(iter290)
+ for iter297 in self.colNames:
+ oprot.writeString(iter297)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 4)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter291 in self.partNames:
- oprot.writeString(iter291)
+ for iter298 in self.partNames:
+ oprot.writeString(iter298)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4904,11 +4989,11 @@ class AddPartitionsResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype295, _size292) = iprot.readListBegin()
- for _i296 in xrange(_size292):
- _elem297 = Partition()
- _elem297.read(iprot)
- self.partitions.append(_elem297)
+ (_etype302, _size299) = iprot.readListBegin()
+ for _i303 in xrange(_size299):
+ _elem304 = Partition()
+ _elem304.read(iprot)
+ self.partitions.append(_elem304)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4925,8 +5010,8 @@ class AddPartitionsResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter298 in self.partitions:
- iter298.write(oprot)
+ for iter305 in self.partitions:
+ iter305.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -4995,11 +5080,11 @@ class AddPartitionsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.parts = []
- (_etype302, _size299) = iprot.readListBegin()
- for _i303 in xrange(_size299):
- _elem304 = Partition()
- _elem304.read(iprot)
- self.parts.append(_elem304)
+ (_etype309, _size306) = iprot.readListBegin()
+ for _i310 in xrange(_size306):
+ _elem311 = Partition()
+ _elem311.read(iprot)
+ self.parts.append(_elem311)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5034,8 +5119,8 @@ class AddPartitionsRequest:
if self.parts is not None:
oprot.writeFieldBegin('parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.parts))
- for iter305 in self.parts:
- iter305.write(oprot)
+ for iter312 in self.parts:
+ iter312.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ifNotExists is not None:
@@ -5098,11 +5183,11 @@ class DropPartitionsResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype309, _size306) = iprot.readListBegin()
- for _i310 in xrange(_size306):
- _elem311 = Partition()
- _elem311.read(iprot)
- self.partitions.append(_elem311)
+ (_etype316, _size313) = iprot.readListBegin()
+ for _i317 in xrange(_size313):
+ _elem318 = Partition()
+ _elem318.read(iprot)
+ self.partitions.append(_elem318)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5119,8 +5204,8 @@ class DropPartitionsResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter312 in self.partitions:
- iter312.write(oprot)
+ for iter319 in self.partitions:
+ iter319.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -5244,21 +5329,21 @@ class RequestPartsSpec:
if fid == 1:
if ftype == TType.LIST:
self.names = []
- (_etype316, _size313) = iprot.readListBegin()
- for _i317 in xrange(_size313):
- _elem318 = iprot.readString();
- self.names.append(_elem318)
+ (_etype323, _size320) = iprot.readListBegin()
+ for _i324 in xrange(_size320):
+ _elem325 = iprot.readString();
+ self.names.append(_elem325)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.exprs = []
- (_etype322, _size319) = iprot.readListBegin()
- for _i323 in xrange(_size319):
- _elem324 = DropPartitionsExpr()
- _elem324.read(iprot)
- self.exprs.append(_elem324)
+ (_etype329, _size326) = iprot.readListBegin()
+ for _i330 in xrange(_size326):
+ _elem331 = DropPartitionsExpr()
+ _elem331.read(iprot)
+ self.exprs.append(_elem331)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5275,15 +5360,15 @@ class RequestPartsSpec:
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter325 in self.names:
- oprot.writeString(iter325)
+ for iter332 in self.names:
+ oprot.writeString(iter332)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.exprs is not None:
oprot.writeFieldBegin('exprs', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.exprs))
- for iter326 in self.exprs:
- iter326.write(oprot)
+ for iter333 in self.exprs:
+ iter333.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -5610,11 +5695,11 @@ class Function:
elif fid == 8:
if ftype == TType.LIST:
self.resourceUris = []
- (_etype330, _size327) = iprot.readListBegin()
- for _i331 in xrange(_size327):
- _elem332 = ResourceUri()
- _elem332.read(iprot)
- self.resourceUris.append(_elem332)
+ (_etype337, _size334) = iprot.readListBegin()
+ for _i338 in xrange(_size334):
+ _elem339 = ResourceUri()
+ _elem339.read(iprot)
+ self.resourceUris.append(_elem339)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5659,8 +5744,8 @@ class Function:
if self.resourceUris is not None:
oprot.writeFieldBegin('resourceUris', TType.LIST, 8)
oprot.writeListBegin(TType.STRUCT, len(self.resourceUris))
- for iter333 in self.resourceUris:
- iter333.write(oprot)
+ for iter340 in self.resourceUris:
+ iter340.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -5819,11 +5904,11 @@ class GetOpenTxnsInfoResponse:
elif fid == 2:
if ftype == TType.LIST:
self.open_txns = []
- (_etype337, _size334) = iprot.readListBegin()
- for _i338 in xrange(_size334):
- _elem339 = TxnInfo()
- _elem339.read(iprot)
- self.open_txns.append(_elem339)
+ (_etype344, _size341) = iprot.readListBegin()
+ for _i345 in xrange(_size341):
+ _elem346 = TxnInfo()
+ _elem346.read(iprot)
+ self.open_txns.append(_elem346)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5844,8 +5929,8 @@ class GetOpenTxnsInfoResponse:
if self.open_txns is not None:
oprot.writeFieldBegin('open_txns', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.open_txns))
- for iter340 in self.open_txns:
- iter340.write(oprot)
+ for iter347 in self.open_txns:
+ iter347.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -5904,10 +5989,10 @@ class GetOpenTxnsResponse:
elif fid == 2:
if ftype == TType.SET:
self.open_txns = set()
- (_etype344, _size341) = iprot.readSetBegin()
- for _i345 in xrange(_size341):
- _elem346 = iprot.readI64();
- self.open_txns.add(_elem346)
+ (_etype351, _size348) = iprot.readSetBegin()
+ for _i352 in xrange(_size348):
+ _elem353 = iprot.readI64();
+ self.open_txns.add(_elem353)
iprot.readSetEnd()
else:
iprot.skip(ftype)
@@ -5928,8 +6013,8 @@ class GetOpenTxnsResponse:
if self.open_txns is not None:
oprot.writeFieldBegin('open_txns', TType.SET, 2)
oprot.writeSetBegin(TType.I64, len(self.open_txns))
- for iter347 in self.open_txns:
- oprot.writeI64(iter347)
+ for iter354 in self.open_txns:
+ oprot.writeI64(iter354)
oprot.writeSetEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -6070,10 +6155,10 @@ class OpenTxnsResponse:
if fid == 1:
if ftype == TType.LIST:
self.txn_ids = []
- (_etype351, _size348) = iprot.readListBegin()
- for _i352 in xrange(_size348):
- _elem353 = iprot.readI64();
- self.txn_ids.append(_elem353)
+ (_etype358, _size355) = iprot.readListBegin()
+ for _i359 in xrange(_size355):
+ _elem360 = iprot.readI64();
+ self.txn_ids.append(_elem360)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6090,8 +6175,8 @@ class OpenTxnsResponse:
if self.txn_ids is not None:
oprot.writeFieldBegin('txn_ids', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.txn_ids))
- for iter354 in self.txn_ids:
- oprot.writeI64(iter354)
+ for iter361 in self.txn_ids:
+ oprot.writeI64(iter361)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -6387,11 +6472,11 @@ class LockRequest:
if fid == 1:
if ftype == TType.LIST:
self.component = []
- (_etype358, _size355) = iprot.readListBegin()
- for _i359 in xrange(_size355):
- _elem360 = LockComponent()
- _elem360.read(iprot)
- self.component.append(_elem360)
+ (_etype365, _size362) = iprot.readListBegin()
+ for _i366 in xrange(_size362):
+ _elem367 = LockComponent()
+ _elem367.read(iprot)
+ self.component.append(_elem367)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6423,8 +6508,8 @@ class LockRequest:
if self.component is not None:
oprot.writeFieldBegin('component', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.component))
- for iter361 in self.component:
- iter361.write(oprot)
+ for iter368 in self.component:
+ iter368.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.txnid is not None:
@@ -6925,11 +7010,11 @@ class ShowLocksResponse:
if fid == 1:
if ftype == TType.LIST:
self.locks = []
- (_etype365, _size362) = iprot.readListBegin()
- for _i366 in xrange(_size362):
- _elem367 = ShowLocksResponseElement()
- _elem367.read(iprot)
- self.locks.append(_elem367)
+ (_etype372, _size369) = iprot.readListBegin()
+ for _i373 in xrange(_size369):
+ _elem374 = ShowLocksResponseElement()
+ _elem374.read(iprot)
+ self.locks.append(_elem374)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6946,8 +7031,8 @@ class ShowLocksResponse:
if self.locks is not None:
oprot.writeFieldBegin('locks', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.locks))
- for iter368 in self.locks:
- iter368.write(oprot)
+ for iter375 in self.locks:
+ iter375.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7145,20 +7230,20 @@ class HeartbeatTxnRangeResponse:
if fid == 1:
if ftype == TType.SET:
self.aborted = set()
- (_etype372, _size369) = iprot.readSetBegin()
- for _i373 in xrange(_size369):
- _elem374 = iprot.readI64();
- self.aborted.add(_elem374)
+ (_etype379, _size376) = iprot.readSetBegin()
+ for _i380 in xrange(_size376):
+ _elem381 = iprot.readI64();
+ self.aborted.add(_elem381)
iprot.readSetEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.SET:
self.nosuch = set()
- (_etype378, _size375) = iprot.readSetBegin()
- for _i379 in xrange(_size375):
- _elem380 = iprot.readI64();
- self.nosuch.add(_elem380)
+ (_etype385, _size382) = iprot.readSetBegin()
+ for _i386 in xrange(_size382):
+ _elem387 = iprot.readI64();
+ self.nosuch.add(_elem387)
iprot.readSetEnd()
else:
iprot.skip(ftype)
@@ -7175,15 +7260,15 @@ class HeartbeatTxnRangeResponse:
if self.aborted is not None:
oprot.writeFieldBegin('aborted', TType.SET, 1)
oprot.writeSetBegin(TType.I64, len(self.aborted))
- for iter381 in self.aborted:
- oprot.writeI64(iter381)
+ for iter388 in self.aborted:
+ oprot.writeI64(iter388)
oprot.writeSetEnd()
oprot.writeFieldEnd()
if self.nosuch is not None:
oprot.writeFieldBegin('nosuch', TType.SET, 2)
oprot.writeSetBegin(TType.I64, len(self.nosuch))
- for iter382 in self.nosuch:
- oprot.writeI64(iter382)
+ for iter389 in self.nosuch:
+ oprot.writeI64(iter389)
oprot.writeSetEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7550,11 +7635,11 @@ class ShowCompactResponse:
if fid == 1:
if ftype == TType.LIST:
self.compacts = []
- (_etype386, _size383) = iprot.readListBegin()
- for _i387 in xrange(_size383):
- _elem388 = ShowCompactResponseElement()
- _elem388.read(iprot)
- self.compacts.append(_elem388)
+ (_etype393, _size390) = iprot.readListBegin()
+ for _i394 in xrange(_size390):
+ _elem395 = ShowCompactResponseElement()
+ _elem395.read(iprot)
+ self.compacts.append(_elem395)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7571,8 +7656,8 @@ class ShowCompactResponse:
if self.compacts is not None:
oprot.writeFieldBegin('compacts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.compacts))
- for iter389 in self.compacts:
- iter389.write(oprot)
+ for iter396 in self.compacts:
+ iter396.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()