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 2017/10/30 19:13:26 UTC
[07/16] hive git commit: HIVE-17884 : Implement create,
alter and drop workload management triggers (Harish Jaiprakash,
reviewed by Prasanth Jayachandran, Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/c29df540/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 08864b7..e627952 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1335,6 +1335,34 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def create_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def alter_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def drop_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def get_triggers_for_resourceplan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
class Client(fb303.FacebookService.Client, Iface):
"""
@@ -7383,6 +7411,154 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o3
raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_resource_plan failed: unknown result")
+ def create_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_create_wm_trigger(request)
+ return self.recv_create_wm_trigger()
+
+ def send_create_wm_trigger(self, request):
+ self._oprot.writeMessageBegin('create_wm_trigger', TMessageType.CALL, self._seqid)
+ args = create_wm_trigger_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_create_wm_trigger(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = create_wm_trigger_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
+ if result.o3 is not None:
+ raise result.o3
+ if result.o4 is not None:
+ raise result.o4
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "create_wm_trigger failed: unknown result")
+
+ def alter_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_alter_wm_trigger(request)
+ return self.recv_alter_wm_trigger()
+
+ def send_alter_wm_trigger(self, request):
+ self._oprot.writeMessageBegin('alter_wm_trigger', TMessageType.CALL, self._seqid)
+ args = alter_wm_trigger_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_alter_wm_trigger(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = alter_wm_trigger_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
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_wm_trigger failed: unknown result")
+
+ def drop_wm_trigger(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_drop_wm_trigger(request)
+ return self.recv_drop_wm_trigger()
+
+ def send_drop_wm_trigger(self, request):
+ self._oprot.writeMessageBegin('drop_wm_trigger', TMessageType.CALL, self._seqid)
+ args = drop_wm_trigger_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_drop_wm_trigger(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = drop_wm_trigger_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
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_wm_trigger failed: unknown result")
+
+ def get_triggers_for_resourceplan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_triggers_for_resourceplan(request)
+ return self.recv_get_triggers_for_resourceplan()
+
+ def send_get_triggers_for_resourceplan(self, request):
+ self._oprot.writeMessageBegin('get_triggers_for_resourceplan', TMessageType.CALL, self._seqid)
+ args = get_triggers_for_resourceplan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_triggers_for_resourceplan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_triggers_for_resourceplan_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_triggers_for_resourceplan failed: unknown result")
+
class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
def __init__(self, handler):
@@ -7555,6 +7731,10 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["alter_resource_plan"] = Processor.process_alter_resource_plan
self._processMap["validate_resource_plan"] = Processor.process_validate_resource_plan
self._processMap["drop_resource_plan"] = Processor.process_drop_resource_plan
+ self._processMap["create_wm_trigger"] = Processor.process_create_wm_trigger
+ self._processMap["alter_wm_trigger"] = Processor.process_alter_wm_trigger
+ self._processMap["drop_wm_trigger"] = Processor.process_drop_wm_trigger
+ self._processMap["get_triggers_for_resourceplan"] = Processor.process_get_triggers_for_resourceplan
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
@@ -11672,6 +11852,118 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_create_wm_trigger(self, seqid, iprot, oprot):
+ args = create_wm_trigger_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = create_wm_trigger_result()
+ try:
+ result.success = self._handler.create_wm_trigger(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AlreadyExistsException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except NoSuchObjectException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except InvalidObjectException as o3:
+ msg_type = TMessageType.REPLY
+ result.o3 = o3
+ except MetaException as o4:
+ msg_type = TMessageType.REPLY
+ result.o4 = o4
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("create_wm_trigger", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_alter_wm_trigger(self, seqid, iprot, oprot):
+ args = alter_wm_trigger_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = alter_wm_trigger_result()
+ try:
+ result.success = self._handler.alter_wm_trigger(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NoSuchObjectException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except InvalidObjectException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except MetaException as o3:
+ msg_type = TMessageType.REPLY
+ result.o3 = o3
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("alter_wm_trigger", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_drop_wm_trigger(self, seqid, iprot, oprot):
+ args = drop_wm_trigger_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = drop_wm_trigger_result()
+ try:
+ result.success = self._handler.drop_wm_trigger(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NoSuchObjectException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except InvalidOperationException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except MetaException as o3:
+ msg_type = TMessageType.REPLY
+ result.o3 = o3
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("drop_wm_trigger", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_get_triggers_for_resourceplan(self, seqid, iprot, oprot):
+ args = get_triggers_for_resourceplan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_triggers_for_resourceplan_result()
+ try:
+ result.success = self._handler.get_triggers_for_resourceplan(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NoSuchObjectException 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("get_triggers_for_resourceplan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
# HELPER FUNCTIONS AND STRUCTURES
@@ -12558,10 +12850,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readString()
- self.success.append(_elem662)
+ (_etype667, _size664) = iprot.readListBegin()
+ for _i668 in xrange(_size664):
+ _elem669 = iprot.readString()
+ self.success.append(_elem669)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12584,8 +12876,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 iter663 in self.success:
- oprot.writeString(iter663)
+ for iter670 in self.success:
+ oprot.writeString(iter670)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12690,10 +12982,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = iprot.readString()
- self.success.append(_elem669)
+ (_etype674, _size671) = iprot.readListBegin()
+ for _i675 in xrange(_size671):
+ _elem676 = iprot.readString()
+ self.success.append(_elem676)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12716,8 +13008,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 iter670 in self.success:
- oprot.writeString(iter670)
+ for iter677 in self.success:
+ oprot.writeString(iter677)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13487,12 +13779,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype672, _vtype673, _size671 ) = iprot.readMapBegin()
- for _i675 in xrange(_size671):
- _key676 = iprot.readString()
- _val677 = Type()
- _val677.read(iprot)
- self.success[_key676] = _val677
+ (_ktype679, _vtype680, _size678 ) = iprot.readMapBegin()
+ for _i682 in xrange(_size678):
+ _key683 = iprot.readString()
+ _val684 = Type()
+ _val684.read(iprot)
+ self.success[_key683] = _val684
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13515,9 +13807,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 kiter678,viter679 in self.success.items():
- oprot.writeString(kiter678)
- viter679.write(oprot)
+ for kiter685,viter686 in self.success.items():
+ oprot.writeString(kiter685)
+ viter686.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -13660,11 +13952,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = FieldSchema()
- _elem685.read(iprot)
- self.success.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = FieldSchema()
+ _elem692.read(iprot)
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13699,8 +13991,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 iter686 in self.success:
- iter686.write(oprot)
+ for iter693 in self.success:
+ iter693.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13867,11 +14159,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = FieldSchema()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = FieldSchema()
+ _elem699.read(iprot)
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13906,8 +14198,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 iter693 in self.success:
- iter693.write(oprot)
+ for iter700 in self.success:
+ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14060,11 +14352,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = FieldSchema()
- _elem699.read(iprot)
- self.success.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = FieldSchema()
+ _elem706.read(iprot)
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14099,8 +14391,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 iter700 in self.success:
- iter700.write(oprot)
+ for iter707 in self.success:
+ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14267,11 +14559,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = FieldSchema()
- _elem706.read(iprot)
- self.success.append(_elem706)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = FieldSchema()
+ _elem713.read(iprot)
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14306,8 +14598,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 iter707 in self.success:
- iter707.write(oprot)
+ for iter714 in self.success:
+ iter714.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14754,44 +15046,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = SQLPrimaryKey()
- _elem713.read(iprot)
- self.primaryKeys.append(_elem713)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = SQLPrimaryKey()
+ _elem720.read(iprot)
+ self.primaryKeys.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype717, _size714) = iprot.readListBegin()
- for _i718 in xrange(_size714):
- _elem719 = SQLForeignKey()
- _elem719.read(iprot)
- self.foreignKeys.append(_elem719)
+ (_etype724, _size721) = iprot.readListBegin()
+ for _i725 in xrange(_size721):
+ _elem726 = SQLForeignKey()
+ _elem726.read(iprot)
+ self.foreignKeys.append(_elem726)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype723, _size720) = iprot.readListBegin()
- for _i724 in xrange(_size720):
- _elem725 = SQLUniqueConstraint()
- _elem725.read(iprot)
- self.uniqueConstraints.append(_elem725)
+ (_etype730, _size727) = iprot.readListBegin()
+ for _i731 in xrange(_size727):
+ _elem732 = SQLUniqueConstraint()
+ _elem732.read(iprot)
+ self.uniqueConstraints.append(_elem732)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype729, _size726) = iprot.readListBegin()
- for _i730 in xrange(_size726):
- _elem731 = SQLNotNullConstraint()
- _elem731.read(iprot)
- self.notNullConstraints.append(_elem731)
+ (_etype736, _size733) = iprot.readListBegin()
+ for _i737 in xrange(_size733):
+ _elem738 = SQLNotNullConstraint()
+ _elem738.read(iprot)
+ self.notNullConstraints.append(_elem738)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14812,29 +15104,29 @@ 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 iter732 in self.primaryKeys:
- iter732.write(oprot)
+ for iter739 in self.primaryKeys:
+ iter739.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 iter733 in self.foreignKeys:
- iter733.write(oprot)
+ for iter740 in self.foreignKeys:
+ iter740.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 iter734 in self.uniqueConstraints:
- iter734.write(oprot)
+ for iter741 in self.uniqueConstraints:
+ iter741.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 iter735 in self.notNullConstraints:
- iter735.write(oprot)
+ for iter742 in self.notNullConstraints:
+ iter742.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16100,10 +16392,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString()
- self.partNames.append(_elem741)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = iprot.readString()
+ self.partNames.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16128,8 +16420,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 iter742 in self.partNames:
- oprot.writeString(iter742)
+ for iter749 in self.partNames:
+ oprot.writeString(iter749)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16329,10 +16621,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString()
- self.success.append(_elem748)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = iprot.readString()
+ self.success.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16355,8 +16647,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 iter749 in self.success:
- oprot.writeString(iter749)
+ for iter756 in self.success:
+ oprot.writeString(iter756)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16506,10 +16798,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = iprot.readString()
- self.success.append(_elem755)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString()
+ self.success.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16532,8 +16824,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 iter756 in self.success:
- oprot.writeString(iter756)
+ for iter763 in self.success:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16606,10 +16898,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = iprot.readString()
- self.tbl_types.append(_elem762)
+ (_etype767, _size764) = iprot.readListBegin()
+ for _i768 in xrange(_size764):
+ _elem769 = iprot.readString()
+ self.tbl_types.append(_elem769)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16634,8 +16926,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 iter763 in self.tbl_types:
- oprot.writeString(iter763)
+ for iter770 in self.tbl_types:
+ oprot.writeString(iter770)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16691,11 +16983,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype767, _size764) = iprot.readListBegin()
- for _i768 in xrange(_size764):
- _elem769 = TableMeta()
- _elem769.read(iprot)
- self.success.append(_elem769)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = TableMeta()
+ _elem776.read(iprot)
+ self.success.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16718,8 +17010,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 iter770 in self.success:
- iter770.write(oprot)
+ for iter777 in self.success:
+ iter777.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16843,10 +17135,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = iprot.readString()
- self.success.append(_elem776)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString()
+ self.success.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16869,8 +17161,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 iter777 in self.success:
- oprot.writeString(iter777)
+ for iter784 in self.success:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17106,10 +17398,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype781, _size778) = iprot.readListBegin()
- for _i782 in xrange(_size778):
- _elem783 = iprot.readString()
- self.tbl_names.append(_elem783)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = iprot.readString()
+ self.tbl_names.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17130,8 +17422,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 iter784 in self.tbl_names:
- oprot.writeString(iter784)
+ for iter791 in self.tbl_names:
+ oprot.writeString(iter791)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17183,11 +17475,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype788, _size785) = iprot.readListBegin()
- for _i789 in xrange(_size785):
- _elem790 = Table()
- _elem790.read(iprot)
- self.success.append(_elem790)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = Table()
+ _elem797.read(iprot)
+ self.success.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17204,8 +17496,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 iter791 in self.success:
- iter791.write(oprot)
+ for iter798 in self.success:
+ iter798.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17688,10 +17980,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = iprot.readString()
- self.success.append(_elem797)
+ (_etype802, _size799) = iprot.readListBegin()
+ for _i803 in xrange(_size799):
+ _elem804 = iprot.readString()
+ self.success.append(_elem804)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17726,8 +18018,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 iter798 in self.success:
- oprot.writeString(iter798)
+ for iter805 in self.success:
+ oprot.writeString(iter805)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18697,11 +18989,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = Partition()
- _elem804.read(iprot)
- self.new_parts.append(_elem804)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = Partition()
+ _elem811.read(iprot)
+ self.new_parts.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18718,8 +19010,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 iter805 in self.new_parts:
- iter805.write(oprot)
+ for iter812 in self.new_parts:
+ iter812.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18877,11 +19169,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = PartitionSpec()
- _elem811.read(iprot)
- self.new_parts.append(_elem811)
+ (_etype816, _size813) = iprot.readListBegin()
+ for _i817 in xrange(_size813):
+ _elem818 = PartitionSpec()
+ _elem818.read(iprot)
+ self.new_parts.append(_elem818)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18898,8 +19190,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 iter812 in self.new_parts:
- iter812.write(oprot)
+ for iter819 in self.new_parts:
+ iter819.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19073,10 +19365,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = iprot.readString()
- self.part_vals.append(_elem818)
+ (_etype823, _size820) = iprot.readListBegin()
+ for _i824 in xrange(_size820):
+ _elem825 = iprot.readString()
+ self.part_vals.append(_elem825)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19101,8 +19393,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 iter819 in self.part_vals:
- oprot.writeString(iter819)
+ for iter826 in self.part_vals:
+ oprot.writeString(iter826)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19455,10 +19747,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = iprot.readString()
- self.part_vals.append(_elem825)
+ (_etype830, _size827) = iprot.readListBegin()
+ for _i831 in xrange(_size827):
+ _elem832 = iprot.readString()
+ self.part_vals.append(_elem832)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19489,8 +19781,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 iter826 in self.part_vals:
- oprot.writeString(iter826)
+ for iter833 in self.part_vals:
+ oprot.writeString(iter833)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -20085,10 +20377,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype830, _size827) = iprot.readListBegin()
- for _i831 in xrange(_size827):
- _elem832 = iprot.readString()
- self.part_vals.append(_elem832)
+ (_etype837, _size834) = iprot.readListBegin()
+ for _i838 in xrange(_size834):
+ _elem839 = iprot.readString()
+ self.part_vals.append(_elem839)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20118,8 +20410,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 iter833 in self.part_vals:
- oprot.writeString(iter833)
+ for iter840 in self.part_vals:
+ oprot.writeString(iter840)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -20292,10 +20584,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype837, _size834) = iprot.readListBegin()
- for _i838 in xrange(_size834):
- _elem839 = iprot.readString()
- self.part_vals.append(_elem839)
+ (_etype844, _size841) = iprot.readListBegin()
+ for _i845 in xrange(_size841):
+ _elem846 = iprot.readString()
+ self.part_vals.append(_elem846)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20331,8 +20623,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 iter840 in self.part_vals:
- oprot.writeString(iter840)
+ for iter847 in self.part_vals:
+ oprot.writeString(iter847)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -21069,10 +21361,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype844, _size841) = iprot.readListBegin()
- for _i845 in xrange(_size841):
- _elem846 = iprot.readString()
- self.part_vals.append(_elem846)
+ (_etype851, _size848) = iprot.readListBegin()
+ for _i852 in xrange(_size848):
+ _elem853 = iprot.readString()
+ self.part_vals.append(_elem853)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21097,8 +21389,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 iter847 in self.part_vals:
- oprot.writeString(iter847)
+ for iter854 in self.part_vals:
+ oprot.writeString(iter854)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21257,11 +21549,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype849, _vtype850, _size848 ) = iprot.readMapBegin()
- for _i852 in xrange(_size848):
- _key853 = iprot.readString()
- _val854 = iprot.readString()
- self.partitionSpecs[_key853] = _val854
+ (_ktype856, _vtype857, _size855 ) = iprot.readMapBegin()
+ for _i859 in xrange(_size855):
+ _key860 = iprot.readString()
+ _val861 = iprot.readString()
+ self.partitionSpecs[_key860] = _val861
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21298,9 +21590,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 kiter855,viter856 in self.partitionSpecs.items():
- oprot.writeString(kiter855)
- oprot.writeString(viter856)
+ for kiter862,viter863 in self.partitionSpecs.items():
+ oprot.writeString(kiter862)
+ oprot.writeString(viter863)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21505,11 +21797,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype858, _vtype859, _size857 ) = iprot.readMapBegin()
- for _i861 in xrange(_size857):
- _key862 = iprot.readString()
- _val863 = iprot.readString()
- self.partitionSpecs[_key862] = _val863
+ (_ktype865, _vtype866, _size864 ) = iprot.readMapBegin()
+ for _i868 in xrange(_size864):
+ _key869 = iprot.readString()
+ _val870 = iprot.readString()
+ self.partitionSpecs[_key869] = _val870
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21546,9 +21838,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 kiter864,viter865 in self.partitionSpecs.items():
- oprot.writeString(kiter864)
- oprot.writeString(viter865)
+ for kiter871,viter872 in self.partitionSpecs.items():
+ oprot.writeString(kiter871)
+ oprot.writeString(viter872)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21631,11 +21923,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = Partition()
- _elem871.read(iprot)
- self.success.append(_elem871)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = Partition()
+ _elem878.read(iprot)
+ self.success.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21676,8 +21968,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 iter872 in self.success:
- iter872.write(oprot)
+ for iter879 in self.success:
+ iter879.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21771,10 +22063,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = iprot.readString()
- self.part_vals.append(_elem878)
+ (_etype883, _size880) = iprot.readListBegin()
+ for _i884 in xrange(_size880):
+ _elem885 = iprot.readString()
+ self.part_vals.append(_elem885)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21786,10 +22078,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype882, _size879) = iprot.readListBegin()
- for _i883 in xrange(_size879):
- _elem884 = iprot.readString()
- self.group_names.append(_elem884)
+ (_etype889, _size886) = iprot.readListBegin()
+ for _i890 in xrange(_size886):
+ _elem891 = iprot.readString()
+ self.group_names.append(_elem891)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21814,8 +22106,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 iter885 in self.part_vals:
- oprot.writeString(iter885)
+ for iter892 in self.part_vals:
+ oprot.writeString(iter892)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -21825,8 +22117,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 iter886 in self.group_names:
- oprot.writeString(iter886)
+ for iter893 in self.group_names:
+ oprot.writeString(iter893)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22255,11 +22547,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = Partition()
- _elem892.read(iprot)
- self.success.append(_elem892)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = Partition()
+ _elem899.read(iprot)
+ self.success.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22288,8 +22580,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 iter893 in self.success:
- iter893.write(oprot)
+ for iter900 in self.success:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22383,10 +22675,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = iprot.readString()
- self.group_names.append(_elem899)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = iprot.readString()
+ self.group_names.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22419,8 +22711,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 iter900 in self.group_names:
- oprot.writeString(iter900)
+ for iter907 in self.group_names:
+ oprot.writeString(iter907)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22481,11 +22773,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = Partition()
- _elem906.read(iprot)
- self.success.append(_elem906)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = Partition()
+ _elem913.read(iprot)
+ self.success.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22514,8 +22806,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 iter907 in self.success:
- iter907.write(oprot)
+ for iter914 in self.success:
+ iter914.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22673,11 +22965,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype911, _size908) = iprot.readListBegin()
- for _i912 in xrange(_size908):
- _elem913 = PartitionSpec()
- _elem913.read(iprot)
- self.success.append(_elem913)
+ (_etype918, _size915) = iprot.readListBegin()
+ for _i919 in xrange(_size915):
+ _elem920 = PartitionSpec()
+ _elem920.read(iprot)
+ self.success.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22706,8 +22998,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 iter914 in self.success:
- iter914.write(oprot)
+ for iter921 in self.success:
+ iter921.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22865,10 +23157,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = iprot.readString()
- self.success.append(_elem920)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = iprot.readString()
+ self.success.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22897,8 +23189,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 iter921 in self.success:
- oprot.writeString(iter921)
+ for iter928 in self.success:
+ oprot.writeString(iter928)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23138,10 +23430,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype925, _size922) = iprot.readListBegin()
- for _i926 in xrange(_size922):
- _elem927 = iprot.readString()
- self.part_vals.append(_elem927)
+ (_etype932, _size929) = iprot.readListBegin()
+ for _i933 in xrange(_size929):
+ _elem934 = iprot.readString()
+ self.part_vals.append(_elem934)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23171,8 +23463,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 iter928 in self.part_vals:
- oprot.writeString(iter928)
+ for iter935 in self.part_vals:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23236,11 +23528,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype932, _size929) = iprot.readListBegin()
- for _i933 in xrange(_size929):
- _elem934 = Partition()
- _elem934.read(iprot)
- self.success.append(_elem934)
+ (_etype939, _size936) = iprot.readListBegin()
+ for _i940 in xrange(_size936):
+ _elem941 = Partition()
+ _elem941.read(iprot)
+ self.success.append(_elem941)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23269,8 +23561,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 iter935 in self.success:
- iter935.write(oprot)
+ for iter942 in self.success:
+ iter942.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23357,10 +23649,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype939, _size936) = iprot.readListBegin()
- for _i940 in xrange(_size936):
- _elem941 = iprot.readString()
- self.part_vals.append(_elem941)
+ (_etype946, _size943) = iprot.readListBegin()
+ for _i947 in xrange(_size943):
+ _elem948 = iprot.readString()
+ self.part_vals.append(_elem948)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23377,10 +23669,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype945, _size942) = iprot.readListBegin()
- for _i946 in xrange(_size942):
- _elem947 = iprot.readString()
- self.group_names.append(_elem947)
+ (_etype952, _size949) = iprot.readListBegin()
+ for _i953 in xrange(_size949):
+ _elem954 = iprot.readString()
+ self.group_names.append(_elem954)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23405,8 +23697,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 iter948 in self.part_vals:
- oprot.writeString(iter948)
+ for iter955 in self.part_vals:
+ oprot.writeString(iter955)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23420,8 +23712,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 iter949 in self.group_names:
- oprot.writeString(iter949)
+ for iter956 in self.group_names:
+ oprot.writeString(iter956)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23483,11 +23775,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype953, _size950) = iprot.readListBegin()
- for _i954 in xrange(_size950):
- _elem955 = Partition()
- _elem955.read(iprot)
- self.success.append(_elem955)
+ (_etype960, _size957) = iprot.readListBegin()
+ for _i961 in xrange(_size957):
+ _elem962 = Partition()
+ _elem962.read(iprot)
+ self.success.append(_elem962)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23516,8 +23808,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 iter956 in self.success:
- iter956.write(oprot)
+ for iter963 in self.success:
+ iter963.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23598,10 +23890,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype960, _size957) = iprot.readListBegin()
- for _i961 in xrange(_size957):
- _elem962 = iprot.readString()
- self.part_vals.append(_elem962)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = iprot.readString()
+ self.part_vals.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23631,8 +23923,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 iter963 in self.part_vals:
- oprot.writeString(iter963)
+ for iter970 in self.part_vals:
+ oprot.writeString(iter970)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23696,10 +23988,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype967, _size964) = iprot.readListBegin()
- for _i968 in xrange(_size964):
- _elem969 = iprot.readString()
- self.success.append(_elem969)
+ (_etype974, _size971) = iprot.readListBegin()
+ for _i975 in xrange(_size971):
+ _elem976 = iprot.readString()
+ self.success.append(_elem976)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23728,8 +24020,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 iter970 in self.success:
- oprot.writeString(iter970)
+ for iter977 in self.success:
+ oprot.writeString(iter977)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23900,11 +24192,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype974, _size971) = iprot.readListBegin()
- for _i975 in xrange(_size971):
- _elem976 = Partition()
- _elem976.read(iprot)
- self.success.append(_elem976)
+ (_etype981, _size978) = iprot.readListBegin()
+ for _i982 in xrange(_size978):
+ _elem983 = Partition()
+ _elem983.read(iprot)
+ self.success.append(_elem983)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23933,8 +24225,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 iter977 in self.success:
- iter977.write(oprot)
+ for iter984 in self.success:
+ iter984.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24105,11 +24397,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype981, _size978) = iprot.readListBegin()
- for _i982 in xrange(_size978):
- _elem983 = PartitionSpec()
- _elem983.read(iprot)
- self.success.append(_elem983)
+ (_etype988, _size985) = iprot.readListBegin()
+ for _i989 in xrange(_size985):
+ _elem990 = PartitionSpec()
+ _elem990.read(iprot)
+ self.success.append(_elem990)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24138,8 +24430,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 iter984 in self.success:
- iter984.write(oprot)
+ for iter991 in self.success:
+ iter991.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24559,10 +24851,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype988, _size985) = iprot.readListBegin()
- for _i989 in xrange(_size985):
- _elem990 = iprot.readString()
- self.names.append(_elem990)
+ (_etype995, _size992) = iprot.readListBegin()
+ for _i996 in xrange(_size992):
+ _elem997 = iprot.readString()
+ self.names.append(_elem997)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24587,8 +24879,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 iter991 in self.names:
- oprot.writeString(iter991)
+ for iter998 in self.names:
+ oprot.writeString(iter998)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24647,11 +24939,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype995, _size992) = iprot.readListBegin()
- for _i996 in xrange(_size992):
- _elem997 = Partition()
- _elem997.read(iprot)
- self.success.append(_elem997)
+ (_etype1002, _size999) = iprot.readListBegin()
+ for _i1003 in xrange(_size999):
+ _elem1004 = Partition()
+ _elem1004.read(iprot)
+ self.success.append(_elem1004)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24680,8 +24972,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 iter998 in self.success:
- iter998.write(oprot)
+ for iter1005 in self.success:
+ iter1005.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24931,11 +25223,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1002, _size999) = iprot.readListBegin()
- for _i1003 in xrange(_size999):
- _elem1004 = Partition()
- _elem1004.read(iprot)
- self.new_parts.append(_elem1004)
+ (_etype1009, _size1006) = iprot.readListBegin()
+ for _i1010 in xrange(_size1006):
+ _elem1011 = Partition()
+ _elem1011.read(iprot)
+ self.new_parts.append(_elem1011)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24960,8 +25252,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 iter1005 in self.new_parts:
- iter1005.write(oprot)
+ for iter1012 in self.new_parts:
+ iter1012.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25114,11 +25406,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1009, _size1006) = iprot.readListBegin()
- for _i1010 in xrange(_size1006):
- _elem1011 = Partition()
- _elem1011.read(iprot)
- self.new_parts.append(_elem1011)
+ (_etype1016, _size1013) = iprot.readListBegin()
+ for _i1017 in xrange(_size1013):
+ _elem1018 = Partition()
+ _elem1018.read(iprot)
+ self.new_parts.append(_elem1018)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25149,8 +25441,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 iter1012 in self.new_parts:
- iter1012.write(oprot)
+ for iter1019 in self.new_parts:
+ iter1019.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25494,10 +25786,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1016, _size1013) = iprot.readListBegin()
- for _i1017 in xrange(_size1013):
- _elem1018 = iprot.readString()
- self.part_vals.append(_elem1018)
+ (_etype1023, _size1020) = iprot.readListBegin()
+ for _i1024 in xrange(_size1020):
+ _elem1025 = iprot.readString()
+ self.part_vals.append(_elem1025)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25528,8 +25820,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 iter1019 in self.part_vals:
- oprot.writeString(iter1019)
+ for iter1026 in self.part_vals:
+ oprot.writeString(iter1026)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -25671,10 +25963,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1023, _size1020) = iprot.readListBegin()
- for _i1024 in xrange(_size1020):
- _elem1025 = iprot.readString()
- self.part_vals.append(_elem1025)
+ (_etype1030, _size1027) = iprot.readListBegin()
+ for _i1031 in xrange(_size1027):
+ _elem1032 = iprot.readString()
+ self.part_vals.append(_elem1032)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25696,8 +25988,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 iter1026 in self.part_vals:
- oprot.writeString(iter1026)
+ for iter1033 in self.part_vals:
+ oprot.writeString(iter1033)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -26055,10 +26347,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1030, _size1027) = iprot.readListBegin()
- for _i1031 in xrange(_size1027):
- _elem1032 = iprot.readString()
- self.success.append(_elem1032)
+ (_etype1037, _size1034) = iprot.readListBegin()
+ for _i1038 in xrange(_size1034):
+ _elem1039 = iprot.readString()
+ self.success.append(_elem1039)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26081,8 +26373,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 iter1033 in self.success:
- oprot.writeString(iter1033)
+ for iter1040 in self.success:
+ oprot.writeString(iter1040)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26206,11 +26498,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1035, _vtype1036, _size1034 ) = iprot.readMapBegin()
- for _i1038 in xrange(_size1034):
- _key1039 = iprot.readString()
- _val1040 = iprot.readString()
- self.success[_key1039] = _val1040
+ (_ktype1042, _vtype1043, _size1041 ) = iprot.readMapBegin()
+ for _i1045 in xrange(_size1041):
+ _key1046 = iprot.readString()
+ _val1047 = iprot.readString()
+ self.success[_key1046] = _val1047
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26233,9 +26525,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 kiter1041,viter1042 in self.success.items():
- oprot.writeString(kiter1041)
- oprot.writeString(viter1042)
+ for kiter1048,viter1049 in self.success.items():
+ oprot.writeString(kiter1048)
+ oprot.writeString(viter1049)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26311,11 +26603,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1044, _vtype1045, _size1043 ) = iprot.readMapBegin()
- for _i1047 in xrange(_size1043):
- _key1048 = iprot.readString()
- _val1049 = iprot.readString()
- self.part_vals[_key1048] = _val1049
+ (_ktype1051, _vtype1052, _size1050 ) = iprot.readMapBegin()
+ for _i1054 in xrange(_size1050):
+ _key1055 = iprot.readString()
+ _val1056 = iprot.readString()
+ self.part_vals[_key1055] = _val1056
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26345,9 +26637,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 kiter1050,viter1051 in self.part_vals.items():
- oprot.writeString(kiter1050)
- oprot.writeString(viter1051)
+ for kiter1057,viter1058 in self.part_vals.items():
+ oprot.writeString(kiter1057)
+ oprot.writeString(viter1058)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -26561,11 +26853,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1053, _vtype1054, _size1052 ) = iprot.readMapBegin()
- for _i1056 in xrange(_size1052):
- _key1057 = iprot.readString()
- _val1058 = iprot.readString()
- self.part_vals[_key1057] = _val1058
+ (_ktype1060, _vtype1061, _size1059 ) = iprot.readMapBegin()
+ for _i1063 in xrange(_size1059):
+ _key1064 = iprot.readString()
+ _val1065 = iprot.readString()
+ self.part_vals[_key1064] = _val1065
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26595,9 +26887,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 kiter1059,viter1060 in self.part_vals.items():
- oprot.writeString(kiter1059)
- oprot.writeString(viter1060)
+ for kiter1066,viter1067 in self.part_vals.items():
+ oprot.writeString(kiter1066)
+ oprot.writeString(viter1067)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -27652,11 +27944,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1064, _size1061) = iprot.readListBegin()
- for _i1065 in xrange(_size1061):
- _elem1066 = Index()
- _elem1066.read(iprot)
- self.success.append(_elem1066)
+ (_etype1071, _size1068) = iprot.readListBegin()
+ for _i1072 in xrange(_size1068):
+ _elem1073 = Index()
+ _elem1073.read(iprot)
+ self.success.append(_elem1073)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27685,346 +27977,10 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1067 in self.success:
- iter1067.write(oprot)
- oprot.writeListEnd()
- 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 get_index_names_args:
- """
- Attributes:
- - db_name
- - tbl_name
- - max_indexes
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.I16, 'max_indexes', None, -1, ), # 3
- )
-
- def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
- self.db_name = db_name
- self.tbl_name = tbl_name
- self.max_indexes = max_indexes
-
- 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.STRING:
- self.db_name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.tbl_name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I16:
- self.max_indexes = iprot.readI16()
- 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_index_names_args')
- if self.db_name is not None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.tbl_name is not None:
- oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
- oprot.writeString(self.tbl_name)
- oprot.writeFieldEnd()
- if self.max_indexes is not None:
- oprot.writeFieldBegin('max_indexes', TType.I16, 3)
- oprot.writeI16(self.max_indexes)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.db_name)
- value = (value * 31) ^ hash(self.tbl_name)
- value = (value * 31) ^ hash(self.max_indexes)
- 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_index_names_result:
- """
- Attributes:
- - success
- - o2
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
- (1, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, o2=None,):
- self.success = success
- 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.LIST:
- self.success = []
- (_etype1071, _size1068) = iprot.readListBegin()
- for _i1072 in xrange(_size1068):
- _elem1073 = iprot.readString()
- self.success.append(_elem1073)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.o2 = MetaException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_index_names_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
for iter1074 in self.success:
- oprot.writeString(iter1074)
+ iter1074.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.o2 is not None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 1)
- 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.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 get_primary_keys_args:
- """
- Attributes:
- - request
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'request', (PrimaryKeysRequest, PrimaryKeysRequest.thrift_spec), None, ), # 1
- )
-
- def __init__(self, request=None,):
- self.request = request
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.request = PrimaryKeysRequest()
- self.request.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_primary_keys_args')
- if self.request is not None:
- oprot.writeFieldBegin('request', TType.STRUCT, 1)
- self.request.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.request)
- 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_primary_keys_result:
- """
- Attributes:
- - success
- - o1
- - o2
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (PrimaryKeysResponse, PrimaryKeysResponse.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 = PrimaryKeysResponse()
- 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_primary_keys_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)
@@ -28058,7 +28014,184 @@ class get_primary_keys_result:
def __ne__(self, other):
return not (self == other)
-class get_foreign_keys_args:
+class get_index_names_args:
+ """
+ Attributes:
+ - db_name
+ - tbl_name
+ - max_indexes
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.I16, 'max_indexes', None, -1, ), # 3
+ )
+
+ def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+ self.max_indexes = max_indexes
+
+ 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.STRING:
+ self.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.tbl_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I16:
+ self.max_indexes = iprot.readI16()
+ 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_index_names_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.tbl_name is not None:
+ oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
+ oprot.writeString(self.tbl_name)
+ oprot.writeFieldEnd()
+ if self.max_indexes is not None:
+ oprot.writeFieldBegin('max_indexes', TType.I16, 3)
+ oprot.writeI16(self.max_indexes)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.tbl_name)
+ value = (value * 31) ^ hash(self.max_indexes)
+ 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_index_names_result:
+ """
+ Attributes:
+ - success
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
+ (1, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, o2=None,):
+ self.success = success
+ 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.LIST:
+ self.success = []
+ (_etype1078, _size1075) = iprot.readListBegin()
+ for _i1079 in xrange(_size1075):
+ _elem1080 = iprot.readString()
+ self.success.append(_elem1080)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o2 = MetaException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_index_names_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRING, len(self.success))
+ for iter1081 in self.success:
+ oprot.writeString(iter1081)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 1)
+ 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.o2)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '
<TRUNCATED>