Index: conf/hive-default.xml.template
===================================================================
--- conf/hive-default.xml.template (revision 1242898)
+++ conf/hive-default.xml.template (working copy)
@@ -23,7 +23,7 @@
-
+
mapred.reduce.tasks
@@ -998,45 +998,45 @@
hive.security.authorization.manager
org.apache.hadoop.hive.ql.security.authorization.DefaultHiveAuthorizationProvider
the hive client authorization manager class name.
- The user defined authorization class should implement interface org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider.
+ The user defined authorization class should implement interface org.apache.hadoop.hive.ql.security.authorization.HiveAuthorizationProvider.
hive.security.authenticator.manager
org.apache.hadoop.hive.ql.security.HadoopDefaultAuthenticator
- hive client authenticator manager class name.
+ hive client authenticator manager class name.
The user defined authenticator should implement interface org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider.
hive.security.authorization.createtable.user.grants
- the privileges automatically granted to some users whenever a table gets created.
- An example like "userX,userY:select;userZ:create" will grant select privilege to userX and userY,
+ the privileges automatically granted to some users whenever a table gets created.
+ An example like "userX,userY:select;userZ:create" will grant select privilege to userX and userY,
and grant create privilege to userZ whenever a new table created.
hive.security.authorization.createtable.group.grants
- the privileges automatically granted to some groups whenever a table gets created.
- An example like "groupX,groupY:select;groupZ:create" will grant select privilege to groupX and groupY,
+ the privileges automatically granted to some groups whenever a table gets created.
+ An example like "groupX,groupY:select;groupZ:create" will grant select privilege to groupX and groupY,
and grant create privilege to groupZ whenever a new table created.
hive.security.authorization.createtable.role.grants
- the privileges automatically granted to some roles whenever a table gets created.
- An example like "roleX,roleY:select;roleZ:create" will grant select privilege to roleX and roleY,
+ the privileges automatically granted to some roles whenever a table gets created.
+ An example like "roleX,roleY:select;roleZ:create" will grant select privilege to roleX and roleY,
and grant create privilege to roleZ whenever a new table created.
hive.security.authorization.createtable.owner.grants
- the privileges automatically granted to the owner whenever a table gets created.
+ the privileges automatically granted to the owner whenever a table gets created.
An example like "select,drop" will grant select and drop privilege to the owner of the table
@@ -1044,7 +1044,7 @@
hive.metastore.authorization.storage.checks
false
Should the metastore do authorization checks against the underlying storage
- for operations like drop-partition (disallow the drop-partition if the user in
+ for operations like drop-partition (disallow the drop-partition if the user in
question doesn't have permissions to delete the corresponding directory
on the storage).
@@ -1058,7 +1058,7 @@
hive.index.compact.file.ignore.hdfs
false
- True the hdfs location stored in the index file will be igbored at runtime.
+ True the hdfs location stored in the index file will be igbored at runtime.
If the data got moved or the name of the cluster got changed, the index data should still be usable.
@@ -1102,7 +1102,7 @@
hive.lock.mapred.only.operation
false
- This param is to control whether or not only do lock on queries
+ This param is to control whether or not only do lock on queries
that need to execute at least one mapred job.
@@ -1136,7 +1136,7 @@
hive.rework.mapredwork
false
- should rework the mapred work or not.
+ should rework the mapred work or not.
This is first introduced by SymlinkTextInputFormat to replace symlink files with real paths at compile time.
@@ -1144,9 +1144,9 @@
hive.exec.concatenate.check.index
true
If this sets to true, hive will throw error when doing
- 'alter table tbl_name [partSpec] concatenate' on a table/partition
- that has indexes on it. The reason the user want to set this to true
- is because it can help user to avoid handling all index drop, recreation,
+ 'alter table tbl_name [partSpec] concatenate' on a table/partition
+ that has indexes on it. The reason the user want to set this to true
+ is because it can help user to avoid handling all index drop, recreation,
rebuild work. This is very helpful for tables with thousands of partitions.
@@ -1161,14 +1161,14 @@
hive.io.exception.handlers
A list of io exception handler class names. This is used
- to construct a list exception handlers to handle exceptions thrown
+ to construct a list exception handlers to handle exceptions thrown
by record readers
hive.autogen.columnalias.prefix.label
_c
- String used as a prefix when auto generating column alias.
+ String used as a prefix when auto generating column alias.
By default the prefix label will be appended with a column position number to form the column alias. Auto generation would happen if an aggregate function is used in a select clause without an explicit alias.
@@ -1199,7 +1199,7 @@
hive.insert.into.multilevel.dirs
false
- Where to insert into multilevel directories like
+ Where to insert into multilevel directories like
"insert directory '/HIVEFT25686/chinna/' from table"
@@ -1209,4 +1209,22 @@
The dfs.umask value for the hive created folders
+
+ hive.use.input.primary.region
+ true
+ When creating a table from an input table, create the table in the input table's primary region.
+
+
+
+ hive.default.region.name
+ default
+ The default region name
+
+
+
+ hive.region.properties
+
+ The default filesystem and jobtracker for a region
+
+
Index: metastore/scripts/upgrade/derby/010-HIVE-2612.derby.sql
===================================================================
--- metastore/scripts/upgrade/derby/010-HIVE-2612.derby.sql (revision 0)
+++ metastore/scripts/upgrade/derby/010-HIVE-2612.derby.sql (revision 0)
@@ -0,0 +1,27 @@
+/*
+ * HIVE-2612 support hive table/partitions exists in more than one region
+ */
+
+/*
+ * Creates the following table:
+ * - REGION_SDS
+ */
+CREATE TABLE "REGION_SDS" (
+ "SD_ID" bigint NOT NULL,
+ "REGION_NAME" varchar(512) NOT NULL,
+ "LOCATION" varchar(4000),
+ PRIMARY KEY ("SD_ID", "REGION_NAME")
+);
+
+ALTER TABLE "REGION_SDS"
+ ADD CONSTRAINT "REGION_SDS_FK1"
+ FOREIGN KEY ("SD_ID") REFERENCES "SDS" ("SD_ID")
+ ON DELETE NO ACTION ON UPDATE NO ACTION
+;
+
+/* Alter the SDS table to:
+ * - add the column PRIMARY_REGION_NAME
+ */
+ALTER TABLE SDS
+ ADD COLUMN PRIMARY_REGION_NAME varchar(512) NOT NULL DEFAULT ''
+;
Index: metastore/scripts/upgrade/derby/upgrade-0.9.0-to-0.10.0.derby.sql
===================================================================
--- metastore/scripts/upgrade/derby/upgrade-0.9.0-to-0.10.0.derby.sql (revision 0)
+++ metastore/scripts/upgrade/derby/upgrade-0.9.0-to-0.10.0.derby.sql (revision 0)
@@ -0,0 +1,2 @@
+-- Upgrade MetaStore schema from 0.9.0 to 0.10.0
+RUN '010-HIVE-2612.derby.sql';
Index: metastore/scripts/upgrade/derby/hive-schema-0.10.0.derby.sql
===================================================================
--- metastore/scripts/upgrade/derby/hive-schema-0.10.0.derby.sql (revision 0)
+++ metastore/scripts/upgrade/derby/hive-schema-0.10.0.derby.sql (revision 0)
@@ -0,0 +1,251 @@
+-- Timestamp: 2012-02-10 12:21:25.771
+-- Source database is: /home/kevinwilfong/hive/mdb
+-- Connection URL is: jdbc:derby:/home/kevinwilfong/hive/mdb
+-- appendLogs: false
+
+-- ----------------------------------------------
+-- DDL Statements for functions
+-- ----------------------------------------------
+
+CREATE FUNCTION "APP"."NUCLEUS_ASCII" ("C" CHAR(1)) RETURNS INTEGER LANGUAGE JAVA PARAMETER STYLE JAVA READS SQL DATA CALLED ON NULL INPUT EXTERNAL NAME 'org.datanucleus.store.rdbms.adapter.DerbySQLFunction.ascii' ;
+
+CREATE FUNCTION "APP"."NUCLEUS_MATCHES" ("TEXT" VARCHAR(8000),"PATTERN" VARCHAR(8000)) RETURNS INTEGER LANGUAGE JAVA PARAMETER STYLE JAVA READS SQL DATA CALLED ON NULL INPUT EXTERNAL NAME 'org.datanucleus.store.rdbms.adapter.DerbySQLFunction.matches' ;
+
+-- ----------------------------------------------
+-- DDL Statements for tables
+-- ----------------------------------------------
+
+CREATE TABLE "APP"."SDS" ("SD_ID" BIGINT NOT NULL, "INPUT_FORMAT" VARCHAR(4000), "IS_COMPRESSED" CHAR(1) NOT NULL, "LOCATION" VARCHAR(4000), "NUM_BUCKETS" INTEGER NOT NULL, "OUTPUT_FORMAT" VARCHAR(4000), "SERDE_ID" BIGINT, "CD_ID" BIGINT, "PRIMARY_REGION_NAME" VARCHAR(512) NOT NULL DEFAULT '');
+
+CREATE TABLE "APP"."ROLE_MAP" ("ROLE_GRANT_ID" BIGINT NOT NULL, "ADD_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "ROLE_ID" BIGINT);
+
+CREATE TABLE "APP"."ROLES" ("ROLE_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "OWNER_NAME" VARCHAR(128), "ROLE_NAME" VARCHAR(128));
+
+CREATE TABLE "APP"."TBL_COL_PRIVS" ("TBL_COLUMN_GRANT_ID" BIGINT NOT NULL, "COLUMN_NAME" VARCHAR(128), "CREATE_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "TBL_COL_PRIV" VARCHAR(128), "TBL_ID" BIGINT);
+
+CREATE TABLE "APP"."NUCLEUS_TABLES" ("CLASS_NAME" VARCHAR(128) NOT NULL, "TABLE_NAME" VARCHAR(128) NOT NULL, "TYPE" VARCHAR(4) NOT NULL, "OWNER" VARCHAR(2) NOT NULL, "VERSION" VARCHAR(20) NOT NULL, "INTERFACE_NAME" VARCHAR(256) DEFAULT NULL);
+
+CREATE TABLE "APP"."SERDES" ("SERDE_ID" BIGINT NOT NULL, "NAME" VARCHAR(128), "SLIB" VARCHAR(4000));
+
+CREATE TABLE "APP"."PART_PRIVS" ("PART_GRANT_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PART_ID" BIGINT, "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "PART_PRIV" VARCHAR(128));
+
+CREATE TABLE "APP"."GLOBAL_PRIVS" ("USER_GRANT_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "USER_PRIV" VARCHAR(128));
+
+CREATE TABLE "APP"."SD_PARAMS" ("SD_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(256) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+CREATE TABLE "APP"."DB_PRIVS" ("DB_GRANT_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "DB_ID" BIGINT, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "DB_PRIV" VARCHAR(128));
+
+CREATE TABLE "APP"."TBL_PRIVS" ("TBL_GRANT_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "TBL_PRIV" VARCHAR(128), "TBL_ID" BIGINT);
+
+CREATE TABLE "APP"."REGION_SDS" ("SD_ID" BIGINT NOT NULL, "REGION_NAME" VARCHAR(512) NOT NULL, "LOCATION" VARCHAR(4000));
+
+CREATE TABLE "APP"."BUCKETING_COLS" ("SD_ID" BIGINT NOT NULL, "BUCKET_COL_NAME" VARCHAR(256), "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."SEQUENCE_TABLE" ("SEQUENCE_NAME" VARCHAR(256) NOT NULL, "NEXT_VAL" BIGINT NOT NULL);
+
+CREATE TABLE "APP"."PART_COL_PRIVS" ("PART_COLUMN_GRANT_ID" BIGINT NOT NULL, "COLUMN_NAME" VARCHAR(128), "CREATE_TIME" INTEGER NOT NULL, "GRANT_OPTION" SMALLINT NOT NULL, "GRANTOR" VARCHAR(128), "GRANTOR_TYPE" VARCHAR(128), "PART_ID" BIGINT, "PRINCIPAL_NAME" VARCHAR(128), "PRINCIPAL_TYPE" VARCHAR(128), "PART_COL_PRIV" VARCHAR(128));
+
+CREATE TABLE "APP"."COLUMNS_V2" ("CD_ID" BIGINT NOT NULL, "COMMENT" VARCHAR(4000), "COLUMN_NAME" VARCHAR(128) NOT NULL, "TYPE_NAME" VARCHAR(4000), "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."PARTITION_EVENTS" ("PART_NAME_ID" BIGINT NOT NULL, "DB_NAME" VARCHAR(128), "EVENT_TIME" BIGINT NOT NULL, "EVENT_TYPE" INTEGER NOT NULL, "PARTITION_NAME" VARCHAR(767), "TBL_NAME" VARCHAR(128));
+
+CREATE TABLE "APP"."PARTITION_PARAMS" ("PART_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(256) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+CREATE TABLE "APP"."TBLS" ("TBL_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "DB_ID" BIGINT, "LAST_ACCESS_TIME" INTEGER NOT NULL, "OWNER" VARCHAR(767), "RETENTION" INTEGER NOT NULL, "SD_ID" BIGINT, "TBL_NAME" VARCHAR(128), "TBL_TYPE" VARCHAR(128), "VIEW_EXPANDED_TEXT" LONG VARCHAR, "VIEW_ORIGINAL_TEXT" LONG VARCHAR);
+
+CREATE TABLE "APP"."PARTITIONS" ("PART_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "LAST_ACCESS_TIME" INTEGER NOT NULL, "PART_NAME" VARCHAR(767), "SD_ID" BIGINT, "TBL_ID" BIGINT);
+
+CREATE TABLE "APP"."TABLE_PARAMS" ("TBL_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(256) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+CREATE TABLE "APP"."CDS" ("CD_ID" BIGINT NOT NULL);
+
+CREATE TABLE "APP"."SORT_COLS" ("SD_ID" BIGINT NOT NULL, "COLUMN_NAME" VARCHAR(128), "ORDER" INTEGER NOT NULL, "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."TYPE_FIELDS" ("TYPE_NAME" BIGINT NOT NULL, "COMMENT" VARCHAR(256), "FIELD_NAME" VARCHAR(128) NOT NULL, "FIELD_TYPE" VARCHAR(767) NOT NULL, "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."SERDE_PARAMS" ("SERDE_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(256) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+CREATE TABLE "APP"."PARTITION_KEYS" ("TBL_ID" BIGINT NOT NULL, "PKEY_COMMENT" VARCHAR(4000), "PKEY_NAME" VARCHAR(128) NOT NULL, "PKEY_TYPE" VARCHAR(767) NOT NULL, "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."IDXS" ("INDEX_ID" BIGINT NOT NULL, "CREATE_TIME" INTEGER NOT NULL, "DEFERRED_REBUILD" CHAR(1) NOT NULL, "INDEX_HANDLER_CLASS" VARCHAR(4000), "INDEX_NAME" VARCHAR(128), "INDEX_TBL_ID" BIGINT, "LAST_ACCESS_TIME" INTEGER NOT NULL, "ORIG_TBL_ID" BIGINT, "SD_ID" BIGINT);
+
+CREATE TABLE "APP"."PARTITION_KEY_VALS" ("PART_ID" BIGINT NOT NULL, "PART_KEY_VAL" VARCHAR(256), "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."TYPES" ("TYPES_ID" BIGINT NOT NULL, "TYPE_NAME" VARCHAR(128), "TYPE1" VARCHAR(767), "TYPE2" VARCHAR(767));
+
+CREATE TABLE "APP"."INDEX_PARAMS" ("INDEX_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(256) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+CREATE TABLE "APP"."DBS" ("DB_ID" BIGINT NOT NULL, "DESC" VARCHAR(4000), "DB_LOCATION_URI" VARCHAR(4000) NOT NULL, "NAME" VARCHAR(128));
+
+CREATE TABLE "APP"."COLUMNS" ("SD_ID" BIGINT NOT NULL, "COMMENT" VARCHAR(256), "COLUMN_NAME" VARCHAR(128) NOT NULL, "TYPE_NAME" VARCHAR(4000) NOT NULL, "INTEGER_IDX" INTEGER NOT NULL);
+
+CREATE TABLE "APP"."DATABASE_PARAMS" ("DB_ID" BIGINT NOT NULL, "PARAM_KEY" VARCHAR(180) NOT NULL, "PARAM_VALUE" VARCHAR(4000));
+
+-- ----------------------------------------------
+-- DDL Statements for indexes
+-- ----------------------------------------------
+
+CREATE UNIQUE INDEX "APP"."GLOBALPRIVILEGEINDEX" ON "APP"."GLOBAL_PRIVS" ("PRINCIPAL_NAME", "PRINCIPAL_TYPE", "USER_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE UNIQUE INDEX "APP"."UNIQUEPARTITION" ON "APP"."PARTITIONS" ("PART_NAME", "TBL_ID");
+
+CREATE UNIQUE INDEX "APP"."USERROLEMAPINDEX" ON "APP"."ROLE_MAP" ("PRINCIPAL_NAME", "ROLE_ID", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE UNIQUE INDEX "APP"."UNIQUEINDEX" ON "APP"."IDXS" ("INDEX_NAME", "ORIG_TBL_ID");
+
+CREATE UNIQUE INDEX "APP"."ROLEENTITYINDEX" ON "APP"."ROLES" ("ROLE_NAME");
+
+CREATE UNIQUE INDEX "APP"."UNIQUE_DATABASE" ON "APP"."DBS" ("NAME");
+
+CREATE UNIQUE INDEX "APP"."UNIQUE_TYPE" ON "APP"."TYPES" ("TYPE_NAME");
+
+CREATE INDEX "APP"."PARTITIONCOLUMNPRIVILEGEINDEX" ON "APP"."PART_COL_PRIVS" ("PART_ID", "COLUMN_NAME", "PRINCIPAL_NAME", "PRINCIPAL_TYPE", "PART_COL_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE INDEX "APP"."TABLECOLUMNPRIVILEGEINDEX" ON "APP"."TBL_COL_PRIVS" ("TBL_ID", "COLUMN_NAME", "PRINCIPAL_NAME", "PRINCIPAL_TYPE", "TBL_COL_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE INDEX "APP"."PARTPRIVILEGEINDEX" ON "APP"."PART_PRIVS" ("PART_ID", "PRINCIPAL_NAME", "PRINCIPAL_TYPE", "PART_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE UNIQUE INDEX "APP"."UNIQUETABLE" ON "APP"."TBLS" ("TBL_NAME", "DB_ID");
+
+CREATE INDEX "APP"."TABLEPRIVILEGEINDEX" ON "APP"."TBL_PRIVS" ("TBL_ID", "PRINCIPAL_NAME", "PRINCIPAL_TYPE", "TBL_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+CREATE UNIQUE INDEX "APP"."DBPRIVILEGEINDEX" ON "APP"."DB_PRIVS" ("DB_ID", "PRINCIPAL_NAME", "PRINCIPAL_TYPE", "DB_PRIV", "GRANTOR", "GRANTOR_TYPE");
+
+-- ----------------------------------------------
+-- DDL Statements for keys
+-- ----------------------------------------------
+
+-- primary/unique
+ALTER TABLE "APP"."GLOBAL_PRIVS" ADD CONSTRAINT "GLOBAL_PRIVS_PK" PRIMARY KEY ("USER_GRANT_ID");
+
+ALTER TABLE "APP"."SDS" ADD CONSTRAINT "SDS_PK" PRIMARY KEY ("SD_ID");
+
+ALTER TABLE "APP"."SERDE_PARAMS" ADD CONSTRAINT "SERDE_PARAMS_PK" PRIMARY KEY ("SERDE_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."REGION_SDS" ADD CONSTRAINT "SQL120210122103870" PRIMARY KEY ("SD_ID", "REGION_NAME");
+
+ALTER TABLE "APP"."PARTITIONS" ADD CONSTRAINT "PARTITIONS_PK" PRIMARY KEY ("PART_ID");
+
+ALTER TABLE "APP"."COLUMNS" ADD CONSTRAINT "COLUMNS_PK" PRIMARY KEY ("SD_ID", "COLUMN_NAME");
+
+ALTER TABLE "APP"."BUCKETING_COLS" ADD CONSTRAINT "BUCKETING_COLS_PK" PRIMARY KEY ("SD_ID", "INTEGER_IDX");
+
+ALTER TABLE "APP"."CDS" ADD CONSTRAINT "SQL110922153006460" PRIMARY KEY ("CD_ID");
+
+ALTER TABLE "APP"."ROLE_MAP" ADD CONSTRAINT "ROLE_MAP_PK" PRIMARY KEY ("ROLE_GRANT_ID");
+
+ALTER TABLE "APP"."PARTITION_KEYS" ADD CONSTRAINT "PARTITION_KEY_PK" PRIMARY KEY ("TBL_ID", "PKEY_NAME");
+
+ALTER TABLE "APP"."SD_PARAMS" ADD CONSTRAINT "SD_PARAMS_PK" PRIMARY KEY ("SD_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."DATABASE_PARAMS" ADD CONSTRAINT "DATABASE_PARAMS_PK" PRIMARY KEY ("DB_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."IDXS" ADD CONSTRAINT "IDXS_PK" PRIMARY KEY ("INDEX_ID");
+
+ALTER TABLE "APP"."PARTITION_PARAMS" ADD CONSTRAINT "PARTITION_PARAMS_PK" PRIMARY KEY ("PART_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."SEQUENCE_TABLE" ADD CONSTRAINT "SEQUENCE_TABLE_PK" PRIMARY KEY ("SEQUENCE_NAME");
+
+ALTER TABLE "APP"."COLUMNS_V2" ADD CONSTRAINT "SQL110922153006740" PRIMARY KEY ("CD_ID", "COLUMN_NAME");
+
+ALTER TABLE "APP"."SERDES" ADD CONSTRAINT "SERDES_PK" PRIMARY KEY ("SERDE_ID");
+
+ALTER TABLE "APP"."ROLES" ADD CONSTRAINT "ROLES_PK" PRIMARY KEY ("ROLE_ID");
+
+ALTER TABLE "APP"."TYPE_FIELDS" ADD CONSTRAINT "TYPE_FIELDS_PK" PRIMARY KEY ("TYPE_NAME", "FIELD_NAME");
+
+ALTER TABLE "APP"."DBS" ADD CONSTRAINT "DBS_PK" PRIMARY KEY ("DB_ID");
+
+ALTER TABLE "APP"."PARTITION_KEY_VALS" ADD CONSTRAINT "PARTITION_KEY_VALS_PK" PRIMARY KEY ("PART_ID", "INTEGER_IDX");
+
+ALTER TABLE "APP"."TYPES" ADD CONSTRAINT "TYPES_PK" PRIMARY KEY ("TYPES_ID");
+
+ALTER TABLE "APP"."PART_COL_PRIVS" ADD CONSTRAINT "PART_COL_PRIVS_PK" PRIMARY KEY ("PART_COLUMN_GRANT_ID");
+
+ALTER TABLE "APP"."TBL_COL_PRIVS" ADD CONSTRAINT "TBL_COL_PRIVS_PK" PRIMARY KEY ("TBL_COLUMN_GRANT_ID");
+
+ALTER TABLE "APP"."INDEX_PARAMS" ADD CONSTRAINT "INDEX_PARAMS_PK" PRIMARY KEY ("INDEX_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."PARTITION_EVENTS" ADD CONSTRAINT "PARTITION_EVENTS_PK" PRIMARY KEY ("PART_NAME_ID");
+
+ALTER TABLE "APP"."TABLE_PARAMS" ADD CONSTRAINT "TABLE_PARAMS_PK" PRIMARY KEY ("TBL_ID", "PARAM_KEY");
+
+ALTER TABLE "APP"."SORT_COLS" ADD CONSTRAINT "SORT_COLS_PK" PRIMARY KEY ("SD_ID", "INTEGER_IDX");
+
+ALTER TABLE "APP"."PART_PRIVS" ADD CONSTRAINT "PART_PRIVS_PK" PRIMARY KEY ("PART_GRANT_ID");
+
+ALTER TABLE "APP"."TBLS" ADD CONSTRAINT "TBLS_PK" PRIMARY KEY ("TBL_ID");
+
+ALTER TABLE "APP"."NUCLEUS_TABLES" ADD CONSTRAINT "NUCLEUS_TABLES_PK" PRIMARY KEY ("CLASS_NAME");
+
+ALTER TABLE "APP"."TBL_PRIVS" ADD CONSTRAINT "TBL_PRIVS_PK" PRIMARY KEY ("TBL_GRANT_ID");
+
+ALTER TABLE "APP"."DB_PRIVS" ADD CONSTRAINT "DB_PRIVS_PK" PRIMARY KEY ("DB_GRANT_ID");
+
+-- foreign
+ALTER TABLE "APP"."SDS" ADD CONSTRAINT "SDS_FK1" FOREIGN KEY ("SERDE_ID") REFERENCES "APP"."SERDES" ("SERDE_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."SDS" ADD CONSTRAINT "SDS_FK2" FOREIGN KEY ("CD_ID") REFERENCES "APP"."CDS" ("CD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."SERDE_PARAMS" ADD CONSTRAINT "SERDE_PARAMS_FK1" FOREIGN KEY ("SERDE_ID") REFERENCES "APP"."SERDES" ("SERDE_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."REGION_SDS" ADD CONSTRAINT "REGION_SDS_FK1" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PARTITIONS" ADD CONSTRAINT "PARTITIONS_FK1" FOREIGN KEY ("TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PARTITIONS" ADD CONSTRAINT "PARTITIONS_FK2" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."COLUMNS" ADD CONSTRAINT "COLUMNS_FK1" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."BUCKETING_COLS" ADD CONSTRAINT "BUCKETING_COLS_FK1" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."ROLE_MAP" ADD CONSTRAINT "ROLE_MAP_FK1" FOREIGN KEY ("ROLE_ID") REFERENCES "APP"."ROLES" ("ROLE_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PARTITION_KEYS" ADD CONSTRAINT "PARTITION_KEYS_FK1" FOREIGN KEY ("TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."SD_PARAMS" ADD CONSTRAINT "SD_PARAMS_FK1" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."DATABASE_PARAMS" ADD CONSTRAINT "DATABASE_PARAMS_FK1" FOREIGN KEY ("DB_ID") REFERENCES "APP"."DBS" ("DB_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."IDXS" ADD CONSTRAINT "IDXS_FK1" FOREIGN KEY ("ORIG_TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."IDXS" ADD CONSTRAINT "IDXS_FK2" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."IDXS" ADD CONSTRAINT "IDXS_FK3" FOREIGN KEY ("INDEX_TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PARTITION_PARAMS" ADD CONSTRAINT "PARTITION_PARAMS_FK1" FOREIGN KEY ("PART_ID") REFERENCES "APP"."PARTITIONS" ("PART_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."COLUMNS_V2" ADD CONSTRAINT "COLUMNS_V2_FK1" FOREIGN KEY ("CD_ID") REFERENCES "APP"."CDS" ("CD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TYPE_FIELDS" ADD CONSTRAINT "TYPE_FIELDS_FK1" FOREIGN KEY ("TYPE_NAME") REFERENCES "APP"."TYPES" ("TYPES_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PARTITION_KEY_VALS" ADD CONSTRAINT "PARTITION_KEY_VALS_FK1" FOREIGN KEY ("PART_ID") REFERENCES "APP"."PARTITIONS" ("PART_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PART_COL_PRIVS" ADD CONSTRAINT "PART_COL_PRIVS_FK1" FOREIGN KEY ("PART_ID") REFERENCES "APP"."PARTITIONS" ("PART_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TBL_COL_PRIVS" ADD CONSTRAINT "TBL_COL_PRIVS_FK1" FOREIGN KEY ("TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."INDEX_PARAMS" ADD CONSTRAINT "INDEX_PARAMS_FK1" FOREIGN KEY ("INDEX_ID") REFERENCES "APP"."IDXS" ("INDEX_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TABLE_PARAMS" ADD CONSTRAINT "TABLE_PARAMS_FK1" FOREIGN KEY ("TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."SORT_COLS" ADD CONSTRAINT "SORT_COLS_FK1" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."PART_PRIVS" ADD CONSTRAINT "PART_PRIVS_FK1" FOREIGN KEY ("PART_ID") REFERENCES "APP"."PARTITIONS" ("PART_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TBLS" ADD CONSTRAINT "TBLS_FK2" FOREIGN KEY ("SD_ID") REFERENCES "APP"."SDS" ("SD_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TBLS" ADD CONSTRAINT "TBLS_FK1" FOREIGN KEY ("DB_ID") REFERENCES "APP"."DBS" ("DB_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."TBL_PRIVS" ADD CONSTRAINT "TBL_PRIVS_FK1" FOREIGN KEY ("TBL_ID") REFERENCES "APP"."TBLS" ("TBL_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+ALTER TABLE "APP"."DB_PRIVS" ADD CONSTRAINT "DB_PRIVS_FK1" FOREIGN KEY ("DB_ID") REFERENCES "APP"."DBS" ("DB_ID") ON DELETE NO ACTION ON UPDATE NO ACTION;
+
+-- ----------------------------------------------
+-- DDL Statements for checks
+-- ----------------------------------------------
+
+ALTER TABLE "APP"."SDS" ADD CONSTRAINT "SQL110318025505550" CHECK (IS_COMPRESSED IN ('Y','N'));
+
+ALTER TABLE "APP"."IDXS" ADD CONSTRAINT "SQL110318025504980" CHECK (DEFERRED_REBUILD IN ('Y','N'));
+
Index: metastore/scripts/upgrade/mysql/010-HIVE-2612.mysql.sql
===================================================================
--- metastore/scripts/upgrade/mysql/010-HIVE-2612.mysql.sql (revision 0)
+++ metastore/scripts/upgrade/mysql/010-HIVE-2612.mysql.sql (revision 0)
@@ -0,0 +1,59 @@
+SELECT '< HIVE-2612 support hive table/partitions exists in more than one region >' AS ' ';
+
+DELIMITER $$
+DROP PROCEDURE IF EXISTS REVERT $$
+DROP PROCEDURE IF EXISTS ALTER_SDS $$
+DROP PROCEDURE IF EXISTS CREATE_TABLE $$
+DROP PROCEDURE IF EXISTS MIGRATE $$
+
+/* Call this procedure to revert all changes by this script */
+CREATE PROCEDURE REVERT()
+ BEGIN
+ ALTER TABLE SDS
+ DROP COLUMN PRIMARY_REGION_NAME
+ ;
+ DROP TABLE IF EXISTS REGION_SDS;
+
+ END $$
+
+/* Alter the SDS table to:
+ * - add the column PRIMARY_REGION_NAME
+ */
+CREATE PROCEDURE ALTER_SDS()
+ BEGIN
+ ALTER TABLE SDS
+ ADD COLUMN PRIMARY_REGION_NAME varchar(512) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL DEFAULT ''
+ ;
+ END $$
+
+/*
+ * Creates the following table:
+ * - REGION_SDS
+ */
+CREATE PROCEDURE CREATE_TABLE()
+ BEGIN
+ CREATE TABLE IF NOT EXISTS `REGION_SDS` (
+ SD_ID bigint(20) NOT NULL,
+ REGION_NAME varchar(512) NOT NULL,
+ LOCATION varchar(4000),
+ PRIMARY KEY (`SD_ID`, `REGION_NAME`),
+ KEY `REGION_SDS_N49` (`SD_ID`),
+ CONSTRAINT `REGION_SDS_V2_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+ ) ENGINE=InnoDB DEFAULT CHARSET=latin1
+ ;
+ END $$
+
+/*
+ * Procedures called before migration happens
+ */
+CREATE PROCEDURE MIGRATE()
+ BEGIN
+ call CREATE_TABLE();
+ SELECT 'Created table REGION_SDS';
+ call ALTER_SDS();
+ SELECT 'Altered the SDS table';
+ END $$
+
+DELIMITER ;
+
+CALL MIGRATE();
Index: metastore/scripts/upgrade/mysql/upgrade-0.9.0-to-0.10.0.mysql.sql
===================================================================
--- metastore/scripts/upgrade/mysql/upgrade-0.9.0-to-0.10.0.mysql.sql (revision 0)
+++ metastore/scripts/upgrade/mysql/upgrade-0.9.0-to-0.10.0.mysql.sql (revision 0)
@@ -0,0 +1,3 @@
+SELECT 'Upgrading MetaStore schema from 0.9.0 to 0.10.0' AS ' ';
+SOURCE 010-HIVE-2612.mysql.sql;
+SELECT 'Finished upgrading MetaStore schema from 0.9.0 to 0.10.0' AS ' ';
Index: metastore/scripts/upgrade/mysql/hive-schema-0.10.0.mysql.sql
===================================================================
--- metastore/scripts/upgrade/mysql/hive-schema-0.10.0.mysql.sql (revision 0)
+++ metastore/scripts/upgrade/mysql/hive-schema-0.10.0.mysql.sql (revision 0)
@@ -0,0 +1,655 @@
+-- MySQL dump 10.13 Distrib 5.1.53, for redhat-linux-gnu (x86_64)
+--
+-- Host: cdb259.snc1 Database: test_kevinwilfong_metastore
+-- ------------------------------------------------------
+-- Server version 5.1.47_blackhole_memcache-log
+
+/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
+/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
+/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
+/*!40101 SET NAMES utf8 */;
+/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;
+/*!40103 SET TIME_ZONE='+00:00' */;
+/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
+/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
+/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
+/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
+
+--
+-- Table structure for table `BUCKETING_COLS`
+--
+
+DROP TABLE IF EXISTS `BUCKETING_COLS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `BUCKETING_COLS` (
+ `SD_ID` bigint(20) NOT NULL,
+ `BUCKET_COL_NAME` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`SD_ID`,`INTEGER_IDX`),
+ KEY `BUCKETING_COLS_N49` (`SD_ID`),
+ CONSTRAINT `BUCKETING_COLS_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `CDS`
+--
+
+DROP TABLE IF EXISTS `CDS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `CDS` (
+ `CD_ID` bigint(20) NOT NULL,
+ PRIMARY KEY (`CD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `COLUMNS_V2`
+--
+
+DROP TABLE IF EXISTS `COLUMNS_V2`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `COLUMNS_V2` (
+ `CD_ID` bigint(20) NOT NULL,
+ `COMMENT` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `COLUMN_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `TYPE_NAME` varchar(4000) DEFAULT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`CD_ID`,`COLUMN_NAME`),
+ KEY `COLUMNS_V2_N49` (`CD_ID`),
+ CONSTRAINT `COLUMNS_V2_FK1` FOREIGN KEY (`CD_ID`) REFERENCES `CDS` (`CD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `DATABASE_PARAMS`
+--
+
+DROP TABLE IF EXISTS `DATABASE_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `DATABASE_PARAMS` (
+ `DB_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(180) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`DB_ID`,`PARAM_KEY`),
+ KEY `DATABASE_PARAMS_N49` (`DB_ID`),
+ CONSTRAINT `DATABASE_PARAMS_FK1` FOREIGN KEY (`DB_ID`) REFERENCES `DBS` (`DB_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `DBS`
+--
+
+DROP TABLE IF EXISTS `DBS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `DBS` (
+ `DB_ID` bigint(20) NOT NULL,
+ `DESC` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `DB_LOCATION_URI` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`DB_ID`),
+ UNIQUE KEY `UNIQUE_DATABASE` (`NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `DB_PRIVS`
+--
+
+DROP TABLE IF EXISTS `DB_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `DB_PRIVS` (
+ `DB_GRANT_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `DB_ID` bigint(20) DEFAULT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `DB_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`DB_GRANT_ID`),
+ UNIQUE KEY `DBPRIVILEGEINDEX` (`DB_ID`,`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`DB_PRIV`,`GRANTOR`,`GRANTOR_TYPE`),
+ KEY `DB_PRIVS_N49` (`DB_ID`),
+ CONSTRAINT `DB_PRIVS_FK1` FOREIGN KEY (`DB_ID`) REFERENCES `DBS` (`DB_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `GLOBAL_PRIVS`
+--
+
+DROP TABLE IF EXISTS `GLOBAL_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `GLOBAL_PRIVS` (
+ `USER_GRANT_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `USER_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`USER_GRANT_ID`),
+ UNIQUE KEY `GLOBALPRIVILEGEINDEX` (`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`USER_PRIV`,`GRANTOR`,`GRANTOR_TYPE`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `IDXS`
+--
+
+DROP TABLE IF EXISTS `IDXS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `IDXS` (
+ `INDEX_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `DEFERRED_REBUILD` bit(1) NOT NULL,
+ `INDEX_HANDLER_CLASS` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `INDEX_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `INDEX_TBL_ID` bigint(20) DEFAULT NULL,
+ `LAST_ACCESS_TIME` int(11) NOT NULL,
+ `ORIG_TBL_ID` bigint(20) DEFAULT NULL,
+ `SD_ID` bigint(20) DEFAULT NULL,
+ PRIMARY KEY (`INDEX_ID`),
+ UNIQUE KEY `UNIQUEINDEX` (`INDEX_NAME`,`ORIG_TBL_ID`),
+ KEY `IDXS_N51` (`SD_ID`),
+ KEY `IDXS_N50` (`INDEX_TBL_ID`),
+ KEY `IDXS_N49` (`ORIG_TBL_ID`),
+ CONSTRAINT `IDXS_FK3` FOREIGN KEY (`INDEX_TBL_ID`) REFERENCES `TBLS` (`TBL_ID`),
+ CONSTRAINT `IDXS_FK1` FOREIGN KEY (`ORIG_TBL_ID`) REFERENCES `TBLS` (`TBL_ID`),
+ CONSTRAINT `IDXS_FK2` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `INDEX_PARAMS`
+--
+
+DROP TABLE IF EXISTS `INDEX_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `INDEX_PARAMS` (
+ `INDEX_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`INDEX_ID`,`PARAM_KEY`),
+ KEY `INDEX_PARAMS_N49` (`INDEX_ID`),
+ CONSTRAINT `INDEX_PARAMS_FK1` FOREIGN KEY (`INDEX_ID`) REFERENCES `IDXS` (`INDEX_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `NUCLEUS_TABLES`
+--
+
+DROP TABLE IF EXISTS `NUCLEUS_TABLES`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `NUCLEUS_TABLES` (
+ `CLASS_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `TABLE_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `TYPE` varchar(4) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `OWNER` varchar(2) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `VERSION` varchar(20) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `INTERFACE_NAME` varchar(255) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`CLASS_NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PARTITIONS`
+--
+
+DROP TABLE IF EXISTS `PARTITIONS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PARTITIONS` (
+ `PART_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `LAST_ACCESS_TIME` int(11) NOT NULL,
+ `PART_NAME` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `SD_ID` bigint(20) DEFAULT NULL,
+ `TBL_ID` bigint(20) DEFAULT NULL,
+ PRIMARY KEY (`PART_ID`),
+ UNIQUE KEY `UNIQUEPARTITION` (`PART_NAME`,`TBL_ID`),
+ KEY `PARTITIONS_N49` (`TBL_ID`),
+ KEY `PARTITIONS_N50` (`SD_ID`),
+ CONSTRAINT `PARTITIONS_FK2` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`),
+ CONSTRAINT `PARTITIONS_FK1` FOREIGN KEY (`TBL_ID`) REFERENCES `TBLS` (`TBL_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PARTITION_EVENTS`
+--
+
+DROP TABLE IF EXISTS `PARTITION_EVENTS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PARTITION_EVENTS` (
+ `PART_NAME_ID` bigint(20) NOT NULL,
+ `DB_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `EVENT_TIME` bigint(20) NOT NULL,
+ `EVENT_TYPE` int(11) NOT NULL,
+ `PARTITION_NAME` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`PART_NAME_ID`),
+ KEY `PARTITIONEVENTINDEX` (`PARTITION_NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PARTITION_KEYS`
+--
+
+DROP TABLE IF EXISTS `PARTITION_KEYS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PARTITION_KEYS` (
+ `TBL_ID` bigint(20) NOT NULL,
+ `PKEY_COMMENT` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PKEY_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PKEY_TYPE` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`TBL_ID`,`PKEY_NAME`),
+ KEY `PARTITION_KEYS_N49` (`TBL_ID`),
+ CONSTRAINT `PARTITION_KEYS_FK1` FOREIGN KEY (`TBL_ID`) REFERENCES `TBLS` (`TBL_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PARTITION_KEY_VALS`
+--
+
+DROP TABLE IF EXISTS `PARTITION_KEY_VALS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PARTITION_KEY_VALS` (
+ `PART_ID` bigint(20) NOT NULL,
+ `PART_KEY_VAL` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`PART_ID`,`INTEGER_IDX`),
+ KEY `PARTITION_KEY_VALS_N49` (`PART_ID`),
+ CONSTRAINT `PARTITION_KEY_VALS_FK1` FOREIGN KEY (`PART_ID`) REFERENCES `PARTITIONS` (`PART_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PARTITION_PARAMS`
+--
+
+DROP TABLE IF EXISTS `PARTITION_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PARTITION_PARAMS` (
+ `PART_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`PART_ID`,`PARAM_KEY`),
+ KEY `PARTITION_PARAMS_N49` (`PART_ID`),
+ CONSTRAINT `PARTITION_PARAMS_FK1` FOREIGN KEY (`PART_ID`) REFERENCES `PARTITIONS` (`PART_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PART_COL_PRIVS`
+--
+
+DROP TABLE IF EXISTS `PART_COL_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PART_COL_PRIVS` (
+ `PART_COLUMN_GRANT_ID` bigint(20) NOT NULL,
+ `COLUMN_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PART_ID` bigint(20) DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PART_COL_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`PART_COLUMN_GRANT_ID`),
+ KEY `PART_COL_PRIVS_N49` (`PART_ID`),
+ KEY `PARTITIONCOLUMNPRIVILEGEINDEX` (`PART_ID`,`COLUMN_NAME`,`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`PART_COL_PRIV`,`GRANTOR`,`GRANTOR_TYPE`),
+ CONSTRAINT `PART_COL_PRIVS_FK1` FOREIGN KEY (`PART_ID`) REFERENCES `PARTITIONS` (`PART_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `PART_PRIVS`
+--
+
+DROP TABLE IF EXISTS `PART_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `PART_PRIVS` (
+ `PART_GRANT_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PART_ID` bigint(20) DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PART_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`PART_GRANT_ID`),
+ KEY `PARTPRIVILEGEINDEX` (`PART_ID`,`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`PART_PRIV`,`GRANTOR`,`GRANTOR_TYPE`),
+ KEY `PART_PRIVS_N49` (`PART_ID`),
+ CONSTRAINT `PART_PRIVS_FK1` FOREIGN KEY (`PART_ID`) REFERENCES `PARTITIONS` (`PART_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `REGION_SDS`
+--
+
+DROP TABLE IF EXISTS `REGION_SDS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `REGION_SDS` (
+ `SD_ID` bigint(20) NOT NULL,
+ `REGION_NAME` varchar(512) NOT NULL,
+ `LOCATION` varchar(4000) DEFAULT NULL,
+ PRIMARY KEY (`SD_ID`,`REGION_NAME`),
+ KEY `REGION_SDS_N49` (`SD_ID`),
+ CONSTRAINT `REGION_SDS_V2_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `ROLES`
+--
+
+DROP TABLE IF EXISTS `ROLES`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `ROLES` (
+ `ROLE_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `OWNER_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `ROLE_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`ROLE_ID`),
+ UNIQUE KEY `ROLEENTITYINDEX` (`ROLE_NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `ROLE_MAP`
+--
+
+DROP TABLE IF EXISTS `ROLE_MAP`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `ROLE_MAP` (
+ `ROLE_GRANT_ID` bigint(20) NOT NULL,
+ `ADD_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `ROLE_ID` bigint(20) DEFAULT NULL,
+ PRIMARY KEY (`ROLE_GRANT_ID`),
+ UNIQUE KEY `USERROLEMAPINDEX` (`PRINCIPAL_NAME`,`ROLE_ID`,`GRANTOR`,`GRANTOR_TYPE`),
+ KEY `ROLE_MAP_N49` (`ROLE_ID`),
+ CONSTRAINT `ROLE_MAP_FK1` FOREIGN KEY (`ROLE_ID`) REFERENCES `ROLES` (`ROLE_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SDS`
+--
+
+DROP TABLE IF EXISTS `SDS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SDS` (
+ `SD_ID` bigint(20) NOT NULL,
+ `CD_ID` bigint(20) DEFAULT NULL,
+ `INPUT_FORMAT` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `IS_COMPRESSED` bit(1) NOT NULL,
+ `LOCATION` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `NUM_BUCKETS` int(11) NOT NULL,
+ `OUTPUT_FORMAT` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `SERDE_ID` bigint(20) DEFAULT NULL,
+ `PRIMARY_REGION_NAME` varchar(512) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL DEFAULT '',
+ PRIMARY KEY (`SD_ID`),
+ KEY `SDS_N49` (`SERDE_ID`),
+ KEY `SDS_N50` (`CD_ID`),
+ CONSTRAINT `SDS_FK1` FOREIGN KEY (`SERDE_ID`) REFERENCES `SERDES` (`SERDE_ID`),
+ CONSTRAINT `SDS_FK2` FOREIGN KEY (`CD_ID`) REFERENCES `CDS` (`CD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SD_PARAMS`
+--
+
+DROP TABLE IF EXISTS `SD_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SD_PARAMS` (
+ `SD_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`SD_ID`,`PARAM_KEY`),
+ KEY `SD_PARAMS_N49` (`SD_ID`),
+ CONSTRAINT `SD_PARAMS_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SEQUENCE_TABLE`
+--
+
+DROP TABLE IF EXISTS `SEQUENCE_TABLE`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SEQUENCE_TABLE` (
+ `SEQUENCE_NAME` varchar(255) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `NEXT_VAL` bigint(20) NOT NULL,
+ PRIMARY KEY (`SEQUENCE_NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SERDES`
+--
+
+DROP TABLE IF EXISTS `SERDES`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SERDES` (
+ `SERDE_ID` bigint(20) NOT NULL,
+ `NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `SLIB` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`SERDE_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SERDE_PARAMS`
+--
+
+DROP TABLE IF EXISTS `SERDE_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SERDE_PARAMS` (
+ `SERDE_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`SERDE_ID`,`PARAM_KEY`),
+ KEY `SERDE_PARAMS_N49` (`SERDE_ID`),
+ CONSTRAINT `SERDE_PARAMS_FK1` FOREIGN KEY (`SERDE_ID`) REFERENCES `SERDES` (`SERDE_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `SORT_COLS`
+--
+
+DROP TABLE IF EXISTS `SORT_COLS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `SORT_COLS` (
+ `SD_ID` bigint(20) NOT NULL,
+ `COLUMN_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `ORDER` int(11) NOT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`SD_ID`,`INTEGER_IDX`),
+ KEY `SORT_COLS_N49` (`SD_ID`),
+ CONSTRAINT `SORT_COLS_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TABLE_PARAMS`
+--
+
+DROP TABLE IF EXISTS `TABLE_PARAMS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TABLE_PARAMS` (
+ `TBL_ID` bigint(20) NOT NULL,
+ `PARAM_KEY` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `PARAM_VALUE` varchar(4000) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`TBL_ID`,`PARAM_KEY`),
+ KEY `TABLE_PARAMS_N49` (`TBL_ID`),
+ CONSTRAINT `TABLE_PARAMS_FK1` FOREIGN KEY (`TBL_ID`) REFERENCES `TBLS` (`TBL_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TBLS`
+--
+
+DROP TABLE IF EXISTS `TBLS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TBLS` (
+ `TBL_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `DB_ID` bigint(20) DEFAULT NULL,
+ `LAST_ACCESS_TIME` int(11) NOT NULL,
+ `OWNER` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `RETENTION` int(11) NOT NULL,
+ `SD_ID` bigint(20) DEFAULT NULL,
+ `TBL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `VIEW_EXPANDED_TEXT` mediumtext,
+ `VIEW_ORIGINAL_TEXT` mediumtext,
+ PRIMARY KEY (`TBL_ID`),
+ UNIQUE KEY `UNIQUETABLE` (`TBL_NAME`,`DB_ID`),
+ KEY `TBLS_N50` (`SD_ID`),
+ KEY `TBLS_N49` (`DB_ID`),
+ CONSTRAINT `TBLS_FK1` FOREIGN KEY (`SD_ID`) REFERENCES `SDS` (`SD_ID`),
+ CONSTRAINT `TBLS_FK2` FOREIGN KEY (`DB_ID`) REFERENCES `DBS` (`DB_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TBL_COL_PRIVS`
+--
+
+DROP TABLE IF EXISTS `TBL_COL_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TBL_COL_PRIVS` (
+ `TBL_COLUMN_GRANT_ID` bigint(20) NOT NULL,
+ `COLUMN_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_COL_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_ID` bigint(20) DEFAULT NULL,
+ PRIMARY KEY (`TBL_COLUMN_GRANT_ID`),
+ KEY `TABLECOLUMNPRIVILEGEINDEX` (`TBL_ID`,`COLUMN_NAME`,`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`TBL_COL_PRIV`,`GRANTOR`,`GRANTOR_TYPE`),
+ KEY `TBL_COL_PRIVS_N49` (`TBL_ID`),
+ CONSTRAINT `TBL_COL_PRIVS_FK1` FOREIGN KEY (`TBL_ID`) REFERENCES `TBLS` (`TBL_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TBL_PRIVS`
+--
+
+DROP TABLE IF EXISTS `TBL_PRIVS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TBL_PRIVS` (
+ `TBL_GRANT_ID` bigint(20) NOT NULL,
+ `CREATE_TIME` int(11) NOT NULL,
+ `GRANT_OPTION` smallint(6) NOT NULL,
+ `GRANTOR` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `GRANTOR_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `PRINCIPAL_TYPE` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_PRIV` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TBL_ID` bigint(20) DEFAULT NULL,
+ PRIMARY KEY (`TBL_GRANT_ID`),
+ KEY `TBL_PRIVS_N49` (`TBL_ID`),
+ KEY `TABLEPRIVILEGEINDEX` (`TBL_ID`,`PRINCIPAL_NAME`,`PRINCIPAL_TYPE`,`TBL_PRIV`,`GRANTOR`,`GRANTOR_TYPE`),
+ CONSTRAINT `TBL_PRIVS_FK1` FOREIGN KEY (`TBL_ID`) REFERENCES `TBLS` (`TBL_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TYPES`
+--
+
+DROP TABLE IF EXISTS `TYPES`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TYPES` (
+ `TYPES_ID` bigint(20) NOT NULL,
+ `TYPE_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TYPE1` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `TYPE2` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ PRIMARY KEY (`TYPES_ID`),
+ UNIQUE KEY `UNIQUE_TYPE` (`TYPE_NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+
+--
+-- Table structure for table `TYPE_FIELDS`
+--
+
+DROP TABLE IF EXISTS `TYPE_FIELDS`;
+/*!40101 SET @saved_cs_client = @@character_set_client */;
+/*!40101 SET character_set_client = utf8 */;
+CREATE TABLE `TYPE_FIELDS` (
+ `TYPE_NAME` bigint(20) NOT NULL,
+ `COMMENT` varchar(256) CHARACTER SET latin1 COLLATE latin1_bin DEFAULT NULL,
+ `FIELD_NAME` varchar(128) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `FIELD_TYPE` varchar(767) CHARACTER SET latin1 COLLATE latin1_bin NOT NULL,
+ `INTEGER_IDX` int(11) NOT NULL,
+ PRIMARY KEY (`TYPE_NAME`,`FIELD_NAME`),
+ KEY `TYPE_FIELDS_N49` (`TYPE_NAME`),
+ CONSTRAINT `TYPE_FIELDS_FK1` FOREIGN KEY (`TYPE_NAME`) REFERENCES `TYPES` (`TYPES_ID`)
+) ENGINE=InnoDB DEFAULT CHARSET=latin1;
+/*!40101 SET character_set_client = @saved_cs_client */;
+/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;
+
+/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
+/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
+/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
+/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
+/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
+/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
+/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
+
+-- Dump completed on 2012-02-10 12:02:33
Index: metastore/scripts/upgrade/postgres/010-HIVE-2612.postgres.sql
===================================================================
--- metastore/scripts/upgrade/postgres/010-HIVE-2612.postgres.sql (revision 0)
+++ metastore/scripts/upgrade/postgres/010-HIVE-2612.postgres.sql (revision 0)
@@ -0,0 +1,26 @@
+SELECT '< HIVE-2612 support hive table/partitions exists in more than one region >';
+
+--
+-- Table: REGION_SDS
+--
+
+CREATE TABLE "REGION_SDS" (
+ "SD_ID" bigint NOT NULL,
+ "REGION_NAME" character varying(512) NOT NULL,
+ "LOCATION" character varying(4000) DEFAULT NULL,
+ PRIMARY KEY ("SD_ID", "REGION_NAME")
+);
+
+--
+-- Foreign Key Definitions
+--
+
+ALTER TABLE "REGION_SDS" ADD FOREIGN KEY ("SD_ID")
+ REFERENCES "SDS" ("SD_ID") DEFERRABLE;
+
+--
+-- Alter Table: SDS
+--
+
+ALTER TABLE "SDS" ADD COLUMN "PRIMARY_REGION_NAME"
+ character varying(512) NOT NULL DEFAULT '';
Index: metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java
===================================================================
--- metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java (revision 1242898)
+++ metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java (working copy)
@@ -46,6 +46,7 @@
import org.apache.hadoop.hive.metastore.api.NoSuchObjectException;
import org.apache.hadoop.hive.metastore.api.Order;
import org.apache.hadoop.hive.metastore.api.Partition;
+import org.apache.hadoop.hive.metastore.api.RegionStorageDescriptor;
import org.apache.hadoop.hive.metastore.api.SerDeInfo;
import org.apache.hadoop.hive.metastore.api.StorageDescriptor;
import org.apache.hadoop.hive.metastore.api.Table;
@@ -431,6 +432,8 @@
part4.setSd(tbl.getSd().deepCopy());
part4.getSd().setSerdeInfo(tbl.getSd().getSerdeInfo().deepCopy());
part4.getSd().setLocation(tbl.getSd().getLocation() + ptnLocationSuffix);
+ part4.getSd().setPrimaryRegionName(HiveConf.ConfVars.HIVE_DEFAULT_REGION_NAME.defaultVal);
+ part4.getSd().setSecondaryRegions(new ArrayList());
return part4;
}
Index: metastore/src/model/package.jdo
===================================================================
--- metastore/src/model/package.jdo (revision 1242898)
+++ metastore/src/model/package.jdo (working copy)
@@ -1,5 +1,5 @@
-
-
+
-
-
-
+
+
+
-
+
@@ -50,15 +50,15 @@
-
-
-
+
+
+
-
+
-
+
@@ -216,6 +216,16 @@
+
+
+
+
+
+
+
+
+
+
@@ -274,6 +284,29 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
@@ -319,13 +352,13 @@
-
+
-
+
@@ -386,7 +419,7 @@
-
+
@@ -425,7 +458,7 @@
-
+
@@ -433,7 +466,7 @@
-
+
@@ -462,7 +495,7 @@
-
+
@@ -503,7 +536,7 @@
-
+
@@ -544,7 +577,7 @@
-
+
@@ -585,7 +618,7 @@
-
+
@@ -630,7 +663,7 @@
-
+
@@ -674,17 +707,17 @@
-
-
+
+
-
+
-
-
+
+
Index: metastore/src/model/org/apache/hadoop/hive/metastore/model/MStorageDescriptor.java
===================================================================
--- metastore/src/model/org/apache/hadoop/hive/metastore/model/MStorageDescriptor.java (revision 1242898)
+++ metastore/src/model/org/apache/hadoop/hive/metastore/model/MStorageDescriptor.java (working copy)
@@ -20,6 +20,7 @@
import java.util.List;
import java.util.Map;
+import java.util.Set;
public class MStorageDescriptor {
private MColumnDescriptor cd;
@@ -32,6 +33,8 @@
private List bucketCols;
private List sortCols;
private Map parameters;
+ private String primaryRegionName;
+ private Set secondaryRegions;
public MStorageDescriptor() {}
@@ -47,10 +50,14 @@
* @param bucketCols
* @param sortOrder
* @param parameters
+ * @param primaryRegionName
+ * @param secondaryRegions
*/
public MStorageDescriptor(MColumnDescriptor cd, String location, String inputFormat,
String outputFormat, boolean isCompressed, int numBuckets, MSerDeInfo serDeInfo,
- List bucketCols, List sortOrder, Map parameters) {
+ List bucketCols, List sortOrder, Map parameters,
+ String primaryRegionName,
+ Set secondaryRegions) {
this.cd = cd;
this.location = location;
this.inputFormat = inputFormat;
@@ -61,6 +68,8 @@
this.bucketCols = bucketCols;
this.sortCols = sortOrder;
this.parameters = parameters;
+ this.primaryRegionName = primaryRegionName;
+ this.secondaryRegions = secondaryRegions;
}
@@ -205,4 +214,22 @@
public List getSortCols() {
return sortCols;
}
+
+ public String getPrimaryRegionName() {
+ return primaryRegionName;
+ }
+
+ public void setPrimaryRegionName(String primaryRegionName) {
+ this.primaryRegionName = primaryRegionName;
+ }
+
+ public Set getSecondaryRegions() {
+ return secondaryRegions;
+ }
+
+ public void setSecondaryRegions(
+ Set secondaryRegions) {
+ this.secondaryRegions = secondaryRegions;
+ }
+
}
Index: metastore/src/model/org/apache/hadoop/hive/metastore/model/MRegionStorageDescriptor.java
===================================================================
--- metastore/src/model/org/apache/hadoop/hive/metastore/model/MRegionStorageDescriptor.java (revision 0)
+++ metastore/src/model/org/apache/hadoop/hive/metastore/model/MRegionStorageDescriptor.java (revision 0)
@@ -0,0 +1,70 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.hadoop.hive.metastore.model;
+
+import java.io.Serializable;
+import java.util.Map;
+
+public class MRegionStorageDescriptor implements Serializable {
+
+ private String regionName;
+ private String location;
+
+ public MRegionStorageDescriptor() {}
+
+ /**
+ * @param regionName
+ * @param location
+ */
+ public MRegionStorageDescriptor(
+ String regionName,
+ String location) {
+ this.regionName = regionName;
+ this.location = location;
+ }
+
+
+ /**
+ * @return region name
+ */
+ public String getRegionName() {
+ return regionName;
+ }
+
+ /**
+ * @param region
+ */
+ public void setRegionName(String regionName) {
+ this.regionName = regionName;
+ }
+
+ /**
+ * @return data location stored in this region descriptor
+ */
+ public String getLocation() {
+ return location;
+ }
+
+ /**
+ * @param location in this region descriptor
+ */
+ public void setLocation(String location) {
+ this.location = location;
+ }
+}
Index: metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
===================================================================
--- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (revision 1242898)
+++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (working copy)
@@ -1033,6 +1033,8 @@
tbl.getSd().setLocation(tblPath.toString());
}
+ MetaStoreUtils.checkOrSetPrimaryRegionName(tbl.getSd(), hiveConf);
+
if (tblPath != null) {
if (!wh.isDir(tblPath)) {
if (!wh.mkdirs(tblPath)) {
@@ -1354,6 +1356,8 @@
.makePartName(tbl.getPartitionKeys(), part_vals));
part.getSd().setLocation(partLocation.toString());
+ MetaStoreUtils.checkOrSetPrimaryRegionName(part.getSd(), hiveConf);
+
Partition old_part = null;
try {
old_part = ms.getPartition(part.getDbName(), part
@@ -1560,6 +1564,8 @@
}
}
+ MetaStoreUtils.checkOrSetPrimaryRegionName(part.getSd(), hiveConf);
+
// set create time
long time = System.currentTimeMillis() / 1000;
part.setCreateTime((int) time);
Index: metastore/src/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java
===================================================================
--- metastore/src/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java (revision 1242898)
+++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveAlterHandler.java (working copy)
@@ -114,6 +114,8 @@
}
}
+ MetaStoreUtils.checkOrSetPrimaryRegionName(newt.getSd(), hiveConf);
+
// if this alter is a rename, the table is not a virtual view, the user
// didn't change the default location (or new location is empty), and
// table is not an external table, that means useris asking metastore to
@@ -157,6 +159,7 @@
+ destPath + " for table " + newt.getDbName() + "."
+ newt.getTableName());
}
+
// also the location field in partition
List parts = msdb.getPartitions(dbname, name, 0);
for (Partition part : parts) {
@@ -247,6 +250,9 @@
new_part.putToParameters(Constants.DDL_TIME, Long.toString(System
.currentTimeMillis() / 1000));
}
+
+ MetaStoreUtils.checkOrSetPrimaryRegionName(new_part.getSd(), hiveConf);
+
//alter partition
if (part_vals == null || part_vals.size() == 0) {
try {
@@ -286,6 +292,7 @@
throw new InvalidObjectException(
"Unable to rename partition because table or database do not exist");
}
+
try {
destPath = new Path(wh.getTablePath(msdb.getDatabase(dbname), name),
Warehouse.makePartName(tbl.getPartitionKeys(), new_part.getValues()));
@@ -391,4 +398,4 @@
return true;
}
-}
\ No newline at end of file
+}
Index: metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
===================================================================
--- metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java (revision 1242898)
+++ metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java (working copy)
@@ -54,6 +54,7 @@
import org.apache.hadoop.hive.common.classification.InterfaceStability;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
+import org.apache.hadoop.hive.metastore.api.RegionStorageDescriptor;
import org.apache.hadoop.hive.metastore.api.Database;
import org.apache.hadoop.hive.metastore.api.FieldSchema;
import org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege;
@@ -79,6 +80,7 @@
import org.apache.hadoop.hive.metastore.api.UnknownDBException;
import org.apache.hadoop.hive.metastore.api.UnknownPartitionException;
import org.apache.hadoop.hive.metastore.api.UnknownTableException;
+import org.apache.hadoop.hive.metastore.model.MRegionStorageDescriptor;
import org.apache.hadoop.hive.metastore.model.MColumnDescriptor;
import org.apache.hadoop.hive.metastore.model.MDBPrivilege;
import org.apache.hadoop.hive.metastore.model.MDatabase;
@@ -940,6 +942,32 @@
return mkeys;
}
+ private List convertToRegionStorageDescriptors(
+ Set mDescs) {
+ List descs = null;
+ if (mDescs != null) {
+ descs = new ArrayList(mDescs.size());
+ for (MRegionStorageDescriptor mDesc : mDescs) {
+ descs.add(new RegionStorageDescriptor(mDesc.getRegionName(),
+ mDesc.getLocation()));
+ }
+ }
+ return descs;
+ }
+
+ private Set convertToMRegionStorageDescriptors(
+ List descs) {
+ Set mDescs = null;
+ if (descs != null) {
+ mDescs = new HashSet(descs.size());
+ for (RegionStorageDescriptor desc : descs) {
+ mDescs.add(new MRegionStorageDescriptor(desc.getRegionName(),
+ desc.getLocation()));
+ }
+ }
+ return mDescs;
+ }
+
private List convertToOrders(List mkeys) {
List keys = null;
if (mkeys != null) {
@@ -992,7 +1020,8 @@
msd.getLocation(), msd.getInputFormat(), msd.getOutputFormat(), msd
.isCompressed(), msd.getNumBuckets(), converToSerDeInfo(msd
.getSerDeInfo()), msd.getBucketCols(), convertToOrders(msd
- .getSortCols()), msd.getParameters());
+ .getSortCols()), msd.getParameters(), msd.getPrimaryRegionName(),
+ convertToRegionStorageDescriptors(msd.getSecondaryRegions()));
}
private StorageDescriptor convertToStorageDescriptor(MStorageDescriptor msd)
@@ -1034,7 +1063,9 @@
.getLocation(), sd.getInputFormat(), sd.getOutputFormat(), sd
.isCompressed(), sd.getNumBuckets(), converToMSerDeInfo(sd
.getSerdeInfo()), sd.getBucketCols(),
- convertToMOrders(sd.getSortCols()), sd.getParameters());
+ convertToMOrders(sd.getSortCols()), sd.getParameters(),
+ sd.getPrimaryRegionName(),
+ convertToMRegionStorageDescriptors(sd.getSecondaryRegions()));
}
public boolean addPartition(Partition part) throws InvalidObjectException,
@@ -1960,6 +1991,7 @@
oldSd.getSerDeInfo().setSerializationLib(
newSd.getSerDeInfo().getSerializationLib());
oldSd.getSerDeInfo().setParameters(newSd.getSerDeInfo().getParameters());
+ oldSd.setPrimaryRegionName(newSd.getPrimaryRegionName());
}
/**
Index: metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java
===================================================================
--- metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java (revision 1242898)
+++ metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java (working copy)
@@ -991,4 +991,28 @@
return listeners;
}
+
+ /**
+ * Temporary check that if the primary region name was set in the storage descriptor, it is
+ * equal to the default region name. If the primary region name was not set it sets it to the
+ * default region name.
+ * @param sd
+ * @param conf
+ * @throws MetaException
+ */
+ public static void checkOrSetPrimaryRegionName(StorageDescriptor sd, Configuration conf)
+ throws MetaException {
+
+ String defaultRegionName =
+ HiveConf.getVar(conf, HiveConf.ConfVars.HIVE_DEFAULT_REGION_NAME);
+
+ if (sd.getPrimaryRegionName() != null &&
+ !sd.getPrimaryRegionName().equals(defaultRegionName)) {
+
+ throw new MetaException("Only default region can be used");
+ } else {
+ // either the primary region name was null or already equal to defaultRegionName
+ sd.setPrimaryRegionName(defaultRegionName);
+ }
+ }
}
Index: metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
===================================================================
--- metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (revision 1242898)
+++ metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (working copy)
@@ -1230,6 +1230,78 @@
def __ne__(self, other):
return not (self == other)
+class RegionStorageDescriptor:
+ """
+ Attributes:
+ - regionName
+ - location
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'regionName', None, None, ), # 1
+ (2, TType.STRING, 'location', None, None, ), # 2
+ )
+
+ def __init__(self, regionName=None, location=None,):
+ self.regionName = regionName
+ self.location = location
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.regionName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.location = iprot.readString();
+ 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('RegionStorageDescriptor')
+ if self.regionName is not None:
+ oprot.writeFieldBegin('regionName', TType.STRING, 1)
+ oprot.writeString(self.regionName)
+ oprot.writeFieldEnd()
+ if self.location is not None:
+ oprot.writeFieldBegin('location', TType.STRING, 2)
+ oprot.writeString(self.location)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ 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 StorageDescriptor:
"""
Attributes:
@@ -1243,6 +1315,8 @@
- bucketCols
- sortCols
- parameters
+ - primaryRegionName
+ - secondaryRegions
"""
thrift_spec = (
@@ -1257,9 +1331,11 @@
(8, TType.LIST, 'bucketCols', (TType.STRING,None), None, ), # 8
(9, TType.LIST, 'sortCols', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 9
(10, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 10
+ (11, TType.STRING, 'primaryRegionName', None, None, ), # 11
+ (12, TType.LIST, 'secondaryRegions', (TType.STRUCT,(RegionStorageDescriptor, RegionStorageDescriptor.thrift_spec)), None, ), # 12
)
- def __init__(self, cols=None, location=None, inputFormat=None, outputFormat=None, compressed=None, numBuckets=None, serdeInfo=None, bucketCols=None, sortCols=None, parameters=None,):
+ def __init__(self, cols=None, location=None, inputFormat=None, outputFormat=None, compressed=None, numBuckets=None, serdeInfo=None, bucketCols=None, sortCols=None, parameters=None, primaryRegionName=None, secondaryRegions=None,):
self.cols = cols
self.location = location
self.inputFormat = inputFormat
@@ -1270,6 +1346,8 @@
self.bucketCols = bucketCols
self.sortCols = sortCols
self.parameters = parameters
+ self.primaryRegionName = primaryRegionName
+ self.secondaryRegions = secondaryRegions
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:
@@ -1354,6 +1432,22 @@
iprot.readMapEnd()
else:
iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.STRING:
+ self.primaryRegionName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.LIST:
+ self.secondaryRegions = []
+ (_etype115, _size112) = iprot.readListBegin()
+ for _i116 in xrange(_size112):
+ _elem117 = RegionStorageDescriptor()
+ _elem117.read(iprot)
+ self.secondaryRegions.append(_elem117)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -1367,8 +1461,8 @@
if self.cols is not None:
oprot.writeFieldBegin('cols', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.cols))
- for iter112 in self.cols:
- iter112.write(oprot)
+ for iter118 in self.cols:
+ iter118.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.location is not None:
@@ -1398,25 +1492,36 @@
if self.bucketCols is not None:
oprot.writeFieldBegin('bucketCols', TType.LIST, 8)
oprot.writeListBegin(TType.STRING, len(self.bucketCols))
- for iter113 in self.bucketCols:
- oprot.writeString(iter113)
+ for iter119 in self.bucketCols:
+ oprot.writeString(iter119)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.sortCols is not None:
oprot.writeFieldBegin('sortCols', TType.LIST, 9)
oprot.writeListBegin(TType.STRUCT, len(self.sortCols))
- for iter114 in self.sortCols:
- iter114.write(oprot)
+ for iter120 in self.sortCols:
+ iter120.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 10)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter115,viter116 in self.parameters.items():
- oprot.writeString(kiter115)
- oprot.writeString(viter116)
+ for kiter121,viter122 in self.parameters.items():
+ oprot.writeString(kiter121)
+ oprot.writeString(viter122)
oprot.writeMapEnd()
oprot.writeFieldEnd()
+ if self.primaryRegionName is not None:
+ oprot.writeFieldBegin('primaryRegionName', TType.STRING, 11)
+ oprot.writeString(self.primaryRegionName)
+ oprot.writeFieldEnd()
+ if self.secondaryRegions is not None:
+ oprot.writeFieldBegin('secondaryRegions', TType.LIST, 12)
+ oprot.writeListBegin(TType.STRUCT, len(self.secondaryRegions))
+ for iter123 in self.secondaryRegions:
+ iter123.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -1533,22 +1638,22 @@
elif fid == 8:
if ftype == TType.LIST:
self.partitionKeys = []
- (_etype120, _size117) = iprot.readListBegin()
- for _i121 in xrange(_size117):
- _elem122 = FieldSchema()
- _elem122.read(iprot)
- self.partitionKeys.append(_elem122)
+ (_etype127, _size124) = iprot.readListBegin()
+ for _i128 in xrange(_size124):
+ _elem129 = FieldSchema()
+ _elem129.read(iprot)
+ self.partitionKeys.append(_elem129)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 9:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype124, _vtype125, _size123 ) = iprot.readMapBegin()
- for _i127 in xrange(_size123):
- _key128 = iprot.readString();
- _val129 = iprot.readString();
- self.parameters[_key128] = _val129
+ (_ktype131, _vtype132, _size130 ) = iprot.readMapBegin()
+ for _i134 in xrange(_size130):
+ _key135 = iprot.readString();
+ _val136 = iprot.readString();
+ self.parameters[_key135] = _val136
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1614,16 +1719,16 @@
if self.partitionKeys is not None:
oprot.writeFieldBegin('partitionKeys', TType.LIST, 8)
oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys))
- for iter130 in self.partitionKeys:
- iter130.write(oprot)
+ for iter137 in self.partitionKeys:
+ iter137.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 9)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter131,viter132 in self.parameters.items():
- oprot.writeString(kiter131)
- oprot.writeString(viter132)
+ for kiter138,viter139 in self.parameters.items():
+ oprot.writeString(kiter138)
+ oprot.writeString(viter139)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.viewOriginalText is not None:
@@ -1707,10 +1812,10 @@
if fid == 1:
if ftype == TType.LIST:
self.values = []
- (_etype136, _size133) = iprot.readListBegin()
- for _i137 in xrange(_size133):
- _elem138 = iprot.readString();
- self.values.append(_elem138)
+ (_etype143, _size140) = iprot.readListBegin()
+ for _i144 in xrange(_size140):
+ _elem145 = iprot.readString();
+ self.values.append(_elem145)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -1743,11 +1848,11 @@
elif fid == 7:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype140, _vtype141, _size139 ) = iprot.readMapBegin()
- for _i143 in xrange(_size139):
- _key144 = iprot.readString();
- _val145 = iprot.readString();
- self.parameters[_key144] = _val145
+ (_ktype147, _vtype148, _size146 ) = iprot.readMapBegin()
+ for _i150 in xrange(_size146):
+ _key151 = iprot.readString();
+ _val152 = iprot.readString();
+ self.parameters[_key151] = _val152
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1770,8 +1875,8 @@
if self.values is not None:
oprot.writeFieldBegin('values', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.values))
- for iter146 in self.values:
- oprot.writeString(iter146)
+ for iter153 in self.values:
+ oprot.writeString(iter153)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.dbName is not None:
@@ -1797,9 +1902,9 @@
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 7)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter147,viter148 in self.parameters.items():
- oprot.writeString(kiter147)
- oprot.writeString(viter148)
+ for kiter154,viter155 in self.parameters.items():
+ oprot.writeString(kiter154)
+ oprot.writeString(viter155)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.privileges is not None:
@@ -1918,11 +2023,11 @@
elif fid == 9:
if ftype == TType.MAP:
self.parameters = {}
- (_ktype150, _vtype151, _size149 ) = iprot.readMapBegin()
- for _i153 in xrange(_size149):
- _key154 = iprot.readString();
- _val155 = iprot.readString();
- self.parameters[_key154] = _val155
+ (_ktype157, _vtype158, _size156 ) = iprot.readMapBegin()
+ for _i160 in xrange(_size156):
+ _key161 = iprot.readString();
+ _val162 = iprot.readString();
+ self.parameters[_key161] = _val162
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -1976,9 +2081,9 @@
if self.parameters is not None:
oprot.writeFieldBegin('parameters', TType.MAP, 9)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
- for kiter156,viter157 in self.parameters.items():
- oprot.writeString(kiter156)
- oprot.writeString(viter157)
+ for kiter163,viter164 in self.parameters.items():
+ oprot.writeString(kiter163)
+ oprot.writeString(viter164)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.deferredRebuild is not None:
@@ -2032,22 +2137,22 @@
if fid == 1:
if ftype == TType.LIST:
self.fieldSchemas = []
- (_etype161, _size158) = iprot.readListBegin()
- for _i162 in xrange(_size158):
- _elem163 = FieldSchema()
- _elem163.read(iprot)
- self.fieldSchemas.append(_elem163)
+ (_etype168, _size165) = iprot.readListBegin()
+ for _i169 in xrange(_size165):
+ _elem170 = FieldSchema()
+ _elem170.read(iprot)
+ self.fieldSchemas.append(_elem170)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.MAP:
self.properties = {}
- (_ktype165, _vtype166, _size164 ) = iprot.readMapBegin()
- for _i168 in xrange(_size164):
- _key169 = iprot.readString();
- _val170 = iprot.readString();
- self.properties[_key169] = _val170
+ (_ktype172, _vtype173, _size171 ) = iprot.readMapBegin()
+ for _i175 in xrange(_size171):
+ _key176 = iprot.readString();
+ _val177 = iprot.readString();
+ self.properties[_key176] = _val177
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -2064,16 +2169,16 @@
if self.fieldSchemas is not None:
oprot.writeFieldBegin('fieldSchemas', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.fieldSchemas))
- for iter171 in self.fieldSchemas:
- iter171.write(oprot)
+ for iter178 in self.fieldSchemas:
+ iter178.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 2)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter172,viter173 in self.properties.items():
- oprot.writeString(kiter172)
- oprot.writeString(viter173)
+ for kiter179,viter180 in self.properties.items():
+ oprot.writeString(kiter179)
+ oprot.writeString(viter180)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
Index: metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
===================================================================
--- metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (revision 1242898)
+++ metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (working copy)
@@ -4553,10 +4553,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype177, _size174) = iprot.readListBegin()
- for _i178 in xrange(_size174):
- _elem179 = iprot.readString();
- self.success.append(_elem179)
+ (_etype184, _size181) = iprot.readListBegin()
+ for _i185 in xrange(_size181):
+ _elem186 = iprot.readString();
+ self.success.append(_elem186)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4579,8 +4579,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter180 in self.success:
- oprot.writeString(iter180)
+ for iter187 in self.success:
+ oprot.writeString(iter187)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -4675,10 +4675,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype184, _size181) = iprot.readListBegin()
- for _i185 in xrange(_size181):
- _elem186 = iprot.readString();
- self.success.append(_elem186)
+ (_etype191, _size188) = iprot.readListBegin()
+ for _i192 in xrange(_size188):
+ _elem193 = iprot.readString();
+ self.success.append(_elem193)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -4701,8 +4701,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter187 in self.success:
- oprot.writeString(iter187)
+ for iter194 in self.success:
+ oprot.writeString(iter194)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -5412,12 +5412,12 @@
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype189, _vtype190, _size188 ) = iprot.readMapBegin()
- for _i192 in xrange(_size188):
- _key193 = iprot.readString();
- _val194 = Type()
- _val194.read(iprot)
- self.success[_key193] = _val194
+ (_ktype196, _vtype197, _size195 ) = iprot.readMapBegin()
+ for _i199 in xrange(_size195):
+ _key200 = iprot.readString();
+ _val201 = Type()
+ _val201.read(iprot)
+ self.success[_key200] = _val201
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -5440,9 +5440,9 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter195,viter196 in self.success.items():
- oprot.writeString(kiter195)
- viter196.write(oprot)
+ for kiter202,viter203 in self.success.items():
+ oprot.writeString(kiter202)
+ viter203.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -5573,11 +5573,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype200, _size197) = iprot.readListBegin()
- for _i201 in xrange(_size197):
- _elem202 = FieldSchema()
- _elem202.read(iprot)
- self.success.append(_elem202)
+ (_etype207, _size204) = iprot.readListBegin()
+ for _i208 in xrange(_size204):
+ _elem209 = FieldSchema()
+ _elem209.read(iprot)
+ self.success.append(_elem209)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5612,8 +5612,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter203 in self.success:
- iter203.write(oprot)
+ for iter210 in self.success:
+ iter210.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -5752,11 +5752,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype207, _size204) = iprot.readListBegin()
- for _i208 in xrange(_size204):
- _elem209 = FieldSchema()
- _elem209.read(iprot)
- self.success.append(_elem209)
+ (_etype214, _size211) = iprot.readListBegin()
+ for _i215 in xrange(_size211):
+ _elem216 = FieldSchema()
+ _elem216.read(iprot)
+ self.success.append(_elem216)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -5791,8 +5791,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter210 in self.success:
- iter210.write(oprot)
+ for iter217 in self.success:
+ iter217.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6244,10 +6244,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype214, _size211) = iprot.readListBegin()
- for _i215 in xrange(_size211):
- _elem216 = iprot.readString();
- self.success.append(_elem216)
+ (_etype221, _size218) = iprot.readListBegin()
+ for _i222 in xrange(_size218):
+ _elem223 = iprot.readString();
+ self.success.append(_elem223)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6270,8 +6270,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter217 in self.success:
- oprot.writeString(iter217)
+ for iter224 in self.success:
+ oprot.writeString(iter224)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6384,10 +6384,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype221, _size218) = iprot.readListBegin()
- for _i222 in xrange(_size218):
- _elem223 = iprot.readString();
- self.success.append(_elem223)
+ (_etype228, _size225) = iprot.readListBegin()
+ for _i229 in xrange(_size225):
+ _elem230 = iprot.readString();
+ self.success.append(_elem230)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6410,8 +6410,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter224 in self.success:
- oprot.writeString(iter224)
+ for iter231 in self.success:
+ oprot.writeString(iter231)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6628,10 +6628,10 @@
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype228, _size225) = iprot.readListBegin()
- for _i229 in xrange(_size225):
- _elem230 = iprot.readString();
- self.tbl_names.append(_elem230)
+ (_etype235, _size232) = iprot.readListBegin()
+ for _i236 in xrange(_size232):
+ _elem237 = iprot.readString();
+ self.tbl_names.append(_elem237)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6652,8 +6652,8 @@
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter231 in self.tbl_names:
- oprot.writeString(iter231)
+ for iter238 in self.tbl_names:
+ oprot.writeString(iter238)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -6708,11 +6708,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype235, _size232) = iprot.readListBegin()
- for _i236 in xrange(_size232):
- _elem237 = Table()
- _elem237.read(iprot)
- self.success.append(_elem237)
+ (_etype242, _size239) = iprot.readListBegin()
+ for _i243 in xrange(_size239):
+ _elem244 = Table()
+ _elem244.read(iprot)
+ self.success.append(_elem244)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6747,8 +6747,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter238 in self.success:
- iter238.write(oprot)
+ for iter245 in self.success:
+ iter245.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6899,10 +6899,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype242, _size239) = iprot.readListBegin()
- for _i243 in xrange(_size239):
- _elem244 = iprot.readString();
- self.success.append(_elem244)
+ (_etype249, _size246) = iprot.readListBegin()
+ for _i250 in xrange(_size246):
+ _elem251 = iprot.readString();
+ self.success.append(_elem251)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6937,8 +6937,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter245 in self.success:
- oprot.writeString(iter245)
+ for iter252 in self.success:
+ oprot.writeString(iter252)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7316,11 +7316,11 @@
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype249, _size246) = iprot.readListBegin()
- for _i250 in xrange(_size246):
- _elem251 = Partition()
- _elem251.read(iprot)
- self.new_parts.append(_elem251)
+ (_etype256, _size253) = iprot.readListBegin()
+ for _i257 in xrange(_size253):
+ _elem258 = Partition()
+ _elem258.read(iprot)
+ self.new_parts.append(_elem258)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7337,8 +7337,8 @@
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter252 in self.new_parts:
- iter252.write(oprot)
+ for iter259 in self.new_parts:
+ iter259.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7499,10 +7499,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype256, _size253) = iprot.readListBegin()
- for _i257 in xrange(_size253):
- _elem258 = iprot.readString();
- self.part_vals.append(_elem258)
+ (_etype263, _size260) = iprot.readListBegin()
+ for _i264 in xrange(_size260):
+ _elem265 = iprot.readString();
+ self.part_vals.append(_elem265)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7527,8 +7527,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter259 in self.part_vals:
- oprot.writeString(iter259)
+ for iter266 in self.part_vals:
+ oprot.writeString(iter266)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7876,10 +7876,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype263, _size260) = iprot.readListBegin()
- for _i264 in xrange(_size260):
- _elem265 = iprot.readString();
- self.part_vals.append(_elem265)
+ (_etype270, _size267) = iprot.readListBegin()
+ for _i271 in xrange(_size267):
+ _elem272 = iprot.readString();
+ self.part_vals.append(_elem272)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7909,8 +7909,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter266 in self.part_vals:
- oprot.writeString(iter266)
+ for iter273 in self.part_vals:
+ oprot.writeString(iter273)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -8243,10 +8243,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype270, _size267) = iprot.readListBegin()
- for _i271 in xrange(_size267):
- _elem272 = iprot.readString();
- self.part_vals.append(_elem272)
+ (_etype277, _size274) = iprot.readListBegin()
+ for _i278 in xrange(_size274):
+ _elem279 = iprot.readString();
+ self.part_vals.append(_elem279)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8271,8 +8271,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter273 in self.part_vals:
- oprot.writeString(iter273)
+ for iter280 in self.part_vals:
+ oprot.writeString(iter280)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8427,10 +8427,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype277, _size274) = iprot.readListBegin()
- for _i278 in xrange(_size274):
- _elem279 = iprot.readString();
- self.part_vals.append(_elem279)
+ (_etype284, _size281) = iprot.readListBegin()
+ for _i285 in xrange(_size281):
+ _elem286 = iprot.readString();
+ self.part_vals.append(_elem286)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8442,10 +8442,10 @@
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype283, _size280) = iprot.readListBegin()
- for _i284 in xrange(_size280):
- _elem285 = iprot.readString();
- self.group_names.append(_elem285)
+ (_etype290, _size287) = iprot.readListBegin()
+ for _i291 in xrange(_size287):
+ _elem292 = iprot.readString();
+ self.group_names.append(_elem292)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8470,8 +8470,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter286 in self.part_vals:
- oprot.writeString(iter286)
+ for iter293 in self.part_vals:
+ oprot.writeString(iter293)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -8481,8 +8481,8 @@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter287 in self.group_names:
- oprot.writeString(iter287)
+ for iter294 in self.group_names:
+ oprot.writeString(iter294)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8874,11 +8874,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype291, _size288) = iprot.readListBegin()
- for _i292 in xrange(_size288):
- _elem293 = Partition()
- _elem293.read(iprot)
- self.success.append(_elem293)
+ (_etype298, _size295) = iprot.readListBegin()
+ for _i299 in xrange(_size295):
+ _elem300 = Partition()
+ _elem300.read(iprot)
+ self.success.append(_elem300)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8907,8 +8907,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter294 in self.success:
- iter294.write(oprot)
+ for iter301 in self.success:
+ iter301.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8995,10 +8995,10 @@
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype298, _size295) = iprot.readListBegin()
- for _i299 in xrange(_size295):
- _elem300 = iprot.readString();
- self.group_names.append(_elem300)
+ (_etype305, _size302) = iprot.readListBegin()
+ for _i306 in xrange(_size302):
+ _elem307 = iprot.readString();
+ self.group_names.append(_elem307)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9031,8 +9031,8 @@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter301 in self.group_names:
- oprot.writeString(iter301)
+ for iter308 in self.group_names:
+ oprot.writeString(iter308)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9084,11 +9084,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype305, _size302) = iprot.readListBegin()
- for _i306 in xrange(_size302):
- _elem307 = Partition()
- _elem307.read(iprot)
- self.success.append(_elem307)
+ (_etype312, _size309) = iprot.readListBegin()
+ for _i313 in xrange(_size309):
+ _elem314 = Partition()
+ _elem314.read(iprot)
+ self.success.append(_elem314)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9117,8 +9117,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter308 in self.success:
- iter308.write(oprot)
+ for iter315 in self.success:
+ iter315.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9259,10 +9259,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype312, _size309) = iprot.readListBegin()
- for _i313 in xrange(_size309):
- _elem314 = iprot.readString();
- self.success.append(_elem314)
+ (_etype319, _size316) = iprot.readListBegin()
+ for _i320 in xrange(_size316):
+ _elem321 = iprot.readString();
+ self.success.append(_elem321)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9285,8 +9285,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter315 in self.success:
- oprot.writeString(iter315)
+ for iter322 in self.success:
+ oprot.writeString(iter322)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -9356,10 +9356,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype319, _size316) = iprot.readListBegin()
- for _i320 in xrange(_size316):
- _elem321 = iprot.readString();
- self.part_vals.append(_elem321)
+ (_etype326, _size323) = iprot.readListBegin()
+ for _i327 in xrange(_size323):
+ _elem328 = iprot.readString();
+ self.part_vals.append(_elem328)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9389,8 +9389,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter322 in self.part_vals:
- oprot.writeString(iter322)
+ for iter329 in self.part_vals:
+ oprot.writeString(iter329)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -9446,11 +9446,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype326, _size323) = iprot.readListBegin()
- for _i327 in xrange(_size323):
- _elem328 = Partition()
- _elem328.read(iprot)
- self.success.append(_elem328)
+ (_etype333, _size330) = iprot.readListBegin()
+ for _i334 in xrange(_size330):
+ _elem335 = Partition()
+ _elem335.read(iprot)
+ self.success.append(_elem335)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9479,8 +9479,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter329 in self.success:
- iter329.write(oprot)
+ for iter336 in self.success:
+ iter336.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9560,10 +9560,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype333, _size330) = iprot.readListBegin()
- for _i334 in xrange(_size330):
- _elem335 = iprot.readString();
- self.part_vals.append(_elem335)
+ (_etype340, _size337) = iprot.readListBegin()
+ for _i341 in xrange(_size337):
+ _elem342 = iprot.readString();
+ self.part_vals.append(_elem342)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9580,10 +9580,10 @@
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype339, _size336) = iprot.readListBegin()
- for _i340 in xrange(_size336):
- _elem341 = iprot.readString();
- self.group_names.append(_elem341)
+ (_etype346, _size343) = iprot.readListBegin()
+ for _i347 in xrange(_size343):
+ _elem348 = iprot.readString();
+ self.group_names.append(_elem348)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9608,8 +9608,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter342 in self.part_vals:
- oprot.writeString(iter342)
+ for iter349 in self.part_vals:
+ oprot.writeString(iter349)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -9623,8 +9623,8 @@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 6)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter343 in self.group_names:
- oprot.writeString(iter343)
+ for iter350 in self.group_names:
+ oprot.writeString(iter350)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9676,11 +9676,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype347, _size344) = iprot.readListBegin()
- for _i348 in xrange(_size344):
- _elem349 = Partition()
- _elem349.read(iprot)
- self.success.append(_elem349)
+ (_etype354, _size351) = iprot.readListBegin()
+ for _i355 in xrange(_size351):
+ _elem356 = Partition()
+ _elem356.read(iprot)
+ self.success.append(_elem356)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9709,8 +9709,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter350 in self.success:
- iter350.write(oprot)
+ for iter357 in self.success:
+ iter357.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9784,10 +9784,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype354, _size351) = iprot.readListBegin()
- for _i355 in xrange(_size351):
- _elem356 = iprot.readString();
- self.part_vals.append(_elem356)
+ (_etype361, _size358) = iprot.readListBegin()
+ for _i362 in xrange(_size358):
+ _elem363 = iprot.readString();
+ self.part_vals.append(_elem363)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9817,8 +9817,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter357 in self.part_vals:
- oprot.writeString(iter357)
+ for iter364 in self.part_vals:
+ oprot.writeString(iter364)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -9874,10 +9874,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype361, _size358) = iprot.readListBegin()
- for _i362 in xrange(_size358):
- _elem363 = iprot.readString();
- self.success.append(_elem363)
+ (_etype368, _size365) = iprot.readListBegin()
+ for _i369 in xrange(_size365):
+ _elem370 = iprot.readString();
+ self.success.append(_elem370)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9906,8 +9906,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter364 in self.success:
- oprot.writeString(iter364)
+ for iter371 in self.success:
+ oprot.writeString(iter371)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10063,11 +10063,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype368, _size365) = iprot.readListBegin()
- for _i369 in xrange(_size365):
- _elem370 = Partition()
- _elem370.read(iprot)
- self.success.append(_elem370)
+ (_etype375, _size372) = iprot.readListBegin()
+ for _i376 in xrange(_size372):
+ _elem377 = Partition()
+ _elem377.read(iprot)
+ self.success.append(_elem377)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10096,8 +10096,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter371 in self.success:
- iter371.write(oprot)
+ for iter378 in self.success:
+ iter378.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10168,10 +10168,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype375, _size372) = iprot.readListBegin()
- for _i376 in xrange(_size372):
- _elem377 = iprot.readString();
- self.names.append(_elem377)
+ (_etype382, _size379) = iprot.readListBegin()
+ for _i383 in xrange(_size379):
+ _elem384 = iprot.readString();
+ self.names.append(_elem384)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10196,8 +10196,8 @@
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter378 in self.names:
- oprot.writeString(iter378)
+ for iter385 in self.names:
+ oprot.writeString(iter385)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10249,11 +10249,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype382, _size379) = iprot.readListBegin()
- for _i383 in xrange(_size379):
- _elem384 = Partition()
- _elem384.read(iprot)
- self.success.append(_elem384)
+ (_etype389, _size386) = iprot.readListBegin()
+ for _i390 in xrange(_size386):
+ _elem391 = Partition()
+ _elem391.read(iprot)
+ self.success.append(_elem391)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10282,8 +10282,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter385 in self.success:
- iter385.write(oprot)
+ for iter392 in self.success:
+ iter392.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10516,10 +10516,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype389, _size386) = iprot.readListBegin()
- for _i390 in xrange(_size386):
- _elem391 = iprot.readString();
- self.part_vals.append(_elem391)
+ (_etype396, _size393) = iprot.readListBegin()
+ for _i397 in xrange(_size393):
+ _elem398 = iprot.readString();
+ self.part_vals.append(_elem398)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10550,8 +10550,8 @@
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter392 in self.part_vals:
- oprot.writeString(iter392)
+ for iter399 in self.part_vals:
+ oprot.writeString(iter399)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -10882,10 +10882,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype396, _size393) = iprot.readListBegin()
- for _i397 in xrange(_size393):
- _elem398 = iprot.readString();
- self.success.append(_elem398)
+ (_etype403, _size400) = iprot.readListBegin()
+ for _i404 in xrange(_size400):
+ _elem405 = iprot.readString();
+ self.success.append(_elem405)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10908,8 +10908,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter399 in self.success:
- oprot.writeString(iter399)
+ for iter406 in self.success:
+ oprot.writeString(iter406)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11022,11 +11022,11 @@
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype401, _vtype402, _size400 ) = iprot.readMapBegin()
- for _i404 in xrange(_size400):
- _key405 = iprot.readString();
- _val406 = iprot.readString();
- self.success[_key405] = _val406
+ (_ktype408, _vtype409, _size407 ) = iprot.readMapBegin()
+ for _i411 in xrange(_size407):
+ _key412 = iprot.readString();
+ _val413 = iprot.readString();
+ self.success[_key412] = _val413
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11049,9 +11049,9 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter407,viter408 in self.success.items():
- oprot.writeString(kiter407)
- oprot.writeString(viter408)
+ for kiter414,viter415 in self.success.items():
+ oprot.writeString(kiter414)
+ oprot.writeString(viter415)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11121,11 +11121,11 @@
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype410, _vtype411, _size409 ) = iprot.readMapBegin()
- for _i413 in xrange(_size409):
- _key414 = iprot.readString();
- _val415 = iprot.readString();
- self.part_vals[_key414] = _val415
+ (_ktype417, _vtype418, _size416 ) = iprot.readMapBegin()
+ for _i420 in xrange(_size416):
+ _key421 = iprot.readString();
+ _val422 = iprot.readString();
+ self.part_vals[_key421] = _val422
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11155,9 +11155,9 @@
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 kiter416,viter417 in self.part_vals.items():
- oprot.writeString(kiter416)
- oprot.writeString(viter417)
+ for kiter423,viter424 in self.part_vals.items():
+ oprot.writeString(kiter423)
+ oprot.writeString(viter424)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -11353,11 +11353,11 @@
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype419, _vtype420, _size418 ) = iprot.readMapBegin()
- for _i422 in xrange(_size418):
- _key423 = iprot.readString();
- _val424 = iprot.readString();
- self.part_vals[_key423] = _val424
+ (_ktype426, _vtype427, _size425 ) = iprot.readMapBegin()
+ for _i429 in xrange(_size425):
+ _key430 = iprot.readString();
+ _val431 = iprot.readString();
+ self.part_vals[_key430] = _val431
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11387,9 +11387,9 @@
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 kiter425,viter426 in self.part_vals.items():
- oprot.writeString(kiter425)
- oprot.writeString(viter426)
+ for kiter432,viter433 in self.part_vals.items():
+ oprot.writeString(kiter432)
+ oprot.writeString(viter433)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -12361,11 +12361,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype430, _size427) = iprot.readListBegin()
- for _i431 in xrange(_size427):
- _elem432 = Index()
- _elem432.read(iprot)
- self.success.append(_elem432)
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = Index()
+ _elem439.read(iprot)
+ self.success.append(_elem439)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12394,8 +12394,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter433 in self.success:
- iter433.write(oprot)
+ for iter440 in self.success:
+ iter440.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12536,10 +12536,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype437, _size434) = iprot.readListBegin()
- for _i438 in xrange(_size434):
- _elem439 = iprot.readString();
- self.success.append(_elem439)
+ (_etype444, _size441) = iprot.readListBegin()
+ for _i445 in xrange(_size441):
+ _elem446 = iprot.readString();
+ self.success.append(_elem446)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12562,8 +12562,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter440 in self.success:
- oprot.writeString(iter440)
+ for iter447 in self.success:
+ oprot.writeString(iter447)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12923,10 +12923,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString();
- self.success.append(_elem446)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = iprot.readString();
+ self.success.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12949,8 +12949,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter447 in self.success:
- oprot.writeString(iter447)
+ for iter454 in self.success:
+ oprot.writeString(iter454)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13423,11 +13423,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = Role()
- _elem453.read(iprot)
- self.success.append(_elem453)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = Role()
+ _elem460.read(iprot)
+ self.success.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13450,8 +13450,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter454 in self.success:
- iter454.write(oprot)
+ for iter461 in self.success:
+ iter461.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13519,10 +13519,10 @@
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString();
- self.group_names.append(_elem460)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = iprot.readString();
+ self.group_names.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13547,8 +13547,8 @@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter461 in self.group_names:
- oprot.writeString(iter461)
+ for iter468 in self.group_names:
+ oprot.writeString(iter468)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13755,11 +13755,11 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = HiveObjectPrivilege()
- _elem467.read(iprot)
- self.success.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = HiveObjectPrivilege()
+ _elem474.read(iprot)
+ self.success.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13782,8 +13782,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter468 in self.success:
- iter468.write(oprot)
+ for iter475 in self.success:
+ iter475.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14108,10 +14108,10 @@
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readString();
- self.group_names.append(_elem474)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = iprot.readString();
+ self.group_names.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14132,8 +14132,8 @@
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter475 in self.group_names:
- oprot.writeString(iter475)
+ for iter482 in self.group_names:
+ oprot.writeString(iter482)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14182,10 +14182,10 @@
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype479, _size476) = iprot.readListBegin()
- for _i480 in xrange(_size476):
- _elem481 = iprot.readString();
- self.success.append(_elem481)
+ (_etype486, _size483) = iprot.readListBegin()
+ for _i487 in xrange(_size483):
+ _elem488 = iprot.readString();
+ self.success.append(_elem488)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14208,8 +14208,8 @@
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter482 in self.success:
- oprot.writeString(iter482)
+ for iter489 in self.success:
+ oprot.writeString(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
Index: metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp
===================================================================
--- metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp (revision 1242898)
+++ metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp (working copy)
@@ -715,14 +715,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size155;
- ::apache::thrift::protocol::TType _etype158;
- iprot->readListBegin(_etype158, _size155);
- this->success.resize(_size155);
- uint32_t _i159;
- for (_i159 = 0; _i159 < _size155; ++_i159)
+ uint32_t _size161;
+ ::apache::thrift::protocol::TType _etype164;
+ iprot->readListBegin(_etype164, _size161);
+ this->success.resize(_size161);
+ uint32_t _i165;
+ for (_i165 = 0; _i165 < _size161; ++_i165)
{
- xfer += iprot->readString(this->success[_i159]);
+ xfer += iprot->readString(this->success[_i165]);
}
iprot->readListEnd();
}
@@ -761,10 +761,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter160;
- for (_iter160 = this->success.begin(); _iter160 != this->success.end(); ++_iter160)
+ std::vector ::const_iterator _iter166;
+ for (_iter166 = this->success.begin(); _iter166 != this->success.end(); ++_iter166)
{
- xfer += oprot->writeString((*_iter160));
+ xfer += oprot->writeString((*_iter166));
}
xfer += oprot->writeListEnd();
}
@@ -803,14 +803,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size161;
- ::apache::thrift::protocol::TType _etype164;
- iprot->readListBegin(_etype164, _size161);
- (*(this->success)).resize(_size161);
- uint32_t _i165;
- for (_i165 = 0; _i165 < _size161; ++_i165)
+ uint32_t _size167;
+ ::apache::thrift::protocol::TType _etype170;
+ iprot->readListBegin(_etype170, _size167);
+ (*(this->success)).resize(_size167);
+ uint32_t _i171;
+ for (_i171 = 0; _i171 < _size167; ++_i171)
{
- xfer += iprot->readString((*(this->success))[_i165]);
+ xfer += iprot->readString((*(this->success))[_i171]);
}
iprot->readListEnd();
}
@@ -911,14 +911,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size166;
- ::apache::thrift::protocol::TType _etype169;
- iprot->readListBegin(_etype169, _size166);
- this->success.resize(_size166);
- uint32_t _i170;
- for (_i170 = 0; _i170 < _size166; ++_i170)
+ uint32_t _size172;
+ ::apache::thrift::protocol::TType _etype175;
+ iprot->readListBegin(_etype175, _size172);
+ this->success.resize(_size172);
+ uint32_t _i176;
+ for (_i176 = 0; _i176 < _size172; ++_i176)
{
- xfer += iprot->readString(this->success[_i170]);
+ xfer += iprot->readString(this->success[_i176]);
}
iprot->readListEnd();
}
@@ -957,10 +957,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter171;
- for (_iter171 = this->success.begin(); _iter171 != this->success.end(); ++_iter171)
+ std::vector ::const_iterator _iter177;
+ for (_iter177 = this->success.begin(); _iter177 != this->success.end(); ++_iter177)
{
- xfer += oprot->writeString((*_iter171));
+ xfer += oprot->writeString((*_iter177));
}
xfer += oprot->writeListEnd();
}
@@ -999,14 +999,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size172;
- ::apache::thrift::protocol::TType _etype175;
- iprot->readListBegin(_etype175, _size172);
- (*(this->success)).resize(_size172);
- uint32_t _i176;
- for (_i176 = 0; _i176 < _size172; ++_i176)
+ uint32_t _size178;
+ ::apache::thrift::protocol::TType _etype181;
+ iprot->readListBegin(_etype181, _size178);
+ (*(this->success)).resize(_size178);
+ uint32_t _i182;
+ for (_i182 = 0; _i182 < _size178; ++_i182)
{
- xfer += iprot->readString((*(this->success))[_i176]);
+ xfer += iprot->readString((*(this->success))[_i182]);
}
iprot->readListEnd();
}
@@ -1927,17 +1927,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size177;
- ::apache::thrift::protocol::TType _ktype178;
- ::apache::thrift::protocol::TType _vtype179;
- iprot->readMapBegin(_ktype178, _vtype179, _size177);
- uint32_t _i181;
- for (_i181 = 0; _i181 < _size177; ++_i181)
+ uint32_t _size183;
+ ::apache::thrift::protocol::TType _ktype184;
+ ::apache::thrift::protocol::TType _vtype185;
+ iprot->readMapBegin(_ktype184, _vtype185, _size183);
+ uint32_t _i187;
+ for (_i187 = 0; _i187 < _size183; ++_i187)
{
- std::string _key182;
- xfer += iprot->readString(_key182);
- Type& _val183 = this->success[_key182];
- xfer += _val183.read(iprot);
+ std::string _key188;
+ xfer += iprot->readString(_key188);
+ Type& _val189 = this->success[_key188];
+ xfer += _val189.read(iprot);
}
iprot->readMapEnd();
}
@@ -1976,11 +1976,11 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::map ::const_iterator _iter184;
- for (_iter184 = this->success.begin(); _iter184 != this->success.end(); ++_iter184)
+ std::map ::const_iterator _iter190;
+ for (_iter190 = this->success.begin(); _iter190 != this->success.end(); ++_iter190)
{
- xfer += oprot->writeString(_iter184->first);
- xfer += _iter184->second.write(oprot);
+ xfer += oprot->writeString(_iter190->first);
+ xfer += _iter190->second.write(oprot);
}
xfer += oprot->writeMapEnd();
}
@@ -2019,17 +2019,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size185;
- ::apache::thrift::protocol::TType _ktype186;
- ::apache::thrift::protocol::TType _vtype187;
- iprot->readMapBegin(_ktype186, _vtype187, _size185);
- uint32_t _i189;
- for (_i189 = 0; _i189 < _size185; ++_i189)
+ uint32_t _size191;
+ ::apache::thrift::protocol::TType _ktype192;
+ ::apache::thrift::protocol::TType _vtype193;
+ iprot->readMapBegin(_ktype192, _vtype193, _size191);
+ uint32_t _i195;
+ for (_i195 = 0; _i195 < _size191; ++_i195)
{
- std::string _key190;
- xfer += iprot->readString(_key190);
- Type& _val191 = (*(this->success))[_key190];
- xfer += _val191.read(iprot);
+ std::string _key196;
+ xfer += iprot->readString(_key196);
+ Type& _val197 = (*(this->success))[_key196];
+ xfer += _val197.read(iprot);
}
iprot->readMapEnd();
}
@@ -2158,14 +2158,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size192;
- ::apache::thrift::protocol::TType _etype195;
- iprot->readListBegin(_etype195, _size192);
- this->success.resize(_size192);
- uint32_t _i196;
- for (_i196 = 0; _i196 < _size192; ++_i196)
+ uint32_t _size198;
+ ::apache::thrift::protocol::TType _etype201;
+ iprot->readListBegin(_etype201, _size198);
+ this->success.resize(_size198);
+ uint32_t _i202;
+ for (_i202 = 0; _i202 < _size198; ++_i202)
{
- xfer += this->success[_i196].read(iprot);
+ xfer += this->success[_i202].read(iprot);
}
iprot->readListEnd();
}
@@ -2220,10 +2220,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter197;
- for (_iter197 = this->success.begin(); _iter197 != this->success.end(); ++_iter197)
+ std::vector ::const_iterator _iter203;
+ for (_iter203 = this->success.begin(); _iter203 != this->success.end(); ++_iter203)
{
- xfer += (*_iter197).write(oprot);
+ xfer += (*_iter203).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2270,14 +2270,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size198;
- ::apache::thrift::protocol::TType _etype201;
- iprot->readListBegin(_etype201, _size198);
- (*(this->success)).resize(_size198);
- uint32_t _i202;
- for (_i202 = 0; _i202 < _size198; ++_i202)
+ uint32_t _size204;
+ ::apache::thrift::protocol::TType _etype207;
+ iprot->readListBegin(_etype207, _size204);
+ (*(this->success)).resize(_size204);
+ uint32_t _i208;
+ for (_i208 = 0; _i208 < _size204; ++_i208)
{
- xfer += (*(this->success))[_i202].read(iprot);
+ xfer += (*(this->success))[_i208].read(iprot);
}
iprot->readListEnd();
}
@@ -2422,14 +2422,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size203;
- ::apache::thrift::protocol::TType _etype206;
- iprot->readListBegin(_etype206, _size203);
- this->success.resize(_size203);
- uint32_t _i207;
- for (_i207 = 0; _i207 < _size203; ++_i207)
+ uint32_t _size209;
+ ::apache::thrift::protocol::TType _etype212;
+ iprot->readListBegin(_etype212, _size209);
+ this->success.resize(_size209);
+ uint32_t _i213;
+ for (_i213 = 0; _i213 < _size209; ++_i213)
{
- xfer += this->success[_i207].read(iprot);
+ xfer += this->success[_i213].read(iprot);
}
iprot->readListEnd();
}
@@ -2484,10 +2484,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter208;
- for (_iter208 = this->success.begin(); _iter208 != this->success.end(); ++_iter208)
+ std::vector ::const_iterator _iter214;
+ for (_iter214 = this->success.begin(); _iter214 != this->success.end(); ++_iter214)
{
- xfer += (*_iter208).write(oprot);
+ xfer += (*_iter214).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2534,14 +2534,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size209;
- ::apache::thrift::protocol::TType _etype212;
- iprot->readListBegin(_etype212, _size209);
- (*(this->success)).resize(_size209);
- uint32_t _i213;
- for (_i213 = 0; _i213 < _size209; ++_i213)
+ uint32_t _size215;
+ ::apache::thrift::protocol::TType _etype218;
+ iprot->readListBegin(_etype218, _size215);
+ (*(this->success)).resize(_size215);
+ uint32_t _i219;
+ for (_i219 = 0; _i219 < _size215; ++_i219)
{
- xfer += (*(this->success))[_i213].read(iprot);
+ xfer += (*(this->success))[_i219].read(iprot);
}
iprot->readListEnd();
}
@@ -3110,14 +3110,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size214;
- ::apache::thrift::protocol::TType _etype217;
- iprot->readListBegin(_etype217, _size214);
- this->success.resize(_size214);
- uint32_t _i218;
- for (_i218 = 0; _i218 < _size214; ++_i218)
+ uint32_t _size220;
+ ::apache::thrift::protocol::TType _etype223;
+ iprot->readListBegin(_etype223, _size220);
+ this->success.resize(_size220);
+ uint32_t _i224;
+ for (_i224 = 0; _i224 < _size220; ++_i224)
{
- xfer += iprot->readString(this->success[_i218]);
+ xfer += iprot->readString(this->success[_i224]);
}
iprot->readListEnd();
}
@@ -3156,10 +3156,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter219;
- for (_iter219 = this->success.begin(); _iter219 != this->success.end(); ++_iter219)
+ std::vector ::const_iterator _iter225;
+ for (_iter225 = this->success.begin(); _iter225 != this->success.end(); ++_iter225)
{
- xfer += oprot->writeString((*_iter219));
+ xfer += oprot->writeString((*_iter225));
}
xfer += oprot->writeListEnd();
}
@@ -3198,14 +3198,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size220;
- ::apache::thrift::protocol::TType _etype223;
- iprot->readListBegin(_etype223, _size220);
- (*(this->success)).resize(_size220);
- uint32_t _i224;
- for (_i224 = 0; _i224 < _size220; ++_i224)
+ uint32_t _size226;
+ ::apache::thrift::protocol::TType _etype229;
+ iprot->readListBegin(_etype229, _size226);
+ (*(this->success)).resize(_size226);
+ uint32_t _i230;
+ for (_i230 = 0; _i230 < _size226; ++_i230)
{
- xfer += iprot->readString((*(this->success))[_i224]);
+ xfer += iprot->readString((*(this->success))[_i230]);
}
iprot->readListEnd();
}
@@ -3320,14 +3320,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size225;
- ::apache::thrift::protocol::TType _etype228;
- iprot->readListBegin(_etype228, _size225);
- this->success.resize(_size225);
- uint32_t _i229;
- for (_i229 = 0; _i229 < _size225; ++_i229)
+ uint32_t _size231;
+ ::apache::thrift::protocol::TType _etype234;
+ iprot->readListBegin(_etype234, _size231);
+ this->success.resize(_size231);
+ uint32_t _i235;
+ for (_i235 = 0; _i235 < _size231; ++_i235)
{
- xfer += iprot->readString(this->success[_i229]);
+ xfer += iprot->readString(this->success[_i235]);
}
iprot->readListEnd();
}
@@ -3366,10 +3366,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter230;
- for (_iter230 = this->success.begin(); _iter230 != this->success.end(); ++_iter230)
+ std::vector ::const_iterator _iter236;
+ for (_iter236 = this->success.begin(); _iter236 != this->success.end(); ++_iter236)
{
- xfer += oprot->writeString((*_iter230));
+ xfer += oprot->writeString((*_iter236));
}
xfer += oprot->writeListEnd();
}
@@ -3408,14 +3408,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size231;
- ::apache::thrift::protocol::TType _etype234;
- iprot->readListBegin(_etype234, _size231);
- (*(this->success)).resize(_size231);
- uint32_t _i235;
- for (_i235 = 0; _i235 < _size231; ++_i235)
+ uint32_t _size237;
+ ::apache::thrift::protocol::TType _etype240;
+ iprot->readListBegin(_etype240, _size237);
+ (*(this->success)).resize(_size237);
+ uint32_t _i241;
+ for (_i241 = 0; _i241 < _size237; ++_i241)
{
- xfer += iprot->readString((*(this->success))[_i235]);
+ xfer += iprot->readString((*(this->success))[_i241]);
}
iprot->readListEnd();
}
@@ -3688,14 +3688,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->tbl_names.clear();
- uint32_t _size236;
- ::apache::thrift::protocol::TType _etype239;
- iprot->readListBegin(_etype239, _size236);
- this->tbl_names.resize(_size236);
- uint32_t _i240;
- for (_i240 = 0; _i240 < _size236; ++_i240)
+ uint32_t _size242;
+ ::apache::thrift::protocol::TType _etype245;
+ iprot->readListBegin(_etype245, _size242);
+ this->tbl_names.resize(_size242);
+ uint32_t _i246;
+ for (_i246 = 0; _i246 < _size242; ++_i246)
{
- xfer += iprot->readString(this->tbl_names[_i240]);
+ xfer += iprot->readString(this->tbl_names[_i246]);
}
iprot->readListEnd();
}
@@ -3725,10 +3725,10 @@
xfer += oprot->writeFieldBegin("tbl_names", ::apache::thrift::protocol::T_LIST, 2);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->tbl_names.size()));
- std::vector ::const_iterator _iter241;
- for (_iter241 = this->tbl_names.begin(); _iter241 != this->tbl_names.end(); ++_iter241)
+ std::vector ::const_iterator _iter247;
+ for (_iter247 = this->tbl_names.begin(); _iter247 != this->tbl_names.end(); ++_iter247)
{
- xfer += oprot->writeString((*_iter241));
+ xfer += oprot->writeString((*_iter247));
}
xfer += oprot->writeListEnd();
}
@@ -3747,10 +3747,10 @@
xfer += oprot->writeFieldBegin("tbl_names", ::apache::thrift::protocol::T_LIST, 2);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->tbl_names)).size()));
- std::vector ::const_iterator _iter242;
- for (_iter242 = (*(this->tbl_names)).begin(); _iter242 != (*(this->tbl_names)).end(); ++_iter242)
+ std::vector ::const_iterator _iter248;
+ for (_iter248 = (*(this->tbl_names)).begin(); _iter248 != (*(this->tbl_names)).end(); ++_iter248)
{
- xfer += oprot->writeString((*_iter242));
+ xfer += oprot->writeString((*_iter248));
}
xfer += oprot->writeListEnd();
}
@@ -3784,14 +3784,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size243;
- ::apache::thrift::protocol::TType _etype246;
- iprot->readListBegin(_etype246, _size243);
- this->success.resize(_size243);
- uint32_t _i247;
- for (_i247 = 0; _i247 < _size243; ++_i247)
+ uint32_t _size249;
+ ::apache::thrift::protocol::TType _etype252;
+ iprot->readListBegin(_etype252, _size249);
+ this->success.resize(_size249);
+ uint32_t _i253;
+ for (_i253 = 0; _i253 < _size249; ++_i253)
{
- xfer += this->success[_i247].read(iprot);
+ xfer += this->success[_i253].read(iprot);
}
iprot->readListEnd();
}
@@ -3846,10 +3846,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter248;
- for (_iter248 = this->success.begin(); _iter248 != this->success.end(); ++_iter248)
+ std::vector ::const_iterator _iter254;
+ for (_iter254 = this->success.begin(); _iter254 != this->success.end(); ++_iter254)
{
- xfer += (*_iter248).write(oprot);
+ xfer += (*_iter254).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -3896,14 +3896,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size249;
- ::apache::thrift::protocol::TType _etype252;
- iprot->readListBegin(_etype252, _size249);
- (*(this->success)).resize(_size249);
- uint32_t _i253;
- for (_i253 = 0; _i253 < _size249; ++_i253)
+ uint32_t _size255;
+ ::apache::thrift::protocol::TType _etype258;
+ iprot->readListBegin(_etype258, _size255);
+ (*(this->success)).resize(_size255);
+ uint32_t _i259;
+ for (_i259 = 0; _i259 < _size255; ++_i259)
{
- xfer += (*(this->success))[_i253].read(iprot);
+ xfer += (*(this->success))[_i259].read(iprot);
}
iprot->readListEnd();
}
@@ -4062,14 +4062,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size254;
- ::apache::thrift::protocol::TType _etype257;
- iprot->readListBegin(_etype257, _size254);
- this->success.resize(_size254);
- uint32_t _i258;
- for (_i258 = 0; _i258 < _size254; ++_i258)
+ uint32_t _size260;
+ ::apache::thrift::protocol::TType _etype263;
+ iprot->readListBegin(_etype263, _size260);
+ this->success.resize(_size260);
+ uint32_t _i264;
+ for (_i264 = 0; _i264 < _size260; ++_i264)
{
- xfer += iprot->readString(this->success[_i258]);
+ xfer += iprot->readString(this->success[_i264]);
}
iprot->readListEnd();
}
@@ -4124,10 +4124,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter259;
- for (_iter259 = this->success.begin(); _iter259 != this->success.end(); ++_iter259)
+ std::vector ::const_iterator _iter265;
+ for (_iter265 = this->success.begin(); _iter265 != this->success.end(); ++_iter265)
{
- xfer += oprot->writeString((*_iter259));
+ xfer += oprot->writeString((*_iter265));
}
xfer += oprot->writeListEnd();
}
@@ -4174,14 +4174,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size260;
- ::apache::thrift::protocol::TType _etype263;
- iprot->readListBegin(_etype263, _size260);
- (*(this->success)).resize(_size260);
- uint32_t _i264;
- for (_i264 = 0; _i264 < _size260; ++_i264)
+ uint32_t _size266;
+ ::apache::thrift::protocol::TType _etype269;
+ iprot->readListBegin(_etype269, _size266);
+ (*(this->success)).resize(_size266);
+ uint32_t _i270;
+ for (_i270 = 0; _i270 < _size266; ++_i270)
{
- xfer += iprot->readString((*(this->success))[_i264]);
+ xfer += iprot->readString((*(this->success))[_i270]);
}
iprot->readListEnd();
}
@@ -4674,14 +4674,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->new_parts.clear();
- uint32_t _size265;
- ::apache::thrift::protocol::TType _etype268;
- iprot->readListBegin(_etype268, _size265);
- this->new_parts.resize(_size265);
- uint32_t _i269;
- for (_i269 = 0; _i269 < _size265; ++_i269)
+ uint32_t _size271;
+ ::apache::thrift::protocol::TType _etype274;
+ iprot->readListBegin(_etype274, _size271);
+ this->new_parts.resize(_size271);
+ uint32_t _i275;
+ for (_i275 = 0; _i275 < _size271; ++_i275)
{
- xfer += this->new_parts[_i269].read(iprot);
+ xfer += this->new_parts[_i275].read(iprot);
}
iprot->readListEnd();
}
@@ -4708,10 +4708,10 @@
xfer += oprot->writeFieldBegin("new_parts", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->new_parts.size()));
- std::vector ::const_iterator _iter270;
- for (_iter270 = this->new_parts.begin(); _iter270 != this->new_parts.end(); ++_iter270)
+ std::vector ::const_iterator _iter276;
+ for (_iter276 = this->new_parts.begin(); _iter276 != this->new_parts.end(); ++_iter276)
{
- xfer += (*_iter270).write(oprot);
+ xfer += (*_iter276).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4727,10 +4727,10 @@
xfer += oprot->writeFieldBegin("new_parts", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->new_parts)).size()));
- std::vector ::const_iterator _iter271;
- for (_iter271 = (*(this->new_parts)).begin(); _iter271 != (*(this->new_parts)).end(); ++_iter271)
+ std::vector ::const_iterator _iter277;
+ for (_iter277 = (*(this->new_parts)).begin(); _iter277 != (*(this->new_parts)).end(); ++_iter277)
{
- xfer += (*_iter271).write(oprot);
+ xfer += (*_iter277).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -4936,14 +4936,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size272;
- ::apache::thrift::protocol::TType _etype275;
- iprot->readListBegin(_etype275, _size272);
- this->part_vals.resize(_size272);
- uint32_t _i276;
- for (_i276 = 0; _i276 < _size272; ++_i276)
+ uint32_t _size278;
+ ::apache::thrift::protocol::TType _etype281;
+ iprot->readListBegin(_etype281, _size278);
+ this->part_vals.resize(_size278);
+ uint32_t _i282;
+ for (_i282 = 0; _i282 < _size278; ++_i282)
{
- xfer += iprot->readString(this->part_vals[_i276]);
+ xfer += iprot->readString(this->part_vals[_i282]);
}
iprot->readListEnd();
}
@@ -4976,10 +4976,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter277;
- for (_iter277 = this->part_vals.begin(); _iter277 != this->part_vals.end(); ++_iter277)
+ std::vector ::const_iterator _iter283;
+ for (_iter283 = this->part_vals.begin(); _iter283 != this->part_vals.end(); ++_iter283)
{
- xfer += oprot->writeString((*_iter277));
+ xfer += oprot->writeString((*_iter283));
}
xfer += oprot->writeListEnd();
}
@@ -5001,10 +5001,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter278;
- for (_iter278 = (*(this->part_vals)).begin(); _iter278 != (*(this->part_vals)).end(); ++_iter278)
+ std::vector ::const_iterator _iter284;
+ for (_iter284 = (*(this->part_vals)).begin(); _iter284 != (*(this->part_vals)).end(); ++_iter284)
{
- xfer += oprot->writeString((*_iter278));
+ xfer += oprot->writeString((*_iter284));
}
xfer += oprot->writeListEnd();
}
@@ -5456,14 +5456,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size279;
- ::apache::thrift::protocol::TType _etype282;
- iprot->readListBegin(_etype282, _size279);
- this->part_vals.resize(_size279);
- uint32_t _i283;
- for (_i283 = 0; _i283 < _size279; ++_i283)
+ uint32_t _size285;
+ ::apache::thrift::protocol::TType _etype288;
+ iprot->readListBegin(_etype288, _size285);
+ this->part_vals.resize(_size285);
+ uint32_t _i289;
+ for (_i289 = 0; _i289 < _size285; ++_i289)
{
- xfer += iprot->readString(this->part_vals[_i283]);
+ xfer += iprot->readString(this->part_vals[_i289]);
}
iprot->readListEnd();
}
@@ -5504,10 +5504,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter284;
- for (_iter284 = this->part_vals.begin(); _iter284 != this->part_vals.end(); ++_iter284)
+ std::vector ::const_iterator _iter290;
+ for (_iter290 = this->part_vals.begin(); _iter290 != this->part_vals.end(); ++_iter290)
{
- xfer += oprot->writeString((*_iter284));
+ xfer += oprot->writeString((*_iter290));
}
xfer += oprot->writeListEnd();
}
@@ -5532,10 +5532,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter285;
- for (_iter285 = (*(this->part_vals)).begin(); _iter285 != (*(this->part_vals)).end(); ++_iter285)
+ std::vector ::const_iterator _iter291;
+ for (_iter291 = (*(this->part_vals)).begin(); _iter291 != (*(this->part_vals)).end(); ++_iter291)
{
- xfer += oprot->writeString((*_iter285));
+ xfer += oprot->writeString((*_iter291));
}
xfer += oprot->writeListEnd();
}
@@ -5964,14 +5964,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size286;
- ::apache::thrift::protocol::TType _etype289;
- iprot->readListBegin(_etype289, _size286);
- this->part_vals.resize(_size286);
- uint32_t _i290;
- for (_i290 = 0; _i290 < _size286; ++_i290)
+ uint32_t _size292;
+ ::apache::thrift::protocol::TType _etype295;
+ iprot->readListBegin(_etype295, _size292);
+ this->part_vals.resize(_size292);
+ uint32_t _i296;
+ for (_i296 = 0; _i296 < _size292; ++_i296)
{
- xfer += iprot->readString(this->part_vals[_i290]);
+ xfer += iprot->readString(this->part_vals[_i296]);
}
iprot->readListEnd();
}
@@ -6004,10 +6004,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter291;
- for (_iter291 = this->part_vals.begin(); _iter291 != this->part_vals.end(); ++_iter291)
+ std::vector ::const_iterator _iter297;
+ for (_iter297 = this->part_vals.begin(); _iter297 != this->part_vals.end(); ++_iter297)
{
- xfer += oprot->writeString((*_iter291));
+ xfer += oprot->writeString((*_iter297));
}
xfer += oprot->writeListEnd();
}
@@ -6029,10 +6029,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter292;
- for (_iter292 = (*(this->part_vals)).begin(); _iter292 != (*(this->part_vals)).end(); ++_iter292)
+ std::vector ::const_iterator _iter298;
+ for (_iter298 = (*(this->part_vals)).begin(); _iter298 != (*(this->part_vals)).end(); ++_iter298)
{
- xfer += oprot->writeString((*_iter292));
+ xfer += oprot->writeString((*_iter298));
}
xfer += oprot->writeListEnd();
}
@@ -6218,14 +6218,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size293;
- ::apache::thrift::protocol::TType _etype296;
- iprot->readListBegin(_etype296, _size293);
- this->part_vals.resize(_size293);
- uint32_t _i297;
- for (_i297 = 0; _i297 < _size293; ++_i297)
+ uint32_t _size299;
+ ::apache::thrift::protocol::TType _etype302;
+ iprot->readListBegin(_etype302, _size299);
+ this->part_vals.resize(_size299);
+ uint32_t _i303;
+ for (_i303 = 0; _i303 < _size299; ++_i303)
{
- xfer += iprot->readString(this->part_vals[_i297]);
+ xfer += iprot->readString(this->part_vals[_i303]);
}
iprot->readListEnd();
}
@@ -6246,14 +6246,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size298;
- ::apache::thrift::protocol::TType _etype301;
- iprot->readListBegin(_etype301, _size298);
- this->group_names.resize(_size298);
- uint32_t _i302;
- for (_i302 = 0; _i302 < _size298; ++_i302)
+ uint32_t _size304;
+ ::apache::thrift::protocol::TType _etype307;
+ iprot->readListBegin(_etype307, _size304);
+ this->group_names.resize(_size304);
+ uint32_t _i308;
+ for (_i308 = 0; _i308 < _size304; ++_i308)
{
- xfer += iprot->readString(this->group_names[_i302]);
+ xfer += iprot->readString(this->group_names[_i308]);
}
iprot->readListEnd();
}
@@ -6286,10 +6286,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter303;
- for (_iter303 = this->part_vals.begin(); _iter303 != this->part_vals.end(); ++_iter303)
+ std::vector ::const_iterator _iter309;
+ for (_iter309 = this->part_vals.begin(); _iter309 != this->part_vals.end(); ++_iter309)
{
- xfer += oprot->writeString((*_iter303));
+ xfer += oprot->writeString((*_iter309));
}
xfer += oprot->writeListEnd();
}
@@ -6300,10 +6300,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 5);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->group_names.size()));
- std::vector ::const_iterator _iter304;
- for (_iter304 = this->group_names.begin(); _iter304 != this->group_names.end(); ++_iter304)
+ std::vector ::const_iterator _iter310;
+ for (_iter310 = this->group_names.begin(); _iter310 != this->group_names.end(); ++_iter310)
{
- xfer += oprot->writeString((*_iter304));
+ xfer += oprot->writeString((*_iter310));
}
xfer += oprot->writeListEnd();
}
@@ -6325,10 +6325,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter305;
- for (_iter305 = (*(this->part_vals)).begin(); _iter305 != (*(this->part_vals)).end(); ++_iter305)
+ std::vector ::const_iterator _iter311;
+ for (_iter311 = (*(this->part_vals)).begin(); _iter311 != (*(this->part_vals)).end(); ++_iter311)
{
- xfer += oprot->writeString((*_iter305));
+ xfer += oprot->writeString((*_iter311));
}
xfer += oprot->writeListEnd();
}
@@ -6339,10 +6339,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 5);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->group_names)).size()));
- std::vector ::const_iterator _iter306;
- for (_iter306 = (*(this->group_names)).begin(); _iter306 != (*(this->group_names)).end(); ++_iter306)
+ std::vector ::const_iterator _iter312;
+ for (_iter312 = (*(this->group_names)).begin(); _iter312 != (*(this->group_names)).end(); ++_iter312)
{
- xfer += oprot->writeString((*_iter306));
+ xfer += oprot->writeString((*_iter312));
}
xfer += oprot->writeListEnd();
}
@@ -6828,14 +6828,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size307;
- ::apache::thrift::protocol::TType _etype310;
- iprot->readListBegin(_etype310, _size307);
- this->success.resize(_size307);
- uint32_t _i311;
- for (_i311 = 0; _i311 < _size307; ++_i311)
+ uint32_t _size313;
+ ::apache::thrift::protocol::TType _etype316;
+ iprot->readListBegin(_etype316, _size313);
+ this->success.resize(_size313);
+ uint32_t _i317;
+ for (_i317 = 0; _i317 < _size313; ++_i317)
{
- xfer += this->success[_i311].read(iprot);
+ xfer += this->success[_i317].read(iprot);
}
iprot->readListEnd();
}
@@ -6882,10 +6882,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter312;
- for (_iter312 = this->success.begin(); _iter312 != this->success.end(); ++_iter312)
+ std::vector ::const_iterator _iter318;
+ for (_iter318 = this->success.begin(); _iter318 != this->success.end(); ++_iter318)
{
- xfer += (*_iter312).write(oprot);
+ xfer += (*_iter318).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -6928,14 +6928,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size313;
- ::apache::thrift::protocol::TType _etype316;
- iprot->readListBegin(_etype316, _size313);
- (*(this->success)).resize(_size313);
- uint32_t _i317;
- for (_i317 = 0; _i317 < _size313; ++_i317)
+ uint32_t _size319;
+ ::apache::thrift::protocol::TType _etype322;
+ iprot->readListBegin(_etype322, _size319);
+ (*(this->success)).resize(_size319);
+ uint32_t _i323;
+ for (_i323 = 0; _i323 < _size319; ++_i323)
{
- xfer += (*(this->success))[_i317].read(iprot);
+ xfer += (*(this->success))[_i323].read(iprot);
}
iprot->readListEnd();
}
@@ -7028,14 +7028,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size318;
- ::apache::thrift::protocol::TType _etype321;
- iprot->readListBegin(_etype321, _size318);
- this->group_names.resize(_size318);
- uint32_t _i322;
- for (_i322 = 0; _i322 < _size318; ++_i322)
+ uint32_t _size324;
+ ::apache::thrift::protocol::TType _etype327;
+ iprot->readListBegin(_etype327, _size324);
+ this->group_names.resize(_size324);
+ uint32_t _i328;
+ for (_i328 = 0; _i328 < _size324; ++_i328)
{
- xfer += iprot->readString(this->group_names[_i322]);
+ xfer += iprot->readString(this->group_names[_i328]);
}
iprot->readListEnd();
}
@@ -7074,10 +7074,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 5);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->group_names.size()));
- std::vector ::const_iterator _iter323;
- for (_iter323 = this->group_names.begin(); _iter323 != this->group_names.end(); ++_iter323)
+ std::vector ::const_iterator _iter329;
+ for (_iter329 = this->group_names.begin(); _iter329 != this->group_names.end(); ++_iter329)
{
- xfer += oprot->writeString((*_iter323));
+ xfer += oprot->writeString((*_iter329));
}
xfer += oprot->writeListEnd();
}
@@ -7105,10 +7105,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 5);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->group_names)).size()));
- std::vector ::const_iterator _iter324;
- for (_iter324 = (*(this->group_names)).begin(); _iter324 != (*(this->group_names)).end(); ++_iter324)
+ std::vector ::const_iterator _iter330;
+ for (_iter330 = (*(this->group_names)).begin(); _iter330 != (*(this->group_names)).end(); ++_iter330)
{
- xfer += oprot->writeString((*_iter324));
+ xfer += oprot->writeString((*_iter330));
}
xfer += oprot->writeListEnd();
}
@@ -7142,14 +7142,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size325;
- ::apache::thrift::protocol::TType _etype328;
- iprot->readListBegin(_etype328, _size325);
- this->success.resize(_size325);
- uint32_t _i329;
- for (_i329 = 0; _i329 < _size325; ++_i329)
+ uint32_t _size331;
+ ::apache::thrift::protocol::TType _etype334;
+ iprot->readListBegin(_etype334, _size331);
+ this->success.resize(_size331);
+ uint32_t _i335;
+ for (_i335 = 0; _i335 < _size331; ++_i335)
{
- xfer += this->success[_i329].read(iprot);
+ xfer += this->success[_i335].read(iprot);
}
iprot->readListEnd();
}
@@ -7196,10 +7196,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter330;
- for (_iter330 = this->success.begin(); _iter330 != this->success.end(); ++_iter330)
+ std::vector ::const_iterator _iter336;
+ for (_iter336 = this->success.begin(); _iter336 != this->success.end(); ++_iter336)
{
- xfer += (*_iter330).write(oprot);
+ xfer += (*_iter336).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7242,14 +7242,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size331;
- ::apache::thrift::protocol::TType _etype334;
- iprot->readListBegin(_etype334, _size331);
- (*(this->success)).resize(_size331);
- uint32_t _i335;
- for (_i335 = 0; _i335 < _size331; ++_i335)
+ uint32_t _size337;
+ ::apache::thrift::protocol::TType _etype340;
+ iprot->readListBegin(_etype340, _size337);
+ (*(this->success)).resize(_size337);
+ uint32_t _i341;
+ for (_i341 = 0; _i341 < _size337; ++_i341)
{
- xfer += (*(this->success))[_i335].read(iprot);
+ xfer += (*(this->success))[_i341].read(iprot);
}
iprot->readListEnd();
}
@@ -7400,14 +7400,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size336;
- ::apache::thrift::protocol::TType _etype339;
- iprot->readListBegin(_etype339, _size336);
- this->success.resize(_size336);
- uint32_t _i340;
- for (_i340 = 0; _i340 < _size336; ++_i340)
+ uint32_t _size342;
+ ::apache::thrift::protocol::TType _etype345;
+ iprot->readListBegin(_etype345, _size342);
+ this->success.resize(_size342);
+ uint32_t _i346;
+ for (_i346 = 0; _i346 < _size342; ++_i346)
{
- xfer += iprot->readString(this->success[_i340]);
+ xfer += iprot->readString(this->success[_i346]);
}
iprot->readListEnd();
}
@@ -7446,10 +7446,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter341;
- for (_iter341 = this->success.begin(); _iter341 != this->success.end(); ++_iter341)
+ std::vector ::const_iterator _iter347;
+ for (_iter347 = this->success.begin(); _iter347 != this->success.end(); ++_iter347)
{
- xfer += oprot->writeString((*_iter341));
+ xfer += oprot->writeString((*_iter347));
}
xfer += oprot->writeListEnd();
}
@@ -7488,14 +7488,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size342;
- ::apache::thrift::protocol::TType _etype345;
- iprot->readListBegin(_etype345, _size342);
- (*(this->success)).resize(_size342);
- uint32_t _i346;
- for (_i346 = 0; _i346 < _size342; ++_i346)
+ uint32_t _size348;
+ ::apache::thrift::protocol::TType _etype351;
+ iprot->readListBegin(_etype351, _size348);
+ (*(this->success)).resize(_size348);
+ uint32_t _i352;
+ for (_i352 = 0; _i352 < _size348; ++_i352)
{
- xfer += iprot->readString((*(this->success))[_i346]);
+ xfer += iprot->readString((*(this->success))[_i352]);
}
iprot->readListEnd();
}
@@ -7564,14 +7564,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size347;
- ::apache::thrift::protocol::TType _etype350;
- iprot->readListBegin(_etype350, _size347);
- this->part_vals.resize(_size347);
- uint32_t _i351;
- for (_i351 = 0; _i351 < _size347; ++_i351)
+ uint32_t _size353;
+ ::apache::thrift::protocol::TType _etype356;
+ iprot->readListBegin(_etype356, _size353);
+ this->part_vals.resize(_size353);
+ uint32_t _i357;
+ for (_i357 = 0; _i357 < _size353; ++_i357)
{
- xfer += iprot->readString(this->part_vals[_i351]);
+ xfer += iprot->readString(this->part_vals[_i357]);
}
iprot->readListEnd();
}
@@ -7612,10 +7612,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter352;
- for (_iter352 = this->part_vals.begin(); _iter352 != this->part_vals.end(); ++_iter352)
+ std::vector ::const_iterator _iter358;
+ for (_iter358 = this->part_vals.begin(); _iter358 != this->part_vals.end(); ++_iter358)
{
- xfer += oprot->writeString((*_iter352));
+ xfer += oprot->writeString((*_iter358));
}
xfer += oprot->writeListEnd();
}
@@ -7640,10 +7640,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter353;
- for (_iter353 = (*(this->part_vals)).begin(); _iter353 != (*(this->part_vals)).end(); ++_iter353)
+ std::vector ::const_iterator _iter359;
+ for (_iter359 = (*(this->part_vals)).begin(); _iter359 != (*(this->part_vals)).end(); ++_iter359)
{
- xfer += oprot->writeString((*_iter353));
+ xfer += oprot->writeString((*_iter359));
}
xfer += oprot->writeListEnd();
}
@@ -7680,14 +7680,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size354;
- ::apache::thrift::protocol::TType _etype357;
- iprot->readListBegin(_etype357, _size354);
- this->success.resize(_size354);
- uint32_t _i358;
- for (_i358 = 0; _i358 < _size354; ++_i358)
+ uint32_t _size360;
+ ::apache::thrift::protocol::TType _etype363;
+ iprot->readListBegin(_etype363, _size360);
+ this->success.resize(_size360);
+ uint32_t _i364;
+ for (_i364 = 0; _i364 < _size360; ++_i364)
{
- xfer += this->success[_i358].read(iprot);
+ xfer += this->success[_i364].read(iprot);
}
iprot->readListEnd();
}
@@ -7734,10 +7734,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter359;
- for (_iter359 = this->success.begin(); _iter359 != this->success.end(); ++_iter359)
+ std::vector ::const_iterator _iter365;
+ for (_iter365 = this->success.begin(); _iter365 != this->success.end(); ++_iter365)
{
- xfer += (*_iter359).write(oprot);
+ xfer += (*_iter365).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -7780,14 +7780,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size360;
- ::apache::thrift::protocol::TType _etype363;
- iprot->readListBegin(_etype363, _size360);
- (*(this->success)).resize(_size360);
- uint32_t _i364;
- for (_i364 = 0; _i364 < _size360; ++_i364)
+ uint32_t _size366;
+ ::apache::thrift::protocol::TType _etype369;
+ iprot->readListBegin(_etype369, _size366);
+ (*(this->success)).resize(_size366);
+ uint32_t _i370;
+ for (_i370 = 0; _i370 < _size366; ++_i370)
{
- xfer += (*(this->success))[_i364].read(iprot);
+ xfer += (*(this->success))[_i370].read(iprot);
}
iprot->readListEnd();
}
@@ -7864,14 +7864,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size365;
- ::apache::thrift::protocol::TType _etype368;
- iprot->readListBegin(_etype368, _size365);
- this->part_vals.resize(_size365);
- uint32_t _i369;
- for (_i369 = 0; _i369 < _size365; ++_i369)
+ uint32_t _size371;
+ ::apache::thrift::protocol::TType _etype374;
+ iprot->readListBegin(_etype374, _size371);
+ this->part_vals.resize(_size371);
+ uint32_t _i375;
+ for (_i375 = 0; _i375 < _size371; ++_i375)
{
- xfer += iprot->readString(this->part_vals[_i369]);
+ xfer += iprot->readString(this->part_vals[_i375]);
}
iprot->readListEnd();
}
@@ -7900,14 +7900,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size370;
- ::apache::thrift::protocol::TType _etype373;
- iprot->readListBegin(_etype373, _size370);
- this->group_names.resize(_size370);
- uint32_t _i374;
- for (_i374 = 0; _i374 < _size370; ++_i374)
+ uint32_t _size376;
+ ::apache::thrift::protocol::TType _etype379;
+ iprot->readListBegin(_etype379, _size376);
+ this->group_names.resize(_size376);
+ uint32_t _i380;
+ for (_i380 = 0; _i380 < _size376; ++_i380)
{
- xfer += iprot->readString(this->group_names[_i374]);
+ xfer += iprot->readString(this->group_names[_i380]);
}
iprot->readListEnd();
}
@@ -7940,10 +7940,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter375;
- for (_iter375 = this->part_vals.begin(); _iter375 != this->part_vals.end(); ++_iter375)
+ std::vector ::const_iterator _iter381;
+ for (_iter381 = this->part_vals.begin(); _iter381 != this->part_vals.end(); ++_iter381)
{
- xfer += oprot->writeString((*_iter375));
+ xfer += oprot->writeString((*_iter381));
}
xfer += oprot->writeListEnd();
}
@@ -7957,10 +7957,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->group_names.size()));
- std::vector ::const_iterator _iter376;
- for (_iter376 = this->group_names.begin(); _iter376 != this->group_names.end(); ++_iter376)
+ std::vector ::const_iterator _iter382;
+ for (_iter382 = this->group_names.begin(); _iter382 != this->group_names.end(); ++_iter382)
{
- xfer += oprot->writeString((*_iter376));
+ xfer += oprot->writeString((*_iter382));
}
xfer += oprot->writeListEnd();
}
@@ -7982,10 +7982,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter377;
- for (_iter377 = (*(this->part_vals)).begin(); _iter377 != (*(this->part_vals)).end(); ++_iter377)
+ std::vector ::const_iterator _iter383;
+ for (_iter383 = (*(this->part_vals)).begin(); _iter383 != (*(this->part_vals)).end(); ++_iter383)
{
- xfer += oprot->writeString((*_iter377));
+ xfer += oprot->writeString((*_iter383));
}
xfer += oprot->writeListEnd();
}
@@ -7999,10 +7999,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 6);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->group_names)).size()));
- std::vector ::const_iterator _iter378;
- for (_iter378 = (*(this->group_names)).begin(); _iter378 != (*(this->group_names)).end(); ++_iter378)
+ std::vector ::const_iterator _iter384;
+ for (_iter384 = (*(this->group_names)).begin(); _iter384 != (*(this->group_names)).end(); ++_iter384)
{
- xfer += oprot->writeString((*_iter378));
+ xfer += oprot->writeString((*_iter384));
}
xfer += oprot->writeListEnd();
}
@@ -8036,14 +8036,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size379;
- ::apache::thrift::protocol::TType _etype382;
- iprot->readListBegin(_etype382, _size379);
- this->success.resize(_size379);
- uint32_t _i383;
- for (_i383 = 0; _i383 < _size379; ++_i383)
+ uint32_t _size385;
+ ::apache::thrift::protocol::TType _etype388;
+ iprot->readListBegin(_etype388, _size385);
+ this->success.resize(_size385);
+ uint32_t _i389;
+ for (_i389 = 0; _i389 < _size385; ++_i389)
{
- xfer += this->success[_i383].read(iprot);
+ xfer += this->success[_i389].read(iprot);
}
iprot->readListEnd();
}
@@ -8090,10 +8090,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter384;
- for (_iter384 = this->success.begin(); _iter384 != this->success.end(); ++_iter384)
+ std::vector ::const_iterator _iter390;
+ for (_iter390 = this->success.begin(); _iter390 != this->success.end(); ++_iter390)
{
- xfer += (*_iter384).write(oprot);
+ xfer += (*_iter390).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8136,14 +8136,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size385;
- ::apache::thrift::protocol::TType _etype388;
- iprot->readListBegin(_etype388, _size385);
- (*(this->success)).resize(_size385);
- uint32_t _i389;
- for (_i389 = 0; _i389 < _size385; ++_i389)
+ uint32_t _size391;
+ ::apache::thrift::protocol::TType _etype394;
+ iprot->readListBegin(_etype394, _size391);
+ (*(this->success)).resize(_size391);
+ uint32_t _i395;
+ for (_i395 = 0; _i395 < _size391; ++_i395)
{
- xfer += (*(this->success))[_i389].read(iprot);
+ xfer += (*(this->success))[_i395].read(iprot);
}
iprot->readListEnd();
}
@@ -8220,14 +8220,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size390;
- ::apache::thrift::protocol::TType _etype393;
- iprot->readListBegin(_etype393, _size390);
- this->part_vals.resize(_size390);
- uint32_t _i394;
- for (_i394 = 0; _i394 < _size390; ++_i394)
+ uint32_t _size396;
+ ::apache::thrift::protocol::TType _etype399;
+ iprot->readListBegin(_etype399, _size396);
+ this->part_vals.resize(_size396);
+ uint32_t _i400;
+ for (_i400 = 0; _i400 < _size396; ++_i400)
{
- xfer += iprot->readString(this->part_vals[_i394]);
+ xfer += iprot->readString(this->part_vals[_i400]);
}
iprot->readListEnd();
}
@@ -8268,10 +8268,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter395;
- for (_iter395 = this->part_vals.begin(); _iter395 != this->part_vals.end(); ++_iter395)
+ std::vector ::const_iterator _iter401;
+ for (_iter401 = this->part_vals.begin(); _iter401 != this->part_vals.end(); ++_iter401)
{
- xfer += oprot->writeString((*_iter395));
+ xfer += oprot->writeString((*_iter401));
}
xfer += oprot->writeListEnd();
}
@@ -8296,10 +8296,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter396;
- for (_iter396 = (*(this->part_vals)).begin(); _iter396 != (*(this->part_vals)).end(); ++_iter396)
+ std::vector ::const_iterator _iter402;
+ for (_iter402 = (*(this->part_vals)).begin(); _iter402 != (*(this->part_vals)).end(); ++_iter402)
{
- xfer += oprot->writeString((*_iter396));
+ xfer += oprot->writeString((*_iter402));
}
xfer += oprot->writeListEnd();
}
@@ -8336,14 +8336,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size397;
- ::apache::thrift::protocol::TType _etype400;
- iprot->readListBegin(_etype400, _size397);
- this->success.resize(_size397);
- uint32_t _i401;
- for (_i401 = 0; _i401 < _size397; ++_i401)
+ uint32_t _size403;
+ ::apache::thrift::protocol::TType _etype406;
+ iprot->readListBegin(_etype406, _size403);
+ this->success.resize(_size403);
+ uint32_t _i407;
+ for (_i407 = 0; _i407 < _size403; ++_i407)
{
- xfer += iprot->readString(this->success[_i401]);
+ xfer += iprot->readString(this->success[_i407]);
}
iprot->readListEnd();
}
@@ -8390,10 +8390,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter402;
- for (_iter402 = this->success.begin(); _iter402 != this->success.end(); ++_iter402)
+ std::vector ::const_iterator _iter408;
+ for (_iter408 = this->success.begin(); _iter408 != this->success.end(); ++_iter408)
{
- xfer += oprot->writeString((*_iter402));
+ xfer += oprot->writeString((*_iter408));
}
xfer += oprot->writeListEnd();
}
@@ -8436,14 +8436,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size403;
- ::apache::thrift::protocol::TType _etype406;
- iprot->readListBegin(_etype406, _size403);
- (*(this->success)).resize(_size403);
- uint32_t _i407;
- for (_i407 = 0; _i407 < _size403; ++_i407)
+ uint32_t _size409;
+ ::apache::thrift::protocol::TType _etype412;
+ iprot->readListBegin(_etype412, _size409);
+ (*(this->success)).resize(_size409);
+ uint32_t _i413;
+ for (_i413 = 0; _i413 < _size409; ++_i413)
{
- xfer += iprot->readString((*(this->success))[_i407]);
+ xfer += iprot->readString((*(this->success))[_i413]);
}
iprot->readListEnd();
}
@@ -8608,14 +8608,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size408;
- ::apache::thrift::protocol::TType _etype411;
- iprot->readListBegin(_etype411, _size408);
- this->success.resize(_size408);
- uint32_t _i412;
- for (_i412 = 0; _i412 < _size408; ++_i412)
+ uint32_t _size414;
+ ::apache::thrift::protocol::TType _etype417;
+ iprot->readListBegin(_etype417, _size414);
+ this->success.resize(_size414);
+ uint32_t _i418;
+ for (_i418 = 0; _i418 < _size414; ++_i418)
{
- xfer += this->success[_i412].read(iprot);
+ xfer += this->success[_i418].read(iprot);
}
iprot->readListEnd();
}
@@ -8662,10 +8662,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter413;
- for (_iter413 = this->success.begin(); _iter413 != this->success.end(); ++_iter413)
+ std::vector ::const_iterator _iter419;
+ for (_iter419 = this->success.begin(); _iter419 != this->success.end(); ++_iter419)
{
- xfer += (*_iter413).write(oprot);
+ xfer += (*_iter419).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8708,14 +8708,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size414;
- ::apache::thrift::protocol::TType _etype417;
- iprot->readListBegin(_etype417, _size414);
- (*(this->success)).resize(_size414);
- uint32_t _i418;
- for (_i418 = 0; _i418 < _size414; ++_i418)
+ uint32_t _size420;
+ ::apache::thrift::protocol::TType _etype423;
+ iprot->readListBegin(_etype423, _size420);
+ (*(this->success)).resize(_size420);
+ uint32_t _i424;
+ for (_i424 = 0; _i424 < _size420; ++_i424)
{
- xfer += (*(this->success))[_i418].read(iprot);
+ xfer += (*(this->success))[_i424].read(iprot);
}
iprot->readListEnd();
}
@@ -8792,14 +8792,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->names.clear();
- uint32_t _size419;
- ::apache::thrift::protocol::TType _etype422;
- iprot->readListBegin(_etype422, _size419);
- this->names.resize(_size419);
- uint32_t _i423;
- for (_i423 = 0; _i423 < _size419; ++_i423)
+ uint32_t _size425;
+ ::apache::thrift::protocol::TType _etype428;
+ iprot->readListBegin(_etype428, _size425);
+ this->names.resize(_size425);
+ uint32_t _i429;
+ for (_i429 = 0; _i429 < _size425; ++_i429)
{
- xfer += iprot->readString(this->names[_i423]);
+ xfer += iprot->readString(this->names[_i429]);
}
iprot->readListEnd();
}
@@ -8832,10 +8832,10 @@
xfer += oprot->writeFieldBegin("names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->names.size()));
- std::vector ::const_iterator _iter424;
- for (_iter424 = this->names.begin(); _iter424 != this->names.end(); ++_iter424)
+ std::vector ::const_iterator _iter430;
+ for (_iter430 = this->names.begin(); _iter430 != this->names.end(); ++_iter430)
{
- xfer += oprot->writeString((*_iter424));
+ xfer += oprot->writeString((*_iter430));
}
xfer += oprot->writeListEnd();
}
@@ -8857,10 +8857,10 @@
xfer += oprot->writeFieldBegin("names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->names)).size()));
- std::vector ::const_iterator _iter425;
- for (_iter425 = (*(this->names)).begin(); _iter425 != (*(this->names)).end(); ++_iter425)
+ std::vector ::const_iterator _iter431;
+ for (_iter431 = (*(this->names)).begin(); _iter431 != (*(this->names)).end(); ++_iter431)
{
- xfer += oprot->writeString((*_iter425));
+ xfer += oprot->writeString((*_iter431));
}
xfer += oprot->writeListEnd();
}
@@ -8894,14 +8894,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size426;
- ::apache::thrift::protocol::TType _etype429;
- iprot->readListBegin(_etype429, _size426);
- this->success.resize(_size426);
- uint32_t _i430;
- for (_i430 = 0; _i430 < _size426; ++_i430)
+ uint32_t _size432;
+ ::apache::thrift::protocol::TType _etype435;
+ iprot->readListBegin(_etype435, _size432);
+ this->success.resize(_size432);
+ uint32_t _i436;
+ for (_i436 = 0; _i436 < _size432; ++_i436)
{
- xfer += this->success[_i430].read(iprot);
+ xfer += this->success[_i436].read(iprot);
}
iprot->readListEnd();
}
@@ -8948,10 +8948,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter431;
- for (_iter431 = this->success.begin(); _iter431 != this->success.end(); ++_iter431)
+ std::vector ::const_iterator _iter437;
+ for (_iter437 = this->success.begin(); _iter437 != this->success.end(); ++_iter437)
{
- xfer += (*_iter431).write(oprot);
+ xfer += (*_iter437).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -8994,14 +8994,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size432;
- ::apache::thrift::protocol::TType _etype435;
- iprot->readListBegin(_etype435, _size432);
- (*(this->success)).resize(_size432);
- uint32_t _i436;
- for (_i436 = 0; _i436 < _size432; ++_i436)
+ uint32_t _size438;
+ ::apache::thrift::protocol::TType _etype441;
+ iprot->readListBegin(_etype441, _size438);
+ (*(this->success)).resize(_size438);
+ uint32_t _i442;
+ for (_i442 = 0; _i442 < _size438; ++_i442)
{
- xfer += (*(this->success))[_i436].read(iprot);
+ xfer += (*(this->success))[_i442].read(iprot);
}
iprot->readListEnd();
}
@@ -9284,14 +9284,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->part_vals.clear();
- uint32_t _size437;
- ::apache::thrift::protocol::TType _etype440;
- iprot->readListBegin(_etype440, _size437);
- this->part_vals.resize(_size437);
- uint32_t _i441;
- for (_i441 = 0; _i441 < _size437; ++_i441)
+ uint32_t _size443;
+ ::apache::thrift::protocol::TType _etype446;
+ iprot->readListBegin(_etype446, _size443);
+ this->part_vals.resize(_size443);
+ uint32_t _i447;
+ for (_i447 = 0; _i447 < _size443; ++_i447)
{
- xfer += iprot->readString(this->part_vals[_i441]);
+ xfer += iprot->readString(this->part_vals[_i447]);
}
iprot->readListEnd();
}
@@ -9332,10 +9332,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::vector ::const_iterator _iter442;
- for (_iter442 = this->part_vals.begin(); _iter442 != this->part_vals.end(); ++_iter442)
+ std::vector ::const_iterator _iter448;
+ for (_iter448 = this->part_vals.begin(); _iter448 != this->part_vals.end(); ++_iter448)
{
- xfer += oprot->writeString((*_iter442));
+ xfer += oprot->writeString((*_iter448));
}
xfer += oprot->writeListEnd();
}
@@ -9360,10 +9360,10 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::vector ::const_iterator _iter443;
- for (_iter443 = (*(this->part_vals)).begin(); _iter443 != (*(this->part_vals)).end(); ++_iter443)
+ std::vector ::const_iterator _iter449;
+ for (_iter449 = (*(this->part_vals)).begin(); _iter449 != (*(this->part_vals)).end(); ++_iter449)
{
- xfer += oprot->writeString((*_iter443));
+ xfer += oprot->writeString((*_iter449));
}
xfer += oprot->writeListEnd();
}
@@ -9770,14 +9770,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size444;
- ::apache::thrift::protocol::TType _etype447;
- iprot->readListBegin(_etype447, _size444);
- this->success.resize(_size444);
- uint32_t _i448;
- for (_i448 = 0; _i448 < _size444; ++_i448)
+ uint32_t _size450;
+ ::apache::thrift::protocol::TType _etype453;
+ iprot->readListBegin(_etype453, _size450);
+ this->success.resize(_size450);
+ uint32_t _i454;
+ for (_i454 = 0; _i454 < _size450; ++_i454)
{
- xfer += iprot->readString(this->success[_i448]);
+ xfer += iprot->readString(this->success[_i454]);
}
iprot->readListEnd();
}
@@ -9816,10 +9816,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter449;
- for (_iter449 = this->success.begin(); _iter449 != this->success.end(); ++_iter449)
+ std::vector ::const_iterator _iter455;
+ for (_iter455 = this->success.begin(); _iter455 != this->success.end(); ++_iter455)
{
- xfer += oprot->writeString((*_iter449));
+ xfer += oprot->writeString((*_iter455));
}
xfer += oprot->writeListEnd();
}
@@ -9858,14 +9858,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size450;
- ::apache::thrift::protocol::TType _etype453;
- iprot->readListBegin(_etype453, _size450);
- (*(this->success)).resize(_size450);
- uint32_t _i454;
- for (_i454 = 0; _i454 < _size450; ++_i454)
+ uint32_t _size456;
+ ::apache::thrift::protocol::TType _etype459;
+ iprot->readListBegin(_etype459, _size456);
+ (*(this->success)).resize(_size456);
+ uint32_t _i460;
+ for (_i460 = 0; _i460 < _size456; ++_i460)
{
- xfer += iprot->readString((*(this->success))[_i454]);
+ xfer += iprot->readString((*(this->success))[_i460]);
}
iprot->readListEnd();
}
@@ -9980,17 +9980,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->success.clear();
- uint32_t _size455;
- ::apache::thrift::protocol::TType _ktype456;
- ::apache::thrift::protocol::TType _vtype457;
- iprot->readMapBegin(_ktype456, _vtype457, _size455);
- uint32_t _i459;
- for (_i459 = 0; _i459 < _size455; ++_i459)
+ uint32_t _size461;
+ ::apache::thrift::protocol::TType _ktype462;
+ ::apache::thrift::protocol::TType _vtype463;
+ iprot->readMapBegin(_ktype462, _vtype463, _size461);
+ uint32_t _i465;
+ for (_i465 = 0; _i465 < _size461; ++_i465)
{
- std::string _key460;
- xfer += iprot->readString(_key460);
- std::string& _val461 = this->success[_key460];
- xfer += iprot->readString(_val461);
+ std::string _key466;
+ xfer += iprot->readString(_key466);
+ std::string& _val467 = this->success[_key466];
+ xfer += iprot->readString(_val467);
}
iprot->readMapEnd();
}
@@ -10029,11 +10029,11 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_MAP, 0);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::map ::const_iterator _iter462;
- for (_iter462 = this->success.begin(); _iter462 != this->success.end(); ++_iter462)
+ std::map ::const_iterator _iter468;
+ for (_iter468 = this->success.begin(); _iter468 != this->success.end(); ++_iter468)
{
- xfer += oprot->writeString(_iter462->first);
- xfer += oprot->writeString(_iter462->second);
+ xfer += oprot->writeString(_iter468->first);
+ xfer += oprot->writeString(_iter468->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10072,17 +10072,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
(*(this->success)).clear();
- uint32_t _size463;
- ::apache::thrift::protocol::TType _ktype464;
- ::apache::thrift::protocol::TType _vtype465;
- iprot->readMapBegin(_ktype464, _vtype465, _size463);
- uint32_t _i467;
- for (_i467 = 0; _i467 < _size463; ++_i467)
+ uint32_t _size469;
+ ::apache::thrift::protocol::TType _ktype470;
+ ::apache::thrift::protocol::TType _vtype471;
+ iprot->readMapBegin(_ktype470, _vtype471, _size469);
+ uint32_t _i473;
+ for (_i473 = 0; _i473 < _size469; ++_i473)
{
- std::string _key468;
- xfer += iprot->readString(_key468);
- std::string& _val469 = (*(this->success))[_key468];
- xfer += iprot->readString(_val469);
+ std::string _key474;
+ xfer += iprot->readString(_key474);
+ std::string& _val475 = (*(this->success))[_key474];
+ xfer += iprot->readString(_val475);
}
iprot->readMapEnd();
}
@@ -10151,17 +10151,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->part_vals.clear();
- uint32_t _size470;
- ::apache::thrift::protocol::TType _ktype471;
- ::apache::thrift::protocol::TType _vtype472;
- iprot->readMapBegin(_ktype471, _vtype472, _size470);
- uint32_t _i474;
- for (_i474 = 0; _i474 < _size470; ++_i474)
+ uint32_t _size476;
+ ::apache::thrift::protocol::TType _ktype477;
+ ::apache::thrift::protocol::TType _vtype478;
+ iprot->readMapBegin(_ktype477, _vtype478, _size476);
+ uint32_t _i480;
+ for (_i480 = 0; _i480 < _size476; ++_i480)
{
- std::string _key475;
- xfer += iprot->readString(_key475);
- std::string& _val476 = this->part_vals[_key475];
- xfer += iprot->readString(_val476);
+ std::string _key481;
+ xfer += iprot->readString(_key481);
+ std::string& _val482 = this->part_vals[_key481];
+ xfer += iprot->readString(_val482);
}
iprot->readMapEnd();
}
@@ -10172,9 +10172,9 @@
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast477;
- xfer += iprot->readI32(ecast477);
- this->eventType = (PartitionEventType::type)ecast477;
+ int32_t ecast483;
+ xfer += iprot->readI32(ecast483);
+ this->eventType = (PartitionEventType::type)ecast483;
this->__isset.eventType = true;
} else {
xfer += iprot->skip(ftype);
@@ -10204,11 +10204,11 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::map ::const_iterator _iter478;
- for (_iter478 = this->part_vals.begin(); _iter478 != this->part_vals.end(); ++_iter478)
+ std::map ::const_iterator _iter484;
+ for (_iter484 = this->part_vals.begin(); _iter484 != this->part_vals.end(); ++_iter484)
{
- xfer += oprot->writeString(_iter478->first);
- xfer += oprot->writeString(_iter478->second);
+ xfer += oprot->writeString(_iter484->first);
+ xfer += oprot->writeString(_iter484->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10233,11 +10233,11 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::map ::const_iterator _iter479;
- for (_iter479 = (*(this->part_vals)).begin(); _iter479 != (*(this->part_vals)).end(); ++_iter479)
+ std::map ::const_iterator _iter485;
+ for (_iter485 = (*(this->part_vals)).begin(); _iter485 != (*(this->part_vals)).end(); ++_iter485)
{
- xfer += oprot->writeString(_iter479->first);
- xfer += oprot->writeString(_iter479->second);
+ xfer += oprot->writeString(_iter485->first);
+ xfer += oprot->writeString(_iter485->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10486,17 +10486,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->part_vals.clear();
- uint32_t _size480;
- ::apache::thrift::protocol::TType _ktype481;
- ::apache::thrift::protocol::TType _vtype482;
- iprot->readMapBegin(_ktype481, _vtype482, _size480);
- uint32_t _i484;
- for (_i484 = 0; _i484 < _size480; ++_i484)
+ uint32_t _size486;
+ ::apache::thrift::protocol::TType _ktype487;
+ ::apache::thrift::protocol::TType _vtype488;
+ iprot->readMapBegin(_ktype487, _vtype488, _size486);
+ uint32_t _i490;
+ for (_i490 = 0; _i490 < _size486; ++_i490)
{
- std::string _key485;
- xfer += iprot->readString(_key485);
- std::string& _val486 = this->part_vals[_key485];
- xfer += iprot->readString(_val486);
+ std::string _key491;
+ xfer += iprot->readString(_key491);
+ std::string& _val492 = this->part_vals[_key491];
+ xfer += iprot->readString(_val492);
}
iprot->readMapEnd();
}
@@ -10507,9 +10507,9 @@
break;
case 4:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast487;
- xfer += iprot->readI32(ecast487);
- this->eventType = (PartitionEventType::type)ecast487;
+ int32_t ecast493;
+ xfer += iprot->readI32(ecast493);
+ this->eventType = (PartitionEventType::type)ecast493;
this->__isset.eventType = true;
} else {
xfer += iprot->skip(ftype);
@@ -10539,11 +10539,11 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->part_vals.size()));
- std::map ::const_iterator _iter488;
- for (_iter488 = this->part_vals.begin(); _iter488 != this->part_vals.end(); ++_iter488)
+ std::map ::const_iterator _iter494;
+ for (_iter494 = this->part_vals.begin(); _iter494 != this->part_vals.end(); ++_iter494)
{
- xfer += oprot->writeString(_iter488->first);
- xfer += oprot->writeString(_iter488->second);
+ xfer += oprot->writeString(_iter494->first);
+ xfer += oprot->writeString(_iter494->second);
}
xfer += oprot->writeMapEnd();
}
@@ -10568,11 +10568,11 @@
xfer += oprot->writeFieldBegin("part_vals", ::apache::thrift::protocol::T_MAP, 3);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast((*(this->part_vals)).size()));
- std::map ::const_iterator _iter489;
- for (_iter489 = (*(this->part_vals)).begin(); _iter489 != (*(this->part_vals)).end(); ++_iter489)
+ std::map ::const_iterator _iter495;
+ for (_iter495 = (*(this->part_vals)).begin(); _iter495 != (*(this->part_vals)).end(); ++_iter495)
{
- xfer += oprot->writeString(_iter489->first);
- xfer += oprot->writeString(_iter489->second);
+ xfer += oprot->writeString(_iter495->first);
+ xfer += oprot->writeString(_iter495->second);
}
xfer += oprot->writeMapEnd();
}
@@ -11833,14 +11833,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size490;
- ::apache::thrift::protocol::TType _etype493;
- iprot->readListBegin(_etype493, _size490);
- this->success.resize(_size490);
- uint32_t _i494;
- for (_i494 = 0; _i494 < _size490; ++_i494)
+ uint32_t _size496;
+ ::apache::thrift::protocol::TType _etype499;
+ iprot->readListBegin(_etype499, _size496);
+ this->success.resize(_size496);
+ uint32_t _i500;
+ for (_i500 = 0; _i500 < _size496; ++_i500)
{
- xfer += this->success[_i494].read(iprot);
+ xfer += this->success[_i500].read(iprot);
}
iprot->readListEnd();
}
@@ -11887,10 +11887,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter495;
- for (_iter495 = this->success.begin(); _iter495 != this->success.end(); ++_iter495)
+ std::vector ::const_iterator _iter501;
+ for (_iter501 = this->success.begin(); _iter501 != this->success.end(); ++_iter501)
{
- xfer += (*_iter495).write(oprot);
+ xfer += (*_iter501).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -11933,14 +11933,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size496;
- ::apache::thrift::protocol::TType _etype499;
- iprot->readListBegin(_etype499, _size496);
- (*(this->success)).resize(_size496);
- uint32_t _i500;
- for (_i500 = 0; _i500 < _size496; ++_i500)
+ uint32_t _size502;
+ ::apache::thrift::protocol::TType _etype505;
+ iprot->readListBegin(_etype505, _size502);
+ (*(this->success)).resize(_size502);
+ uint32_t _i506;
+ for (_i506 = 0; _i506 < _size502; ++_i506)
{
- xfer += (*(this->success))[_i500].read(iprot);
+ xfer += (*(this->success))[_i506].read(iprot);
}
iprot->readListEnd();
}
@@ -12091,14 +12091,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size501;
- ::apache::thrift::protocol::TType _etype504;
- iprot->readListBegin(_etype504, _size501);
- this->success.resize(_size501);
- uint32_t _i505;
- for (_i505 = 0; _i505 < _size501; ++_i505)
+ uint32_t _size507;
+ ::apache::thrift::protocol::TType _etype510;
+ iprot->readListBegin(_etype510, _size507);
+ this->success.resize(_size507);
+ uint32_t _i511;
+ for (_i511 = 0; _i511 < _size507; ++_i511)
{
- xfer += iprot->readString(this->success[_i505]);
+ xfer += iprot->readString(this->success[_i511]);
}
iprot->readListEnd();
}
@@ -12137,10 +12137,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter506;
- for (_iter506 = this->success.begin(); _iter506 != this->success.end(); ++_iter506)
+ std::vector ::const_iterator _iter512;
+ for (_iter512 = this->success.begin(); _iter512 != this->success.end(); ++_iter512)
{
- xfer += oprot->writeString((*_iter506));
+ xfer += oprot->writeString((*_iter512));
}
xfer += oprot->writeListEnd();
}
@@ -12179,14 +12179,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size507;
- ::apache::thrift::protocol::TType _etype510;
- iprot->readListBegin(_etype510, _size507);
- (*(this->success)).resize(_size507);
- uint32_t _i511;
- for (_i511 = 0; _i511 < _size507; ++_i511)
+ uint32_t _size513;
+ ::apache::thrift::protocol::TType _etype516;
+ iprot->readListBegin(_etype516, _size513);
+ (*(this->success)).resize(_size513);
+ uint32_t _i517;
+ for (_i517 = 0; _i517 < _size513; ++_i517)
{
- xfer += iprot->readString((*(this->success))[_i511]);
+ xfer += iprot->readString((*(this->success))[_i517]);
}
iprot->readListEnd();
}
@@ -12643,14 +12643,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size512;
- ::apache::thrift::protocol::TType _etype515;
- iprot->readListBegin(_etype515, _size512);
- this->success.resize(_size512);
- uint32_t _i516;
- for (_i516 = 0; _i516 < _size512; ++_i516)
+ uint32_t _size518;
+ ::apache::thrift::protocol::TType _etype521;
+ iprot->readListBegin(_etype521, _size518);
+ this->success.resize(_size518);
+ uint32_t _i522;
+ for (_i522 = 0; _i522 < _size518; ++_i522)
{
- xfer += iprot->readString(this->success[_i516]);
+ xfer += iprot->readString(this->success[_i522]);
}
iprot->readListEnd();
}
@@ -12689,10 +12689,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter517;
- for (_iter517 = this->success.begin(); _iter517 != this->success.end(); ++_iter517)
+ std::vector ::const_iterator _iter523;
+ for (_iter523 = this->success.begin(); _iter523 != this->success.end(); ++_iter523)
{
- xfer += oprot->writeString((*_iter517));
+ xfer += oprot->writeString((*_iter523));
}
xfer += oprot->writeListEnd();
}
@@ -12731,14 +12731,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size518;
- ::apache::thrift::protocol::TType _etype521;
- iprot->readListBegin(_etype521, _size518);
- (*(this->success)).resize(_size518);
- uint32_t _i522;
- for (_i522 = 0; _i522 < _size518; ++_i522)
+ uint32_t _size524;
+ ::apache::thrift::protocol::TType _etype527;
+ iprot->readListBegin(_etype527, _size524);
+ (*(this->success)).resize(_size524);
+ uint32_t _i528;
+ for (_i528 = 0; _i528 < _size524; ++_i528)
{
- xfer += iprot->readString((*(this->success))[_i522]);
+ xfer += iprot->readString((*(this->success))[_i528]);
}
iprot->readListEnd();
}
@@ -12805,9 +12805,9 @@
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast523;
- xfer += iprot->readI32(ecast523);
- this->principal_type = (PrincipalType::type)ecast523;
+ int32_t ecast529;
+ xfer += iprot->readI32(ecast529);
+ this->principal_type = (PrincipalType::type)ecast529;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -12823,9 +12823,9 @@
break;
case 5:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast524;
- xfer += iprot->readI32(ecast524);
- this->grantorType = (PrincipalType::type)ecast524;
+ int32_t ecast530;
+ xfer += iprot->readI32(ecast530);
+ this->grantorType = (PrincipalType::type)ecast530;
this->__isset.grantorType = true;
} else {
xfer += iprot->skip(ftype);
@@ -13057,9 +13057,9 @@
break;
case 3:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast525;
- xfer += iprot->readI32(ecast525);
- this->principal_type = (PrincipalType::type)ecast525;
+ int32_t ecast531;
+ xfer += iprot->readI32(ecast531);
+ this->principal_type = (PrincipalType::type)ecast531;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -13257,9 +13257,9 @@
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast526;
- xfer += iprot->readI32(ecast526);
- this->principal_type = (PrincipalType::type)ecast526;
+ int32_t ecast532;
+ xfer += iprot->readI32(ecast532);
+ this->principal_type = (PrincipalType::type)ecast532;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -13329,14 +13329,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size527;
- ::apache::thrift::protocol::TType _etype530;
- iprot->readListBegin(_etype530, _size527);
- this->success.resize(_size527);
- uint32_t _i531;
- for (_i531 = 0; _i531 < _size527; ++_i531)
+ uint32_t _size533;
+ ::apache::thrift::protocol::TType _etype536;
+ iprot->readListBegin(_etype536, _size533);
+ this->success.resize(_size533);
+ uint32_t _i537;
+ for (_i537 = 0; _i537 < _size533; ++_i537)
{
- xfer += this->success[_i531].read(iprot);
+ xfer += this->success[_i537].read(iprot);
}
iprot->readListEnd();
}
@@ -13375,10 +13375,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter532;
- for (_iter532 = this->success.begin(); _iter532 != this->success.end(); ++_iter532)
+ std::vector ::const_iterator _iter538;
+ for (_iter538 = this->success.begin(); _iter538 != this->success.end(); ++_iter538)
{
- xfer += (*_iter532).write(oprot);
+ xfer += (*_iter538).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -13417,14 +13417,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size533;
- ::apache::thrift::protocol::TType _etype536;
- iprot->readListBegin(_etype536, _size533);
- (*(this->success)).resize(_size533);
- uint32_t _i537;
- for (_i537 = 0; _i537 < _size533; ++_i537)
+ uint32_t _size539;
+ ::apache::thrift::protocol::TType _etype542;
+ iprot->readListBegin(_etype542, _size539);
+ (*(this->success)).resize(_size539);
+ uint32_t _i543;
+ for (_i543 = 0; _i543 < _size539; ++_i543)
{
- xfer += (*(this->success))[_i537].read(iprot);
+ xfer += (*(this->success))[_i543].read(iprot);
}
iprot->readListEnd();
}
@@ -13493,14 +13493,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size538;
- ::apache::thrift::protocol::TType _etype541;
- iprot->readListBegin(_etype541, _size538);
- this->group_names.resize(_size538);
- uint32_t _i542;
- for (_i542 = 0; _i542 < _size538; ++_i542)
+ uint32_t _size544;
+ ::apache::thrift::protocol::TType _etype547;
+ iprot->readListBegin(_etype547, _size544);
+ this->group_names.resize(_size544);
+ uint32_t _i548;
+ for (_i548 = 0; _i548 < _size544; ++_i548)
{
- xfer += iprot->readString(this->group_names[_i542]);
+ xfer += iprot->readString(this->group_names[_i548]);
}
iprot->readListEnd();
}
@@ -13533,10 +13533,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->group_names.size()));
- std::vector ::const_iterator _iter543;
- for (_iter543 = this->group_names.begin(); _iter543 != this->group_names.end(); ++_iter543)
+ std::vector ::const_iterator _iter549;
+ for (_iter549 = this->group_names.begin(); _iter549 != this->group_names.end(); ++_iter549)
{
- xfer += oprot->writeString((*_iter543));
+ xfer += oprot->writeString((*_iter549));
}
xfer += oprot->writeListEnd();
}
@@ -13558,10 +13558,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 3);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->group_names)).size()));
- std::vector ::const_iterator _iter544;
- for (_iter544 = (*(this->group_names)).begin(); _iter544 != (*(this->group_names)).end(); ++_iter544)
+ std::vector ::const_iterator _iter550;
+ for (_iter550 = (*(this->group_names)).begin(); _iter550 != (*(this->group_names)).end(); ++_iter550)
{
- xfer += oprot->writeString((*_iter544));
+ xfer += oprot->writeString((*_iter550));
}
xfer += oprot->writeListEnd();
}
@@ -13717,9 +13717,9 @@
break;
case 2:
if (ftype == ::apache::thrift::protocol::T_I32) {
- int32_t ecast545;
- xfer += iprot->readI32(ecast545);
- this->principal_type = (PrincipalType::type)ecast545;
+ int32_t ecast551;
+ xfer += iprot->readI32(ecast551);
+ this->principal_type = (PrincipalType::type)ecast551;
this->__isset.principal_type = true;
} else {
xfer += iprot->skip(ftype);
@@ -13803,14 +13803,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size546;
- ::apache::thrift::protocol::TType _etype549;
- iprot->readListBegin(_etype549, _size546);
- this->success.resize(_size546);
- uint32_t _i550;
- for (_i550 = 0; _i550 < _size546; ++_i550)
+ uint32_t _size552;
+ ::apache::thrift::protocol::TType _etype555;
+ iprot->readListBegin(_etype555, _size552);
+ this->success.resize(_size552);
+ uint32_t _i556;
+ for (_i556 = 0; _i556 < _size552; ++_i556)
{
- xfer += this->success[_i550].read(iprot);
+ xfer += this->success[_i556].read(iprot);
}
iprot->readListEnd();
}
@@ -13849,10 +13849,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size()));
- std::vector ::const_iterator _iter551;
- for (_iter551 = this->success.begin(); _iter551 != this->success.end(); ++_iter551)
+ std::vector ::const_iterator _iter557;
+ for (_iter557 = this->success.begin(); _iter557 != this->success.end(); ++_iter557)
{
- xfer += (*_iter551).write(oprot);
+ xfer += (*_iter557).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -13891,14 +13891,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size552;
- ::apache::thrift::protocol::TType _etype555;
- iprot->readListBegin(_etype555, _size552);
- (*(this->success)).resize(_size552);
- uint32_t _i556;
- for (_i556 = 0; _i556 < _size552; ++_i556)
+ uint32_t _size558;
+ ::apache::thrift::protocol::TType _etype561;
+ iprot->readListBegin(_etype561, _size558);
+ (*(this->success)).resize(_size558);
+ uint32_t _i562;
+ for (_i562 = 0; _i562 < _size558; ++_i562)
{
- xfer += (*(this->success))[_i556].read(iprot);
+ xfer += (*(this->success))[_i562].read(iprot);
}
iprot->readListEnd();
}
@@ -14315,14 +14315,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->group_names.clear();
- uint32_t _size557;
- ::apache::thrift::protocol::TType _etype560;
- iprot->readListBegin(_etype560, _size557);
- this->group_names.resize(_size557);
- uint32_t _i561;
- for (_i561 = 0; _i561 < _size557; ++_i561)
+ uint32_t _size563;
+ ::apache::thrift::protocol::TType _etype566;
+ iprot->readListBegin(_etype566, _size563);
+ this->group_names.resize(_size563);
+ uint32_t _i567;
+ for (_i567 = 0; _i567 < _size563; ++_i567)
{
- xfer += iprot->readString(this->group_names[_i561]);
+ xfer += iprot->readString(this->group_names[_i567]);
}
iprot->readListEnd();
}
@@ -14352,10 +14352,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 2);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->group_names.size()));
- std::vector ::const_iterator _iter562;
- for (_iter562 = this->group_names.begin(); _iter562 != this->group_names.end(); ++_iter562)
+ std::vector ::const_iterator _iter568;
+ for (_iter568 = this->group_names.begin(); _iter568 != this->group_names.end(); ++_iter568)
{
- xfer += oprot->writeString((*_iter562));
+ xfer += oprot->writeString((*_iter568));
}
xfer += oprot->writeListEnd();
}
@@ -14374,10 +14374,10 @@
xfer += oprot->writeFieldBegin("group_names", ::apache::thrift::protocol::T_LIST, 2);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->group_names)).size()));
- std::vector ::const_iterator _iter563;
- for (_iter563 = (*(this->group_names)).begin(); _iter563 != (*(this->group_names)).end(); ++_iter563)
+ std::vector ::const_iterator _iter569;
+ for (_iter569 = (*(this->group_names)).begin(); _iter569 != (*(this->group_names)).end(); ++_iter569)
{
- xfer += oprot->writeString((*_iter563));
+ xfer += oprot->writeString((*_iter569));
}
xfer += oprot->writeListEnd();
}
@@ -14411,14 +14411,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->success.clear();
- uint32_t _size564;
- ::apache::thrift::protocol::TType _etype567;
- iprot->readListBegin(_etype567, _size564);
- this->success.resize(_size564);
- uint32_t _i568;
- for (_i568 = 0; _i568 < _size564; ++_i568)
+ uint32_t _size570;
+ ::apache::thrift::protocol::TType _etype573;
+ iprot->readListBegin(_etype573, _size570);
+ this->success.resize(_size570);
+ uint32_t _i574;
+ for (_i574 = 0; _i574 < _size570; ++_i574)
{
- xfer += iprot->readString(this->success[_i568]);
+ xfer += iprot->readString(this->success[_i574]);
}
iprot->readListEnd();
}
@@ -14457,10 +14457,10 @@
xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size()));
- std::vector ::const_iterator _iter569;
- for (_iter569 = this->success.begin(); _iter569 != this->success.end(); ++_iter569)
+ std::vector ::const_iterator _iter575;
+ for (_iter575 = this->success.begin(); _iter575 != this->success.end(); ++_iter575)
{
- xfer += oprot->writeString((*_iter569));
+ xfer += oprot->writeString((*_iter575));
}
xfer += oprot->writeListEnd();
}
@@ -14499,14 +14499,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
(*(this->success)).clear();
- uint32_t _size570;
- ::apache::thrift::protocol::TType _etype573;
- iprot->readListBegin(_etype573, _size570);
- (*(this->success)).resize(_size570);
- uint32_t _i574;
- for (_i574 = 0; _i574 < _size570; ++_i574)
+ uint32_t _size576;
+ ::apache::thrift::protocol::TType _etype579;
+ iprot->readListBegin(_etype579, _size576);
+ (*(this->success)).resize(_size576);
+ uint32_t _i580;
+ for (_i580 = 0; _i580 < _size576; ++_i580)
{
- xfer += iprot->readString((*(this->success))[_i574]);
+ xfer += iprot->readString((*(this->success))[_i580]);
}
iprot->readListEnd();
}
Index: metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
===================================================================
--- metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp (revision 1242898)
+++ metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp (working copy)
@@ -1253,9 +1253,74 @@
return xfer;
}
-const char* StorageDescriptor::ascii_fingerprint = "11E4CE18F895C13812C853DFDCD1293F";
-const uint8_t StorageDescriptor::binary_fingerprint[16] = {0x11,0xE4,0xCE,0x18,0xF8,0x95,0xC1,0x38,0x12,0xC8,0x53,0xDF,0xDC,0xD1,0x29,0x3F};
+const char* RegionStorageDescriptor::ascii_fingerprint = "07A9615F837F7D0A952B595DD3020972";
+const uint8_t RegionStorageDescriptor::binary_fingerprint[16] = {0x07,0xA9,0x61,0x5F,0x83,0x7F,0x7D,0x0A,0x95,0x2B,0x59,0x5D,0xD3,0x02,0x09,0x72};
+uint32_t RegionStorageDescriptor::read(::apache::thrift::protocol::TProtocol* iprot) {
+
+ uint32_t xfer = 0;
+ std::string fname;
+ ::apache::thrift::protocol::TType ftype;
+ int16_t fid;
+
+ xfer += iprot->readStructBegin(fname);
+
+ using ::apache::thrift::protocol::TProtocolException;
+
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->regionName);
+ this->__isset.regionName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->location);
+ this->__isset.location = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ return xfer;
+}
+
+uint32_t RegionStorageDescriptor::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("RegionStorageDescriptor");
+ xfer += oprot->writeFieldBegin("regionName", ::apache::thrift::protocol::T_STRING, 1);
+ xfer += oprot->writeString(this->regionName);
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("location", ::apache::thrift::protocol::T_STRING, 2);
+ xfer += oprot->writeString(this->location);
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+const char* StorageDescriptor::ascii_fingerprint = "67BFF60B597E40E541193F85E811DC8D";
+const uint8_t StorageDescriptor::binary_fingerprint[16] = {0x67,0xBF,0xF6,0x0B,0x59,0x7E,0x40,0xE5,0x41,0x19,0x3F,0x85,0xE8,0x11,0xDC,0x8D};
+
uint32_t StorageDescriptor::read(::apache::thrift::protocol::TProtocol* iprot) {
uint32_t xfer = 0;
@@ -1407,6 +1472,34 @@
xfer += iprot->skip(ftype);
}
break;
+ case 11:
+ if (ftype == ::apache::thrift::protocol::T_STRING) {
+ xfer += iprot->readString(this->primaryRegionName);
+ this->__isset.primaryRegionName = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 12:
+ if (ftype == ::apache::thrift::protocol::T_LIST) {
+ {
+ this->secondaryRegions.clear();
+ uint32_t _size101;
+ ::apache::thrift::protocol::TType _etype104;
+ iprot->readListBegin(_etype104, _size101);
+ this->secondaryRegions.resize(_size101);
+ uint32_t _i105;
+ for (_i105 = 0; _i105 < _size101; ++_i105)
+ {
+ xfer += this->secondaryRegions[_i105].read(iprot);
+ }
+ iprot->readListEnd();
+ }
+ this->__isset.secondaryRegions = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
default:
xfer += iprot->skip(ftype);
break;
@@ -1425,10 +1518,10 @@
xfer += oprot->writeFieldBegin("cols", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->cols.size()));
- std::vector ::const_iterator _iter101;
- for (_iter101 = this->cols.begin(); _iter101 != this->cols.end(); ++_iter101)
+ std::vector ::const_iterator _iter106;
+ for (_iter106 = this->cols.begin(); _iter106 != this->cols.end(); ++_iter106)
{
- xfer += (*_iter101).write(oprot);
+ xfer += (*_iter106).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1454,10 +1547,10 @@
xfer += oprot->writeFieldBegin("bucketCols", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->bucketCols.size()));
- std::vector ::const_iterator _iter102;
- for (_iter102 = this->bucketCols.begin(); _iter102 != this->bucketCols.end(); ++_iter102)
+ std::vector ::const_iterator _iter107;
+ for (_iter107 = this->bucketCols.begin(); _iter107 != this->bucketCols.end(); ++_iter107)
{
- xfer += oprot->writeString((*_iter102));
+ xfer += oprot->writeString((*_iter107));
}
xfer += oprot->writeListEnd();
}
@@ -1465,10 +1558,10 @@
xfer += oprot->writeFieldBegin("sortCols", ::apache::thrift::protocol::T_LIST, 9);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->sortCols.size()));
- std::vector ::const_iterator _iter103;
- for (_iter103 = this->sortCols.begin(); _iter103 != this->sortCols.end(); ++_iter103)
+ std::vector ::const_iterator _iter108;
+ for (_iter108 = this->sortCols.begin(); _iter108 != this->sortCols.end(); ++_iter108)
{
- xfer += (*_iter103).write(oprot);
+ xfer += (*_iter108).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1476,22 +1569,36 @@
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 10);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->parameters.size()));
- std::map ::const_iterator _iter104;
- for (_iter104 = this->parameters.begin(); _iter104 != this->parameters.end(); ++_iter104)
+ std::map ::const_iterator _iter109;
+ for (_iter109 = this->parameters.begin(); _iter109 != this->parameters.end(); ++_iter109)
{
- xfer += oprot->writeString(_iter104->first);
- xfer += oprot->writeString(_iter104->second);
+ xfer += oprot->writeString(_iter109->first);
+ xfer += oprot->writeString(_iter109->second);
}
xfer += oprot->writeMapEnd();
}
xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("primaryRegionName", ::apache::thrift::protocol::T_STRING, 11);
+ xfer += oprot->writeString(this->primaryRegionName);
+ xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("secondaryRegions", ::apache::thrift::protocol::T_LIST, 12);
+ {
+ xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->secondaryRegions.size()));
+ std::vector ::const_iterator _iter110;
+ for (_iter110 = this->secondaryRegions.begin(); _iter110 != this->secondaryRegions.end(); ++_iter110)
+ {
+ xfer += (*_iter110).write(oprot);
+ }
+ xfer += oprot->writeListEnd();
+ }
+ xfer += oprot->writeFieldEnd();
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
}
-const char* Table::ascii_fingerprint = "26BE788C09746068A2616712C9262900";
-const uint8_t Table::binary_fingerprint[16] = {0x26,0xBE,0x78,0x8C,0x09,0x74,0x60,0x68,0xA2,0x61,0x67,0x12,0xC9,0x26,0x29,0x00};
+const char* Table::ascii_fingerprint = "6FF520A3FDB5F73BB03D09C027BC88E2";
+const uint8_t Table::binary_fingerprint[16] = {0x6F,0xF5,0x20,0xA3,0xFD,0xB5,0xF7,0x3B,0xB0,0x3D,0x09,0xC0,0x27,0xBC,0x88,0xE2};
uint32_t Table::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1573,14 +1680,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->partitionKeys.clear();
- uint32_t _size105;
- ::apache::thrift::protocol::TType _etype108;
- iprot->readListBegin(_etype108, _size105);
- this->partitionKeys.resize(_size105);
- uint32_t _i109;
- for (_i109 = 0; _i109 < _size105; ++_i109)
+ uint32_t _size111;
+ ::apache::thrift::protocol::TType _etype114;
+ iprot->readListBegin(_etype114, _size111);
+ this->partitionKeys.resize(_size111);
+ uint32_t _i115;
+ for (_i115 = 0; _i115 < _size111; ++_i115)
{
- xfer += this->partitionKeys[_i109].read(iprot);
+ xfer += this->partitionKeys[_i115].read(iprot);
}
iprot->readListEnd();
}
@@ -1593,17 +1700,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size110;
- ::apache::thrift::protocol::TType _ktype111;
- ::apache::thrift::protocol::TType _vtype112;
- iprot->readMapBegin(_ktype111, _vtype112, _size110);
- uint32_t _i114;
- for (_i114 = 0; _i114 < _size110; ++_i114)
+ uint32_t _size116;
+ ::apache::thrift::protocol::TType _ktype117;
+ ::apache::thrift::protocol::TType _vtype118;
+ iprot->readMapBegin(_ktype117, _vtype118, _size116);
+ uint32_t _i120;
+ for (_i120 = 0; _i120 < _size116; ++_i120)
{
- std::string _key115;
- xfer += iprot->readString(_key115);
- std::string& _val116 = this->parameters[_key115];
- xfer += iprot->readString(_val116);
+ std::string _key121;
+ xfer += iprot->readString(_key121);
+ std::string& _val122 = this->parameters[_key121];
+ xfer += iprot->readString(_val122);
}
iprot->readMapEnd();
}
@@ -1683,10 +1790,10 @@
xfer += oprot->writeFieldBegin("partitionKeys", ::apache::thrift::protocol::T_LIST, 8);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->partitionKeys.size()));
- std::vector ::const_iterator _iter117;
- for (_iter117 = this->partitionKeys.begin(); _iter117 != this->partitionKeys.end(); ++_iter117)
+ std::vector ::const_iterator _iter123;
+ for (_iter123 = this->partitionKeys.begin(); _iter123 != this->partitionKeys.end(); ++_iter123)
{
- xfer += (*_iter117).write(oprot);
+ xfer += (*_iter123).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -1694,11 +1801,11 @@
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 9);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->parameters.size()));
- std::map ::const_iterator _iter118;
- for (_iter118 = this->parameters.begin(); _iter118 != this->parameters.end(); ++_iter118)
+ std::map ::const_iterator _iter124;
+ for (_iter124 = this->parameters.begin(); _iter124 != this->parameters.end(); ++_iter124)
{
- xfer += oprot->writeString(_iter118->first);
- xfer += oprot->writeString(_iter118->second);
+ xfer += oprot->writeString(_iter124->first);
+ xfer += oprot->writeString(_iter124->second);
}
xfer += oprot->writeMapEnd();
}
@@ -1722,8 +1829,8 @@
return xfer;
}
-const char* Partition::ascii_fingerprint = "F480E1D1B8AEBDDB37F8E180C0F07395";
-const uint8_t Partition::binary_fingerprint[16] = {0xF4,0x80,0xE1,0xD1,0xB8,0xAE,0xBD,0xDB,0x37,0xF8,0xE1,0x80,0xC0,0xF0,0x73,0x95};
+const char* Partition::ascii_fingerprint = "9DC9BCB205A70AFE078D9663673DA11B";
+const uint8_t Partition::binary_fingerprint[16] = {0x9D,0xC9,0xBC,0xB2,0x05,0xA7,0x0A,0xFE,0x07,0x8D,0x96,0x63,0x67,0x3D,0xA1,0x1B};
uint32_t Partition::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1749,14 +1856,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->values.clear();
- uint32_t _size119;
- ::apache::thrift::protocol::TType _etype122;
- iprot->readListBegin(_etype122, _size119);
- this->values.resize(_size119);
- uint32_t _i123;
- for (_i123 = 0; _i123 < _size119; ++_i123)
+ uint32_t _size125;
+ ::apache::thrift::protocol::TType _etype128;
+ iprot->readListBegin(_etype128, _size125);
+ this->values.resize(_size125);
+ uint32_t _i129;
+ for (_i129 = 0; _i129 < _size125; ++_i129)
{
- xfer += iprot->readString(this->values[_i123]);
+ xfer += iprot->readString(this->values[_i129]);
}
iprot->readListEnd();
}
@@ -1809,17 +1916,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size124;
- ::apache::thrift::protocol::TType _ktype125;
- ::apache::thrift::protocol::TType _vtype126;
- iprot->readMapBegin(_ktype125, _vtype126, _size124);
- uint32_t _i128;
- for (_i128 = 0; _i128 < _size124; ++_i128)
+ uint32_t _size130;
+ ::apache::thrift::protocol::TType _ktype131;
+ ::apache::thrift::protocol::TType _vtype132;
+ iprot->readMapBegin(_ktype131, _vtype132, _size130);
+ uint32_t _i134;
+ for (_i134 = 0; _i134 < _size130; ++_i134)
{
- std::string _key129;
- xfer += iprot->readString(_key129);
- std::string& _val130 = this->parameters[_key129];
- xfer += iprot->readString(_val130);
+ std::string _key135;
+ xfer += iprot->readString(_key135);
+ std::string& _val136 = this->parameters[_key135];
+ xfer += iprot->readString(_val136);
}
iprot->readMapEnd();
}
@@ -1854,10 +1961,10 @@
xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->values.size()));
- std::vector ::const_iterator _iter131;
- for (_iter131 = this->values.begin(); _iter131 != this->values.end(); ++_iter131)
+ std::vector ::const_iterator _iter137;
+ for (_iter137 = this->values.begin(); _iter137 != this->values.end(); ++_iter137)
{
- xfer += oprot->writeString((*_iter131));
+ xfer += oprot->writeString((*_iter137));
}
xfer += oprot->writeListEnd();
}
@@ -1880,11 +1987,11 @@
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 7);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->parameters.size()));
- std::map ::const_iterator _iter132;
- for (_iter132 = this->parameters.begin(); _iter132 != this->parameters.end(); ++_iter132)
+ std::map ::const_iterator _iter138;
+ for (_iter138 = this->parameters.begin(); _iter138 != this->parameters.end(); ++_iter138)
{
- xfer += oprot->writeString(_iter132->first);
- xfer += oprot->writeString(_iter132->second);
+ xfer += oprot->writeString(_iter138->first);
+ xfer += oprot->writeString(_iter138->second);
}
xfer += oprot->writeMapEnd();
}
@@ -1899,8 +2006,8 @@
return xfer;
}
-const char* Index::ascii_fingerprint = "5FEE4F7E28935B644F207D74459F6A29";
-const uint8_t Index::binary_fingerprint[16] = {0x5F,0xEE,0x4F,0x7E,0x28,0x93,0x5B,0x64,0x4F,0x20,0x7D,0x74,0x45,0x9F,0x6A,0x29};
+const char* Index::ascii_fingerprint = "23D1851E2E1791DEBCC4F08B8E0AA688";
+const uint8_t Index::binary_fingerprint[16] = {0x23,0xD1,0x85,0x1E,0x2E,0x17,0x91,0xDE,0xBC,0xC4,0xF0,0x8B,0x8E,0x0A,0xA6,0x88};
uint32_t Index::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -1990,17 +2097,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->parameters.clear();
- uint32_t _size133;
- ::apache::thrift::protocol::TType _ktype134;
- ::apache::thrift::protocol::TType _vtype135;
- iprot->readMapBegin(_ktype134, _vtype135, _size133);
- uint32_t _i137;
- for (_i137 = 0; _i137 < _size133; ++_i137)
+ uint32_t _size139;
+ ::apache::thrift::protocol::TType _ktype140;
+ ::apache::thrift::protocol::TType _vtype141;
+ iprot->readMapBegin(_ktype140, _vtype141, _size139);
+ uint32_t _i143;
+ for (_i143 = 0; _i143 < _size139; ++_i143)
{
- std::string _key138;
- xfer += iprot->readString(_key138);
- std::string& _val139 = this->parameters[_key138];
- xfer += iprot->readString(_val139);
+ std::string _key144;
+ xfer += iprot->readString(_key144);
+ std::string& _val145 = this->parameters[_key144];
+ xfer += iprot->readString(_val145);
}
iprot->readMapEnd();
}
@@ -2059,11 +2166,11 @@
xfer += oprot->writeFieldBegin("parameters", ::apache::thrift::protocol::T_MAP, 9);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->parameters.size()));
- std::map ::const_iterator _iter140;
- for (_iter140 = this->parameters.begin(); _iter140 != this->parameters.end(); ++_iter140)
+ std::map ::const_iterator _iter146;
+ for (_iter146 = this->parameters.begin(); _iter146 != this->parameters.end(); ++_iter146)
{
- xfer += oprot->writeString(_iter140->first);
- xfer += oprot->writeString(_iter140->second);
+ xfer += oprot->writeString(_iter146->first);
+ xfer += oprot->writeString(_iter146->second);
}
xfer += oprot->writeMapEnd();
}
@@ -2103,14 +2210,14 @@
if (ftype == ::apache::thrift::protocol::T_LIST) {
{
this->fieldSchemas.clear();
- uint32_t _size141;
- ::apache::thrift::protocol::TType _etype144;
- iprot->readListBegin(_etype144, _size141);
- this->fieldSchemas.resize(_size141);
- uint32_t _i145;
- for (_i145 = 0; _i145 < _size141; ++_i145)
+ uint32_t _size147;
+ ::apache::thrift::protocol::TType _etype150;
+ iprot->readListBegin(_etype150, _size147);
+ this->fieldSchemas.resize(_size147);
+ uint32_t _i151;
+ for (_i151 = 0; _i151 < _size147; ++_i151)
{
- xfer += this->fieldSchemas[_i145].read(iprot);
+ xfer += this->fieldSchemas[_i151].read(iprot);
}
iprot->readListEnd();
}
@@ -2123,17 +2230,17 @@
if (ftype == ::apache::thrift::protocol::T_MAP) {
{
this->properties.clear();
- uint32_t _size146;
- ::apache::thrift::protocol::TType _ktype147;
- ::apache::thrift::protocol::TType _vtype148;
- iprot->readMapBegin(_ktype147, _vtype148, _size146);
- uint32_t _i150;
- for (_i150 = 0; _i150 < _size146; ++_i150)
+ uint32_t _size152;
+ ::apache::thrift::protocol::TType _ktype153;
+ ::apache::thrift::protocol::TType _vtype154;
+ iprot->readMapBegin(_ktype153, _vtype154, _size152);
+ uint32_t _i156;
+ for (_i156 = 0; _i156 < _size152; ++_i156)
{
- std::string _key151;
- xfer += iprot->readString(_key151);
- std::string& _val152 = this->properties[_key151];
- xfer += iprot->readString(_val152);
+ std::string _key157;
+ xfer += iprot->readString(_key157);
+ std::string& _val158 = this->properties[_key157];
+ xfer += iprot->readString(_val158);
}
iprot->readMapEnd();
}
@@ -2160,10 +2267,10 @@
xfer += oprot->writeFieldBegin("fieldSchemas", ::apache::thrift::protocol::T_LIST, 1);
{
xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->fieldSchemas.size()));
- std::vector ::const_iterator _iter153;
- for (_iter153 = this->fieldSchemas.begin(); _iter153 != this->fieldSchemas.end(); ++_iter153)
+ std::vector ::const_iterator _iter159;
+ for (_iter159 = this->fieldSchemas.begin(); _iter159 != this->fieldSchemas.end(); ++_iter159)
{
- xfer += (*_iter153).write(oprot);
+ xfer += (*_iter159).write(oprot);
}
xfer += oprot->writeListEnd();
}
@@ -2171,11 +2278,11 @@
xfer += oprot->writeFieldBegin("properties", ::apache::thrift::protocol::T_MAP, 2);
{
xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->properties.size()));
- std::map ::const_iterator _iter154;
- for (_iter154 = this->properties.begin(); _iter154 != this->properties.end(); ++_iter154)
+ std::map ::const_iterator _iter160;
+ for (_iter160 = this->properties.begin(); _iter160 != this->properties.end(); ++_iter160)
{
- xfer += oprot->writeString(_iter154->first);
- xfer += oprot->writeString(_iter154->second);
+ xfer += oprot->writeString(_iter160->first);
+ xfer += oprot->writeString(_iter160->second);
}
xfer += oprot->writeMapEnd();
}
Index: metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
===================================================================
--- metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (revision 1242898)
+++ metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (working copy)
@@ -774,8 +774,57 @@
};
+typedef struct _RegionStorageDescriptor__isset {
+ _RegionStorageDescriptor__isset() : regionName(false), location(false) {}
+ bool regionName;
+ bool location;
+} _RegionStorageDescriptor__isset;
+
+class RegionStorageDescriptor {
+ public:
+
+ static const char* ascii_fingerprint; // = "07A9615F837F7D0A952B595DD3020972";
+ static const uint8_t binary_fingerprint[16]; // = {0x07,0xA9,0x61,0x5F,0x83,0x7F,0x7D,0x0A,0x95,0x2B,0x59,0x5D,0xD3,0x02,0x09,0x72};
+
+ RegionStorageDescriptor() : regionName(""), location("") {
+ }
+
+ virtual ~RegionStorageDescriptor() throw() {}
+
+ std::string regionName;
+ std::string location;
+
+ _RegionStorageDescriptor__isset __isset;
+
+ void __set_regionName(const std::string& val) {
+ regionName = val;
+ }
+
+ void __set_location(const std::string& val) {
+ location = val;
+ }
+
+ bool operator == (const RegionStorageDescriptor & rhs) const
+ {
+ if (!(regionName == rhs.regionName))
+ return false;
+ if (!(location == rhs.location))
+ return false;
+ return true;
+ }
+ bool operator != (const RegionStorageDescriptor &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const RegionStorageDescriptor & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
typedef struct _StorageDescriptor__isset {
- _StorageDescriptor__isset() : cols(false), location(false), inputFormat(false), outputFormat(false), compressed(false), numBuckets(false), serdeInfo(false), bucketCols(false), sortCols(false), parameters(false) {}
+ _StorageDescriptor__isset() : cols(false), location(false), inputFormat(false), outputFormat(false), compressed(false), numBuckets(false), serdeInfo(false), bucketCols(false), sortCols(false), parameters(false), primaryRegionName(false), secondaryRegions(false) {}
bool cols;
bool location;
bool inputFormat;
@@ -786,15 +835,17 @@
bool bucketCols;
bool sortCols;
bool parameters;
+ bool primaryRegionName;
+ bool secondaryRegions;
} _StorageDescriptor__isset;
class StorageDescriptor {
public:
- static const char* ascii_fingerprint; // = "11E4CE18F895C13812C853DFDCD1293F";
- static const uint8_t binary_fingerprint[16]; // = {0x11,0xE4,0xCE,0x18,0xF8,0x95,0xC1,0x38,0x12,0xC8,0x53,0xDF,0xDC,0xD1,0x29,0x3F};
+ static const char* ascii_fingerprint; // = "67BFF60B597E40E541193F85E811DC8D";
+ static const uint8_t binary_fingerprint[16]; // = {0x67,0xBF,0xF6,0x0B,0x59,0x7E,0x40,0xE5,0x41,0x19,0x3F,0x85,0xE8,0x11,0xDC,0x8D};
- StorageDescriptor() : location(""), inputFormat(""), outputFormat(""), compressed(0), numBuckets(0) {
+ StorageDescriptor() : location(""), inputFormat(""), outputFormat(""), compressed(0), numBuckets(0), primaryRegionName("") {
}
virtual ~StorageDescriptor() throw() {}
@@ -809,6 +860,8 @@
std::vector