You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2019/01/29 14:46:43 UTC
[03/11] hive git commit: HIVE-21079: Replicate column statistics for
partitions of partitioned table (Ashutosh Bapat, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index ba06c54..9aeae9f 100755
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -107,6 +107,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)')
print(' i32 get_num_partitions_by_filter(string db_name, string tbl_name, string filter)')
print(' get_partitions_by_names(string db_name, string tbl_name, names)')
+ print(' GetPartitionsByNamesResult get_partitions_by_names_req(GetPartitionsByNamesRequest req)')
print(' void alter_partition(string db_name, string tbl_name, Partition new_part)')
print(' void alter_partitions(string db_name, string tbl_name, new_parts)')
print(' void alter_partitions_with_environment_context(string db_name, string tbl_name, new_parts, EnvironmentContext environment_context)')
@@ -813,6 +814,12 @@ elif cmd == 'get_partitions_by_names':
sys.exit(1)
pp.pprint(client.get_partitions_by_names(args[0],args[1],eval(args[2]),))
+elif cmd == 'get_partitions_by_names_req':
+ if len(args) != 1:
+ print('get_partitions_by_names_req requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.get_partitions_by_names_req(eval(args[0]),))
+
elif cmd == 'alter_partition':
if len(args) != 3:
print('alter_partition requires 3 args')
http://git-wip-us.apache.org/repos/asf/hive/blob/71dfd1d1/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 37db81f..eadf300 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
@@ -713,6 +713,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_partitions_by_names_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
def alter_partition(self, db_name, tbl_name, new_part):
"""
Parameters:
@@ -4835,6 +4842,41 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result")
+ def get_partitions_by_names_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_get_partitions_by_names_req(req)
+ return self.recv_get_partitions_by_names_req()
+
+ def send_get_partitions_by_names_req(self, req):
+ self._oprot.writeMessageBegin('get_partitions_by_names_req', TMessageType.CALL, self._seqid)
+ args = get_partitions_by_names_req_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_partitions_by_names_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_partitions_by_names_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, "get_partitions_by_names_req failed: unknown result")
+
def alter_partition(self, db_name, tbl_name, new_part):
"""
Parameters:
@@ -9694,6 +9736,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_partitions_by_expr"] = Processor.process_get_partitions_by_expr
self._processMap["get_num_partitions_by_filter"] = Processor.process_get_num_partitions_by_filter
self._processMap["get_partitions_by_names"] = Processor.process_get_partitions_by_names
+ self._processMap["get_partitions_by_names_req"] = Processor.process_get_partitions_by_names_req
self._processMap["alter_partition"] = Processor.process_alter_partition
self._processMap["alter_partitions"] = Processor.process_alter_partitions
self._processMap["alter_partitions_with_environment_context"] = Processor.process_alter_partitions_with_environment_context
@@ -11978,6 +12021,31 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_partitions_by_names_req(self, seqid, iprot, oprot):
+ args = get_partitions_by_names_req_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_partitions_by_names_req_result()
+ try:
+ result.success = self._handler.get_partitions_by_names_req(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except MetaException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except NoSuchObjectException 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("get_partitions_by_names_req", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_alter_partition(self, seqid, iprot, oprot):
args = alter_partition_args()
args.read(iprot)
@@ -16953,10 +17021,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype896, _size893) = iprot.readListBegin()
- for _i897 in xrange(_size893):
- _elem898 = iprot.readString()
- self.success.append(_elem898)
+ (_etype910, _size907) = iprot.readListBegin()
+ for _i911 in xrange(_size907):
+ _elem912 = iprot.readString()
+ self.success.append(_elem912)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16979,8 +17047,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 iter899 in self.success:
- oprot.writeString(iter899)
+ for iter913 in self.success:
+ oprot.writeString(iter913)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17085,10 +17153,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype903, _size900) = iprot.readListBegin()
- for _i904 in xrange(_size900):
- _elem905 = iprot.readString()
- self.success.append(_elem905)
+ (_etype917, _size914) = iprot.readListBegin()
+ for _i918 in xrange(_size914):
+ _elem919 = iprot.readString()
+ self.success.append(_elem919)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17111,8 +17179,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 iter906 in self.success:
- oprot.writeString(iter906)
+ for iter920 in self.success:
+ oprot.writeString(iter920)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17882,12 +17950,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype908, _vtype909, _size907 ) = iprot.readMapBegin()
- for _i911 in xrange(_size907):
- _key912 = iprot.readString()
- _val913 = Type()
- _val913.read(iprot)
- self.success[_key912] = _val913
+ (_ktype922, _vtype923, _size921 ) = iprot.readMapBegin()
+ for _i925 in xrange(_size921):
+ _key926 = iprot.readString()
+ _val927 = Type()
+ _val927.read(iprot)
+ self.success[_key926] = _val927
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -17910,9 +17978,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 kiter914,viter915 in self.success.items():
- oprot.writeString(kiter914)
- viter915.write(oprot)
+ for kiter928,viter929 in self.success.items():
+ oprot.writeString(kiter928)
+ viter929.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -18055,11 +18123,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype919, _size916) = iprot.readListBegin()
- for _i920 in xrange(_size916):
- _elem921 = FieldSchema()
- _elem921.read(iprot)
- self.success.append(_elem921)
+ (_etype933, _size930) = iprot.readListBegin()
+ for _i934 in xrange(_size930):
+ _elem935 = FieldSchema()
+ _elem935.read(iprot)
+ self.success.append(_elem935)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18094,8 +18162,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 iter922 in self.success:
- iter922.write(oprot)
+ for iter936 in self.success:
+ iter936.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18262,11 +18330,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype926, _size923) = iprot.readListBegin()
- for _i927 in xrange(_size923):
- _elem928 = FieldSchema()
- _elem928.read(iprot)
- self.success.append(_elem928)
+ (_etype940, _size937) = iprot.readListBegin()
+ for _i941 in xrange(_size937):
+ _elem942 = FieldSchema()
+ _elem942.read(iprot)
+ self.success.append(_elem942)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18301,8 +18369,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 iter929 in self.success:
- iter929.write(oprot)
+ for iter943 in self.success:
+ iter943.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18455,11 +18523,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype933, _size930) = iprot.readListBegin()
- for _i934 in xrange(_size930):
- _elem935 = FieldSchema()
- _elem935.read(iprot)
- self.success.append(_elem935)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = FieldSchema()
+ _elem949.read(iprot)
+ self.success.append(_elem949)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18494,8 +18562,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 iter936 in self.success:
- iter936.write(oprot)
+ for iter950 in self.success:
+ iter950.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18662,11 +18730,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = FieldSchema()
- _elem942.read(iprot)
- self.success.append(_elem942)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = FieldSchema()
+ _elem956.read(iprot)
+ self.success.append(_elem956)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18701,8 +18769,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 iter943 in self.success:
- iter943.write(oprot)
+ for iter957 in self.success:
+ iter957.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19155,66 +19223,66 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype947, _size944) = iprot.readListBegin()
- for _i948 in xrange(_size944):
- _elem949 = SQLPrimaryKey()
- _elem949.read(iprot)
- self.primaryKeys.append(_elem949)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = SQLPrimaryKey()
+ _elem963.read(iprot)
+ self.primaryKeys.append(_elem963)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype953, _size950) = iprot.readListBegin()
- for _i954 in xrange(_size950):
- _elem955 = SQLForeignKey()
- _elem955.read(iprot)
- self.foreignKeys.append(_elem955)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = SQLForeignKey()
+ _elem969.read(iprot)
+ self.foreignKeys.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype959, _size956) = iprot.readListBegin()
- for _i960 in xrange(_size956):
- _elem961 = SQLUniqueConstraint()
- _elem961.read(iprot)
- self.uniqueConstraints.append(_elem961)
+ (_etype973, _size970) = iprot.readListBegin()
+ for _i974 in xrange(_size970):
+ _elem975 = SQLUniqueConstraint()
+ _elem975.read(iprot)
+ self.uniqueConstraints.append(_elem975)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype965, _size962) = iprot.readListBegin()
- for _i966 in xrange(_size962):
- _elem967 = SQLNotNullConstraint()
- _elem967.read(iprot)
- self.notNullConstraints.append(_elem967)
+ (_etype979, _size976) = iprot.readListBegin()
+ for _i980 in xrange(_size976):
+ _elem981 = SQLNotNullConstraint()
+ _elem981.read(iprot)
+ self.notNullConstraints.append(_elem981)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype971, _size968) = iprot.readListBegin()
- for _i972 in xrange(_size968):
- _elem973 = SQLDefaultConstraint()
- _elem973.read(iprot)
- self.defaultConstraints.append(_elem973)
+ (_etype985, _size982) = iprot.readListBegin()
+ for _i986 in xrange(_size982):
+ _elem987 = SQLDefaultConstraint()
+ _elem987.read(iprot)
+ self.defaultConstraints.append(_elem987)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.LIST:
self.checkConstraints = []
- (_etype977, _size974) = iprot.readListBegin()
- for _i978 in xrange(_size974):
- _elem979 = SQLCheckConstraint()
- _elem979.read(iprot)
- self.checkConstraints.append(_elem979)
+ (_etype991, _size988) = iprot.readListBegin()
+ for _i992 in xrange(_size988):
+ _elem993 = SQLCheckConstraint()
+ _elem993.read(iprot)
+ self.checkConstraints.append(_elem993)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19235,43 +19303,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 iter980 in self.primaryKeys:
- iter980.write(oprot)
+ for iter994 in self.primaryKeys:
+ iter994.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 iter981 in self.foreignKeys:
- iter981.write(oprot)
+ for iter995 in self.foreignKeys:
+ iter995.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 iter982 in self.uniqueConstraints:
- iter982.write(oprot)
+ for iter996 in self.uniqueConstraints:
+ iter996.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 iter983 in self.notNullConstraints:
- iter983.write(oprot)
+ for iter997 in self.notNullConstraints:
+ iter997.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 iter984 in self.defaultConstraints:
- iter984.write(oprot)
+ for iter998 in self.defaultConstraints:
+ iter998.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 iter985 in self.checkConstraints:
- iter985.write(oprot)
+ for iter999 in self.checkConstraints:
+ iter999.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20831,10 +20899,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype989, _size986) = iprot.readListBegin()
- for _i990 in xrange(_size986):
- _elem991 = iprot.readString()
- self.partNames.append(_elem991)
+ (_etype1003, _size1000) = iprot.readListBegin()
+ for _i1004 in xrange(_size1000):
+ _elem1005 = iprot.readString()
+ self.partNames.append(_elem1005)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20859,8 +20927,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 iter992 in self.partNames:
- oprot.writeString(iter992)
+ for iter1006 in self.partNames:
+ oprot.writeString(iter1006)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21205,10 +21273,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype996, _size993) = iprot.readListBegin()
- for _i997 in xrange(_size993):
- _elem998 = iprot.readString()
- self.success.append(_elem998)
+ (_etype1010, _size1007) = iprot.readListBegin()
+ for _i1011 in xrange(_size1007):
+ _elem1012 = iprot.readString()
+ self.success.append(_elem1012)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21231,8 +21299,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 iter999 in self.success:
- oprot.writeString(iter999)
+ for iter1013 in self.success:
+ oprot.writeString(iter1013)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21382,10 +21450,10 @@ class get_tables_by_type_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)
+ (_etype1017, _size1014) = iprot.readListBegin()
+ for _i1018 in xrange(_size1014):
+ _elem1019 = iprot.readString()
+ self.success.append(_elem1019)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21408,8 +21476,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 iter1006 in self.success:
- oprot.writeString(iter1006)
+ for iter1020 in self.success:
+ oprot.writeString(iter1020)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21533,10 +21601,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1010, _size1007) = iprot.readListBegin()
- for _i1011 in xrange(_size1007):
- _elem1012 = iprot.readString()
- self.success.append(_elem1012)
+ (_etype1024, _size1021) = iprot.readListBegin()
+ for _i1025 in xrange(_size1021):
+ _elem1026 = iprot.readString()
+ self.success.append(_elem1026)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21559,8 +21627,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 iter1013 in self.success:
- oprot.writeString(iter1013)
+ for iter1027 in self.success:
+ oprot.writeString(iter1027)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21633,10 +21701,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype1017, _size1014) = iprot.readListBegin()
- for _i1018 in xrange(_size1014):
- _elem1019 = iprot.readString()
- self.tbl_types.append(_elem1019)
+ (_etype1031, _size1028) = iprot.readListBegin()
+ for _i1032 in xrange(_size1028):
+ _elem1033 = iprot.readString()
+ self.tbl_types.append(_elem1033)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21661,8 +21729,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 iter1020 in self.tbl_types:
- oprot.writeString(iter1020)
+ for iter1034 in self.tbl_types:
+ oprot.writeString(iter1034)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21718,11 +21786,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1024, _size1021) = iprot.readListBegin()
- for _i1025 in xrange(_size1021):
- _elem1026 = TableMeta()
- _elem1026.read(iprot)
- self.success.append(_elem1026)
+ (_etype1038, _size1035) = iprot.readListBegin()
+ for _i1039 in xrange(_size1035):
+ _elem1040 = TableMeta()
+ _elem1040.read(iprot)
+ self.success.append(_elem1040)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21745,8 +21813,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 iter1027 in self.success:
- iter1027.write(oprot)
+ for iter1041 in self.success:
+ iter1041.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21870,10 +21938,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1031, _size1028) = iprot.readListBegin()
- for _i1032 in xrange(_size1028):
- _elem1033 = iprot.readString()
- self.success.append(_elem1033)
+ (_etype1045, _size1042) = iprot.readListBegin()
+ for _i1046 in xrange(_size1042):
+ _elem1047 = iprot.readString()
+ self.success.append(_elem1047)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21896,8 +21964,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 iter1034 in self.success:
- oprot.writeString(iter1034)
+ for iter1048 in self.success:
+ oprot.writeString(iter1048)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22133,10 +22201,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype1038, _size1035) = iprot.readListBegin()
- for _i1039 in xrange(_size1035):
- _elem1040 = iprot.readString()
- self.tbl_names.append(_elem1040)
+ (_etype1052, _size1049) = iprot.readListBegin()
+ for _i1053 in xrange(_size1049):
+ _elem1054 = iprot.readString()
+ self.tbl_names.append(_elem1054)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22157,8 +22225,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 iter1041 in self.tbl_names:
- oprot.writeString(iter1041)
+ for iter1055 in self.tbl_names:
+ oprot.writeString(iter1055)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22210,11 +22278,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1045, _size1042) = iprot.readListBegin()
- for _i1046 in xrange(_size1042):
- _elem1047 = Table()
- _elem1047.read(iprot)
- self.success.append(_elem1047)
+ (_etype1059, _size1056) = iprot.readListBegin()
+ for _i1060 in xrange(_size1056):
+ _elem1061 = Table()
+ _elem1061.read(iprot)
+ self.success.append(_elem1061)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22231,8 +22299,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 iter1048 in self.success:
- iter1048.write(oprot)
+ for iter1062 in self.success:
+ iter1062.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23100,10 +23168,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1052, _size1049) = iprot.readListBegin()
- for _i1053 in xrange(_size1049):
- _elem1054 = iprot.readString()
- self.success.append(_elem1054)
+ (_etype1066, _size1063) = iprot.readListBegin()
+ for _i1067 in xrange(_size1063):
+ _elem1068 = iprot.readString()
+ self.success.append(_elem1068)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23138,8 +23206,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 iter1055 in self.success:
- oprot.writeString(iter1055)
+ for iter1069 in self.success:
+ oprot.writeString(iter1069)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24268,11 +24336,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1059, _size1056) = iprot.readListBegin()
- for _i1060 in xrange(_size1056):
- _elem1061 = Partition()
- _elem1061.read(iprot)
- self.new_parts.append(_elem1061)
+ (_etype1073, _size1070) = iprot.readListBegin()
+ for _i1074 in xrange(_size1070):
+ _elem1075 = Partition()
+ _elem1075.read(iprot)
+ self.new_parts.append(_elem1075)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24289,8 +24357,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 iter1062 in self.new_parts:
- iter1062.write(oprot)
+ for iter1076 in self.new_parts:
+ iter1076.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24448,11 +24516,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1066, _size1063) = iprot.readListBegin()
- for _i1067 in xrange(_size1063):
- _elem1068 = PartitionSpec()
- _elem1068.read(iprot)
- self.new_parts.append(_elem1068)
+ (_etype1080, _size1077) = iprot.readListBegin()
+ for _i1081 in xrange(_size1077):
+ _elem1082 = PartitionSpec()
+ _elem1082.read(iprot)
+ self.new_parts.append(_elem1082)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24469,8 +24537,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 iter1069 in self.new_parts:
- iter1069.write(oprot)
+ for iter1083 in self.new_parts:
+ iter1083.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24644,10 +24712,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1073, _size1070) = iprot.readListBegin()
- for _i1074 in xrange(_size1070):
- _elem1075 = iprot.readString()
- self.part_vals.append(_elem1075)
+ (_etype1087, _size1084) = iprot.readListBegin()
+ for _i1088 in xrange(_size1084):
+ _elem1089 = iprot.readString()
+ self.part_vals.append(_elem1089)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24672,8 +24740,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 iter1076 in self.part_vals:
- oprot.writeString(iter1076)
+ for iter1090 in self.part_vals:
+ oprot.writeString(iter1090)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25026,10 +25094,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1080, _size1077) = iprot.readListBegin()
- for _i1081 in xrange(_size1077):
- _elem1082 = iprot.readString()
- self.part_vals.append(_elem1082)
+ (_etype1094, _size1091) = iprot.readListBegin()
+ for _i1095 in xrange(_size1091):
+ _elem1096 = iprot.readString()
+ self.part_vals.append(_elem1096)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25060,8 +25128,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 iter1083 in self.part_vals:
- oprot.writeString(iter1083)
+ for iter1097 in self.part_vals:
+ oprot.writeString(iter1097)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25656,10 +25724,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1087, _size1084) = iprot.readListBegin()
- for _i1088 in xrange(_size1084):
- _elem1089 = iprot.readString()
- self.part_vals.append(_elem1089)
+ (_etype1101, _size1098) = iprot.readListBegin()
+ for _i1102 in xrange(_size1098):
+ _elem1103 = iprot.readString()
+ self.part_vals.append(_elem1103)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25689,8 +25757,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 iter1090 in self.part_vals:
- oprot.writeString(iter1090)
+ for iter1104 in self.part_vals:
+ oprot.writeString(iter1104)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25863,10 +25931,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1094, _size1091) = iprot.readListBegin()
- for _i1095 in xrange(_size1091):
- _elem1096 = iprot.readString()
- self.part_vals.append(_elem1096)
+ (_etype1108, _size1105) = iprot.readListBegin()
+ for _i1109 in xrange(_size1105):
+ _elem1110 = iprot.readString()
+ self.part_vals.append(_elem1110)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25902,8 +25970,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 iter1097 in self.part_vals:
- oprot.writeString(iter1097)
+ for iter1111 in self.part_vals:
+ oprot.writeString(iter1111)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -26640,10 +26708,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1101, _size1098) = iprot.readListBegin()
- for _i1102 in xrange(_size1098):
- _elem1103 = iprot.readString()
- self.part_vals.append(_elem1103)
+ (_etype1115, _size1112) = iprot.readListBegin()
+ for _i1116 in xrange(_size1112):
+ _elem1117 = iprot.readString()
+ self.part_vals.append(_elem1117)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26668,8 +26736,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 iter1104 in self.part_vals:
- oprot.writeString(iter1104)
+ for iter1118 in self.part_vals:
+ oprot.writeString(iter1118)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26828,11 +26896,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1106, _vtype1107, _size1105 ) = iprot.readMapBegin()
- for _i1109 in xrange(_size1105):
- _key1110 = iprot.readString()
- _val1111 = iprot.readString()
- self.partitionSpecs[_key1110] = _val1111
+ (_ktype1120, _vtype1121, _size1119 ) = iprot.readMapBegin()
+ for _i1123 in xrange(_size1119):
+ _key1124 = iprot.readString()
+ _val1125 = iprot.readString()
+ self.partitionSpecs[_key1124] = _val1125
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26869,9 +26937,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 kiter1112,viter1113 in self.partitionSpecs.items():
- oprot.writeString(kiter1112)
- oprot.writeString(viter1113)
+ for kiter1126,viter1127 in self.partitionSpecs.items():
+ oprot.writeString(kiter1126)
+ oprot.writeString(viter1127)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -27076,11 +27144,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1115, _vtype1116, _size1114 ) = iprot.readMapBegin()
- for _i1118 in xrange(_size1114):
- _key1119 = iprot.readString()
- _val1120 = iprot.readString()
- self.partitionSpecs[_key1119] = _val1120
+ (_ktype1129, _vtype1130, _size1128 ) = iprot.readMapBegin()
+ for _i1132 in xrange(_size1128):
+ _key1133 = iprot.readString()
+ _val1134 = iprot.readString()
+ self.partitionSpecs[_key1133] = _val1134
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -27117,9 +27185,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 kiter1121,viter1122 in self.partitionSpecs.items():
- oprot.writeString(kiter1121)
- oprot.writeString(viter1122)
+ for kiter1135,viter1136 in self.partitionSpecs.items():
+ oprot.writeString(kiter1135)
+ oprot.writeString(viter1136)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -27202,11 +27270,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1126, _size1123) = iprot.readListBegin()
- for _i1127 in xrange(_size1123):
- _elem1128 = Partition()
- _elem1128.read(iprot)
- self.success.append(_elem1128)
+ (_etype1140, _size1137) = iprot.readListBegin()
+ for _i1141 in xrange(_size1137):
+ _elem1142 = Partition()
+ _elem1142.read(iprot)
+ self.success.append(_elem1142)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27247,8 +27315,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 iter1129 in self.success:
- iter1129.write(oprot)
+ for iter1143 in self.success:
+ iter1143.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27342,10 +27410,10 @@ class get_partition_with_auth_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)
+ (_etype1147, _size1144) = iprot.readListBegin()
+ for _i1148 in xrange(_size1144):
+ _elem1149 = iprot.readString()
+ self.part_vals.append(_elem1149)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27357,10 +27425,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1139, _size1136) = iprot.readListBegin()
- for _i1140 in xrange(_size1136):
- _elem1141 = iprot.readString()
- self.group_names.append(_elem1141)
+ (_etype1153, _size1150) = iprot.readListBegin()
+ for _i1154 in xrange(_size1150):
+ _elem1155 = iprot.readString()
+ self.group_names.append(_elem1155)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27385,8 +27453,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 iter1142 in self.part_vals:
- oprot.writeString(iter1142)
+ for iter1156 in self.part_vals:
+ oprot.writeString(iter1156)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -27396,8 +27464,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 iter1143 in self.group_names:
- oprot.writeString(iter1143)
+ for iter1157 in self.group_names:
+ oprot.writeString(iter1157)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27826,11 +27894,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1147, _size1144) = iprot.readListBegin()
- for _i1148 in xrange(_size1144):
- _elem1149 = Partition()
- _elem1149.read(iprot)
- self.success.append(_elem1149)
+ (_etype1161, _size1158) = iprot.readListBegin()
+ for _i1162 in xrange(_size1158):
+ _elem1163 = Partition()
+ _elem1163.read(iprot)
+ self.success.append(_elem1163)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27859,8 +27927,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 iter1150 in self.success:
- iter1150.write(oprot)
+ for iter1164 in self.success:
+ iter1164.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27954,10 +28022,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1154, _size1151) = iprot.readListBegin()
- for _i1155 in xrange(_size1151):
- _elem1156 = iprot.readString()
- self.group_names.append(_elem1156)
+ (_etype1168, _size1165) = iprot.readListBegin()
+ for _i1169 in xrange(_size1165):
+ _elem1170 = iprot.readString()
+ self.group_names.append(_elem1170)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27990,8 +28058,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 iter1157 in self.group_names:
- oprot.writeString(iter1157)
+ for iter1171 in self.group_names:
+ oprot.writeString(iter1171)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28052,11 +28120,11 @@ class get_partitions_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)
+ (_etype1175, _size1172) = iprot.readListBegin()
+ for _i1176 in xrange(_size1172):
+ _elem1177 = Partition()
+ _elem1177.read(iprot)
+ self.success.append(_elem1177)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28085,8 +28153,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 iter1164 in self.success:
- iter1164.write(oprot)
+ for iter1178 in self.success:
+ iter1178.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28244,11 +28312,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1168, _size1165) = iprot.readListBegin()
- for _i1169 in xrange(_size1165):
- _elem1170 = PartitionSpec()
- _elem1170.read(iprot)
- self.success.append(_elem1170)
+ (_etype1182, _size1179) = iprot.readListBegin()
+ for _i1183 in xrange(_size1179):
+ _elem1184 = PartitionSpec()
+ _elem1184.read(iprot)
+ self.success.append(_elem1184)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28277,8 +28345,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 iter1171 in self.success:
- iter1171.write(oprot)
+ for iter1185 in self.success:
+ iter1185.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28436,10 +28504,10 @@ class get_partition_names_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)
+ (_etype1189, _size1186) = iprot.readListBegin()
+ for _i1190 in xrange(_size1186):
+ _elem1191 = iprot.readString()
+ self.success.append(_elem1191)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28468,8 +28536,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 iter1178 in self.success:
- oprot.writeString(iter1178)
+ for iter1192 in self.success:
+ oprot.writeString(iter1192)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28709,10 +28777,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1182, _size1179) = iprot.readListBegin()
- for _i1183 in xrange(_size1179):
- _elem1184 = iprot.readString()
- self.part_vals.append(_elem1184)
+ (_etype1196, _size1193) = iprot.readListBegin()
+ for _i1197 in xrange(_size1193):
+ _elem1198 = iprot.readString()
+ self.part_vals.append(_elem1198)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28742,8 +28810,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 iter1185 in self.part_vals:
- oprot.writeString(iter1185)
+ for iter1199 in self.part_vals:
+ oprot.writeString(iter1199)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28807,11 +28875,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1189, _size1186) = iprot.readListBegin()
- for _i1190 in xrange(_size1186):
- _elem1191 = Partition()
- _elem1191.read(iprot)
- self.success.append(_elem1191)
+ (_etype1203, _size1200) = iprot.readListBegin()
+ for _i1204 in xrange(_size1200):
+ _elem1205 = Partition()
+ _elem1205.read(iprot)
+ self.success.append(_elem1205)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28840,8 +28908,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 iter1192 in self.success:
- iter1192.write(oprot)
+ for iter1206 in self.success:
+ iter1206.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28928,10 +28996,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1196, _size1193) = iprot.readListBegin()
- for _i1197 in xrange(_size1193):
- _elem1198 = iprot.readString()
- self.part_vals.append(_elem1198)
+ (_etype1210, _size1207) = iprot.readListBegin()
+ for _i1211 in xrange(_size1207):
+ _elem1212 = iprot.readString()
+ self.part_vals.append(_elem1212)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28948,10 +29016,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1202, _size1199) = iprot.readListBegin()
- for _i1203 in xrange(_size1199):
- _elem1204 = iprot.readString()
- self.group_names.append(_elem1204)
+ (_etype1216, _size1213) = iprot.readListBegin()
+ for _i1217 in xrange(_size1213):
+ _elem1218 = iprot.readString()
+ self.group_names.append(_elem1218)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28976,8 +29044,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 iter1205 in self.part_vals:
- oprot.writeString(iter1205)
+ for iter1219 in self.part_vals:
+ oprot.writeString(iter1219)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28991,8 +29059,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 iter1206 in self.group_names:
- oprot.writeString(iter1206)
+ for iter1220 in self.group_names:
+ oprot.writeString(iter1220)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29054,11 +29122,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1210, _size1207) = iprot.readListBegin()
- for _i1211 in xrange(_size1207):
- _elem1212 = Partition()
- _elem1212.read(iprot)
- self.success.append(_elem1212)
+ (_etype1224, _size1221) = iprot.readListBegin()
+ for _i1225 in xrange(_size1221):
+ _elem1226 = Partition()
+ _elem1226.read(iprot)
+ self.success.append(_elem1226)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29087,8 +29155,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 iter1213 in self.success:
- iter1213.write(oprot)
+ for iter1227 in self.success:
+ iter1227.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29169,10 +29237,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1217, _size1214) = iprot.readListBegin()
- for _i1218 in xrange(_size1214):
- _elem1219 = iprot.readString()
- self.part_vals.append(_elem1219)
+ (_etype1231, _size1228) = iprot.readListBegin()
+ for _i1232 in xrange(_size1228):
+ _elem1233 = iprot.readString()
+ self.part_vals.append(_elem1233)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29202,8 +29270,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 iter1220 in self.part_vals:
- oprot.writeString(iter1220)
+ for iter1234 in self.part_vals:
+ oprot.writeString(iter1234)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -29267,10 +29335,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1224, _size1221) = iprot.readListBegin()
- for _i1225 in xrange(_size1221):
- _elem1226 = iprot.readString()
- self.success.append(_elem1226)
+ (_etype1238, _size1235) = iprot.readListBegin()
+ for _i1239 in xrange(_size1235):
+ _elem1240 = iprot.readString()
+ self.success.append(_elem1240)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29299,8 +29367,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 iter1227 in self.success:
- oprot.writeString(iter1227)
+ for iter1241 in self.success:
+ oprot.writeString(iter1241)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29471,11 +29539,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1231, _size1228) = iprot.readListBegin()
- for _i1232 in xrange(_size1228):
- _elem1233 = Partition()
- _elem1233.read(iprot)
- self.success.append(_elem1233)
+ (_etype1245, _size1242) = iprot.readListBegin()
+ for _i1246 in xrange(_size1242):
+ _elem1247 = Partition()
+ _elem1247.read(iprot)
+ self.success.append(_elem1247)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29504,8 +29572,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 iter1234 in self.success:
- iter1234.write(oprot)
+ for iter1248 in self.success:
+ iter1248.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29676,11 +29744,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1238, _size1235) = iprot.readListBegin()
- for _i1239 in xrange(_size1235):
- _elem1240 = PartitionSpec()
- _elem1240.read(iprot)
- self.success.append(_elem1240)
+ (_etype1252, _size1249) = iprot.readListBegin()
+ for _i1253 in xrange(_size1249):
+ _elem1254 = PartitionSpec()
+ _elem1254.read(iprot)
+ self.success.append(_elem1254)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29709,8 +29777,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 iter1241 in self.success:
- iter1241.write(oprot)
+ for iter1255 in self.success:
+ iter1255.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30130,10 +30198,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1245, _size1242) = iprot.readListBegin()
- for _i1246 in xrange(_size1242):
- _elem1247 = iprot.readString()
- self.names.append(_elem1247)
+ (_etype1259, _size1256) = iprot.readListBegin()
+ for _i1260 in xrange(_size1256):
+ _elem1261 = iprot.readString()
+ self.names.append(_elem1261)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30158,8 +30226,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 iter1248 in self.names:
- oprot.writeString(iter1248)
+ for iter1262 in self.names:
+ oprot.writeString(iter1262)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -30218,11 +30286,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1252, _size1249) = iprot.readListBegin()
- for _i1253 in xrange(_size1249):
- _elem1254 = Partition()
- _elem1254.read(iprot)
- self.success.append(_elem1254)
+ (_etype1266, _size1263) = iprot.readListBegin()
+ for _i1267 in xrange(_size1263):
+ _elem1268 = Partition()
+ _elem1268.read(iprot)
+ self.success.append(_elem1268)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30251,8 +30319,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 iter1255 in self.success:
- iter1255.write(oprot)
+ for iter1269 in self.success:
+ iter1269.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30288,6 +30356,165 @@ class get_partitions_by_names_result:
def __ne__(self, other):
return not (self == other)
+class get_partitions_by_names_req_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (GetPartitionsByNamesRequest, GetPartitionsByNamesRequest.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 = GetPartitionsByNamesRequest()
+ 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('get_partitions_by_names_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 get_partitions_by_names_req_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (GetPartitionsByNamesResult, GetPartitionsByNamesResult.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = GetPartitionsByNamesResult()
+ 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)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = NoSuchObjectException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_partitions_by_names_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 alter_partition_args:
"""
Attributes:
@@ -30502,11 +30729,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1259, _size1256) = iprot.readListBegin()
- for _i1260 in xrange(_size1256):
- _elem1261 = Partition()
- _elem1261.read(iprot)
- self.new_parts.append(_elem1261)
+ (_etype1273, _size1270) = iprot.readListBegin()
+ for _i1274 in xrange(_size1270):
+ _elem1275 = Partition()
+ _elem1275.read(iprot)
+ self.new_parts.append(_elem1275)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30531,8 +30758,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 iter1262 in self.new_parts:
- iter1262.write(oprot)
+ for iter1276 in self.new_parts:
+ iter1276.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -30685,11 +30912,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1266, _size1263) = iprot.readListBegin()
- for _i1267 in xrange(_size1263):
- _elem1268 = Partition()
- _elem1268.read(iprot)
- self.new_parts.append(_elem1268)
+ (_etype1280, _size1277) = iprot.readListBegin()
+ for _i1281 in xrange(_size1277):
+ _elem1282 = Partition()
+ _elem1282.read(iprot)
+ self.new_parts.append(_elem1282)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30720,8 +30947,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 iter1269 in self.new_parts:
- iter1269.write(oprot)
+ for iter1283 in self.new_parts:
+ iter1283.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -31224,10 +31451,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1273, _size1270) = iprot.readListBegin()
- for _i1274 in xrange(_size1270):
- _elem1275 = iprot.readString()
- self.part_vals.append(_elem1275)
+ (_etype1287, _size1284) = iprot.readListBegin()
+ for _i1288 in xrange(_size1284):
+ _elem1289 = iprot.readString()
+ self.part_vals.append(_elem1289)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31258,8 +31485,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 iter1276 in self.part_vals:
- oprot.writeString(iter1276)
+ for iter1290 in self.part_vals:
+ oprot.writeString(iter1290)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -31560,10 +31787,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1280, _size1277) = iprot.readListBegin()
- for _i1281 in xrange(_size1277):
- _elem1282 = iprot.readString()
- self.part_vals.append(_elem1282)
+ (_etype1294, _size1291) = iprot.readListBegin()
+ for _i1295 in xrange(_size1291):
+ _elem1296 = iprot.readString()
+ self.part_vals.append(_elem1296)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31585,8 +31812,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 iter1283 in self.part_vals:
- oprot.writeString(iter1283)
+ for iter1297 in self.part_vals:
+ oprot.writeString(iter1297)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -31944,10 +32171,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1287, _size1284) = iprot.readListBegin()
- for _i1288 in xrange(_size1284):
- _elem1289 = iprot.readString()
- self.success.append(_elem1289)
+ (_etype1301, _size1298) = iprot.readListBegin()
+ for _i1302 in xrange(_size1298):
+ _elem1303 = iprot.readString()
+ self.success.append(_elem1303)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31970,8 +32197,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 iter1290 in self.success:
- oprot.writeString(iter1290)
+ for iter1304 in self.success:
+ oprot.writeString(iter1304)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32095,11 +32322,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1292, _vtype1293, _size1291 ) = iprot.readMapBegin()
- for _i1295 in xrange(_size1291):
- _key1296 = iprot.readString()
- _val1297 = iprot.readString()
- self.success[_key1296] = _val1297
+ (_ktype1306, _vtype1307, _size1305 ) = iprot.readMapBegin()
+ for _i1309 in xrange(_size1305):
+ _key1310 = iprot.readString()
+ _val1311 = iprot.readString()
+ self.success[_key1310] = _val1311
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -32122,9 +32349,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 kiter1298,viter1299 in self.success.items():
- oprot.writeString(kiter1298)
- oprot.writeString(viter1299)
+ for kiter1312,viter1313 in self.success.items():
+ oprot.writeString(kiter1312)
+ oprot.writeString(viter1313)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32200,11 +32427,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1301, _vtype1302, _size1300 ) = iprot.readMapBegin()
- for _i1304 in xrange(_size1300):
- _key1305 = iprot.readString()
- _val1306 = iprot.readString()
- self.part_vals[_key1305] = _val1306
+ (_ktype1315, _vtype1316, _size1314 ) = iprot.readMapBegin()
+ for _i1318 in xrange(_size1314):
+ _key1319 = iprot.readString()
+ _val1320 = iprot.readString()
+ self.part_vals[_key1319] = _val1320
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -32234,9 +32461,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 kiter1307,viter1308 in self.part_vals.items():
- oprot.writeString(kiter1307)
- oprot.writeString(viter1308)
+ for kiter1321,viter1322 in self.part_vals.items():
+ oprot.writeString(kiter1321)
+ oprot.writeString(viter1322)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -32450,11 +32677,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1310, _vtype1311, _size1309 ) = iprot.readMapBegin()
- for _i1313 in xrange(_size1309):
- _key1314 = iprot.readString()
- _val1315 = iprot.readString()
- self.part_vals[_key1314] = _val1315
+ (_ktype1324, _vtype1325, _size1323 ) = iprot.readMapBegin()
+ for _i1327 in xrange(_size1323):
+ _key1328 = iprot.readString()
+ _val1329 = iprot.readString()
+ self.part_vals[_key1328] = _val1329
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -32484,9 +32711,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 kiter1316,viter1317 in self.part_vals.items():
- oprot.writeString(kiter1316)
- oprot.writeString(viter1317)
+ for kiter1330,viter1331 in self.part_vals.items():
+ oprot.writeString(kiter1330)
+ oprot.writeString(viter1331)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -36512,10 +36739,10 @@ class get_functions_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)
+ (_etype1335, _size1332) = iprot.readListBegin()
+ for _i1336 in xrange(_size1332):
+ _elem1337 = iprot.readString()
+ self.success.append(_elem1337)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36538,8 +36765,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 iter1324 in self.success:
- oprot.writeString(iter1324)
+ for iter1338 in self.success:
+ oprot.writeString(iter1338)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37227,10 +37454,10 @@ class get_role_names_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)
+ (_etype1342, _size1339) = iprot.readListBegin()
+ for _i1343 in xrange(_size1339):
+ _elem1344 = iprot.readString()
+ self.success.append(_elem1344)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37253,8 +37480,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 iter1331 in self.success:
- oprot.writeString(iter1331)
+ for iter1345 in self.success:
+ oprot.writeString(iter1345)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37768,11 +37995,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1335, _size1332) = iprot.readListBegin()
- for _i1336 in xrange(_size1332):
- _elem1337 = Role()
- _elem1337.read(iprot)
- self.success.append(_elem1337)
+ (_etype1349, _size1346) = iprot.readListBegin()
+ for _i1350 in xrange(_size1346):
+ _elem1351 = Role()
+ _elem1351.read(iprot)
+ self.success.append(_elem1351)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37795,8 +38022,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 iter1338 in self.success:
- iter1338.write(oprot)
+ for iter1352 in self.success:
+ iter1352.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -38305,10 +38532,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1342, _size1339) = iprot.readListBegin()
- for _i1343 in xrange(_size1339):
- _elem1344 = iprot.readString()
- self.group_names.append(_elem1344)
+ (_etype1356, _size1353) = iprot.readListBegin()
+ for _i1357 in xrange(_size1353):
+ _elem1358 = iprot.readString()
+ self.group_names.append(_elem1358)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38333,8 +38560,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 iter1345 in self.group_names:
- oprot.writeString(iter1345)
+ for iter1359 in self.group_names:
+ oprot.writeString(iter1359)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38561,11 +38788,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1349, _size1346) = iprot.readListBegin()
- for _i1350 in xrange(_size1346):
- _elem1351 = HiveObjectPrivilege()
- _elem1351.read(iprot)
- self.success.append(_elem1351)
+ (_etype1363, _size1360) = iprot.readListBegin()
+ for _i1364 in xrange(_size1360):
+ _elem1365 = HiveObjectPrivilege()
+ _elem1365.read(iprot)
+ self.success.append(_elem1365)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38588,8 +38815,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 iter1352 in self.success:
- iter1352.write(oprot)
+ for iter1366 in self.success:
+ iter1366.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -39259,10 +39486,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1356, _size1353) = iprot.readListBegin()
- for _i1357 in xrange(_size1353):
- _elem1358 = iprot.readString()
- self.group_names.append(_elem1358)
+ (_etype1370, _size1367) = iprot.readListBegin()
+ for _i1371 in xrange(_size1367):
+ _elem1372 = iprot.readString()
+ self.group_names.append(_elem1372)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -39283,8 +39510,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 iter1359 in self.group_names:
- oprot.writeString(iter1359)
+ for iter1373 in self.group_names:
+ oprot.writeString(iter1373)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -39339,10 +39566,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1363, _size1360) = iprot.readListBegin()
- for _i1364 in xrange(_size1360):
- _elem1365 = iprot.readString()
- self.success.append(_elem1365)
+ (_etype1377, _size1374) = iprot.readListBegin()
+ for _i1378 in xrange(_size1374):
+ _elem1379 = iprot.readString()
+ self.success.append(_elem1379)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -39365,8 +39592,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 iter1366 in self.success:
- oprot.writeString(iter1366)
+ for iter1380 in self.success:
+ oprot.writeString(iter1380)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -40298,10 +40525,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1370, _size1367) = iprot.readListBegin()
- for _i1371 in xrange(_size1367):
- _elem1372 = iprot.readString()
- self.success.append(_elem1372)
+ (_etype1384, _size1381) = iprot.readListBegin()
+ for _i1385 in xrange(_size1381):
+ _elem1386 = iprot.readString()
+ self.success.append(_elem1386)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -40318,8 +40545,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 iter1373 in self.success:
- oprot.writeString(iter1373)
+ for iter1387 in self.success:
+ oprot.writeString(iter1387)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -40846,10 +41073,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1377, _size1374) = iprot.readListBegin()
- for _i1378 in xrange(_size1374):
- _elem1379 = iprot.readString()
- self.success.append(_elem1379)
+ (_etype1391, _size1388) = iprot.readListBegin()
+ for _i1392 in xrange(_size1388):
+ _elem1393 = iprot.readString()
+ self.success.append(_elem1393)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -40866,8 +41093,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 iter1380 in self.success:
- oprot.writeString(iter1380)
+ for iter1394 in self.success:
+ oprot.writeString(iter1394)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -43880,10 +44107,10 @@ class find_columns_with_stats_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1384, _size1381) = iprot.readListBegin()
- for _i1385 in xrange(_size1381):
- _elem1386 = iprot.readString()
- self.success.append(_elem1386)
+ (_etype1398, _size1395) = iprot.readListBegin()
+ for _i1399 in xrange(_size1395):
+ _elem1400 = iprot.readString()
+ self.success.append(_elem1400)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -43900,8 +44127,8 @@ class find_columns_with_stats_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1387 in self.success:
- oprot.writeString(iter1387)
+ for iter1401 in self.success:
+ oprot.writeString(iter1401)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -50211,11 +50438,11 @@ class get_schema_all_versions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1391, _size1388) = iprot.readListBegin()
- for _i1392 in xrange(_size1388):
- _elem1393 = SchemaVersion()
- _elem1393.read(iprot)
- self.success.append(_elem1393)
+ (_etype1405, _size1402) = iprot.readListBegin()
+ for _i1406 in xrange(_size1402):
+ _elem1407 = SchemaVersion()
+ _elem1407.read(iprot)
+ self.success.append(_elem1407)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -50244,8 +50471,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 iter1394 in self.success:
- iter1394.write(oprot)
+ for iter1408 in self.success:
+ iter1408.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -51720,11 +51947,11 @@ class get_runtime_stats_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1398, _size1395) = iprot.readListBegin()
- for _i1399 in xrange(_size1395):
- _elem1400 = RuntimeStat()
- _elem1400.read(iprot)
- self.success.append(_elem1400)
+ (_etype1412, _size1409) = iprot.readListBegin()
+ for _i1413 in xrange(_size1409):
+ _elem1414 = RuntimeStat()
+ _elem1414.read(iprot)
+ self.success.append(_elem1414)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -51747,8 +51974,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 iter1401 in self.success:
- iter1401.write(oprot)
+ for iter1415 in self.success:
+ iter1415.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: