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 2015/08/06 02:50:37 UTC
[31/53] [abbrv] hive git commit: HIVE-10319: Hive CLI startup takes a
long time with a large number of databases (Nezih Yigitbasi,
reviewed by Jason Dere)
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index e299906..9e460f0 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -775,6 +775,9 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_all_functions(self):
+ pass
+
def create_role(self, role):
"""
Parameters:
@@ -4413,6 +4416,34 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result");
+ def get_all_functions(self):
+ self.send_get_all_functions()
+ return self.recv_get_all_functions()
+
+ def send_get_all_functions(self):
+ self._oprot.writeMessageBegin('get_all_functions', TMessageType.CALL, self._seqid)
+ args = get_all_functions_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_all_functions(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_all_functions_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result");
+
def create_role(self, role):
"""
Parameters:
@@ -5650,6 +5681,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["alter_function"] = Processor.process_alter_function
self._processMap["get_functions"] = Processor.process_get_functions
self._processMap["get_function"] = Processor.process_get_function
+ self._processMap["get_all_functions"] = Processor.process_get_all_functions
self._processMap["create_role"] = Processor.process_create_role
self._processMap["drop_role"] = Processor.process_drop_role
self._processMap["get_role_names"] = Processor.process_get_role_names
@@ -7179,6 +7211,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_all_functions(self, seqid, iprot, oprot):
+ args = get_all_functions_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_all_functions_result()
+ try:
+ result.success = self._handler.get_all_functions()
+ except MetaException, o1:
+ result.o1 = o1
+ oprot.writeMessageBegin("get_all_functions", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_create_role(self, seqid, iprot, oprot):
args = create_role_args()
args.read(iprot)
@@ -8541,10 +8587,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString();
- self.success.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = iprot.readString();
+ self.success.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8567,8 +8613,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 iter468 in self.success:
- oprot.writeString(iter468)
+ for iter475 in self.success:
+ oprot.writeString(iter475)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8673,10 +8719,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readString();
- self.success.append(_elem474)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = iprot.readString();
+ self.success.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8699,8 +8745,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 iter475 in self.success:
- oprot.writeString(iter475)
+ for iter482 in self.success:
+ oprot.writeString(iter482)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9470,12 +9516,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype477, _vtype478, _size476 ) = iprot.readMapBegin()
- for _i480 in xrange(_size476):
- _key481 = iprot.readString();
- _val482 = Type()
- _val482.read(iprot)
- self.success[_key481] = _val482
+ (_ktype484, _vtype485, _size483 ) = iprot.readMapBegin()
+ for _i487 in xrange(_size483):
+ _key488 = iprot.readString();
+ _val489 = Type()
+ _val489.read(iprot)
+ self.success[_key488] = _val489
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -9498,9 +9544,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 kiter483,viter484 in self.success.items():
- oprot.writeString(kiter483)
- viter484.write(oprot)
+ for kiter490,viter491 in self.success.items():
+ oprot.writeString(kiter490)
+ viter491.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -9643,11 +9689,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype488, _size485) = iprot.readListBegin()
- for _i489 in xrange(_size485):
- _elem490 = FieldSchema()
- _elem490.read(iprot)
- self.success.append(_elem490)
+ (_etype495, _size492) = iprot.readListBegin()
+ for _i496 in xrange(_size492):
+ _elem497 = FieldSchema()
+ _elem497.read(iprot)
+ self.success.append(_elem497)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9682,8 +9728,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 iter491 in self.success:
- iter491.write(oprot)
+ for iter498 in self.success:
+ iter498.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9850,11 +9896,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype495, _size492) = iprot.readListBegin()
- for _i496 in xrange(_size492):
- _elem497 = FieldSchema()
- _elem497.read(iprot)
- self.success.append(_elem497)
+ (_etype502, _size499) = iprot.readListBegin()
+ for _i503 in xrange(_size499):
+ _elem504 = FieldSchema()
+ _elem504.read(iprot)
+ self.success.append(_elem504)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9889,8 +9935,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 iter498 in self.success:
- iter498.write(oprot)
+ for iter505 in self.success:
+ iter505.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10043,11 +10089,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype502, _size499) = iprot.readListBegin()
- for _i503 in xrange(_size499):
- _elem504 = FieldSchema()
- _elem504.read(iprot)
- self.success.append(_elem504)
+ (_etype509, _size506) = iprot.readListBegin()
+ for _i510 in xrange(_size506):
+ _elem511 = FieldSchema()
+ _elem511.read(iprot)
+ self.success.append(_elem511)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10082,8 +10128,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 iter505 in self.success:
- iter505.write(oprot)
+ for iter512 in self.success:
+ iter512.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10250,11 +10296,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype509, _size506) = iprot.readListBegin()
- for _i510 in xrange(_size506):
- _elem511 = FieldSchema()
- _elem511.read(iprot)
- self.success.append(_elem511)
+ (_etype516, _size513) = iprot.readListBegin()
+ for _i517 in xrange(_size513):
+ _elem518 = FieldSchema()
+ _elem518.read(iprot)
+ self.success.append(_elem518)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10289,8 +10335,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 iter512 in self.success:
- iter512.write(oprot)
+ for iter519 in self.success:
+ iter519.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11155,10 +11201,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = iprot.readString();
- self.success.append(_elem518)
+ (_etype523, _size520) = iprot.readListBegin()
+ for _i524 in xrange(_size520):
+ _elem525 = iprot.readString();
+ self.success.append(_elem525)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11181,8 +11227,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 iter519 in self.success:
- oprot.writeString(iter519)
+ for iter526 in self.success:
+ oprot.writeString(iter526)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11306,10 +11352,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = iprot.readString();
- self.success.append(_elem525)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = iprot.readString();
+ self.success.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11332,8 +11378,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 iter526 in self.success:
- oprot.writeString(iter526)
+ for iter533 in self.success:
+ oprot.writeString(iter533)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11569,10 +11615,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = iprot.readString();
- self.tbl_names.append(_elem532)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = iprot.readString();
+ self.tbl_names.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11593,8 +11639,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 iter533 in self.tbl_names:
- oprot.writeString(iter533)
+ for iter540 in self.tbl_names:
+ oprot.writeString(iter540)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11655,11 +11701,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = Table()
- _elem539.read(iprot)
- self.success.append(_elem539)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = Table()
+ _elem546.read(iprot)
+ self.success.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11694,8 +11740,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 iter540 in self.success:
- iter540.write(oprot)
+ for iter547 in self.success:
+ iter547.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11861,10 +11907,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = iprot.readString();
- self.success.append(_elem546)
+ (_etype551, _size548) = iprot.readListBegin()
+ for _i552 in xrange(_size548):
+ _elem553 = iprot.readString();
+ self.success.append(_elem553)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11899,8 +11945,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 iter547 in self.success:
- oprot.writeString(iter547)
+ for iter554 in self.success:
+ oprot.writeString(iter554)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12870,11 +12916,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = Partition()
- _elem553.read(iprot)
- self.new_parts.append(_elem553)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = Partition()
+ _elem560.read(iprot)
+ self.new_parts.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12891,8 +12937,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 iter554 in self.new_parts:
- iter554.write(oprot)
+ for iter561 in self.new_parts:
+ iter561.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13050,11 +13096,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = PartitionSpec()
- _elem560.read(iprot)
- self.new_parts.append(_elem560)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = PartitionSpec()
+ _elem567.read(iprot)
+ self.new_parts.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13071,8 +13117,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 iter561 in self.new_parts:
- iter561.write(oprot)
+ for iter568 in self.new_parts:
+ iter568.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13246,10 +13292,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = iprot.readString();
- self.part_vals.append(_elem567)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = iprot.readString();
+ self.part_vals.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13274,8 +13320,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 iter568 in self.part_vals:
- oprot.writeString(iter568)
+ for iter575 in self.part_vals:
+ oprot.writeString(iter575)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13628,10 +13674,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = iprot.readString();
- self.part_vals.append(_elem574)
+ (_etype579, _size576) = iprot.readListBegin()
+ for _i580 in xrange(_size576):
+ _elem581 = iprot.readString();
+ self.part_vals.append(_elem581)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13662,8 +13708,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 iter575 in self.part_vals:
- oprot.writeString(iter575)
+ for iter582 in self.part_vals:
+ oprot.writeString(iter582)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -14258,10 +14304,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype579, _size576) = iprot.readListBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString();
- self.part_vals.append(_elem581)
+ (_etype586, _size583) = iprot.readListBegin()
+ for _i587 in xrange(_size583):
+ _elem588 = iprot.readString();
+ self.part_vals.append(_elem588)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14291,8 +14337,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 iter582 in self.part_vals:
- oprot.writeString(iter582)
+ for iter589 in self.part_vals:
+ oprot.writeString(iter589)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -14465,10 +14511,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype586, _size583) = iprot.readListBegin()
- for _i587 in xrange(_size583):
- _elem588 = iprot.readString();
- self.part_vals.append(_elem588)
+ (_etype593, _size590) = iprot.readListBegin()
+ for _i594 in xrange(_size590):
+ _elem595 = iprot.readString();
+ self.part_vals.append(_elem595)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14504,8 +14550,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 iter589 in self.part_vals:
- oprot.writeString(iter589)
+ for iter596 in self.part_vals:
+ oprot.writeString(iter596)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -15242,10 +15288,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = iprot.readString();
- self.part_vals.append(_elem595)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = iprot.readString();
+ self.part_vals.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15270,8 +15316,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 iter596 in self.part_vals:
- oprot.writeString(iter596)
+ for iter603 in self.part_vals:
+ oprot.writeString(iter603)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15430,11 +15476,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype598, _vtype599, _size597 ) = iprot.readMapBegin()
- for _i601 in xrange(_size597):
- _key602 = iprot.readString();
- _val603 = iprot.readString();
- self.partitionSpecs[_key602] = _val603
+ (_ktype605, _vtype606, _size604 ) = iprot.readMapBegin()
+ for _i608 in xrange(_size604):
+ _key609 = iprot.readString();
+ _val610 = iprot.readString();
+ self.partitionSpecs[_key609] = _val610
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -15471,9 +15517,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 kiter604,viter605 in self.partitionSpecs.items():
- oprot.writeString(kiter604)
- oprot.writeString(viter605)
+ for kiter611,viter612 in self.partitionSpecs.items():
+ oprot.writeString(kiter611)
+ oprot.writeString(viter612)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -15688,10 +15734,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype609, _size606) = iprot.readListBegin()
- for _i610 in xrange(_size606):
- _elem611 = iprot.readString();
- self.part_vals.append(_elem611)
+ (_etype616, _size613) = iprot.readListBegin()
+ for _i617 in xrange(_size613):
+ _elem618 = iprot.readString();
+ self.part_vals.append(_elem618)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15703,10 +15749,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype615, _size612) = iprot.readListBegin()
- for _i616 in xrange(_size612):
- _elem617 = iprot.readString();
- self.group_names.append(_elem617)
+ (_etype622, _size619) = iprot.readListBegin()
+ for _i623 in xrange(_size619):
+ _elem624 = iprot.readString();
+ self.group_names.append(_elem624)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15731,8 +15777,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 iter618 in self.part_vals:
- oprot.writeString(iter618)
+ for iter625 in self.part_vals:
+ oprot.writeString(iter625)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -15742,8 +15788,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 iter619 in self.group_names:
- oprot.writeString(iter619)
+ for iter626 in self.group_names:
+ oprot.writeString(iter626)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16172,11 +16218,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype623, _size620) = iprot.readListBegin()
- for _i624 in xrange(_size620):
- _elem625 = Partition()
- _elem625.read(iprot)
- self.success.append(_elem625)
+ (_etype630, _size627) = iprot.readListBegin()
+ for _i631 in xrange(_size627):
+ _elem632 = Partition()
+ _elem632.read(iprot)
+ self.success.append(_elem632)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16205,8 +16251,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 iter626 in self.success:
- iter626.write(oprot)
+ for iter633 in self.success:
+ iter633.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16300,10 +16346,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype630, _size627) = iprot.readListBegin()
- for _i631 in xrange(_size627):
- _elem632 = iprot.readString();
- self.group_names.append(_elem632)
+ (_etype637, _size634) = iprot.readListBegin()
+ for _i638 in xrange(_size634):
+ _elem639 = iprot.readString();
+ self.group_names.append(_elem639)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16336,8 +16382,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 iter633 in self.group_names:
- oprot.writeString(iter633)
+ for iter640 in self.group_names:
+ oprot.writeString(iter640)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16398,11 +16444,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype637, _size634) = iprot.readListBegin()
- for _i638 in xrange(_size634):
- _elem639 = Partition()
- _elem639.read(iprot)
- self.success.append(_elem639)
+ (_etype644, _size641) = iprot.readListBegin()
+ for _i645 in xrange(_size641):
+ _elem646 = Partition()
+ _elem646.read(iprot)
+ self.success.append(_elem646)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16431,8 +16477,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 iter640 in self.success:
- iter640.write(oprot)
+ for iter647 in self.success:
+ iter647.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16590,11 +16636,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype644, _size641) = iprot.readListBegin()
- for _i645 in xrange(_size641):
- _elem646 = PartitionSpec()
- _elem646.read(iprot)
- self.success.append(_elem646)
+ (_etype651, _size648) = iprot.readListBegin()
+ for _i652 in xrange(_size648):
+ _elem653 = PartitionSpec()
+ _elem653.read(iprot)
+ self.success.append(_elem653)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16623,8 +16669,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 iter647 in self.success:
- iter647.write(oprot)
+ for iter654 in self.success:
+ iter654.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16779,10 +16825,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype651, _size648) = iprot.readListBegin()
- for _i652 in xrange(_size648):
- _elem653 = iprot.readString();
- self.success.append(_elem653)
+ (_etype658, _size655) = iprot.readListBegin()
+ for _i659 in xrange(_size655):
+ _elem660 = iprot.readString();
+ self.success.append(_elem660)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16805,8 +16851,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 iter654 in self.success:
- oprot.writeString(iter654)
+ for iter661 in self.success:
+ oprot.writeString(iter661)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -16882,10 +16928,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype658, _size655) = iprot.readListBegin()
- for _i659 in xrange(_size655):
- _elem660 = iprot.readString();
- self.part_vals.append(_elem660)
+ (_etype665, _size662) = iprot.readListBegin()
+ for _i666 in xrange(_size662):
+ _elem667 = iprot.readString();
+ self.part_vals.append(_elem667)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16915,8 +16961,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 iter661 in self.part_vals:
- oprot.writeString(iter661)
+ for iter668 in self.part_vals:
+ oprot.writeString(iter668)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -16980,11 +17026,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype665, _size662) = iprot.readListBegin()
- for _i666 in xrange(_size662):
- _elem667 = Partition()
- _elem667.read(iprot)
- self.success.append(_elem667)
+ (_etype672, _size669) = iprot.readListBegin()
+ for _i673 in xrange(_size669):
+ _elem674 = Partition()
+ _elem674.read(iprot)
+ self.success.append(_elem674)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17013,8 +17059,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 iter668 in self.success:
- iter668.write(oprot)
+ for iter675 in self.success:
+ iter675.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17101,10 +17147,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype672, _size669) = iprot.readListBegin()
- for _i673 in xrange(_size669):
- _elem674 = iprot.readString();
- self.part_vals.append(_elem674)
+ (_etype679, _size676) = iprot.readListBegin()
+ for _i680 in xrange(_size676):
+ _elem681 = iprot.readString();
+ self.part_vals.append(_elem681)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17121,10 +17167,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype678, _size675) = iprot.readListBegin()
- for _i679 in xrange(_size675):
- _elem680 = iprot.readString();
- self.group_names.append(_elem680)
+ (_etype685, _size682) = iprot.readListBegin()
+ for _i686 in xrange(_size682):
+ _elem687 = iprot.readString();
+ self.group_names.append(_elem687)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17149,8 +17195,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 iter681 in self.part_vals:
- oprot.writeString(iter681)
+ for iter688 in self.part_vals:
+ oprot.writeString(iter688)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -17164,8 +17210,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 iter682 in self.group_names:
- oprot.writeString(iter682)
+ for iter689 in self.group_names:
+ oprot.writeString(iter689)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17227,11 +17273,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype686, _size683) = iprot.readListBegin()
- for _i687 in xrange(_size683):
- _elem688 = Partition()
- _elem688.read(iprot)
- self.success.append(_elem688)
+ (_etype693, _size690) = iprot.readListBegin()
+ for _i694 in xrange(_size690):
+ _elem695 = Partition()
+ _elem695.read(iprot)
+ self.success.append(_elem695)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17260,8 +17306,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 iter689 in self.success:
- iter689.write(oprot)
+ for iter696 in self.success:
+ iter696.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17342,10 +17388,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype693, _size690) = iprot.readListBegin()
- for _i694 in xrange(_size690):
- _elem695 = iprot.readString();
- self.part_vals.append(_elem695)
+ (_etype700, _size697) = iprot.readListBegin()
+ for _i701 in xrange(_size697):
+ _elem702 = iprot.readString();
+ self.part_vals.append(_elem702)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17375,8 +17421,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 iter696 in self.part_vals:
- oprot.writeString(iter696)
+ for iter703 in self.part_vals:
+ oprot.writeString(iter703)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -17440,10 +17486,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype700, _size697) = iprot.readListBegin()
- for _i701 in xrange(_size697):
- _elem702 = iprot.readString();
- self.success.append(_elem702)
+ (_etype707, _size704) = iprot.readListBegin()
+ for _i708 in xrange(_size704):
+ _elem709 = iprot.readString();
+ self.success.append(_elem709)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17472,8 +17518,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 iter703 in self.success:
- oprot.writeString(iter703)
+ for iter710 in self.success:
+ oprot.writeString(iter710)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17644,11 +17690,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype707, _size704) = iprot.readListBegin()
- for _i708 in xrange(_size704):
- _elem709 = Partition()
- _elem709.read(iprot)
- self.success.append(_elem709)
+ (_etype714, _size711) = iprot.readListBegin()
+ for _i715 in xrange(_size711):
+ _elem716 = Partition()
+ _elem716.read(iprot)
+ self.success.append(_elem716)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17677,8 +17723,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 iter710 in self.success:
- iter710.write(oprot)
+ for iter717 in self.success:
+ iter717.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17849,11 +17895,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype714, _size711) = iprot.readListBegin()
- for _i715 in xrange(_size711):
- _elem716 = PartitionSpec()
- _elem716.read(iprot)
- self.success.append(_elem716)
+ (_etype721, _size718) = iprot.readListBegin()
+ for _i722 in xrange(_size718):
+ _elem723 = PartitionSpec()
+ _elem723.read(iprot)
+ self.success.append(_elem723)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17882,8 +17928,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 iter717 in self.success:
- iter717.write(oprot)
+ for iter724 in self.success:
+ iter724.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18120,10 +18166,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype721, _size718) = iprot.readListBegin()
- for _i722 in xrange(_size718):
- _elem723 = iprot.readString();
- self.names.append(_elem723)
+ (_etype728, _size725) = iprot.readListBegin()
+ for _i729 in xrange(_size725):
+ _elem730 = iprot.readString();
+ self.names.append(_elem730)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18148,8 +18194,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 iter724 in self.names:
- oprot.writeString(iter724)
+ for iter731 in self.names:
+ oprot.writeString(iter731)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18208,11 +18254,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype728, _size725) = iprot.readListBegin()
- for _i729 in xrange(_size725):
- _elem730 = Partition()
- _elem730.read(iprot)
- self.success.append(_elem730)
+ (_etype735, _size732) = iprot.readListBegin()
+ for _i736 in xrange(_size732):
+ _elem737 = Partition()
+ _elem737.read(iprot)
+ self.success.append(_elem737)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18241,8 +18287,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 iter731 in self.success:
- iter731.write(oprot)
+ for iter738 in self.success:
+ iter738.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18492,11 +18538,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype735, _size732) = iprot.readListBegin()
- for _i736 in xrange(_size732):
- _elem737 = Partition()
- _elem737.read(iprot)
- self.new_parts.append(_elem737)
+ (_etype742, _size739) = iprot.readListBegin()
+ for _i743 in xrange(_size739):
+ _elem744 = Partition()
+ _elem744.read(iprot)
+ self.new_parts.append(_elem744)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18521,8 +18567,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 iter738 in self.new_parts:
- iter738.write(oprot)
+ for iter745 in self.new_parts:
+ iter745.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18861,10 +18907,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype742, _size739) = iprot.readListBegin()
- for _i743 in xrange(_size739):
- _elem744 = iprot.readString();
- self.part_vals.append(_elem744)
+ (_etype749, _size746) = iprot.readListBegin()
+ for _i750 in xrange(_size746):
+ _elem751 = iprot.readString();
+ self.part_vals.append(_elem751)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18895,8 +18941,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 iter745 in self.part_vals:
- oprot.writeString(iter745)
+ for iter752 in self.part_vals:
+ oprot.writeString(iter752)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -19038,10 +19084,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype749, _size746) = iprot.readListBegin()
- for _i750 in xrange(_size746):
- _elem751 = iprot.readString();
- self.part_vals.append(_elem751)
+ (_etype756, _size753) = iprot.readListBegin()
+ for _i757 in xrange(_size753):
+ _elem758 = iprot.readString();
+ self.part_vals.append(_elem758)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19063,8 +19109,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 iter752 in self.part_vals:
- oprot.writeString(iter752)
+ for iter759 in self.part_vals:
+ oprot.writeString(iter759)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -19422,10 +19468,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype756, _size753) = iprot.readListBegin()
- for _i757 in xrange(_size753):
- _elem758 = iprot.readString();
- self.success.append(_elem758)
+ (_etype763, _size760) = iprot.readListBegin()
+ for _i764 in xrange(_size760):
+ _elem765 = iprot.readString();
+ self.success.append(_elem765)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19448,8 +19494,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 iter759 in self.success:
- oprot.writeString(iter759)
+ for iter766 in self.success:
+ oprot.writeString(iter766)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19573,11 +19619,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype761, _vtype762, _size760 ) = iprot.readMapBegin()
- for _i764 in xrange(_size760):
- _key765 = iprot.readString();
- _val766 = iprot.readString();
- self.success[_key765] = _val766
+ (_ktype768, _vtype769, _size767 ) = iprot.readMapBegin()
+ for _i771 in xrange(_size767):
+ _key772 = iprot.readString();
+ _val773 = iprot.readString();
+ self.success[_key772] = _val773
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19600,9 +19646,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 kiter767,viter768 in self.success.items():
- oprot.writeString(kiter767)
- oprot.writeString(viter768)
+ for kiter774,viter775 in self.success.items():
+ oprot.writeString(kiter774)
+ oprot.writeString(viter775)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19678,11 +19724,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype770, _vtype771, _size769 ) = iprot.readMapBegin()
- for _i773 in xrange(_size769):
- _key774 = iprot.readString();
- _val775 = iprot.readString();
- self.part_vals[_key774] = _val775
+ (_ktype777, _vtype778, _size776 ) = iprot.readMapBegin()
+ for _i780 in xrange(_size776):
+ _key781 = iprot.readString();
+ _val782 = iprot.readString();
+ self.part_vals[_key781] = _val782
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19712,9 +19758,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 kiter776,viter777 in self.part_vals.items():
- oprot.writeString(kiter776)
- oprot.writeString(viter777)
+ for kiter783,viter784 in self.part_vals.items():
+ oprot.writeString(kiter783)
+ oprot.writeString(viter784)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -19928,11 +19974,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype779, _vtype780, _size778 ) = iprot.readMapBegin()
- for _i782 in xrange(_size778):
- _key783 = iprot.readString();
- _val784 = iprot.readString();
- self.part_vals[_key783] = _val784
+ (_ktype786, _vtype787, _size785 ) = iprot.readMapBegin()
+ for _i789 in xrange(_size785):
+ _key790 = iprot.readString();
+ _val791 = iprot.readString();
+ self.part_vals[_key790] = _val791
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19962,9 +20008,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 kiter785,viter786 in self.part_vals.items():
- oprot.writeString(kiter785)
- oprot.writeString(viter786)
+ for kiter792,viter793 in self.part_vals.items():
+ oprot.writeString(kiter792)
+ oprot.writeString(viter793)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -21019,11 +21065,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype790, _size787) = iprot.readListBegin()
- for _i791 in xrange(_size787):
- _elem792 = Index()
- _elem792.read(iprot)
- self.success.append(_elem792)
+ (_etype797, _size794) = iprot.readListBegin()
+ for _i798 in xrange(_size794):
+ _elem799 = Index()
+ _elem799.read(iprot)
+ self.success.append(_elem799)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21052,8 +21098,8 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter793 in self.success:
- iter793.write(oprot)
+ for iter800 in self.success:
+ iter800.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21208,10 +21254,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype797, _size794) = iprot.readListBegin()
- for _i798 in xrange(_size794):
- _elem799 = iprot.readString();
- self.success.append(_elem799)
+ (_etype804, _size801) = iprot.readListBegin()
+ for _i805 in xrange(_size801):
+ _elem806 = iprot.readString();
+ self.success.append(_elem806)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21234,8 +21280,8 @@ class get_index_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter800 in self.success:
- oprot.writeString(iter800)
+ for iter807 in self.success:
+ oprot.writeString(iter807)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -23783,10 +23829,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype804, _size801) = iprot.readListBegin()
- for _i805 in xrange(_size801):
- _elem806 = iprot.readString();
- self.success.append(_elem806)
+ (_etype811, _size808) = iprot.readListBegin()
+ for _i812 in xrange(_size808):
+ _elem813 = iprot.readString();
+ self.success.append(_elem813)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23809,8 +23855,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 iter807 in self.success:
- oprot.writeString(iter807)
+ for iter814 in self.success:
+ oprot.writeString(iter814)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24012,6 +24058,131 @@ class get_function_result:
def __ne__(self, other):
return not (self == other)
+class get_all_functions_args:
+
+ thrift_spec = (
+ )
+
+ 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
+ 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_all_functions_args')
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ 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_all_functions_result:
+ """
+ Attributes:
+ - success
+ - o1
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (GetAllFunctionsResponse, GetAllFunctionsResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, o1=None,):
+ self.success = success
+ self.o1 = o1
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = GetAllFunctionsResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_all_functions_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ 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 create_role_args:
"""
Attributes:
@@ -24373,10 +24544,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype811, _size808) = iprot.readListBegin()
- for _i812 in xrange(_size808):
- _elem813 = iprot.readString();
- self.success.append(_elem813)
+ (_etype818, _size815) = iprot.readListBegin()
+ for _i819 in xrange(_size815):
+ _elem820 = iprot.readString();
+ self.success.append(_elem820)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24399,8 +24570,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 iter814 in self.success:
- oprot.writeString(iter814)
+ for iter821 in self.success:
+ oprot.writeString(iter821)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24914,11 +25085,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype818, _size815) = iprot.readListBegin()
- for _i819 in xrange(_size815):
- _elem820 = Role()
- _elem820.read(iprot)
- self.success.append(_elem820)
+ (_etype825, _size822) = iprot.readListBegin()
+ for _i826 in xrange(_size822):
+ _elem827 = Role()
+ _elem827.read(iprot)
+ self.success.append(_elem827)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24941,8 +25112,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 iter821 in self.success:
- iter821.write(oprot)
+ for iter828 in self.success:
+ iter828.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25451,10 +25622,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype825, _size822) = iprot.readListBegin()
- for _i826 in xrange(_size822):
- _elem827 = iprot.readString();
- self.group_names.append(_elem827)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = iprot.readString();
+ self.group_names.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25479,8 +25650,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 iter828 in self.group_names:
- oprot.writeString(iter828)
+ for iter835 in self.group_names:
+ oprot.writeString(iter835)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25707,11 +25878,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype832, _size829) = iprot.readListBegin()
- for _i833 in xrange(_size829):
- _elem834 = HiveObjectPrivilege()
- _elem834.read(iprot)
- self.success.append(_elem834)
+ (_etype839, _size836) = iprot.readListBegin()
+ for _i840 in xrange(_size836):
+ _elem841 = HiveObjectPrivilege()
+ _elem841.read(iprot)
+ self.success.append(_elem841)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25734,8 +25905,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 iter835 in self.success:
- iter835.write(oprot)
+ for iter842 in self.success:
+ iter842.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26233,10 +26404,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype839, _size836) = iprot.readListBegin()
- for _i840 in xrange(_size836):
- _elem841 = iprot.readString();
- self.group_names.append(_elem841)
+ (_etype846, _size843) = iprot.readListBegin()
+ for _i847 in xrange(_size843):
+ _elem848 = iprot.readString();
+ self.group_names.append(_elem848)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26257,8 +26428,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 iter842 in self.group_names:
- oprot.writeString(iter842)
+ for iter849 in self.group_names:
+ oprot.writeString(iter849)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26313,10 +26484,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype846, _size843) = iprot.readListBegin()
- for _i847 in xrange(_size843):
- _elem848 = iprot.readString();
- self.success.append(_elem848)
+ (_etype853, _size850) = iprot.readListBegin()
+ for _i854 in xrange(_size850):
+ _elem855 = iprot.readString();
+ self.success.append(_elem855)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26339,8 +26510,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 iter849 in self.success:
- oprot.writeString(iter849)
+ for iter856 in self.success:
+ oprot.writeString(iter856)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
index 64cd4a0..0b80390 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -9750,6 +9750,80 @@ class FireEventResponse:
def __ne__(self, other):
return not (self == other)
+class GetAllFunctionsResponse:
+ """
+ Attributes:
+ - functions
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'functions', (TType.STRUCT,(Function, Function.thrift_spec)), None, ), # 1
+ )
+
+ def __init__(self, functions=None,):
+ self.functions = functions
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.LIST:
+ self.functions = []
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = Function()
+ _elem467.read(iprot)
+ self.functions.append(_elem467)
+ iprot.readListEnd()
+ 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('GetAllFunctionsResponse')
+ if self.functions is not None:
+ oprot.writeFieldBegin('functions', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.functions))
+ for iter468 in self.functions:
+ iter468.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.functions)
+ 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 MetaException(TException):
"""
Attributes:
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
index a1622ae..4bd4302 100644
--- a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
+++ b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
@@ -2231,6 +2231,22 @@ class FireEventResponse
::Thrift::Struct.generate_accessors self
end
+class GetAllFunctionsResponse
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ FUNCTIONS = 1
+
+ FIELDS = {
+ FUNCTIONS => {:type => ::Thrift::Types::LIST, :name => 'functions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Function}, :optional => true}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class MetaException < ::Thrift::Exception
include ::Thrift::Struct, ::Thrift::Struct_Union
def initialize(message=nil)
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb b/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
index 5645fe2..73a1d20 100644
--- a/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
+++ b/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
@@ -1523,6 +1523,22 @@ module ThriftHiveMetastore
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_function failed: unknown result')
end
+ def get_all_functions()
+ send_get_all_functions()
+ return recv_get_all_functions()
+ end
+
+ def send_get_all_functions()
+ send_message('get_all_functions', Get_all_functions_args)
+ end
+
+ def recv_get_all_functions()
+ result = receive_message(Get_all_functions_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_all_functions failed: unknown result')
+ end
+
def create_role(role)
send_create_role(role)
return recv_create_role()
@@ -3293,6 +3309,17 @@ module ThriftHiveMetastore
write_result(result, oprot, 'get_function', seqid)
end
+ def process_get_all_functions(seqid, iprot, oprot)
+ args = read_args(iprot, Get_all_functions_args)
+ result = Get_all_functions_result.new()
+ begin
+ result.success = @handler.get_all_functions()
+ rescue ::MetaException => o1
+ result.o1 = o1
+ end
+ write_result(result, oprot, 'get_all_functions', seqid)
+ end
+
def process_create_role(seqid, iprot, oprot)
args = read_args(iprot, Create_role_args)
result = Create_role_result.new()
@@ -7143,6 +7170,39 @@ module ThriftHiveMetastore
::Thrift::Struct.generate_accessors self
end
+ class Get_all_functions_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+
+ FIELDS = {
+
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_all_functions_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::GetAllFunctionsResponse},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
class Create_role_args
include ::Thrift::Struct, ::Thrift::Struct_Union
ROLE = 1
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
index 72a837c..b33cb58 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
@@ -68,6 +68,7 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema;
import org.apache.hadoop.hive.metastore.api.FireEventRequest;
import org.apache.hadoop.hive.metastore.api.FireEventResponse;
import org.apache.hadoop.hive.metastore.api.Function;
+import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsResponse;
import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest;
@@ -5537,6 +5538,26 @@ public class HiveMetaStore extends ThriftHiveMetastore {
}
@Override
+ public GetAllFunctionsResponse get_all_functions()
+ throws MetaException {
+ GetAllFunctionsResponse response = new GetAllFunctionsResponse();
+ startFunction("get_all_functions");
+ RawStore ms = getMS();
+ List<Function> allFunctions = null;
+ Exception ex = null;
+ try {
+ allFunctions = ms.getAllFunctions();
+ } catch (Exception e) {
+ ex = e;
+ throw newMetaException(e);
+ } finally {
+ endFunction("get_all_functions", allFunctions != null, ex);
+ }
+ response.setFunctions(allFunctions);
+ return response;
+ }
+
+ @Override
public Function get_function(String dbName, String funcName)
throws MetaException, NoSuchObjectException, TException {
startFunction("get_function", ": " + dbName + "." + funcName);
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index 66fbfe4..482f278 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -76,6 +76,7 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema;
import org.apache.hadoop.hive.metastore.api.FireEventRequest;
import org.apache.hadoop.hive.metastore.api.FireEventResponse;
import org.apache.hadoop.hive.metastore.api.Function;
+import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse;
import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest;
import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleResponse;
@@ -2044,6 +2045,12 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
return client.get_functions(dbName, pattern);
}
+ @Override
+ public GetAllFunctionsResponse getAllFunctions()
+ throws MetaException, TException {
+ return client.get_all_functions();
+ }
+
protected void create_table_with_environment_context(Table tbl, EnvironmentContext envContext)
throws AlreadyExistsException, InvalidObjectException,
MetaException, NoSuchObjectException, TException {
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
index 9bf4bfb..5fde6d3 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
@@ -37,6 +37,7 @@ import org.apache.hadoop.hive.metastore.api.FieldSchema;
import org.apache.hadoop.hive.metastore.api.FireEventRequest;
import org.apache.hadoop.hive.metastore.api.FireEventResponse;
import org.apache.hadoop.hive.metastore.api.Function;
+import org.apache.hadoop.hive.metastore.api.GetAllFunctionsResponse;
import org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse;
import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleRequest;
import org.apache.hadoop.hive.metastore.api.GetPrincipalsInRoleResponse;
@@ -1130,6 +1131,9 @@ public interface IMetaStoreClient {
List<String> getFunctions(String dbName, String pattern)
throws MetaException, TException;
+ GetAllFunctionsResponse getAllFunctions()
+ throws MetaException, TException;
+
/**
* Get a structure that details valid transactions.
* @return list of valid transactions
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
index 39ab9e7..a37fbde 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
@@ -7098,6 +7098,17 @@ public class ObjectStore implements RawStore, Configurable {
return func;
}
+ private List<Function> convertToFunctions(List<MFunction> mfuncs) {
+ if (mfuncs == null) {
+ return null;
+ }
+ List<Function> functions = new ArrayList<>();
+ for (MFunction mfunc : mfuncs) {
+ functions.add(convertToFunction(mfunc));
+ }
+ return functions;
+ }
+
private MFunction convertToMFunction(Function func) throws InvalidObjectException {
if (func == null) {
return null;
@@ -7257,6 +7268,23 @@ public class ObjectStore implements RawStore, Configurable {
}
@Override
+ public List<Function> getAllFunctions() throws MetaException {
+ boolean commited = false;
+ try {
+ openTransaction();
+ Query query = pm.newQuery(MFunction.class);
+ List<MFunction> allFunctions = (List<MFunction>) query.execute();
+ pm.retrieveAll(allFunctions);
+ commited = commitTransaction();
+ return convertToFunctions(allFunctions);
+ } finally {
+ if (!commited) {
+ rollbackTransaction();
+ }
+ }
+ }
+
+ @Override
public List<String> getFunctions(String dbName, String pattern) throws MetaException {
boolean commited = false;
Query query = null;
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
index 2b49eab..7c85eea 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
@@ -551,6 +551,13 @@ public interface RawStore extends Configurable {
public Function getFunction(String dbName, String funcName) throws MetaException;
/**
+ * Retrieve all functions.
+ * @return
+ * @throws MetaException
+ */
+ public List<Function> getAllFunctions() throws MetaException;
+
+ /**
* Retrieve list of function names based on name pattern.
* @param dbName
* @param pattern
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java
----------------------------------------------------------------------
diff --git a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java
index cf068e4..f184c56 100644
--- a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java
+++ b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreControlledCommit.java
@@ -19,6 +19,7 @@
package org.apache.hadoop.hive.metastore;
import java.util.ArrayList;
+import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.SortedSet;
@@ -719,6 +720,12 @@ public class DummyRawStoreControlledCommit implements RawStore, Configurable {
}
@Override
+ public List<Function> getAllFunctions()
+ throws MetaException {
+ return Collections.emptyList();
+ }
+
+ @Override
public List<String> getFunctions(String dbName, String pattern)
throws MetaException {
return objectStore.getFunctions(dbName, pattern);
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java
----------------------------------------------------------------------
diff --git a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java
index ccf928a..83fb4bb 100644
--- a/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java
+++ b/metastore/src/test/org/apache/hadoop/hive/metastore/DummyRawStoreForJdoConnection.java
@@ -733,6 +733,12 @@ public class DummyRawStoreForJdoConnection implements RawStore {
}
@Override
+ public List<Function> getAllFunctions()
+ throws MetaException {
+ return Collections.emptyList();
+ }
+
+ @Override
public List<String> getFunctions(String dbName, String pattern)
throws MetaException {
return Collections.emptyList();
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java
index b71f4ae..5ea9b6e 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Adjacency.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class Adjacency implements org.apache.thrift.TBase<Adjacency, Adjacency._Fields>, java.io.Serializable, Cloneable, Comparable<Adjacency> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Adjacency");
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java
index d02c86d..e621cfa 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Graph.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class Graph implements org.apache.thrift.TBase<Graph, Graph._Fields>, java.io.Serializable, Cloneable, Comparable<Graph> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Graph");
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java
index 52cccad..1b18aab 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class Operator implements org.apache.thrift.TBase<Operator, Operator._Fields>, java.io.Serializable, Cloneable, Comparable<Operator> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Operator");
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java
index bd6c7ca..5c5e0f8 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class Query implements org.apache.thrift.TBase<Query, Query._Fields>, java.io.Serializable, Cloneable, Comparable<Query> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Query");
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java
index 8bae7ad..d340d58 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/QueryPlan.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class QueryPlan implements org.apache.thrift.TBase<QueryPlan, QueryPlan._Fields>, java.io.Serializable, Cloneable, Comparable<QueryPlan> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("QueryPlan");
http://git-wip-us.apache.org/repos/asf/hive/blob/cb648903/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java
----------------------------------------------------------------------
diff --git a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java
index 82a2b92..7353933 100644
--- a/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java
+++ b/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
public class Stage implements org.apache.thrift.TBase<Stage, Stage._Fields>, java.io.Serializable, Cloneable, Comparable<Stage> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Stage");