You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/19 21:44:58 UTC
[20/54] [abbrv] hive git commit: HIVE-19532 : fix tests for
master-txnstats branch - more tests (Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/f0a2fffa/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 913bbf0..d098dba 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -768,6 +768,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def rename_partition_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
def partition_name_has_valid_characters(self, part_vals, throw_exception):
"""
Parameters:
@@ -4996,6 +5003,41 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
return
+ def rename_partition_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_rename_partition_req(req)
+ return self.recv_rename_partition_req()
+
+ def send_rename_partition_req(self, req):
+ self._oprot.writeMessageBegin('rename_partition_req', TMessageType.CALL, self._seqid)
+ args = rename_partition_req_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_rename_partition_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = rename_partition_req_result()
+ result.read(iprot)
+ 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, "rename_partition_req failed: unknown result")
+
def partition_name_has_valid_characters(self, part_vals, throw_exception):
"""
Parameters:
@@ -9348,6 +9390,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["alter_partitions_req"] = Processor.process_alter_partitions_req
self._processMap["alter_partition_with_environment_context"] = Processor.process_alter_partition_with_environment_context
self._processMap["rename_partition"] = Processor.process_rename_partition
+ self._processMap["rename_partition_req"] = Processor.process_rename_partition_req
self._processMap["partition_name_has_valid_characters"] = Processor.process_partition_name_has_valid_characters
self._processMap["get_config_value"] = Processor.process_get_config_value
self._processMap["partition_name_to_vals"] = Processor.process_partition_name_to_vals
@@ -11767,6 +11810,31 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_rename_partition_req(self, seqid, iprot, oprot):
+ args = rename_partition_req_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = rename_partition_req_result()
+ try:
+ result.success = self._handler.rename_partition_req(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except InvalidOperationException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except MetaException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("rename_partition_req", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_partition_name_has_valid_characters(self, seqid, iprot, oprot):
args = partition_name_has_valid_characters_args()
args.read(iprot)
@@ -16400,10 +16468,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype847, _size844) = iprot.readListBegin()
- for _i848 in xrange(_size844):
- _elem849 = iprot.readString()
- self.success.append(_elem849)
+ (_etype854, _size851) = iprot.readListBegin()
+ for _i855 in xrange(_size851):
+ _elem856 = iprot.readString()
+ self.success.append(_elem856)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16426,8 +16494,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 iter850 in self.success:
- oprot.writeString(iter850)
+ for iter857 in self.success:
+ oprot.writeString(iter857)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16532,10 +16600,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype854, _size851) = iprot.readListBegin()
- for _i855 in xrange(_size851):
- _elem856 = iprot.readString()
- self.success.append(_elem856)
+ (_etype861, _size858) = iprot.readListBegin()
+ for _i862 in xrange(_size858):
+ _elem863 = iprot.readString()
+ self.success.append(_elem863)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16558,8 +16626,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 iter857 in self.success:
- oprot.writeString(iter857)
+ for iter864 in self.success:
+ oprot.writeString(iter864)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17329,12 +17397,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype859, _vtype860, _size858 ) = iprot.readMapBegin()
- for _i862 in xrange(_size858):
- _key863 = iprot.readString()
- _val864 = Type()
- _val864.read(iprot)
- self.success[_key863] = _val864
+ (_ktype866, _vtype867, _size865 ) = iprot.readMapBegin()
+ for _i869 in xrange(_size865):
+ _key870 = iprot.readString()
+ _val871 = Type()
+ _val871.read(iprot)
+ self.success[_key870] = _val871
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -17357,9 +17425,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 kiter865,viter866 in self.success.items():
- oprot.writeString(kiter865)
- viter866.write(oprot)
+ for kiter872,viter873 in self.success.items():
+ oprot.writeString(kiter872)
+ viter873.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -17502,11 +17570,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype870, _size867) = iprot.readListBegin()
- for _i871 in xrange(_size867):
- _elem872 = FieldSchema()
- _elem872.read(iprot)
- self.success.append(_elem872)
+ (_etype877, _size874) = iprot.readListBegin()
+ for _i878 in xrange(_size874):
+ _elem879 = FieldSchema()
+ _elem879.read(iprot)
+ self.success.append(_elem879)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17541,8 +17609,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 iter873 in self.success:
- iter873.write(oprot)
+ for iter880 in self.success:
+ iter880.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17709,11 +17777,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype877, _size874) = iprot.readListBegin()
- for _i878 in xrange(_size874):
- _elem879 = FieldSchema()
- _elem879.read(iprot)
- self.success.append(_elem879)
+ (_etype884, _size881) = iprot.readListBegin()
+ for _i885 in xrange(_size881):
+ _elem886 = FieldSchema()
+ _elem886.read(iprot)
+ self.success.append(_elem886)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17748,8 +17816,8 @@ class get_fields_with_environment_context_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter880 in self.success:
- iter880.write(oprot)
+ for iter887 in self.success:
+ iter887.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17902,11 +17970,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype884, _size881) = iprot.readListBegin()
- for _i885 in xrange(_size881):
- _elem886 = FieldSchema()
- _elem886.read(iprot)
- self.success.append(_elem886)
+ (_etype891, _size888) = iprot.readListBegin()
+ for _i892 in xrange(_size888):
+ _elem893 = FieldSchema()
+ _elem893.read(iprot)
+ self.success.append(_elem893)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17941,8 +18009,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 iter887 in self.success:
- iter887.write(oprot)
+ for iter894 in self.success:
+ iter894.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18109,11 +18177,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype891, _size888) = iprot.readListBegin()
- for _i892 in xrange(_size888):
- _elem893 = FieldSchema()
- _elem893.read(iprot)
- self.success.append(_elem893)
+ (_etype898, _size895) = iprot.readListBegin()
+ for _i899 in xrange(_size895):
+ _elem900 = FieldSchema()
+ _elem900.read(iprot)
+ self.success.append(_elem900)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18148,8 +18216,8 @@ class get_schema_with_environment_context_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter894 in self.success:
- iter894.write(oprot)
+ for iter901 in self.success:
+ iter901.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18602,66 +18670,66 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype898, _size895) = iprot.readListBegin()
- for _i899 in xrange(_size895):
- _elem900 = SQLPrimaryKey()
- _elem900.read(iprot)
- self.primaryKeys.append(_elem900)
+ (_etype905, _size902) = iprot.readListBegin()
+ for _i906 in xrange(_size902):
+ _elem907 = SQLPrimaryKey()
+ _elem907.read(iprot)
+ self.primaryKeys.append(_elem907)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = SQLForeignKey()
- _elem906.read(iprot)
- self.foreignKeys.append(_elem906)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = SQLForeignKey()
+ _elem913.read(iprot)
+ self.foreignKeys.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype910, _size907) = iprot.readListBegin()
- for _i911 in xrange(_size907):
- _elem912 = SQLUniqueConstraint()
- _elem912.read(iprot)
- self.uniqueConstraints.append(_elem912)
+ (_etype917, _size914) = iprot.readListBegin()
+ for _i918 in xrange(_size914):
+ _elem919 = SQLUniqueConstraint()
+ _elem919.read(iprot)
+ self.uniqueConstraints.append(_elem919)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype916, _size913) = iprot.readListBegin()
- for _i917 in xrange(_size913):
- _elem918 = SQLNotNullConstraint()
- _elem918.read(iprot)
- self.notNullConstraints.append(_elem918)
+ (_etype923, _size920) = iprot.readListBegin()
+ for _i924 in xrange(_size920):
+ _elem925 = SQLNotNullConstraint()
+ _elem925.read(iprot)
+ self.notNullConstraints.append(_elem925)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype922, _size919) = iprot.readListBegin()
- for _i923 in xrange(_size919):
- _elem924 = SQLDefaultConstraint()
- _elem924.read(iprot)
- self.defaultConstraints.append(_elem924)
+ (_etype929, _size926) = iprot.readListBegin()
+ for _i930 in xrange(_size926):
+ _elem931 = SQLDefaultConstraint()
+ _elem931.read(iprot)
+ self.defaultConstraints.append(_elem931)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.LIST:
self.checkConstraints = []
- (_etype928, _size925) = iprot.readListBegin()
- for _i929 in xrange(_size925):
- _elem930 = SQLCheckConstraint()
- _elem930.read(iprot)
- self.checkConstraints.append(_elem930)
+ (_etype935, _size932) = iprot.readListBegin()
+ for _i936 in xrange(_size932):
+ _elem937 = SQLCheckConstraint()
+ _elem937.read(iprot)
+ self.checkConstraints.append(_elem937)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18682,43 +18750,43 @@ class create_table_with_constraints_args:
if self.primaryKeys is not None:
oprot.writeFieldBegin('primaryKeys', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys))
- for iter931 in self.primaryKeys:
- iter931.write(oprot)
+ for iter938 in self.primaryKeys:
+ iter938.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.foreignKeys is not None:
oprot.writeFieldBegin('foreignKeys', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys))
- for iter932 in self.foreignKeys:
- iter932.write(oprot)
+ for iter939 in self.foreignKeys:
+ iter939.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.uniqueConstraints is not None:
oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 4)
oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints))
- for iter933 in self.uniqueConstraints:
- iter933.write(oprot)
+ for iter940 in self.uniqueConstraints:
+ iter940.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.notNullConstraints is not None:
oprot.writeFieldBegin('notNullConstraints', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints))
- for iter934 in self.notNullConstraints:
- iter934.write(oprot)
+ for iter941 in self.notNullConstraints:
+ iter941.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.defaultConstraints is not None:
oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6)
oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints))
- for iter935 in self.defaultConstraints:
- iter935.write(oprot)
+ for iter942 in self.defaultConstraints:
+ iter942.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.checkConstraints is not None:
oprot.writeFieldBegin('checkConstraints', TType.LIST, 7)
oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints))
- for iter936 in self.checkConstraints:
- iter936.write(oprot)
+ for iter943 in self.checkConstraints:
+ iter943.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20278,10 +20346,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = iprot.readString()
- self.partNames.append(_elem942)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = iprot.readString()
+ self.partNames.append(_elem949)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20306,8 +20374,8 @@ class truncate_table_args:
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter943 in self.partNames:
- oprot.writeString(iter943)
+ for iter950 in self.partNames:
+ oprot.writeString(iter950)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20652,10 +20720,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype947, _size944) = iprot.readListBegin()
- for _i948 in xrange(_size944):
- _elem949 = iprot.readString()
- self.success.append(_elem949)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = iprot.readString()
+ self.success.append(_elem956)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20678,8 +20746,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 iter950 in self.success:
- oprot.writeString(iter950)
+ for iter957 in self.success:
+ oprot.writeString(iter957)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20829,10 +20897,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype954, _size951) = iprot.readListBegin()
- for _i955 in xrange(_size951):
- _elem956 = iprot.readString()
- self.success.append(_elem956)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = iprot.readString()
+ self.success.append(_elem963)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20855,8 +20923,8 @@ class get_tables_by_type_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter957 in self.success:
- oprot.writeString(iter957)
+ for iter964 in self.success:
+ oprot.writeString(iter964)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20980,10 +21048,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype961, _size958) = iprot.readListBegin()
- for _i962 in xrange(_size958):
- _elem963 = iprot.readString()
- self.success.append(_elem963)
+ (_etype968, _size965) = iprot.readListBegin()
+ for _i969 in xrange(_size965):
+ _elem970 = iprot.readString()
+ self.success.append(_elem970)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21006,8 +21074,8 @@ class get_materialized_views_for_rewriting_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter964 in self.success:
- oprot.writeString(iter964)
+ for iter971 in self.success:
+ oprot.writeString(iter971)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21080,10 +21148,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = iprot.readString()
- self.tbl_types.append(_elem970)
+ (_etype975, _size972) = iprot.readListBegin()
+ for _i976 in xrange(_size972):
+ _elem977 = iprot.readString()
+ self.tbl_types.append(_elem977)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21108,8 +21176,8 @@ class get_table_meta_args:
if self.tbl_types is not None:
oprot.writeFieldBegin('tbl_types', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.tbl_types))
- for iter971 in self.tbl_types:
- oprot.writeString(iter971)
+ for iter978 in self.tbl_types:
+ oprot.writeString(iter978)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21165,11 +21233,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype975, _size972) = iprot.readListBegin()
- for _i976 in xrange(_size972):
- _elem977 = TableMeta()
- _elem977.read(iprot)
- self.success.append(_elem977)
+ (_etype982, _size979) = iprot.readListBegin()
+ for _i983 in xrange(_size979):
+ _elem984 = TableMeta()
+ _elem984.read(iprot)
+ self.success.append(_elem984)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21192,8 +21260,8 @@ class get_table_meta_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter978 in self.success:
- iter978.write(oprot)
+ for iter985 in self.success:
+ iter985.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21317,10 +21385,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype982, _size979) = iprot.readListBegin()
- for _i983 in xrange(_size979):
- _elem984 = iprot.readString()
- self.success.append(_elem984)
+ (_etype989, _size986) = iprot.readListBegin()
+ for _i990 in xrange(_size986):
+ _elem991 = iprot.readString()
+ self.success.append(_elem991)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21343,8 +21411,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 iter985 in self.success:
- oprot.writeString(iter985)
+ for iter992 in self.success:
+ oprot.writeString(iter992)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21580,10 +21648,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype989, _size986) = iprot.readListBegin()
- for _i990 in xrange(_size986):
- _elem991 = iprot.readString()
- self.tbl_names.append(_elem991)
+ (_etype996, _size993) = iprot.readListBegin()
+ for _i997 in xrange(_size993):
+ _elem998 = iprot.readString()
+ self.tbl_names.append(_elem998)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21604,8 +21672,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 iter992 in self.tbl_names:
- oprot.writeString(iter992)
+ for iter999 in self.tbl_names:
+ oprot.writeString(iter999)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21657,11 +21725,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype996, _size993) = iprot.readListBegin()
- for _i997 in xrange(_size993):
- _elem998 = Table()
- _elem998.read(iprot)
- self.success.append(_elem998)
+ (_etype1003, _size1000) = iprot.readListBegin()
+ for _i1004 in xrange(_size1000):
+ _elem1005 = Table()
+ _elem1005.read(iprot)
+ self.success.append(_elem1005)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21678,8 +21746,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 iter999 in self.success:
- iter999.write(oprot)
+ for iter1006 in self.success:
+ iter1006.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22547,10 +22615,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1003, _size1000) = iprot.readListBegin()
- for _i1004 in xrange(_size1000):
- _elem1005 = iprot.readString()
- self.success.append(_elem1005)
+ (_etype1010, _size1007) = iprot.readListBegin()
+ for _i1011 in xrange(_size1007):
+ _elem1012 = iprot.readString()
+ self.success.append(_elem1012)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22585,8 +22653,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 iter1006 in self.success:
- oprot.writeString(iter1006)
+ for iter1013 in self.success:
+ oprot.writeString(iter1013)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23715,11 +23783,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1010, _size1007) = iprot.readListBegin()
- for _i1011 in xrange(_size1007):
- _elem1012 = Partition()
- _elem1012.read(iprot)
- self.new_parts.append(_elem1012)
+ (_etype1017, _size1014) = iprot.readListBegin()
+ for _i1018 in xrange(_size1014):
+ _elem1019 = Partition()
+ _elem1019.read(iprot)
+ self.new_parts.append(_elem1019)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23736,8 +23804,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 iter1013 in self.new_parts:
- iter1013.write(oprot)
+ for iter1020 in self.new_parts:
+ iter1020.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23895,11 +23963,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1017, _size1014) = iprot.readListBegin()
- for _i1018 in xrange(_size1014):
- _elem1019 = PartitionSpec()
- _elem1019.read(iprot)
- self.new_parts.append(_elem1019)
+ (_etype1024, _size1021) = iprot.readListBegin()
+ for _i1025 in xrange(_size1021):
+ _elem1026 = PartitionSpec()
+ _elem1026.read(iprot)
+ self.new_parts.append(_elem1026)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23916,8 +23984,8 @@ class add_partitions_pspec_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1020 in self.new_parts:
- iter1020.write(oprot)
+ for iter1027 in self.new_parts:
+ iter1027.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24091,10 +24159,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1024, _size1021) = iprot.readListBegin()
- for _i1025 in xrange(_size1021):
- _elem1026 = iprot.readString()
- self.part_vals.append(_elem1026)
+ (_etype1031, _size1028) = iprot.readListBegin()
+ for _i1032 in xrange(_size1028):
+ _elem1033 = iprot.readString()
+ self.part_vals.append(_elem1033)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24119,8 +24187,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 iter1027 in self.part_vals:
- oprot.writeString(iter1027)
+ for iter1034 in self.part_vals:
+ oprot.writeString(iter1034)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24473,10 +24541,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1031, _size1028) = iprot.readListBegin()
- for _i1032 in xrange(_size1028):
- _elem1033 = iprot.readString()
- self.part_vals.append(_elem1033)
+ (_etype1038, _size1035) = iprot.readListBegin()
+ for _i1039 in xrange(_size1035):
+ _elem1040 = iprot.readString()
+ self.part_vals.append(_elem1040)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24507,8 +24575,8 @@ class append_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1034 in self.part_vals:
- oprot.writeString(iter1034)
+ for iter1041 in self.part_vals:
+ oprot.writeString(iter1041)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25103,10 +25171,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1038, _size1035) = iprot.readListBegin()
- for _i1039 in xrange(_size1035):
- _elem1040 = iprot.readString()
- self.part_vals.append(_elem1040)
+ (_etype1045, _size1042) = iprot.readListBegin()
+ for _i1046 in xrange(_size1042):
+ _elem1047 = iprot.readString()
+ self.part_vals.append(_elem1047)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25136,8 +25204,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 iter1041 in self.part_vals:
- oprot.writeString(iter1041)
+ for iter1048 in self.part_vals:
+ oprot.writeString(iter1048)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25310,10 +25378,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1045, _size1042) = iprot.readListBegin()
- for _i1046 in xrange(_size1042):
- _elem1047 = iprot.readString()
- self.part_vals.append(_elem1047)
+ (_etype1052, _size1049) = iprot.readListBegin()
+ for _i1053 in xrange(_size1049):
+ _elem1054 = iprot.readString()
+ self.part_vals.append(_elem1054)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25349,8 +25417,8 @@ class drop_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1048 in self.part_vals:
- oprot.writeString(iter1048)
+ for iter1055 in self.part_vals:
+ oprot.writeString(iter1055)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -26087,10 +26155,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1052, _size1049) = iprot.readListBegin()
- for _i1053 in xrange(_size1049):
- _elem1054 = iprot.readString()
- self.part_vals.append(_elem1054)
+ (_etype1059, _size1056) = iprot.readListBegin()
+ for _i1060 in xrange(_size1056):
+ _elem1061 = iprot.readString()
+ self.part_vals.append(_elem1061)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26115,8 +26183,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 iter1055 in self.part_vals:
- oprot.writeString(iter1055)
+ for iter1062 in self.part_vals:
+ oprot.writeString(iter1062)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26275,11 +26343,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1057, _vtype1058, _size1056 ) = iprot.readMapBegin()
- for _i1060 in xrange(_size1056):
- _key1061 = iprot.readString()
- _val1062 = iprot.readString()
- self.partitionSpecs[_key1061] = _val1062
+ (_ktype1064, _vtype1065, _size1063 ) = iprot.readMapBegin()
+ for _i1067 in xrange(_size1063):
+ _key1068 = iprot.readString()
+ _val1069 = iprot.readString()
+ self.partitionSpecs[_key1068] = _val1069
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26316,9 +26384,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 kiter1063,viter1064 in self.partitionSpecs.items():
- oprot.writeString(kiter1063)
- oprot.writeString(viter1064)
+ for kiter1070,viter1071 in self.partitionSpecs.items():
+ oprot.writeString(kiter1070)
+ oprot.writeString(viter1071)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -26523,11 +26591,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1066, _vtype1067, _size1065 ) = iprot.readMapBegin()
- for _i1069 in xrange(_size1065):
- _key1070 = iprot.readString()
- _val1071 = iprot.readString()
- self.partitionSpecs[_key1070] = _val1071
+ (_ktype1073, _vtype1074, _size1072 ) = iprot.readMapBegin()
+ for _i1076 in xrange(_size1072):
+ _key1077 = iprot.readString()
+ _val1078 = iprot.readString()
+ self.partitionSpecs[_key1077] = _val1078
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26564,9 +26632,9 @@ class exchange_partitions_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter1072,viter1073 in self.partitionSpecs.items():
- oprot.writeString(kiter1072)
- oprot.writeString(viter1073)
+ for kiter1079,viter1080 in self.partitionSpecs.items():
+ oprot.writeString(kiter1079)
+ oprot.writeString(viter1080)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -26649,11 +26717,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1077, _size1074) = iprot.readListBegin()
- for _i1078 in xrange(_size1074):
- _elem1079 = Partition()
- _elem1079.read(iprot)
- self.success.append(_elem1079)
+ (_etype1084, _size1081) = iprot.readListBegin()
+ for _i1085 in xrange(_size1081):
+ _elem1086 = Partition()
+ _elem1086.read(iprot)
+ self.success.append(_elem1086)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26694,8 +26762,8 @@ class exchange_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1080 in self.success:
- iter1080.write(oprot)
+ for iter1087 in self.success:
+ iter1087.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26789,10 +26857,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1084, _size1081) = iprot.readListBegin()
- for _i1085 in xrange(_size1081):
- _elem1086 = iprot.readString()
- self.part_vals.append(_elem1086)
+ (_etype1091, _size1088) = iprot.readListBegin()
+ for _i1092 in xrange(_size1088):
+ _elem1093 = iprot.readString()
+ self.part_vals.append(_elem1093)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26804,10 +26872,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1090, _size1087) = iprot.readListBegin()
- for _i1091 in xrange(_size1087):
- _elem1092 = iprot.readString()
- self.group_names.append(_elem1092)
+ (_etype1097, _size1094) = iprot.readListBegin()
+ for _i1098 in xrange(_size1094):
+ _elem1099 = iprot.readString()
+ self.group_names.append(_elem1099)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26832,8 +26900,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 iter1093 in self.part_vals:
- oprot.writeString(iter1093)
+ for iter1100 in self.part_vals:
+ oprot.writeString(iter1100)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -26843,8 +26911,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 iter1094 in self.group_names:
- oprot.writeString(iter1094)
+ for iter1101 in self.group_names:
+ oprot.writeString(iter1101)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27273,11 +27341,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1098, _size1095) = iprot.readListBegin()
- for _i1099 in xrange(_size1095):
- _elem1100 = Partition()
- _elem1100.read(iprot)
- self.success.append(_elem1100)
+ (_etype1105, _size1102) = iprot.readListBegin()
+ for _i1106 in xrange(_size1102):
+ _elem1107 = Partition()
+ _elem1107.read(iprot)
+ self.success.append(_elem1107)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27306,8 +27374,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 iter1101 in self.success:
- iter1101.write(oprot)
+ for iter1108 in self.success:
+ iter1108.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27401,10 +27469,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1105, _size1102) = iprot.readListBegin()
- for _i1106 in xrange(_size1102):
- _elem1107 = iprot.readString()
- self.group_names.append(_elem1107)
+ (_etype1112, _size1109) = iprot.readListBegin()
+ for _i1113 in xrange(_size1109):
+ _elem1114 = iprot.readString()
+ self.group_names.append(_elem1114)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27437,8 +27505,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 iter1108 in self.group_names:
- oprot.writeString(iter1108)
+ for iter1115 in self.group_names:
+ oprot.writeString(iter1115)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27499,11 +27567,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1112, _size1109) = iprot.readListBegin()
- for _i1113 in xrange(_size1109):
- _elem1114 = Partition()
- _elem1114.read(iprot)
- self.success.append(_elem1114)
+ (_etype1119, _size1116) = iprot.readListBegin()
+ for _i1120 in xrange(_size1116):
+ _elem1121 = Partition()
+ _elem1121.read(iprot)
+ self.success.append(_elem1121)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27532,8 +27600,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 iter1115 in self.success:
- iter1115.write(oprot)
+ for iter1122 in self.success:
+ iter1122.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27691,11 +27759,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1119, _size1116) = iprot.readListBegin()
- for _i1120 in xrange(_size1116):
- _elem1121 = PartitionSpec()
- _elem1121.read(iprot)
- self.success.append(_elem1121)
+ (_etype1126, _size1123) = iprot.readListBegin()
+ for _i1127 in xrange(_size1123):
+ _elem1128 = PartitionSpec()
+ _elem1128.read(iprot)
+ self.success.append(_elem1128)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27724,8 +27792,8 @@ class get_partitions_pspec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1122 in self.success:
- iter1122.write(oprot)
+ for iter1129 in self.success:
+ iter1129.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27883,10 +27951,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1126, _size1123) = iprot.readListBegin()
- for _i1127 in xrange(_size1123):
- _elem1128 = iprot.readString()
- self.success.append(_elem1128)
+ (_etype1133, _size1130) = iprot.readListBegin()
+ for _i1134 in xrange(_size1130):
+ _elem1135 = iprot.readString()
+ self.success.append(_elem1135)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27915,8 +27983,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 iter1129 in self.success:
- oprot.writeString(iter1129)
+ for iter1136 in self.success:
+ oprot.writeString(iter1136)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28156,10 +28224,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1133, _size1130) = iprot.readListBegin()
- for _i1134 in xrange(_size1130):
- _elem1135 = iprot.readString()
- self.part_vals.append(_elem1135)
+ (_etype1140, _size1137) = iprot.readListBegin()
+ for _i1141 in xrange(_size1137):
+ _elem1142 = iprot.readString()
+ self.part_vals.append(_elem1142)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28189,8 +28257,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 iter1136 in self.part_vals:
- oprot.writeString(iter1136)
+ for iter1143 in self.part_vals:
+ oprot.writeString(iter1143)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28254,11 +28322,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1140, _size1137) = iprot.readListBegin()
- for _i1141 in xrange(_size1137):
- _elem1142 = Partition()
- _elem1142.read(iprot)
- self.success.append(_elem1142)
+ (_etype1147, _size1144) = iprot.readListBegin()
+ for _i1148 in xrange(_size1144):
+ _elem1149 = Partition()
+ _elem1149.read(iprot)
+ self.success.append(_elem1149)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28287,8 +28355,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 iter1143 in self.success:
- iter1143.write(oprot)
+ for iter1150 in self.success:
+ iter1150.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28375,10 +28443,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1147, _size1144) = iprot.readListBegin()
- for _i1148 in xrange(_size1144):
- _elem1149 = iprot.readString()
- self.part_vals.append(_elem1149)
+ (_etype1154, _size1151) = iprot.readListBegin()
+ for _i1155 in xrange(_size1151):
+ _elem1156 = iprot.readString()
+ self.part_vals.append(_elem1156)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28395,10 +28463,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1153, _size1150) = iprot.readListBegin()
- for _i1154 in xrange(_size1150):
- _elem1155 = iprot.readString()
- self.group_names.append(_elem1155)
+ (_etype1160, _size1157) = iprot.readListBegin()
+ for _i1161 in xrange(_size1157):
+ _elem1162 = iprot.readString()
+ self.group_names.append(_elem1162)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28423,8 +28491,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 iter1156 in self.part_vals:
- oprot.writeString(iter1156)
+ for iter1163 in self.part_vals:
+ oprot.writeString(iter1163)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28438,8 +28506,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 iter1157 in self.group_names:
- oprot.writeString(iter1157)
+ for iter1164 in self.group_names:
+ oprot.writeString(iter1164)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28501,11 +28569,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1161, _size1158) = iprot.readListBegin()
- for _i1162 in xrange(_size1158):
- _elem1163 = Partition()
- _elem1163.read(iprot)
- self.success.append(_elem1163)
+ (_etype1168, _size1165) = iprot.readListBegin()
+ for _i1169 in xrange(_size1165):
+ _elem1170 = Partition()
+ _elem1170.read(iprot)
+ self.success.append(_elem1170)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28534,8 +28602,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 iter1164 in self.success:
- iter1164.write(oprot)
+ for iter1171 in self.success:
+ iter1171.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28616,10 +28684,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1168, _size1165) = iprot.readListBegin()
- for _i1169 in xrange(_size1165):
- _elem1170 = iprot.readString()
- self.part_vals.append(_elem1170)
+ (_etype1175, _size1172) = iprot.readListBegin()
+ for _i1176 in xrange(_size1172):
+ _elem1177 = iprot.readString()
+ self.part_vals.append(_elem1177)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28649,8 +28717,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 iter1171 in self.part_vals:
- oprot.writeString(iter1171)
+ for iter1178 in self.part_vals:
+ oprot.writeString(iter1178)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28714,10 +28782,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1175, _size1172) = iprot.readListBegin()
- for _i1176 in xrange(_size1172):
- _elem1177 = iprot.readString()
- self.success.append(_elem1177)
+ (_etype1182, _size1179) = iprot.readListBegin()
+ for _i1183 in xrange(_size1179):
+ _elem1184 = iprot.readString()
+ self.success.append(_elem1184)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28746,8 +28814,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 iter1178 in self.success:
- oprot.writeString(iter1178)
+ for iter1185 in self.success:
+ oprot.writeString(iter1185)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28918,11 +28986,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1182, _size1179) = iprot.readListBegin()
- for _i1183 in xrange(_size1179):
- _elem1184 = Partition()
- _elem1184.read(iprot)
- self.success.append(_elem1184)
+ (_etype1189, _size1186) = iprot.readListBegin()
+ for _i1190 in xrange(_size1186):
+ _elem1191 = Partition()
+ _elem1191.read(iprot)
+ self.success.append(_elem1191)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28951,8 +29019,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 iter1185 in self.success:
- iter1185.write(oprot)
+ for iter1192 in self.success:
+ iter1192.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29123,11 +29191,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1189, _size1186) = iprot.readListBegin()
- for _i1190 in xrange(_size1186):
- _elem1191 = PartitionSpec()
- _elem1191.read(iprot)
- self.success.append(_elem1191)
+ (_etype1196, _size1193) = iprot.readListBegin()
+ for _i1197 in xrange(_size1193):
+ _elem1198 = PartitionSpec()
+ _elem1198.read(iprot)
+ self.success.append(_elem1198)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29156,8 +29224,8 @@ class get_part_specs_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1192 in self.success:
- iter1192.write(oprot)
+ for iter1199 in self.success:
+ iter1199.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29577,10 +29645,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1196, _size1193) = iprot.readListBegin()
- for _i1197 in xrange(_size1193):
- _elem1198 = iprot.readString()
- self.names.append(_elem1198)
+ (_etype1203, _size1200) = iprot.readListBegin()
+ for _i1204 in xrange(_size1200):
+ _elem1205 = iprot.readString()
+ self.names.append(_elem1205)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29605,8 +29673,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 iter1199 in self.names:
- oprot.writeString(iter1199)
+ for iter1206 in self.names:
+ oprot.writeString(iter1206)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29665,11 +29733,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1203, _size1200) = iprot.readListBegin()
- for _i1204 in xrange(_size1200):
- _elem1205 = Partition()
- _elem1205.read(iprot)
- self.success.append(_elem1205)
+ (_etype1210, _size1207) = iprot.readListBegin()
+ for _i1211 in xrange(_size1207):
+ _elem1212 = Partition()
+ _elem1212.read(iprot)
+ self.success.append(_elem1212)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29698,8 +29766,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 iter1206 in self.success:
- iter1206.write(oprot)
+ for iter1213 in self.success:
+ iter1213.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29949,11 +30017,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1210, _size1207) = iprot.readListBegin()
- for _i1211 in xrange(_size1207):
- _elem1212 = Partition()
- _elem1212.read(iprot)
- self.new_parts.append(_elem1212)
+ (_etype1217, _size1214) = iprot.readListBegin()
+ for _i1218 in xrange(_size1214):
+ _elem1219 = Partition()
+ _elem1219.read(iprot)
+ self.new_parts.append(_elem1219)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29978,8 +30046,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 iter1213 in self.new_parts:
- iter1213.write(oprot)
+ for iter1220 in self.new_parts:
+ iter1220.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -30132,11 +30200,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1217, _size1214) = iprot.readListBegin()
- for _i1218 in xrange(_size1214):
- _elem1219 = Partition()
- _elem1219.read(iprot)
- self.new_parts.append(_elem1219)
+ (_etype1224, _size1221) = iprot.readListBegin()
+ for _i1225 in xrange(_size1221):
+ _elem1226 = Partition()
+ _elem1226.read(iprot)
+ self.new_parts.append(_elem1226)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30167,8 +30235,8 @@ class alter_partitions_with_environment_context_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1220 in self.new_parts:
- iter1220.write(oprot)
+ for iter1227 in self.new_parts:
+ iter1227.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -30671,10 +30739,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1224, _size1221) = iprot.readListBegin()
- for _i1225 in xrange(_size1221):
- _elem1226 = iprot.readString()
- self.part_vals.append(_elem1226)
+ (_etype1231, _size1228) = iprot.readListBegin()
+ for _i1232 in xrange(_size1228):
+ _elem1233 = iprot.readString()
+ self.part_vals.append(_elem1233)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30705,8 +30773,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 iter1227 in self.part_vals:
- oprot.writeString(iter1227)
+ for iter1234 in self.part_vals:
+ oprot.writeString(iter1234)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -30819,6 +30887,165 @@ class rename_partition_result:
def __ne__(self, other):
return not (self == other)
+class rename_partition_req_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (RenamePartitionRequest, RenamePartitionRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, req=None,):
+ self.req = req
+
+ 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.req = RenamePartitionRequest()
+ self.req.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('rename_partition_req_args')
+ if self.req is not None:
+ oprot.writeFieldBegin('req', TType.STRUCT, 1)
+ self.req.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.req)
+ return value
+
+ 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 rename_partition_req_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (RenamePartitionResponse, RenamePartitionResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (InvalidOperationException, InvalidOperationException.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 = RenamePartitionResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = InvalidOperationException()
+ 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('rename_partition_req_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 __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ value = (value * 31) ^ hash(self.o2)
+ return value
+
+ 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 partition_name_has_valid_characters_args:
"""
Attributes:
@@ -30848,10 +31075,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1231, _size1228) = iprot.readListBegin()
- for _i1232 in xrange(_size1228):
- _elem1233 = iprot.readString()
- self.part_vals.append(_elem1233)
+ (_etype1238, _size1235) = iprot.readListBegin()
+ for _i1239 in xrange(_size1235):
+ _elem1240 = iprot.readString()
+ self.part_vals.append(_elem1240)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30873,8 +31100,8 @@ class partition_name_has_valid_characters_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1234 in self.part_vals:
- oprot.writeString(iter1234)
+ for iter1241 in self.part_vals:
+ oprot.writeString(iter1241)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -31232,10 +31459,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1238, _size1235) = iprot.readListBegin()
- for _i1239 in xrange(_size1235):
- _elem1240 = iprot.readString()
- self.success.append(_elem1240)
+ (_etype1245, _size1242) = iprot.readListBegin()
+ for _i1246 in xrange(_size1242):
+ _elem1247 = iprot.readString()
+ self.success.append(_elem1247)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31258,8 +31485,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 iter1241 in self.success:
- oprot.writeString(iter1241)
+ for iter1248 in self.success:
+ oprot.writeString(iter1248)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31383,11 +31610,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1243, _vtype1244, _size1242 ) = iprot.readMapBegin()
- for _i1246 in xrange(_size1242):
- _key1247 = iprot.readString()
- _val1248 = iprot.readString()
- self.success[_key1247] = _val1248
+ (_ktype1250, _vtype1251, _size1249 ) = iprot.readMapBegin()
+ for _i1253 in xrange(_size1249):
+ _key1254 = iprot.readString()
+ _val1255 = iprot.readString()
+ self.success[_key1254] = _val1255
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -31410,9 +31637,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 kiter1249,viter1250 in self.success.items():
- oprot.writeString(kiter1249)
- oprot.writeString(viter1250)
+ for kiter1256,viter1257 in self.success.items():
+ oprot.writeString(kiter1256)
+ oprot.writeString(viter1257)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31488,11 +31715,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1252, _vtype1253, _size1251 ) = iprot.readMapBegin()
- for _i1255 in xrange(_size1251):
- _key1256 = iprot.readString()
- _val1257 = iprot.readString()
- self.part_vals[_key1256] = _val1257
+ (_ktype1259, _vtype1260, _size1258 ) = iprot.readMapBegin()
+ for _i1262 in xrange(_size1258):
+ _key1263 = iprot.readString()
+ _val1264 = iprot.readString()
+ self.part_vals[_key1263] = _val1264
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -31522,9 +31749,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 kiter1258,viter1259 in self.part_vals.items():
- oprot.writeString(kiter1258)
- oprot.writeString(viter1259)
+ for kiter1265,viter1266 in self.part_vals.items():
+ oprot.writeString(kiter1265)
+ oprot.writeString(viter1266)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -31738,11 +31965,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1261, _vtype1262, _size1260 ) = iprot.readMapBegin()
- for _i1264 in xrange(_size1260):
- _key1265 = iprot.readString()
- _val1266 = iprot.readString()
- self.part_vals[_key1265] = _val1266
+ (_ktype1268, _vtype1269, _size1267 ) = iprot.readMapBegin()
+ for _i1271 in xrange(_size1267):
+ _key1272 = iprot.readString()
+ _val1273 = iprot.readString()
+ self.part_vals[_key1272] = _val1273
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -31772,9 +31999,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 kiter1267,viter1268 in self.part_vals.items():
- oprot.writeString(kiter1267)
- oprot.writeString(viter1268)
+ for kiter1274,viter1275 in self.part_vals.items():
+ oprot.writeString(kiter1274)
+ oprot.writeString(viter1275)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -35800,10 +36027,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1272, _size1269) = iprot.readListBegin()
- for _i1273 in xrange(_size1269):
- _elem1274 = iprot.readString()
- self.success.append(_elem1274)
+ (_etype1279, _size1276) = iprot.readListBegin()
+ for _i1280 in xrange(_size1276):
+ _elem1281 = iprot.readString()
+ self.success.append(_elem1281)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35826,8 +36053,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 iter1275 in self.success:
- oprot.writeString(iter1275)
+ for iter1282 in self.success:
+ oprot.writeString(iter1282)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36515,10 +36742,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1279, _size1276) = iprot.readListBegin()
- for _i1280 in xrange(_size1276):
- _elem1281 = iprot.readString()
- self.success.append(_elem1281)
+ (_etype1286, _size1283) = iprot.readListBegin()
+ for _i1287 in xrange(_size1283):
+ _elem1288 = iprot.readString()
+ self.success.append(_elem1288)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36541,8 +36768,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 iter1282 in self.success:
- oprot.writeString(iter1282)
+ for iter1289 in self.success:
+ oprot.writeString(iter1289)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37056,11 +37283,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1286, _size1283) = iprot.readListBegin()
- for _i1287 in xrange(_size1283):
- _elem1288 = Role()
- _elem1288.read(iprot)
- self.success.append(_elem1288)
+ (_etype1293, _size1290) = iprot.readListBegin()
+ for _i1294 in xrange(_size1290):
+ _elem1295 = Role()
+ _elem1295.read(iprot)
+ self.success.append(_elem1295)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37083,8 +37310,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 iter1289 in self.success:
- iter1289.write(oprot)
+ for iter1296 in self.success:
+ iter1296.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37593,10 +37820,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1293, _size1290) = iprot.readListBegin()
- for _i1294 in xrange(_size1290):
- _elem1295 = iprot.readString()
- self.group_names.append(_elem1295)
+ (_etype1300, _size1297) = iprot.readListBegin()
+ for _i1301 in xrange(_size1297):
+ _elem1302 = iprot.readString()
+ self.group_names.append(_elem1302)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37621,8 +37848,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 iter1296 in self.group_names:
- oprot.writeString(iter1296)
+ for iter1303 in self.group_names:
+ oprot.writeString(iter1303)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -37849,11 +38076,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1300, _size1297) = iprot.readListBegin()
- for _i1301 in xrange(_size1297):
- _elem1302 = HiveObjectPrivilege()
- _elem1302.read(iprot)
- self.success.append(_elem1302)
+ (_etype1307, _size1304) = iprot.readListBegin()
+ for _i1308 in xrange(_size1304):
+ _elem1309 = HiveObjectPrivilege()
+ _elem1309.read(iprot)
+ self.success.append(_elem1309)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37876,8 +38103,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 iter1303 in self.success:
- iter1303.write(oprot)
+ for iter1310 in self.success:
+ iter1310.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -38547,10 +38774,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1307, _size1304) = iprot.readListBegin()
- for _i1308 in xrange(_size1304):
- _elem1309 = iprot.readString()
- self.group_names.append(_elem1309)
+ (_etype1314, _size1311) = iprot.readListBegin()
+ for _i1315 in xrange(_size1311):
+ _elem1316 = iprot.readString()
+ self.group_names.append(_elem1316)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38571,8 +38798,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 iter1310 in self.group_names:
- oprot.writeString(iter1310)
+ for iter1317 in self.group_names:
+ oprot.writeString(iter1317)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38627,10 +38854,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1314, _size1311) = iprot.readListBegin()
- for _i1315 in xrange(_size1311):
- _elem1316 = iprot.readString()
- self.success.append(_elem1316)
+ (_etype1321, _size1318) = iprot.readListBegin()
+ for _i1322 in xrange(_size1318):
+ _elem1323 = iprot.readString()
+ self.success.append(_elem1323)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38653,8 +38880,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 iter1317 in self.success:
- oprot.writeString(iter1317)
+ for iter1324 in self.success:
+ oprot.writeString(iter1324)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -39586,10 +39813,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1321, _size1318) = iprot.readListBegin()
- for _i1322 in xrange(_size1318):
- _elem1323 = iprot.readString()
- self.success.append(_elem1323)
+ (_etype1328, _size1325) = iprot.readListBegin()
+ for _i1329 in xrange(_size1325):
+ _elem1330 = iprot.readString()
+ self.success.append(_elem1330)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -39606,8 +39833,8 @@ class get_all_token_identifiers_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1324 in self.success:
- oprot.writeString(iter1324)
+ for iter1331 in self.success:
+ oprot.writeString(iter1331)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -40134,10 +40361,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1328, _size1325) = iprot.readListBegin()
- for _i1329 in xrange(_size1325):
- _elem1330 = iprot.readString()
- self.success.append(_elem1330)
+ (_etype1335, _size1332) = iprot.readListBegin()
+ for _i1336 in xrange(_size1332):
+ _elem1337 = iprot.readString()
+ self.success.append(_elem1337)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -40154,8 +40381,8 @@ class get_master_keys_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1331 in self.success:
- oprot.writeString(iter1331)
+ for iter1338 in self.success:
+ oprot.writeString(iter1338)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -48562,11 +48789,11 @@ class get_schema_all_versions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1335, _size1332) = iprot.readListBegin()
- for _i1336 in xrange(_size1332):
- _elem1337 = SchemaVersion()
- _elem1337.read(iprot)
- self.success.append(_elem1337)
+ (_etype1342, _size1339) = iprot.readListBegin()
+ for _i1343 in xrange(_size1339):
+ _elem1344 = SchemaVersion()
+ _elem1344.read(iprot)
+ self.success.append(_elem1344)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -48595,8 +48822,8 @@ class get_schema_all_versions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1338 in self.success:
- iter1338.write(oprot)
+ for iter1345 in self.success:
+ iter1345.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -50071,11 +50298,11 @@ class get_runtime_stats_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1342, _size1339) = iprot.readListBegin()
- for _i1343 in xrange(_size1339):
- _elem1344 = RuntimeStat()
- _elem1344.read(iprot)
- self.success.append(_elem1344)
+ (_etype1349, _size1346) = iprot.readListBegin()
+ for _i1350 in xrange(_size1346):
+ _elem1351 = RuntimeStat()
+ _elem1351.read(iprot)
+ self.success.append(_elem1351)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -50098,8 +50325,8 @@ class get_runtime_stats_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1345 in self.success:
- iter1345.write(oprot)
+ for iter1352 in self.success:
+ iter1352.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: