Return-Path: X-Original-To: apmail-hive-commits-archive@www.apache.org Delivered-To: apmail-hive-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E0C2BDFCE for ; Thu, 8 Nov 2012 09:45:59 +0000 (UTC) Received: (qmail 26948 invoked by uid 500); 8 Nov 2012 09:45:59 -0000 Delivered-To: apmail-hive-commits-archive@hive.apache.org Received: (qmail 26790 invoked by uid 500); 8 Nov 2012 09:45:58 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 26619 invoked by uid 99); 8 Nov 2012 09:45:57 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Nov 2012 09:45:57 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Nov 2012 09:45:52 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id A41F92388C70 for ; Thu, 8 Nov 2012 09:44:46 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1406984 [16/29] - in /hive/trunk: contrib/src/java/org/apache/hadoop/hive/contrib/genericudf/example/ contrib/src/java/org/apache/hadoop/hive/contrib/serde2/ contrib/src/java/org/apache/hadoop/hive/contrib/util/typedbytes/ contrib/src/test... Date: Thu, 08 Nov 2012 09:44:29 -0000 To: commits@hive.apache.org From: hashutosh@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20121108094446.A41F92388C70@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: hive/trunk/metastore/src/gen/thrift/gen-py/__init__.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/__init__.py?rev=1406984&view=auto ============================================================================== (empty) Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Thu Nov 8 09:44:19 2012 @@ -1,9 +1,11 @@ #!/usr/bin/env python # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py +# import sys import pprint @@ -18,7 +20,7 @@ from ttypes import * if len(sys.argv) <= 1 or sys.argv[1] == '--help': print '' - print 'Usage: ' + sys.argv[0] + ' [-h host:port] [-u url] [-f[ramed]] function [arg1 [arg2...]]' + print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]' print '' print 'Functions:' print ' void create_database(Database database)' @@ -110,7 +112,8 @@ argi = 1 if sys.argv[argi] == '-h': parts = sys.argv[argi+1].split(':') host = parts[0] - port = int(parts[1]) + if len(parts) > 1: + port = int(parts[1]) argi += 2 if sys.argv[argi] == '-u': Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Thu Nov 8 09:44:19 2012 @@ -1,10 +1,12 @@ # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType, TException, TApplicationException import fb303.FacebookService from ttypes import * from thrift.Thrift import TProcessor @@ -3528,11 +3530,11 @@ class Processor(fb303.FacebookService.Pr result = create_database_result() try: self._handler.create_database(args.database) - except AlreadyExistsException, o1: + except AlreadyExistsException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("create_database", TMessageType.REPLY, seqid) result.write(oprot) @@ -3546,9 +3548,9 @@ class Processor(fb303.FacebookService.Pr result = get_database_result() try: result.success = self._handler.get_database(args.name) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_database", TMessageType.REPLY, seqid) result.write(oprot) @@ -3562,11 +3564,11 @@ class Processor(fb303.FacebookService.Pr result = drop_database_result() try: self._handler.drop_database(args.name, args.deleteData, args.cascade) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("drop_database", TMessageType.REPLY, seqid) result.write(oprot) @@ -3580,7 +3582,7 @@ class Processor(fb303.FacebookService.Pr result = get_databases_result() try: result.success = self._handler.get_databases(args.pattern) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_databases", TMessageType.REPLY, seqid) result.write(oprot) @@ -3594,7 +3596,7 @@ class Processor(fb303.FacebookService.Pr result = get_all_databases_result() try: result.success = self._handler.get_all_databases() - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_all_databases", TMessageType.REPLY, seqid) result.write(oprot) @@ -3608,9 +3610,9 @@ class Processor(fb303.FacebookService.Pr result = alter_database_result() try: self._handler.alter_database(args.dbname, args.db) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_database", TMessageType.REPLY, seqid) result.write(oprot) @@ -3624,9 +3626,9 @@ class Processor(fb303.FacebookService.Pr result = get_type_result() try: result.success = self._handler.get_type(args.name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_type", TMessageType.REPLY, seqid) result.write(oprot) @@ -3640,11 +3642,11 @@ class Processor(fb303.FacebookService.Pr result = create_type_result() try: result.success = self._handler.create_type(args.type) - except AlreadyExistsException, o1: + except AlreadyExistsException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("create_type", TMessageType.REPLY, seqid) result.write(oprot) @@ -3658,9 +3660,9 @@ class Processor(fb303.FacebookService.Pr result = drop_type_result() try: result.success = self._handler.drop_type(args.type) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("drop_type", TMessageType.REPLY, seqid) result.write(oprot) @@ -3674,7 +3676,7 @@ class Processor(fb303.FacebookService.Pr result = get_type_all_result() try: result.success = self._handler.get_type_all(args.name) - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_type_all", TMessageType.REPLY, seqid) result.write(oprot) @@ -3688,11 +3690,11 @@ class Processor(fb303.FacebookService.Pr result = get_fields_result() try: result.success = self._handler.get_fields(args.db_name, args.table_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 oprot.writeMessageBegin("get_fields", TMessageType.REPLY, seqid) result.write(oprot) @@ -3706,11 +3708,11 @@ class Processor(fb303.FacebookService.Pr result = get_schema_result() try: result.success = self._handler.get_schema(args.db_name, args.table_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except UnknownTableException, o2: + except UnknownTableException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 oprot.writeMessageBegin("get_schema", TMessageType.REPLY, seqid) result.write(oprot) @@ -3724,13 +3726,13 @@ class Processor(fb303.FacebookService.Pr result = create_table_result() try: self._handler.create_table(args.tbl) - except AlreadyExistsException, o1: + except AlreadyExistsException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 - except NoSuchObjectException, o4: + except NoSuchObjectException as o4: result.o4 = o4 oprot.writeMessageBegin("create_table", TMessageType.REPLY, seqid) result.write(oprot) @@ -3744,13 +3746,13 @@ class Processor(fb303.FacebookService.Pr result = create_table_with_environment_context_result() try: self._handler.create_table_with_environment_context(args.tbl, args.environment_context) - except AlreadyExistsException, o1: + except AlreadyExistsException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 - except NoSuchObjectException, o4: + except NoSuchObjectException as o4: result.o4 = o4 oprot.writeMessageBegin("create_table_with_environment_context", TMessageType.REPLY, seqid) result.write(oprot) @@ -3764,9 +3766,9 @@ class Processor(fb303.FacebookService.Pr result = drop_table_result() try: self._handler.drop_table(args.dbname, args.name, args.deleteData) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("drop_table", TMessageType.REPLY, seqid) result.write(oprot) @@ -3780,7 +3782,7 @@ class Processor(fb303.FacebookService.Pr result = get_tables_result() try: result.success = self._handler.get_tables(args.db_name, args.pattern) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_tables", TMessageType.REPLY, seqid) result.write(oprot) @@ -3794,7 +3796,7 @@ class Processor(fb303.FacebookService.Pr result = get_all_tables_result() try: result.success = self._handler.get_all_tables(args.db_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_all_tables", TMessageType.REPLY, seqid) result.write(oprot) @@ -3808,9 +3810,9 @@ class Processor(fb303.FacebookService.Pr result = get_table_result() try: result.success = self._handler.get_table(args.dbname, args.tbl_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_table", TMessageType.REPLY, seqid) result.write(oprot) @@ -3824,11 +3826,11 @@ class Processor(fb303.FacebookService.Pr result = get_table_objects_by_name_result() try: result.success = self._handler.get_table_objects_by_name(args.dbname, args.tbl_names) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 oprot.writeMessageBegin("get_table_objects_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -3842,11 +3844,11 @@ class Processor(fb303.FacebookService.Pr result = get_table_names_by_filter_result() try: result.success = self._handler.get_table_names_by_filter(args.dbname, args.filter, args.max_tables) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except InvalidOperationException, o2: + except InvalidOperationException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 oprot.writeMessageBegin("get_table_names_by_filter", TMessageType.REPLY, seqid) result.write(oprot) @@ -3860,9 +3862,9 @@ class Processor(fb303.FacebookService.Pr result = alter_table_result() try: self._handler.alter_table(args.dbname, args.tbl_name, args.new_tbl) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_table", TMessageType.REPLY, seqid) result.write(oprot) @@ -3876,9 +3878,9 @@ class Processor(fb303.FacebookService.Pr result = alter_table_with_environment_context_result() try: self._handler.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_table_with_environment_context", TMessageType.REPLY, seqid) result.write(oprot) @@ -3892,11 +3894,11 @@ class Processor(fb303.FacebookService.Pr result = add_partition_result() try: result.success = self._handler.add_partition(args.new_part) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("add_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -3910,11 +3912,11 @@ class Processor(fb303.FacebookService.Pr result = add_partition_with_environment_context_result() try: result.success = self._handler.add_partition_with_environment_context(args.new_part, args.environment_context) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("add_partition_with_environment_context", TMessageType.REPLY, seqid) result.write(oprot) @@ -3928,11 +3930,11 @@ class Processor(fb303.FacebookService.Pr result = add_partitions_result() try: result.success = self._handler.add_partitions(args.new_parts) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("add_partitions", TMessageType.REPLY, seqid) result.write(oprot) @@ -3946,11 +3948,11 @@ class Processor(fb303.FacebookService.Pr result = append_partition_result() try: result.success = self._handler.append_partition(args.db_name, args.tbl_name, args.part_vals) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("append_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -3964,11 +3966,11 @@ class Processor(fb303.FacebookService.Pr result = append_partition_by_name_result() try: result.success = self._handler.append_partition_by_name(args.db_name, args.tbl_name, args.part_name) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("append_partition_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -3982,9 +3984,9 @@ class Processor(fb303.FacebookService.Pr result = drop_partition_result() try: result.success = self._handler.drop_partition(args.db_name, args.tbl_name, args.part_vals, args.deleteData) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("drop_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -3998,9 +4000,9 @@ class Processor(fb303.FacebookService.Pr result = drop_partition_by_name_result() try: result.success = self._handler.drop_partition_by_name(args.db_name, args.tbl_name, args.part_name, args.deleteData) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("drop_partition_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -4014,9 +4016,9 @@ class Processor(fb303.FacebookService.Pr result = get_partition_result() try: result.success = self._handler.get_partition(args.db_name, args.tbl_name, args.part_vals) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -4030,9 +4032,9 @@ class Processor(fb303.FacebookService.Pr result = get_partition_with_auth_result() try: result.success = self._handler.get_partition_with_auth(args.db_name, args.tbl_name, args.part_vals, args.user_name, args.group_names) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partition_with_auth", TMessageType.REPLY, seqid) result.write(oprot) @@ -4046,9 +4048,9 @@ class Processor(fb303.FacebookService.Pr result = get_partition_by_name_result() try: result.success = self._handler.get_partition_by_name(args.db_name, args.tbl_name, args.part_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partition_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -4062,9 +4064,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_result() try: result.success = self._handler.get_partitions(args.db_name, args.tbl_name, args.max_parts) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions", TMessageType.REPLY, seqid) result.write(oprot) @@ -4078,9 +4080,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_with_auth_result() try: result.success = self._handler.get_partitions_with_auth(args.db_name, args.tbl_name, args.max_parts, args.user_name, args.group_names) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions_with_auth", TMessageType.REPLY, seqid) result.write(oprot) @@ -4094,7 +4096,7 @@ class Processor(fb303.FacebookService.Pr result = get_partition_names_result() try: result.success = self._handler.get_partition_names(args.db_name, args.tbl_name, args.max_parts) - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partition_names", TMessageType.REPLY, seqid) result.write(oprot) @@ -4108,9 +4110,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_ps_result() try: result.success = self._handler.get_partitions_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions_ps", TMessageType.REPLY, seqid) result.write(oprot) @@ -4124,9 +4126,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_ps_with_auth_result() try: result.success = self._handler.get_partitions_ps_with_auth(args.db_name, args.tbl_name, args.part_vals, args.max_parts, args.user_name, args.group_names) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions_ps_with_auth", TMessageType.REPLY, seqid) result.write(oprot) @@ -4140,9 +4142,9 @@ class Processor(fb303.FacebookService.Pr result = get_partition_names_ps_result() try: result.success = self._handler.get_partition_names_ps(args.db_name, args.tbl_name, args.part_vals, args.max_parts) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partition_names_ps", TMessageType.REPLY, seqid) result.write(oprot) @@ -4156,9 +4158,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_by_filter_result() try: result.success = self._handler.get_partitions_by_filter(args.db_name, args.tbl_name, args.filter, args.max_parts) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions_by_filter", TMessageType.REPLY, seqid) result.write(oprot) @@ -4172,9 +4174,9 @@ class Processor(fb303.FacebookService.Pr result = get_partitions_by_names_result() try: result.success = self._handler.get_partitions_by_names(args.db_name, args.tbl_name, args.names) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_partitions_by_names", TMessageType.REPLY, seqid) result.write(oprot) @@ -4188,9 +4190,9 @@ class Processor(fb303.FacebookService.Pr result = alter_partition_result() try: self._handler.alter_partition(args.db_name, args.tbl_name, args.new_part) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -4204,9 +4206,9 @@ class Processor(fb303.FacebookService.Pr result = alter_partitions_result() try: self._handler.alter_partitions(args.db_name, args.tbl_name, args.new_parts) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_partitions", TMessageType.REPLY, seqid) result.write(oprot) @@ -4220,9 +4222,9 @@ class Processor(fb303.FacebookService.Pr result = alter_partition_with_environment_context_result() try: self._handler.alter_partition_with_environment_context(args.db_name, args.tbl_name, args.new_part, args.environment_context) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_partition_with_environment_context", TMessageType.REPLY, seqid) result.write(oprot) @@ -4236,9 +4238,9 @@ class Processor(fb303.FacebookService.Pr result = rename_partition_result() try: self._handler.rename_partition(args.db_name, args.tbl_name, args.part_vals, args.new_part) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("rename_partition", TMessageType.REPLY, seqid) result.write(oprot) @@ -4252,7 +4254,7 @@ class Processor(fb303.FacebookService.Pr result = get_config_value_result() try: result.success = self._handler.get_config_value(args.name, args.defaultValue) - except ConfigValSecurityException, o1: + except ConfigValSecurityException as o1: result.o1 = o1 oprot.writeMessageBegin("get_config_value", TMessageType.REPLY, seqid) result.write(oprot) @@ -4266,7 +4268,7 @@ class Processor(fb303.FacebookService.Pr result = partition_name_to_vals_result() try: result.success = self._handler.partition_name_to_vals(args.part_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("partition_name_to_vals", TMessageType.REPLY, seqid) result.write(oprot) @@ -4280,7 +4282,7 @@ class Processor(fb303.FacebookService.Pr result = partition_name_to_spec_result() try: result.success = self._handler.partition_name_to_spec(args.part_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("partition_name_to_spec", TMessageType.REPLY, seqid) result.write(oprot) @@ -4294,17 +4296,17 @@ class Processor(fb303.FacebookService.Pr result = markPartitionForEvent_result() try: self._handler.markPartitionForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 - except UnknownTableException, o4: + except UnknownTableException as o4: result.o4 = o4 - except UnknownPartitionException, o5: + except UnknownPartitionException as o5: result.o5 = o5 - except InvalidPartitionException, o6: + except InvalidPartitionException as o6: result.o6 = o6 oprot.writeMessageBegin("markPartitionForEvent", TMessageType.REPLY, seqid) result.write(oprot) @@ -4318,17 +4320,17 @@ class Processor(fb303.FacebookService.Pr result = isPartitionMarkedForEvent_result() try: result.success = self._handler.isPartitionMarkedForEvent(args.db_name, args.tbl_name, args.part_vals, args.eventType) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 - except UnknownDBException, o3: + except UnknownDBException as o3: result.o3 = o3 - except UnknownTableException, o4: + except UnknownTableException as o4: result.o4 = o4 - except UnknownPartitionException, o5: + except UnknownPartitionException as o5: result.o5 = o5 - except InvalidPartitionException, o6: + except InvalidPartitionException as o6: result.o6 = o6 oprot.writeMessageBegin("isPartitionMarkedForEvent", TMessageType.REPLY, seqid) result.write(oprot) @@ -4342,11 +4344,11 @@ class Processor(fb303.FacebookService.Pr result = add_index_result() try: result.success = self._handler.add_index(args.new_index, args.index_table) - except InvalidObjectException, o1: + except InvalidObjectException as o1: result.o1 = o1 - except AlreadyExistsException, o2: + except AlreadyExistsException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 oprot.writeMessageBegin("add_index", TMessageType.REPLY, seqid) result.write(oprot) @@ -4360,9 +4362,9 @@ class Processor(fb303.FacebookService.Pr result = alter_index_result() try: self._handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx) - except InvalidOperationException, o1: + except InvalidOperationException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("alter_index", TMessageType.REPLY, seqid) result.write(oprot) @@ -4376,9 +4378,9 @@ class Processor(fb303.FacebookService.Pr result = drop_index_by_name_result() try: result.success = self._handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("drop_index_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -4392,9 +4394,9 @@ class Processor(fb303.FacebookService.Pr result = get_index_by_name_result() try: result.success = self._handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 - except NoSuchObjectException, o2: + except NoSuchObjectException as o2: result.o2 = o2 oprot.writeMessageBegin("get_index_by_name", TMessageType.REPLY, seqid) result.write(oprot) @@ -4408,9 +4410,9 @@ class Processor(fb303.FacebookService.Pr result = get_indexes_result() try: result.success = self._handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_indexes", TMessageType.REPLY, seqid) result.write(oprot) @@ -4424,7 +4426,7 @@ class Processor(fb303.FacebookService.Pr result = get_index_names_result() try: result.success = self._handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes) - except MetaException, o2: + except MetaException as o2: result.o2 = o2 oprot.writeMessageBegin("get_index_names", TMessageType.REPLY, seqid) result.write(oprot) @@ -4438,13 +4440,13 @@ class Processor(fb303.FacebookService.Pr result = update_table_column_statistics_result() try: result.success = self._handler.update_table_column_statistics(args.stats_obj) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 - except InvalidInputException, o4: + except InvalidInputException as o4: result.o4 = o4 oprot.writeMessageBegin("update_table_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4458,13 +4460,13 @@ class Processor(fb303.FacebookService.Pr result = update_partition_column_statistics_result() try: result.success = self._handler.update_partition_column_statistics(args.stats_obj) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except InvalidObjectException, o2: + except InvalidObjectException as o2: result.o2 = o2 - except MetaException, o3: + except MetaException as o3: result.o3 = o3 - except InvalidInputException, o4: + except InvalidInputException as o4: result.o4 = o4 oprot.writeMessageBegin("update_partition_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4478,13 +4480,13 @@ class Processor(fb303.FacebookService.Pr result = get_table_column_statistics_result() try: result.success = self._handler.get_table_column_statistics(args.db_name, args.tbl_name, args.col_name) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 - except InvalidInputException, o3: + except InvalidInputException as o3: result.o3 = o3 - except InvalidObjectException, o4: + except InvalidObjectException as o4: result.o4 = o4 oprot.writeMessageBegin("get_table_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4498,13 +4500,13 @@ class Processor(fb303.FacebookService.Pr result = get_partition_column_statistics_result() try: result.success = self._handler.get_partition_column_statistics(args.db_name, args.tbl_name, args.part_name, args.col_name) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 - except InvalidInputException, o3: + except InvalidInputException as o3: result.o3 = o3 - except InvalidObjectException, o4: + except InvalidObjectException as o4: result.o4 = o4 oprot.writeMessageBegin("get_partition_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4518,13 +4520,13 @@ class Processor(fb303.FacebookService.Pr result = delete_partition_column_statistics_result() try: result.success = self._handler.delete_partition_column_statistics(args.db_name, args.tbl_name, args.part_name, args.col_name) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 - except InvalidObjectException, o3: + except InvalidObjectException as o3: result.o3 = o3 - except InvalidInputException, o4: + except InvalidInputException as o4: result.o4 = o4 oprot.writeMessageBegin("delete_partition_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4538,13 +4540,13 @@ class Processor(fb303.FacebookService.Pr result = delete_table_column_statistics_result() try: result.success = self._handler.delete_table_column_statistics(args.db_name, args.tbl_name, args.col_name) - except NoSuchObjectException, o1: + except NoSuchObjectException as o1: result.o1 = o1 - except MetaException, o2: + except MetaException as o2: result.o2 = o2 - except InvalidObjectException, o3: + except InvalidObjectException as o3: result.o3 = o3 - except InvalidInputException, o4: + except InvalidInputException as o4: result.o4 = o4 oprot.writeMessageBegin("delete_table_column_statistics", TMessageType.REPLY, seqid) result.write(oprot) @@ -4558,7 +4560,7 @@ class Processor(fb303.FacebookService.Pr result = create_role_result() try: result.success = self._handler.create_role(args.role) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("create_role", TMessageType.REPLY, seqid) result.write(oprot) @@ -4572,7 +4574,7 @@ class Processor(fb303.FacebookService.Pr result = drop_role_result() try: result.success = self._handler.drop_role(args.role_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("drop_role", TMessageType.REPLY, seqid) result.write(oprot) @@ -4586,7 +4588,7 @@ class Processor(fb303.FacebookService.Pr result = get_role_names_result() try: result.success = self._handler.get_role_names() - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_role_names", TMessageType.REPLY, seqid) result.write(oprot) @@ -4600,7 +4602,7 @@ class Processor(fb303.FacebookService.Pr result = grant_role_result() try: result.success = self._handler.grant_role(args.role_name, args.principal_name, args.principal_type, args.grantor, args.grantorType, args.grant_option) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("grant_role", TMessageType.REPLY, seqid) result.write(oprot) @@ -4614,7 +4616,7 @@ class Processor(fb303.FacebookService.Pr result = revoke_role_result() try: result.success = self._handler.revoke_role(args.role_name, args.principal_name, args.principal_type) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("revoke_role", TMessageType.REPLY, seqid) result.write(oprot) @@ -4628,7 +4630,7 @@ class Processor(fb303.FacebookService.Pr result = list_roles_result() try: result.success = self._handler.list_roles(args.principal_name, args.principal_type) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("list_roles", TMessageType.REPLY, seqid) result.write(oprot) @@ -4642,7 +4644,7 @@ class Processor(fb303.FacebookService.Pr result = get_privilege_set_result() try: result.success = self._handler.get_privilege_set(args.hiveObject, args.user_name, args.group_names) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_privilege_set", TMessageType.REPLY, seqid) result.write(oprot) @@ -4656,7 +4658,7 @@ class Processor(fb303.FacebookService.Pr result = list_privileges_result() try: result.success = self._handler.list_privileges(args.principal_name, args.principal_type, args.hiveObject) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("list_privileges", TMessageType.REPLY, seqid) result.write(oprot) @@ -4670,7 +4672,7 @@ class Processor(fb303.FacebookService.Pr result = grant_privileges_result() try: result.success = self._handler.grant_privileges(args.privileges) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("grant_privileges", TMessageType.REPLY, seqid) result.write(oprot) @@ -4684,7 +4686,7 @@ class Processor(fb303.FacebookService.Pr result = revoke_privileges_result() try: result.success = self._handler.revoke_privileges(args.privileges) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("revoke_privileges", TMessageType.REPLY, seqid) result.write(oprot) @@ -4698,7 +4700,7 @@ class Processor(fb303.FacebookService.Pr result = set_ugi_result() try: result.success = self._handler.set_ugi(args.user_name, args.group_names) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("set_ugi", TMessageType.REPLY, seqid) result.write(oprot) @@ -4712,7 +4714,7 @@ class Processor(fb303.FacebookService.Pr result = get_delegation_token_result() try: result.success = self._handler.get_delegation_token(args.token_owner, args.renewer_kerberos_principal_name) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("get_delegation_token", TMessageType.REPLY, seqid) result.write(oprot) @@ -4726,7 +4728,7 @@ class Processor(fb303.FacebookService.Pr result = renew_delegation_token_result() try: result.success = self._handler.renew_delegation_token(args.token_str_form) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("renew_delegation_token", TMessageType.REPLY, seqid) result.write(oprot) @@ -4740,7 +4742,7 @@ class Processor(fb303.FacebookService.Pr result = cancel_delegation_token_result() try: self._handler.cancel_delegation_token(args.token_str_form) - except MetaException, o1: + except MetaException as o1: result.o1 = o1 oprot.writeMessageBegin("cancel_delegation_token", TMessageType.REPLY, seqid) result.write(oprot) Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py Thu Nov 8 09:44:19 2012 @@ -1,10 +1,12 @@ # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType, TException, TApplicationException from ttypes import * DDL_TIME = "transient_lastDdlTime" Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Thu Nov 8 09:44:19 2012 @@ -1,10 +1,12 @@ # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +# options string: py +# -from thrift.Thrift import * +from thrift.Thrift import TType, TMessageType, TException, TApplicationException import fb303.ttypes @@ -3199,7 +3201,7 @@ class EnvironmentContext: def __ne__(self, other): return not (self == other) -class MetaException(Exception): +class MetaException(TException): """ Attributes: - message @@ -3262,7 +3264,7 @@ class MetaException(Exception): def __ne__(self, other): return not (self == other) -class UnknownTableException(Exception): +class UnknownTableException(TException): """ Attributes: - message @@ -3325,7 +3327,7 @@ class UnknownTableException(Exception): def __ne__(self, other): return not (self == other) -class UnknownDBException(Exception): +class UnknownDBException(TException): """ Attributes: - message @@ -3388,7 +3390,7 @@ class UnknownDBException(Exception): def __ne__(self, other): return not (self == other) -class AlreadyExistsException(Exception): +class AlreadyExistsException(TException): """ Attributes: - message @@ -3451,7 +3453,7 @@ class AlreadyExistsException(Exception): def __ne__(self, other): return not (self == other) -class InvalidPartitionException(Exception): +class InvalidPartitionException(TException): """ Attributes: - message @@ -3514,7 +3516,7 @@ class InvalidPartitionException(Exceptio def __ne__(self, other): return not (self == other) -class UnknownPartitionException(Exception): +class UnknownPartitionException(TException): """ Attributes: - message @@ -3577,7 +3579,7 @@ class UnknownPartitionException(Exceptio def __ne__(self, other): return not (self == other) -class InvalidObjectException(Exception): +class InvalidObjectException(TException): """ Attributes: - message @@ -3640,7 +3642,7 @@ class InvalidObjectException(Exception): def __ne__(self, other): return not (self == other) -class NoSuchObjectException(Exception): +class NoSuchObjectException(TException): """ Attributes: - message @@ -3703,7 +3705,7 @@ class NoSuchObjectException(Exception): def __ne__(self, other): return not (self == other) -class IndexAlreadyExistsException(Exception): +class IndexAlreadyExistsException(TException): """ Attributes: - message @@ -3766,7 +3768,7 @@ class IndexAlreadyExistsException(Except def __ne__(self, other): return not (self == other) -class InvalidOperationException(Exception): +class InvalidOperationException(TException): """ Attributes: - message @@ -3829,7 +3831,7 @@ class InvalidOperationException(Exceptio def __ne__(self, other): return not (self == other) -class ConfigValSecurityException(Exception): +class ConfigValSecurityException(TException): """ Attributes: - message @@ -3892,7 +3894,7 @@ class ConfigValSecurityException(Excepti def __ne__(self, other): return not (self == other) -class InvalidInputException(Exception): +class InvalidInputException(TException): """ Attributes: - message Modified: hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb (original) +++ hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb Thu Nov 8 09:44:19 2012 @@ -1,9 +1,10 @@ # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +require 'thrift' require 'hive_metastore_types' DDL_TIME = %q"transient_lastDdlTime" Modified: hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb?rev=1406984&r1=1406983&r2=1406984&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb (original) +++ hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb Thu Nov 8 09:44:19 2012 @@ -1,9 +1,10 @@ # -# Autogenerated by Thrift Compiler (0.7.0) +# Autogenerated by Thrift Compiler (0.9.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # +require 'thrift' require 'fb303_types' @@ -80,7 +81,7 @@ class Type NAME => {:type => ::Thrift::Types::STRING, :name => 'name'}, TYPE1 => {:type => ::Thrift::Types::STRING, :name => 'type1', :optional => true}, TYPE2 => {:type => ::Thrift::Types::STRING, :name => 'type2', :optional => true}, - FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}, :optional => true} + FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}, :optional => true} } def struct_fields; FIELDS; end @@ -100,7 +101,7 @@ class HiveObjectRef COLUMNNAME = 5 FIELDS = { - OBJECTTYPE => {:type => ::Thrift::Types::I32, :name => 'objectType', :enum_class => HiveObjectType}, + OBJECTTYPE => {:type => ::Thrift::Types::I32, :name => 'objectType', :enum_class => ::HiveObjectType}, DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'}, OBJECTNAME => {:type => ::Thrift::Types::STRING, :name => 'objectName'}, PARTVALUES => {:type => ::Thrift::Types::LIST, :name => 'partValues', :element => {:type => ::Thrift::Types::STRING}}, @@ -110,7 +111,7 @@ class HiveObjectRef def struct_fields; FIELDS; end def validate - unless @objectType.nil? || HiveObjectType::VALID_VALUES.include?(@objectType) + unless @objectType.nil? || ::HiveObjectType::VALID_VALUES.include?(@objectType) raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field objectType!') end end @@ -130,14 +131,14 @@ class PrivilegeGrantInfo PRIVILEGE => {:type => ::Thrift::Types::STRING, :name => 'privilege'}, CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, GRANTOR => {:type => ::Thrift::Types::STRING, :name => 'grantor'}, - GRANTORTYPE => {:type => ::Thrift::Types::I32, :name => 'grantorType', :enum_class => PrincipalType}, + GRANTORTYPE => {:type => ::Thrift::Types::I32, :name => 'grantorType', :enum_class => ::PrincipalType}, GRANTOPTION => {:type => ::Thrift::Types::BOOL, :name => 'grantOption'} } def struct_fields; FIELDS; end def validate - unless @grantorType.nil? || PrincipalType::VALID_VALUES.include?(@grantorType) + unless @grantorType.nil? || ::PrincipalType::VALID_VALUES.include?(@grantorType) raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field grantorType!') end end @@ -153,16 +154,16 @@ class HiveObjectPrivilege GRANTINFO = 4 FIELDS = { - HIVEOBJECT => {:type => ::Thrift::Types::STRUCT, :name => 'hiveObject', :class => HiveObjectRef}, + HIVEOBJECT => {:type => ::Thrift::Types::STRUCT, :name => 'hiveObject', :class => ::HiveObjectRef}, PRINCIPALNAME => {:type => ::Thrift::Types::STRING, :name => 'principalName'}, - PRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'principalType', :enum_class => PrincipalType}, - GRANTINFO => {:type => ::Thrift::Types::STRUCT, :name => 'grantInfo', :class => PrivilegeGrantInfo} + PRINCIPALTYPE => {:type => ::Thrift::Types::I32, :name => 'principalType', :enum_class => ::PrincipalType}, + GRANTINFO => {:type => ::Thrift::Types::STRUCT, :name => 'grantInfo', :class => ::PrivilegeGrantInfo} } def struct_fields; FIELDS; end def validate - unless @principalType.nil? || PrincipalType::VALID_VALUES.include?(@principalType) + unless @principalType.nil? || ::PrincipalType::VALID_VALUES.include?(@principalType) raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field principalType!') end end @@ -175,7 +176,7 @@ class PrivilegeBag PRIVILEGES = 1 FIELDS = { - PRIVILEGES => {:type => ::Thrift::Types::LIST, :name => 'privileges', :element => {:type => ::Thrift::Types::STRUCT, :class => HiveObjectPrivilege}} + PRIVILEGES => {:type => ::Thrift::Types::LIST, :name => 'privileges', :element => {:type => ::Thrift::Types::STRUCT, :class => ::HiveObjectPrivilege}} } def struct_fields; FIELDS; end @@ -193,9 +194,9 @@ class PrincipalPrivilegeSet ROLEPRIVILEGES = 3 FIELDS = { - USERPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'userPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => PrivilegeGrantInfo}}}, - GROUPPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'groupPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => PrivilegeGrantInfo}}}, - ROLEPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'rolePrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => PrivilegeGrantInfo}}} + USERPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'userPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}}, + GROUPPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'groupPrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}}, + ROLEPRIVILEGES => {:type => ::Thrift::Types::MAP, :name => 'rolePrivileges', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => ::PrivilegeGrantInfo}}} } def struct_fields; FIELDS; end @@ -239,7 +240,7 @@ class Database DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description'}, LOCATIONURI => {:type => ::Thrift::Types::STRING, :name => 'locationUri'}, PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, - PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => PrincipalPrivilegeSet, :optional => true} + PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true} } def struct_fields; FIELDS; end @@ -323,17 +324,17 @@ class StorageDescriptor SKEWEDINFO = 11 FIELDS = { - COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}}, + COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, LOCATION => {:type => ::Thrift::Types::STRING, :name => 'location'}, INPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'inputFormat'}, OUTPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'outputFormat'}, COMPRESSED => {:type => ::Thrift::Types::BOOL, :name => 'compressed'}, NUMBUCKETS => {:type => ::Thrift::Types::I32, :name => 'numBuckets'}, - SERDEINFO => {:type => ::Thrift::Types::STRUCT, :name => 'serdeInfo', :class => SerDeInfo}, + SERDEINFO => {:type => ::Thrift::Types::STRUCT, :name => 'serdeInfo', :class => ::SerDeInfo}, BUCKETCOLS => {:type => ::Thrift::Types::LIST, :name => 'bucketCols', :element => {:type => ::Thrift::Types::STRING}}, - SORTCOLS => {:type => ::Thrift::Types::LIST, :name => 'sortCols', :element => {:type => ::Thrift::Types::STRUCT, :class => Order}}, + SORTCOLS => {:type => ::Thrift::Types::LIST, :name => 'sortCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::Order}}, PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, - SKEWEDINFO => {:type => ::Thrift::Types::STRUCT, :name => 'skewedInfo', :class => SkewedInfo, :optional => true} + SKEWEDINFO => {:type => ::Thrift::Types::STRUCT, :name => 'skewedInfo', :class => ::SkewedInfo, :optional => true} } def struct_fields; FIELDS; end @@ -367,13 +368,13 @@ class Table CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, RETENTION => {:type => ::Thrift::Types::I32, :name => 'retention'}, - SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor}, - PARTITIONKEYS => {:type => ::Thrift::Types::LIST, :name => 'partitionKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}}, + SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor}, + PARTITIONKEYS => {:type => ::Thrift::Types::LIST, :name => 'partitionKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, VIEWORIGINALTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewOriginalText'}, VIEWEXPANDEDTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewExpandedText'}, TABLETYPE => {:type => ::Thrift::Types::STRING, :name => 'tableType'}, - PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => PrincipalPrivilegeSet, :optional => true} + PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true} } def struct_fields; FIELDS; end @@ -401,9 +402,9 @@ class Partition TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}, CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, - SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor}, + SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor}, PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, - PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => PrincipalPrivilegeSet, :optional => true} + PRIVILEGES => {:type => ::Thrift::Types::STRUCT, :name => 'privileges', :class => ::PrincipalPrivilegeSet, :optional => true} } def struct_fields; FIELDS; end @@ -435,7 +436,7 @@ class Index CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'}, LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'}, INDEXTABLENAME => {:type => ::Thrift::Types::STRING, :name => 'indexTableName'}, - SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor}, + SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => ::StorageDescriptor}, PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}, DEFERREDREBUILD => {:type => ::Thrift::Types::BOOL, :name => 'deferredRebuild'} } @@ -603,11 +604,11 @@ class ColumnStatisticsData < ::Thrift::U BINARYSTATS = 5 FIELDS = { - BOOLEANSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'booleanStats', :class => BooleanColumnStatsData}, - LONGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'longStats', :class => LongColumnStatsData}, - DOUBLESTATS => {:type => ::Thrift::Types::STRUCT, :name => 'doubleStats', :class => DoubleColumnStatsData}, - STRINGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'stringStats', :class => StringColumnStatsData}, - BINARYSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'binaryStats', :class => BinaryColumnStatsData} + BOOLEANSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'booleanStats', :class => ::BooleanColumnStatsData}, + LONGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'longStats', :class => ::LongColumnStatsData}, + DOUBLESTATS => {:type => ::Thrift::Types::STRUCT, :name => 'doubleStats', :class => ::DoubleColumnStatsData}, + STRINGSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'stringStats', :class => ::StringColumnStatsData}, + BINARYSTATS => {:type => ::Thrift::Types::STRUCT, :name => 'binaryStats', :class => ::BinaryColumnStatsData} } def struct_fields; FIELDS; end @@ -628,7 +629,7 @@ class ColumnStatisticsObj FIELDS = { COLNAME => {:type => ::Thrift::Types::STRING, :name => 'colName'}, COLTYPE => {:type => ::Thrift::Types::STRING, :name => 'colType'}, - STATSDATA => {:type => ::Thrift::Types::STRUCT, :name => 'statsData', :class => ColumnStatisticsData} + STATSDATA => {:type => ::Thrift::Types::STRUCT, :name => 'statsData', :class => ::ColumnStatisticsData} } def struct_fields; FIELDS; end @@ -675,8 +676,8 @@ class ColumnStatistics STATSOBJ = 2 FIELDS = { - STATSDESC => {:type => ::Thrift::Types::STRUCT, :name => 'statsDesc', :class => ColumnStatisticsDesc}, - STATSOBJ => {:type => ::Thrift::Types::LIST, :name => 'statsObj', :element => {:type => ::Thrift::Types::STRUCT, :class => ColumnStatisticsObj}} + STATSDESC => {:type => ::Thrift::Types::STRUCT, :name => 'statsDesc', :class => ::ColumnStatisticsDesc}, + STATSOBJ => {:type => ::Thrift::Types::LIST, :name => 'statsObj', :element => {:type => ::Thrift::Types::STRUCT, :class => ::ColumnStatisticsObj}} } def struct_fields; FIELDS; end @@ -695,7 +696,7 @@ class Schema PROPERTIES = 2 FIELDS = { - FIELDSCHEMAS => {:type => ::Thrift::Types::LIST, :name => 'fieldSchemas', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}}, + FIELDSCHEMAS => {:type => ::Thrift::Types::LIST, :name => 'fieldSchemas', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}}, PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}} }