You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by th...@apache.org on 2014/03/29 00:33:55 UTC
svn commit: r1582912 [11/13] - in /hive/branches/branch-0.13: 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/thri...
Modified: hive/branches/branch-0.13/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/branches/branch-0.13/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1582912&r1=1582911&r2=1582912&view=diff
==============================================================================
--- hive/branches/branch-0.13/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/branches/branch-0.13/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Mar 28 23:33:53 2014
@@ -745,6 +745,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def get_role_grants_for_principal(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def get_privilege_set(self, hiveObject, user_name, group_names):
"""
Parameters:
@@ -4057,6 +4064,38 @@ class Client(fb303.FacebookService.Clien
raise result.o1
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_principals_in_role failed: unknown result");
+ def get_role_grants_for_principal(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_role_grants_for_principal(request)
+ return self.recv_get_role_grants_for_principal()
+
+ def send_get_role_grants_for_principal(self, request):
+ self._oprot.writeMessageBegin('get_role_grants_for_principal', TMessageType.CALL, self._seqid)
+ args = get_role_grants_for_principal_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_role_grants_for_principal(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = get_role_grants_for_principal_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
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_grants_for_principal failed: unknown result");
+
def get_privilege_set(self, hiveObject, user_name, group_names):
"""
Parameters:
@@ -4778,6 +4817,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["revoke_role"] = Processor.process_revoke_role
self._processMap["list_roles"] = Processor.process_list_roles
self._processMap["get_principals_in_role"] = Processor.process_get_principals_in_role
+ self._processMap["get_role_grants_for_principal"] = Processor.process_get_role_grants_for_principal
self._processMap["get_privilege_set"] = Processor.process_get_privilege_set
self._processMap["list_privileges"] = Processor.process_list_privileges
self._processMap["grant_privileges"] = Processor.process_grant_privileges
@@ -6224,6 +6264,20 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_role_grants_for_principal(self, seqid, iprot, oprot):
+ args = get_role_grants_for_principal_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_role_grants_for_principal_result()
+ try:
+ result.success = self._handler.get_role_grants_for_principal(args.request)
+ except MetaException as o1:
+ result.o1 = o1
+ oprot.writeMessageBegin("get_role_grants_for_principal", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_privilege_set(self, seqid, iprot, oprot):
args = get_privilege_set_args()
args.read(iprot)
@@ -7056,10 +7110,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype372, _size369) = iprot.readListBegin()
- for _i373 in xrange(_size369):
- _elem374 = iprot.readString();
- self.success.append(_elem374)
+ (_etype379, _size376) = iprot.readListBegin()
+ for _i380 in xrange(_size376):
+ _elem381 = iprot.readString();
+ self.success.append(_elem381)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7082,8 +7136,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 iter375 in self.success:
- oprot.writeString(iter375)
+ for iter382 in self.success:
+ oprot.writeString(iter382)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7178,10 +7232,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype379, _size376) = iprot.readListBegin()
- for _i380 in xrange(_size376):
- _elem381 = iprot.readString();
- self.success.append(_elem381)
+ (_etype386, _size383) = iprot.readListBegin()
+ for _i387 in xrange(_size383):
+ _elem388 = iprot.readString();
+ self.success.append(_elem388)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7204,8 +7258,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 iter382 in self.success:
- oprot.writeString(iter382)
+ for iter389 in self.success:
+ oprot.writeString(iter389)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7915,12 +7969,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype384, _vtype385, _size383 ) = iprot.readMapBegin()
- for _i387 in xrange(_size383):
- _key388 = iprot.readString();
- _val389 = Type()
- _val389.read(iprot)
- self.success[_key388] = _val389
+ (_ktype391, _vtype392, _size390 ) = iprot.readMapBegin()
+ for _i394 in xrange(_size390):
+ _key395 = iprot.readString();
+ _val396 = Type()
+ _val396.read(iprot)
+ self.success[_key395] = _val396
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -7943,9 +7997,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 kiter390,viter391 in self.success.items():
- oprot.writeString(kiter390)
- viter391.write(oprot)
+ for kiter397,viter398 in self.success.items():
+ oprot.writeString(kiter397)
+ viter398.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -8076,11 +8130,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype395, _size392) = iprot.readListBegin()
- for _i396 in xrange(_size392):
- _elem397 = FieldSchema()
- _elem397.read(iprot)
- self.success.append(_elem397)
+ (_etype402, _size399) = iprot.readListBegin()
+ for _i403 in xrange(_size399):
+ _elem404 = FieldSchema()
+ _elem404.read(iprot)
+ self.success.append(_elem404)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8115,8 +8169,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 iter398 in self.success:
- iter398.write(oprot)
+ for iter405 in self.success:
+ iter405.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8255,11 +8309,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype402, _size399) = iprot.readListBegin()
- for _i403 in xrange(_size399):
- _elem404 = FieldSchema()
- _elem404.read(iprot)
- self.success.append(_elem404)
+ (_etype409, _size406) = iprot.readListBegin()
+ for _i410 in xrange(_size406):
+ _elem411 = FieldSchema()
+ _elem411.read(iprot)
+ self.success.append(_elem411)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8294,8 +8348,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 iter405 in self.success:
- iter405.write(oprot)
+ for iter412 in self.success:
+ iter412.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9092,10 +9146,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype409, _size406) = iprot.readListBegin()
- for _i410 in xrange(_size406):
- _elem411 = iprot.readString();
- self.success.append(_elem411)
+ (_etype416, _size413) = iprot.readListBegin()
+ for _i417 in xrange(_size413):
+ _elem418 = iprot.readString();
+ self.success.append(_elem418)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9118,8 +9172,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 iter412 in self.success:
- oprot.writeString(iter412)
+ for iter419 in self.success:
+ oprot.writeString(iter419)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9232,10 +9286,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype416, _size413) = iprot.readListBegin()
- for _i417 in xrange(_size413):
- _elem418 = iprot.readString();
- self.success.append(_elem418)
+ (_etype423, _size420) = iprot.readListBegin()
+ for _i424 in xrange(_size420):
+ _elem425 = iprot.readString();
+ self.success.append(_elem425)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9258,8 +9312,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 iter419 in self.success:
- oprot.writeString(iter419)
+ for iter426 in self.success:
+ oprot.writeString(iter426)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9476,10 +9530,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype423, _size420) = iprot.readListBegin()
- for _i424 in xrange(_size420):
- _elem425 = iprot.readString();
- self.tbl_names.append(_elem425)
+ (_etype430, _size427) = iprot.readListBegin()
+ for _i431 in xrange(_size427):
+ _elem432 = iprot.readString();
+ self.tbl_names.append(_elem432)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9500,8 +9554,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 iter426 in self.tbl_names:
- oprot.writeString(iter426)
+ for iter433 in self.tbl_names:
+ oprot.writeString(iter433)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9556,11 +9610,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype430, _size427) = iprot.readListBegin()
- for _i431 in xrange(_size427):
- _elem432 = Table()
- _elem432.read(iprot)
- self.success.append(_elem432)
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = Table()
+ _elem439.read(iprot)
+ self.success.append(_elem439)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9595,8 +9649,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 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:
@@ -9747,10 +9801,10 @@ class get_table_names_by_filter_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)
@@ -9785,8 +9839,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 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:
@@ -10509,11 +10563,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = Partition()
- _elem446.read(iprot)
- self.new_parts.append(_elem446)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = Partition()
+ _elem453.read(iprot)
+ self.new_parts.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10530,8 +10584,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 iter447 in self.new_parts:
- iter447.write(oprot)
+ for iter454 in self.new_parts:
+ iter454.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10692,10 +10746,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = iprot.readString();
- self.part_vals.append(_elem453)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = iprot.readString();
+ self.part_vals.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10720,8 +10774,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 iter454 in self.part_vals:
- oprot.writeString(iter454)
+ for iter461 in self.part_vals:
+ oprot.writeString(iter461)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11046,10 +11100,10 @@ class append_partition_with_environment_
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString();
- self.part_vals.append(_elem460)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = iprot.readString();
+ self.part_vals.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11080,8 +11134,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 iter461 in self.part_vals:
- oprot.writeString(iter461)
+ for iter468 in self.part_vals:
+ oprot.writeString(iter468)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -11629,10 +11683,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString();
- self.part_vals.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = iprot.readString();
+ self.part_vals.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11662,8 +11716,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 iter468 in self.part_vals:
- oprot.writeString(iter468)
+ for iter475 in self.part_vals:
+ oprot.writeString(iter475)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -11821,10 +11875,10 @@ class drop_partition_with_environment_co
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)
@@ -11860,8 +11914,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 iter475 in self.part_vals:
- oprot.writeString(iter475)
+ for iter482 in self.part_vals:
+ oprot.writeString(iter482)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -12539,10 +12593,10 @@ class get_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)
@@ -12567,8 +12621,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 iter482 in self.part_vals:
- oprot.writeString(iter482)
+ for iter489 in self.part_vals:
+ oprot.writeString(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12713,11 +12767,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype484, _vtype485, _size483 ) = iprot.readMapBegin()
- for _i487 in xrange(_size483):
- _key488 = iprot.readString();
- _val489 = iprot.readString();
- self.partitionSpecs[_key488] = _val489
+ (_ktype491, _vtype492, _size490 ) = iprot.readMapBegin()
+ for _i494 in xrange(_size490):
+ _key495 = iprot.readString();
+ _val496 = iprot.readString();
+ self.partitionSpecs[_key495] = _val496
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12754,9 +12808,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 kiter490,viter491 in self.partitionSpecs.items():
- oprot.writeString(kiter490)
- oprot.writeString(viter491)
+ for kiter497,viter498 in self.partitionSpecs.items():
+ oprot.writeString(kiter497)
+ oprot.writeString(viter498)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -12953,10 +13007,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype495, _size492) = iprot.readListBegin()
- for _i496 in xrange(_size492):
- _elem497 = iprot.readString();
- self.part_vals.append(_elem497)
+ (_etype502, _size499) = iprot.readListBegin()
+ for _i503 in xrange(_size499):
+ _elem504 = iprot.readString();
+ self.part_vals.append(_elem504)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12968,10 +13022,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype501, _size498) = iprot.readListBegin()
- for _i502 in xrange(_size498):
- _elem503 = iprot.readString();
- self.group_names.append(_elem503)
+ (_etype508, _size505) = iprot.readListBegin()
+ for _i509 in xrange(_size505):
+ _elem510 = iprot.readString();
+ self.group_names.append(_elem510)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12996,8 +13050,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 iter504 in self.part_vals:
- oprot.writeString(iter504)
+ for iter511 in self.part_vals:
+ oprot.writeString(iter511)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -13007,8 +13061,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 iter505 in self.group_names:
- oprot.writeString(iter505)
+ for iter512 in self.group_names:
+ oprot.writeString(iter512)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13400,11 +13454,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype509, _size506) = iprot.readListBegin()
- for _i510 in xrange(_size506):
- _elem511 = Partition()
- _elem511.read(iprot)
- self.success.append(_elem511)
+ (_etype516, _size513) = iprot.readListBegin()
+ for _i517 in xrange(_size513):
+ _elem518 = Partition()
+ _elem518.read(iprot)
+ self.success.append(_elem518)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13433,8 +13487,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 iter512 in self.success:
- iter512.write(oprot)
+ for iter519 in self.success:
+ iter519.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13521,10 +13575,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = iprot.readString();
- self.group_names.append(_elem518)
+ (_etype523, _size520) = iprot.readListBegin()
+ for _i524 in xrange(_size520):
+ _elem525 = iprot.readString();
+ self.group_names.append(_elem525)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13557,8 +13611,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 iter519 in self.group_names:
- oprot.writeString(iter519)
+ for iter526 in self.group_names:
+ oprot.writeString(iter526)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13610,11 +13664,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = Partition()
- _elem525.read(iprot)
- self.success.append(_elem525)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = Partition()
+ _elem532.read(iprot)
+ self.success.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13643,8 +13697,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 iter526 in self.success:
- iter526.write(oprot)
+ for iter533 in self.success:
+ iter533.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13785,10 +13839,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = iprot.readString();
- self.success.append(_elem532)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = iprot.readString();
+ self.success.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13811,8 +13865,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 iter533 in self.success:
- oprot.writeString(iter533)
+ for iter540 in self.success:
+ oprot.writeString(iter540)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -13882,10 +13936,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString();
- self.part_vals.append(_elem539)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = iprot.readString();
+ self.part_vals.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13915,8 +13969,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 iter540 in self.part_vals:
- oprot.writeString(iter540)
+ for iter547 in self.part_vals:
+ oprot.writeString(iter547)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -13972,11 +14026,11 @@ class get_partitions_ps_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)
@@ -14005,8 +14059,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 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:
@@ -14086,10 +14140,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = iprot.readString();
- self.part_vals.append(_elem553)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = iprot.readString();
+ self.part_vals.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14106,10 +14160,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype557, _size554) = iprot.readListBegin()
- for _i558 in xrange(_size554):
- _elem559 = iprot.readString();
- self.group_names.append(_elem559)
+ (_etype564, _size561) = iprot.readListBegin()
+ for _i565 in xrange(_size561):
+ _elem566 = iprot.readString();
+ self.group_names.append(_elem566)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14134,8 +14188,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 iter560 in self.part_vals:
- oprot.writeString(iter560)
+ for iter567 in self.part_vals:
+ oprot.writeString(iter567)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14149,8 +14203,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 iter561 in self.group_names:
- oprot.writeString(iter561)
+ for iter568 in self.group_names:
+ oprot.writeString(iter568)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14202,11 +14256,11 @@ class get_partitions_ps_with_auth_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)
@@ -14235,8 +14289,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 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:
@@ -14310,10 +14364,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = iprot.readString();
- self.part_vals.append(_elem574)
+ (_etype579, _size576) = iprot.readListBegin()
+ for _i580 in xrange(_size576):
+ _elem581 = iprot.readString();
+ self.part_vals.append(_elem581)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14343,8 +14397,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 iter575 in self.part_vals:
- oprot.writeString(iter575)
+ for iter582 in self.part_vals:
+ oprot.writeString(iter582)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -14400,10 +14454,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype579, _size576) = iprot.readListBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString();
- self.success.append(_elem581)
+ (_etype586, _size583) = iprot.readListBegin()
+ for _i587 in xrange(_size583):
+ _elem588 = iprot.readString();
+ self.success.append(_elem588)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14432,8 +14486,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 iter582 in self.success:
- oprot.writeString(iter582)
+ for iter589 in self.success:
+ oprot.writeString(iter589)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14589,11 +14643,11 @@ class get_partitions_by_filter_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)
@@ -14622,8 +14676,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 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:
@@ -14841,10 +14895,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = iprot.readString();
- self.names.append(_elem595)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = iprot.readString();
+ self.names.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14869,8 +14923,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 iter596 in self.names:
- oprot.writeString(iter596)
+ for iter603 in self.names:
+ oprot.writeString(iter603)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14922,11 +14976,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype600, _size597) = iprot.readListBegin()
- for _i601 in xrange(_size597):
- _elem602 = Partition()
- _elem602.read(iprot)
- self.success.append(_elem602)
+ (_etype607, _size604) = iprot.readListBegin()
+ for _i608 in xrange(_size604):
+ _elem609 = Partition()
+ _elem609.read(iprot)
+ self.success.append(_elem609)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14955,8 +15009,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 iter603 in self.success:
- iter603.write(oprot)
+ for iter610 in self.success:
+ iter610.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15186,11 +15240,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = Partition()
- _elem609.read(iprot)
- self.new_parts.append(_elem609)
+ (_etype614, _size611) = iprot.readListBegin()
+ for _i615 in xrange(_size611):
+ _elem616 = Partition()
+ _elem616.read(iprot)
+ self.new_parts.append(_elem616)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15215,8 +15269,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 iter610 in self.new_parts:
- iter610.write(oprot)
+ for iter617 in self.new_parts:
+ iter617.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15528,10 +15582,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype614, _size611) = iprot.readListBegin()
- for _i615 in xrange(_size611):
- _elem616 = iprot.readString();
- self.part_vals.append(_elem616)
+ (_etype621, _size618) = iprot.readListBegin()
+ for _i622 in xrange(_size618):
+ _elem623 = iprot.readString();
+ self.part_vals.append(_elem623)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15562,8 +15616,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 iter617 in self.part_vals:
- oprot.writeString(iter617)
+ for iter624 in self.part_vals:
+ oprot.writeString(iter624)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -15691,10 +15745,10 @@ class partition_name_has_valid_character
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype621, _size618) = iprot.readListBegin()
- for _i622 in xrange(_size618):
- _elem623 = iprot.readString();
- self.part_vals.append(_elem623)
+ (_etype628, _size625) = iprot.readListBegin()
+ for _i629 in xrange(_size625):
+ _elem630 = iprot.readString();
+ self.part_vals.append(_elem630)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15716,8 +15770,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 iter624 in self.part_vals:
- oprot.writeString(iter624)
+ for iter631 in self.part_vals:
+ oprot.writeString(iter631)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -16046,10 +16100,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype628, _size625) = iprot.readListBegin()
- for _i629 in xrange(_size625):
- _elem630 = iprot.readString();
- self.success.append(_elem630)
+ (_etype635, _size632) = iprot.readListBegin()
+ for _i636 in xrange(_size632):
+ _elem637 = iprot.readString();
+ self.success.append(_elem637)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16072,8 +16126,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 iter631 in self.success:
- oprot.writeString(iter631)
+ for iter638 in self.success:
+ oprot.writeString(iter638)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16186,11 +16240,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype633, _vtype634, _size632 ) = iprot.readMapBegin()
- for _i636 in xrange(_size632):
- _key637 = iprot.readString();
- _val638 = iprot.readString();
- self.success[_key637] = _val638
+ (_ktype640, _vtype641, _size639 ) = iprot.readMapBegin()
+ for _i643 in xrange(_size639):
+ _key644 = iprot.readString();
+ _val645 = iprot.readString();
+ self.success[_key644] = _val645
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16213,9 +16267,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 kiter639,viter640 in self.success.items():
- oprot.writeString(kiter639)
- oprot.writeString(viter640)
+ for kiter646,viter647 in self.success.items():
+ oprot.writeString(kiter646)
+ oprot.writeString(viter647)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16285,11 +16339,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype642, _vtype643, _size641 ) = iprot.readMapBegin()
- for _i645 in xrange(_size641):
- _key646 = iprot.readString();
- _val647 = iprot.readString();
- self.part_vals[_key646] = _val647
+ (_ktype649, _vtype650, _size648 ) = iprot.readMapBegin()
+ for _i652 in xrange(_size648):
+ _key653 = iprot.readString();
+ _val654 = iprot.readString();
+ self.part_vals[_key653] = _val654
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16319,9 +16373,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 kiter648,viter649 in self.part_vals.items():
- oprot.writeString(kiter648)
- oprot.writeString(viter649)
+ for kiter655,viter656 in self.part_vals.items():
+ oprot.writeString(kiter655)
+ oprot.writeString(viter656)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -16517,11 +16571,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype651, _vtype652, _size650 ) = iprot.readMapBegin()
- for _i654 in xrange(_size650):
- _key655 = iprot.readString();
- _val656 = iprot.readString();
- self.part_vals[_key655] = _val656
+ (_ktype658, _vtype659, _size657 ) = iprot.readMapBegin()
+ for _i661 in xrange(_size657):
+ _key662 = iprot.readString();
+ _val663 = iprot.readString();
+ self.part_vals[_key662] = _val663
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16551,9 +16605,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 kiter657,viter658 in self.part_vals.items():
- oprot.writeString(kiter657)
- oprot.writeString(viter658)
+ for kiter664,viter665 in self.part_vals.items():
+ oprot.writeString(kiter664)
+ oprot.writeString(viter665)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -17525,11 +17579,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype662, _size659) = iprot.readListBegin()
- for _i663 in xrange(_size659):
- _elem664 = Index()
- _elem664.read(iprot)
- self.success.append(_elem664)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = Index()
+ _elem671.read(iprot)
+ self.success.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17558,8 +17612,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 iter665 in self.success:
- iter665.write(oprot)
+ for iter672 in self.success:
+ iter672.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17700,10 +17754,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype669, _size666) = iprot.readListBegin()
- for _i670 in xrange(_size666):
- _elem671 = iprot.readString();
- self.success.append(_elem671)
+ (_etype676, _size673) = iprot.readListBegin()
+ for _i677 in xrange(_size673):
+ _elem678 = iprot.readString();
+ self.success.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17726,8 +17780,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 iter672 in self.success:
- oprot.writeString(iter672)
+ for iter679 in self.success:
+ oprot.writeString(iter679)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -19762,10 +19816,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = iprot.readString();
- self.success.append(_elem678)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = iprot.readString();
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19788,8 +19842,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 iter679 in self.success:
- oprot.writeString(iter679)
+ for iter686 in self.success:
+ oprot.writeString(iter686)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20307,10 +20361,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = iprot.readString();
- self.success.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString();
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20333,8 +20387,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 iter686 in self.success:
- oprot.writeString(iter686)
+ for iter693 in self.success:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20807,11 +20861,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = Role()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = Role()
+ _elem699.read(iprot)
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20834,8 +20888,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 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:
@@ -20994,6 +21048,140 @@ class get_principals_in_role_result:
def __ne__(self, other):
return not (self == other)
+class get_role_grants_for_principal_args:
+ """
+ Attributes:
+ - request
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'request', (GetRoleGrantsForPrincipalRequest, GetRoleGrantsForPrincipalRequest.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 = GetRoleGrantsForPrincipalRequest()
+ 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_role_grants_for_principal_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_role_grants_for_principal_result:
+ """
+ Attributes:
+ - success
+ - o1
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (GetRoleGrantsForPrincipalResponse, GetRoleGrantsForPrincipalResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, o1=None,):
+ self.success = success
+ self.o1 = o1
+
+ 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 = GetRoleGrantsForPrincipalResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.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_role_grants_for_principal_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()
+ 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_privilege_set_args:
"""
Attributes:
@@ -21037,10 +21225,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = iprot.readString();
- self.group_names.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = iprot.readString();
+ self.group_names.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21065,8 +21253,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 iter700 in self.group_names:
- oprot.writeString(iter700)
+ for iter707 in self.group_names:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21273,11 +21461,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = HiveObjectPrivilege()
- _elem706.read(iprot)
- self.success.append(_elem706)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = HiveObjectPrivilege()
+ _elem713.read(iprot)
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21300,8 +21488,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 iter707 in self.success:
- iter707.write(oprot)
+ for iter714 in self.success:
+ iter714.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21626,10 +21814,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = iprot.readString();
- self.group_names.append(_elem713)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString();
+ self.group_names.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21650,8 +21838,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 iter714 in self.group_names:
- oprot.writeString(iter714)
+ for iter721 in self.group_names:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21700,10 +21888,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = iprot.readString();
- self.success.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = iprot.readString();
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21726,8 +21914,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 iter721 in self.success:
- oprot.writeString(iter721)
+ for iter728 in self.success:
+ oprot.writeString(iter728)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: