Author: khorgath Date: Fri Jan 9 22:09:50 2015 New Revision: 1650682 URL: http://svn.apache.org/r1650682 Log: HIVE-9296 : Need to add schema upgrade changes for queueing events in the database (Alan Gates via Sushanth Sowmyan)
Added: hive/trunk/metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql hive/trunk/metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql hive/trunk/metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql hive/trunk/metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql hive/trunk/metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql Modified: hive/trunk/metastore/if/hive_metastore.thrift hive/trunk/metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql hive/trunk/metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql hive/trunk/metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql hive/trunk/metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql hive/trunk/metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql hive/trunk/metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql hive/trunk/metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql hive/trunk/metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql hive/trunk/metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql hive/trunk/metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py hive/trunk/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java Modified: hive/trunk/metastore/if/hive_metastore.thrift URL: http://svn.apache.org/viewvc/hive/trunk/metastore/if/hive_metastore.thrift?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/if/hive_metastore.thrift (original) +++ hive/trunk/metastore/if/hive_metastore.thrift Fri Jan 9 22:09:50 2015 @@ -1132,8 +1132,8 @@ service ThriftHiveMetastore extends fb30 ShowCompactResponse show_compact(1:ShowCompactRequest rqst) // Notification logging calls - NotificationEventResponse getNextNotification(1:NotificationEventRequest rqst) - CurrentNotificationEventId getCurrentNotificationEventId() + NotificationEventResponse get_next_notification(1:NotificationEventRequest rqst) + CurrentNotificationEventId get_current_notificationEventId() } // * Note about the DDL_TIME: When creating or altering a table or a partition, Added: hive/trunk/metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql?rev=1650682&view=auto ============================================================================== --- hive/trunk/metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql (added) +++ hive/trunk/metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql Fri Jan 9 22:09:50 2015 @@ -0,0 +1,7 @@ +CREATE TABLE "APP"."NOTIFICATION_LOG" ("NL_ID" BIGINT NOT NULL, "DB_NAME" VARCHAR(128), "EVENT_ID" BIGINT NOT NULL, "EVENT_TIME" INTEGER NOT NULL, "EVENT_TYPE" VARCHAR(32) NOT NULL, "MESSAGE" VARCHAR(1024) NOT NULL, "TBL_NAME" VARCHAR(128)); + +CREATE TABLE "APP"."NOTIFICATION_SEQUENCE" ("NNI_ID" BIGINT NOT NULL, "NEXT_EVENT_ID" BIGINT NOT NULL); + +ALTER TABLE "APP"."NOTIFICATION_LOG" ADD CONSTRAINT "NOTIFICATION_LOG_PK" PRIMARY KEY ("NL_ID"); + +ALTER TABLE "APP"."NOTIFICATION_SEQUENCE" ADD CONSTRAINT "NOTIFICATION_SEQUENCE_PK" PRIMARY KEY ("NNI_ID"); Modified: hive/trunk/metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql (original) +++ hive/trunk/metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql Fri Jan 9 22:09:50 2015 @@ -104,6 +104,10 @@ CREATE TABLE "APP"."FUNCS" ("FUNC_ID" BI CREATE TABLE "APP"."FUNC_RU" ("FUNC_ID" BIGINT NOT NULL, "RESOURCE_TYPE" INTEGER NOT NULL, "RESOURCE_URI" VARCHAR(4000), "INTEGER_IDX" INTEGER NOT NULL); +CREATE TABLE "APP"."NOTIFICATION_LOG" ("NL_ID" BIGINT NOT NULL, "DB_NAME" VARCHAR(128), "EVENT_ID" BIGINT NOT NULL, "EVENT_TIME" INTEGER NOT NULL, "EVENT_TYPE" VARCHAR(32) NOT NULL, "MESSAGE" VARCHAR(1024) NOT NULL, "TBL_NAME" VARCHAR(128)); + +CREATE TABLE "APP"."NOTIFICATION_SEQUENCE" ("NNI_ID" BIGINT NOT NULL, "NEXT_EVENT_ID" BIGINT NOT NULL); + -- ---------------------------------------------- -- DDL Statements for indexes -- ---------------------------------------------- @@ -229,6 +233,10 @@ ALTER TABLE "APP"."FUNCS" ADD CONSTRAINT ALTER TABLE "APP"."FUNC_RU" ADD CONSTRAINT "FUNC_RU_PK" PRIMARY KEY ("FUNC_ID", "INTEGER_IDX"); +ALTER TABLE "APP"."NOTIFICATION_LOG" ADD CONSTRAINT "NOTIFICATION_LOG_PK" PRIMARY KEY ("NL_ID"); + +ALTER TABLE "APP"."NOTIFICATION_SEQUENCE" ADD CONSTRAINT "NOTIFICATION_SEQUENCE_PK" PRIMARY KEY ("NNI_ID"); + -- foreign 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; Modified: hive/trunk/metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql (original) +++ hive/trunk/metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql Fri Jan 9 22:09:50 2015 @@ -1,3 +1,5 @@ -- Upgrade MetaStore schema from 0.14.0 to 0.15.0 +RUN '020-HIVE-9296.derby.sql'; + UPDATE "APP".VERSION SET SCHEMA_VERSION='0.15.0', VERSION_COMMENT='Hive release version 0.15.0' where VER_ID=1; Added: hive/trunk/metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql?rev=1650682&view=auto ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql (added) +++ hive/trunk/metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql Fri Jan 9 22:09:50 2015 @@ -0,0 +1,26 @@ +CREATE TABLE NOTIFICATION_LOG +( + NL_ID bigint NOT NULL, + EVENT_ID bigint NOT NULL, + EVENT_TIME int NOT NULL, + EVENT_TYPE varchar(32) NOT NULL, + DB_NAME varchar(128) NULL, + TBL_NAME varchar(128) NULL, + MESSAGE varchar(1024) NOT NULL +); +GO + +ALTER TABLE NOTIFICATION_LOG ADD CONSTRAINT NOTIFICATION_LOG_PK PRIMARY KEY (NL_ID); +GO + +CREATE TABLE NOTIFICATION_SEQUENCE +( + NNI_ID bigint NOT NULL, + NEXT_EVENT_ID bigint NOT NULL +); +GO + +ALTER TABLE NOTIFICATION_SEQUENCE ADD CONSTRAINT NOTIFICATION_SEQUENCE_PK PRIMARY KEY (NNI_ID); +GO + + Modified: hive/trunk/metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql (original) +++ hive/trunk/metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql Fri Jan 9 22:09:50 2015 @@ -570,6 +570,27 @@ CREATE TABLE TABLE_PARAMS ALTER TABLE TABLE_PARAMS ADD CONSTRAINT TABLE_PARAMS_PK PRIMARY KEY (TBL_ID,PARAM_KEY); +CREATE TABLE NOTIFICATION_LOG +( + NL_ID bigint NOT NULL, + EVENT_ID bigint NOT NULL, + EVENT_TIME int NOT NULL, + EVENT_TYPE varchar(32) NOT NULL, + DB_NAME varchar(128) NULL, + TBL_NAME varchar(128) NULL, + MESSAGE varchar(1024) NOT NULL +); + +ALTER TABLE NOTIFICATION_LOG ADD CONSTRAINT NOTIFICATION_LOG_PK PRIMARY KEY (NL_ID); + +CREATE TABLE NOTIFICATION_SEQUENCE +( + NNI_ID bigint NOT NULL, + NEXT_EVENT_ID bigint NOT NULL +); + +ALTER TABLE NOTIFICATION_SEQUENCE ADD CONSTRAINT NOTIFICATION_SEQUENCE_PK PRIMARY KEY (NNI_ID); + -- Constraints for table MASTER_KEYS for class(es) [org.apache.hadoop.hive.metastore.model.MMasterKey] -- Constraints for table IDXS for class(es) [org.apache.hadoop.hive.metastore.model.MIndex] Modified: hive/trunk/metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql (original) +++ hive/trunk/metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql Fri Jan 9 22:09:50 2015 @@ -1,4 +1,6 @@ SELECT 'Upgrading MetaStore schema from 0.14.0 to 0.15.0' AS MESSAGE; +:r 005-HIVE-9296.mssql.sql; + UPDATE VERSION SET SCHEMA_VERSION='0.15.0', VERSION_COMMENT='Hive release version 0.15.0' where VER_ID=1; SELECT 'Finished upgrading MetaStore schema from 0.14.0 to 0.15.0' AS MESSAGE; Added: hive/trunk/metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql?rev=1650682&view=auto ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql (added) +++ hive/trunk/metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql Fri Jan 9 22:09:50 2015 @@ -0,0 +1,18 @@ +CREATE TABLE IF NOT EXISTS `NOTIFICATION_LOG` +( + `NL_ID` BIGINT(20) NOT NULL, + `EVENT_ID` BIGINT(20) NOT NULL, + `EVENT_TIME` INT(11) NOT NULL, + `EVENT_TYPE` varchar(32) NOT NULL, + `DB_NAME` varchar(128), + `TBL_NAME` varchar(128), + `MESSAGE` varchar(1024) NOT NULL, + PRIMARY KEY (`NL_ID`) +) ENGINE=InnoDB DEFAULT CHARSET=latin1; + +CREATE TABLE IF NOT EXISTS `NOTIFICATION_SEQUENCE` +( + `NNI_ID` BIGINT(20) NOT NULL, + `NEXT_EVENT_ID` BIGINT(20) NOT NULL, + PRIMARY KEY (`NNI_ID`) +) ENGINE=InnoDB DEFAULT CHARSET=latin1; Modified: hive/trunk/metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql (original) +++ hive/trunk/metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql Fri Jan 9 22:09:50 2015 @@ -795,6 +795,26 @@ CREATE TABLE IF NOT EXISTS `FUNC_RU` ( CONSTRAINT `FUNC_RU_FK1` FOREIGN KEY (`FUNC_ID`) REFERENCES `FUNCS` (`FUNC_ID`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1; +CREATE TABLE IF NOT EXISTS `NOTIFICATION_LOG` +( + `NL_ID` BIGINT(20) NOT NULL, + `EVENT_ID` BIGINT(20) NOT NULL, + `EVENT_TIME` INT(11) NOT NULL, + `EVENT_TYPE` varchar(32) NOT NULL, + `DB_NAME` varchar(128), + `TBL_NAME` varchar(128), + `MESSAGE` varchar(1024) NOT NULL, + PRIMARY KEY (`NL_ID`) +) ENGINE=InnoDB DEFAULT CHARSET=latin1; + +CREATE TABLE IF NOT EXISTS `NOTIFICATION_SEQUENCE` +( + `NNI_ID` BIGINT(20) NOT NULL, + `NEXT_EVENT_ID` BIGINT(20) NOT NULL, + PRIMARY KEY (`NNI_ID`) +) ENGINE=InnoDB DEFAULT CHARSET=latin1; + + -- ---------------------------- -- Transaction and Lock Tables Modified: hive/trunk/metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql (original) +++ hive/trunk/metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql Fri Jan 9 22:09:50 2015 @@ -1,5 +1,7 @@ SELECT 'Upgrading MetaStore schema from 0.14.0 to 0.15.0' AS ' '; +SOURCE 020-HIVE-9296.mysql.sql; + UPDATE VERSION SET SCHEMA_VERSION='0.14.0', VERSION_COMMENT='Hive release version 0.15.0' where VER_ID=1; SELECT 'Finished upgrading MetaStore schema from 0.14.0 to 0.15.0' AS ' '; Added: hive/trunk/metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql?rev=1650682&view=auto ============================================================================== --- hive/trunk/metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql (added) +++ hive/trunk/metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql Fri Jan 9 22:09:50 2015 @@ -0,0 +1,18 @@ +CREATE TABLE NOTIFICATION_LOG +( + NL_ID NUMBER NOT NULL, + EVENT_ID NUMBER NOT NULL, + EVENT_TIME NUMBER(10) NOT NULL, + EVENT_TYPE VARCHAR2(32) NOT NULL, + DB_NAME VARCHAR2(128), + TBL_NAME VARCHAR2(128), + MESSAGE VARCHAR2(1024) NOT NULL +); + +ALTER TABLE NOTIFICATION_LOG ADD CONSTRAINT NOTIFICATION_LOG_PK PRIMARY KEY (NL_ID); + +CREATE TABLE NOTIFICATION_SEQUENCE +( + NNI_ID NUMBER NOT NULL, + NEXT_EVENT_ID NUMBER NOT NULL +); Modified: hive/trunk/metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql (original) +++ hive/trunk/metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql Fri Jan 9 22:09:50 2015 @@ -551,6 +551,28 @@ CREATE TABLE FUNC_RU ( ALTER TABLE FUNC_RU ADD CONSTRAINT FUNC_RU_PK PRIMARY KEY (FUNC_ID, INTEGER_IDX); +CREATE TABLE NOTIFICATION_LOG +( + NL_ID NUMBER NOT NULL, + EVENT_ID NUMBER NOT NULL, + EVENT_TIME NUMBER(10) NOT NULL, + EVENT_TYPE VARCHAR2(32) NOT NULL, + DB_NAME VARCHAR2(128), + TBL_NAME VARCHAR2(128), + MESSAGE VARCHAR2(1024) NOT NULL +); + +ALTER TABLE NOTIFICATION_LOG ADD CONSTRAINT NOTIFICATION_LOG_PK PRIMARY KEY (NL_ID); + +CREATE TABLE NOTIFICATION_SEQUENCE +( + NNI_ID NUMBER NOT NULL, + NEXT_EVENT_ID NUMBER NOT NULL +); + +ALTER TABLE NOTIFICATION_SEQUENCE ADD CONSTRAINT NOTIFICATION_SEQUENCE_PK PRIMARY KEY (NNI_ID); + + -- Constraints for table PART_COL_PRIVS for class(es) [org.apache.hadoop.hive.metastore.model.MPartitionColumnPrivilege] ALTER TABLE PART_COL_PRIVS ADD CONSTRAINT PART_COL_PRIVS_FK1 FOREIGN KEY (PART_ID) REFERENCES PARTITIONS (PART_ID) INITIALLY DEFERRED ; Modified: hive/trunk/metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql (original) +++ hive/trunk/metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql Fri Jan 9 22:09:50 2015 @@ -1,4 +1,6 @@ SELECT 'Upgrading MetaStore schema from 0.14.0 to 0.15.0' AS Status from dual; +@021-HIVE-9296.oracle.sql; + UPDATE VERSION SET SCHEMA_VERSION='0.15.0', VERSION_COMMENT='Hive release version 0.15.0' where VER_ID=1; SELECT 'Finished upgrading MetaStore schema from 0.14.0 to 0.15.0' AS Status from dual; Added: hive/trunk/metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql?rev=1650682&view=auto ============================================================================== --- hive/trunk/metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql (added) +++ hive/trunk/metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql Fri Jan 9 22:09:50 2015 @@ -0,0 +1,18 @@ +CREATE TABLE "NOTIFICATION_LOG" +( + "NL_ID" BIGINT NOT NULL, + "EVENT_ID" BIGINT NOT NULL, + "EVENT_TIME" INTEGER NOT NULL, + "EVENT_TYPE" VARCHAR(32) NOT NULL, + "DB_NAME" VARCHAR(128), + "TBL_NAME" VARCHAR(128), + "MESSAGE" VARCHAR(1024) NOT NULL, + PRIMARY KEY ("NL_ID") +); + +CREATE TABLE "NOTIFICATION_SEQUENCE" +( + "NNI_ID" BIGINT NOT NULL, + "NEXT_EVENT_ID" BIGINT NOT NULL, + PRIMARY KEY ("NNI_ID") +); Modified: hive/trunk/metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql (original) +++ hive/trunk/metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql Fri Jan 9 22:09:50 2015 @@ -579,6 +579,25 @@ CREATE TABLE "FUNC_RU" ( PRIMARY KEY ("FUNC_ID", "INTEGER_IDX") ); +CREATE TABLE "NOTIFICATION_LOG" +( + "NL_ID" BIGINT NOT NULL, + "EVENT_ID" BIGINT NOT NULL, + "EVENT_TIME" INTEGER NOT NULL, + "EVENT_TYPE" VARCHAR(32) NOT NULL, + "DB_NAME" VARCHAR(128), + "TBL_NAME" VARCHAR(128), + "MESSAGE" VARCHAR(1024) NOT NULL, + PRIMARY KEY ("NL_ID") +); + +CREATE TABLE "NOTIFICATION_SEQUENCE" +( + "NNI_ID" BIGINT NOT NULL, + "NEXT_EVENT_ID" BIGINT NOT NULL, + PRIMARY KEY ("NNI_ID") +); + -- -- Name: BUCKETING_COLS_pkey; Type: CONSTRAINT; Schema: public; Owner: hiveuser; Tablespace: -- Modified: hive/trunk/metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql URL: http://svn.apache.org/viewvc/hive/trunk/metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql (original) +++ hive/trunk/metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql Fri Jan 9 22:09:50 2015 @@ -1,5 +1,7 @@ SELECT 'Upgrading MetaStore schema from 0.14.0 to 0.15.0'; +\i 020-HIVE-9296.postgres.sql; + UPDATE "VERSION" SET "SCHEMA_VERSION"='0.15.0', "VERSION_COMMENT"='Hive release version 0.15.0' where "VER_ID"=1; SELECT 'Finished upgrading MetaStore schema from 0.14.0 to 0.15.0'; Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp (original) +++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp Fri Jan 9 22:09:50 2015 @@ -27094,7 +27094,7 @@ uint32_t ThriftHiveMetastore_show_compac return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_next_notification_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -27134,9 +27134,9 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_next_notification_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getNextNotification_args"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_next_notification_args"); xfer += oprot->writeFieldBegin("rqst", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->rqst.write(oprot); @@ -27147,9 +27147,9 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_next_notification_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getNextNotification_pargs"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_next_notification_pargs"); xfer += oprot->writeFieldBegin("rqst", ::apache::thrift::protocol::T_STRUCT, 1); xfer += (*(this->rqst)).write(oprot); @@ -27160,7 +27160,7 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_next_notification_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -27200,11 +27200,11 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_next_notification_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getNextNotification_result"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_next_notification_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); @@ -27216,7 +27216,7 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getNextNotification_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_next_notification_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -27256,7 +27256,7 @@ uint32_t ThriftHiveMetastore_getNextNoti return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_args::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_args::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -27283,25 +27283,25 @@ uint32_t ThriftHiveMetastore_getCurrentN return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_args::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getCurrentNotificationEventId_args"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_current_notificationEventId_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getCurrentNotificationEventId_pargs"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_current_notificationEventId_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_result::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_result::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -27341,11 +27341,11 @@ uint32_t ThriftHiveMetastore_getCurrentN return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_result::write(::apache::thrift::protocol::TProtocol* oprot) const { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; - xfer += oprot->writeStructBegin("ThriftHiveMetastore_getCurrentNotificationEventId_result"); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_get_current_notificationEventId_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); @@ -27357,7 +27357,7 @@ uint32_t ThriftHiveMetastore_getCurrentN return xfer; } -uint32_t ThriftHiveMetastore_getCurrentNotificationEventId_presult::read(::apache::thrift::protocol::TProtocol* iprot) { +uint32_t ThriftHiveMetastore_get_current_notificationEventId_presult::read(::apache::thrift::protocol::TProtocol* iprot) { uint32_t xfer = 0; std::string fname; @@ -34908,18 +34908,18 @@ void ThriftHiveMetastoreClient::recv_sho throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "show_compact failed: unknown result"); } -void ThriftHiveMetastoreClient::getNextNotification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) +void ThriftHiveMetastoreClient::get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) { - send_getNextNotification(rqst); - recv_getNextNotification(_return); + send_get_next_notification(rqst); + recv_get_next_notification(_return); } -void ThriftHiveMetastoreClient::send_getNextNotification(const NotificationEventRequest& rqst) +void ThriftHiveMetastoreClient::send_get_next_notification(const NotificationEventRequest& rqst) { int32_t cseqid = 0; - oprot_->writeMessageBegin("getNextNotification", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("get_next_notification", ::apache::thrift::protocol::T_CALL, cseqid); - ThriftHiveMetastore_getNextNotification_pargs args; + ThriftHiveMetastore_get_next_notification_pargs args; args.rqst = &rqst; args.write(oprot_); @@ -34928,7 +34928,7 @@ void ThriftHiveMetastoreClient::send_get oprot_->getTransport()->flush(); } -void ThriftHiveMetastoreClient::recv_getNextNotification(NotificationEventResponse& _return) +void ThriftHiveMetastoreClient::recv_get_next_notification(NotificationEventResponse& _return) { int32_t rseqid = 0; @@ -34948,12 +34948,12 @@ void ThriftHiveMetastoreClient::recv_get iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getNextNotification") != 0) { + if (fname.compare("get_next_notification") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - ThriftHiveMetastore_getNextNotification_presult result; + ThriftHiveMetastore_get_next_notification_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -34963,21 +34963,21 @@ void ThriftHiveMetastoreClient::recv_get // _return pointer has now been filled return; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getNextNotification failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "get_next_notification failed: unknown result"); } -void ThriftHiveMetastoreClient::getCurrentNotificationEventId(CurrentNotificationEventId& _return) +void ThriftHiveMetastoreClient::get_current_notificationEventId(CurrentNotificationEventId& _return) { - send_getCurrentNotificationEventId(); - recv_getCurrentNotificationEventId(_return); + send_get_current_notificationEventId(); + recv_get_current_notificationEventId(_return); } -void ThriftHiveMetastoreClient::send_getCurrentNotificationEventId() +void ThriftHiveMetastoreClient::send_get_current_notificationEventId() { int32_t cseqid = 0; - oprot_->writeMessageBegin("getCurrentNotificationEventId", ::apache::thrift::protocol::T_CALL, cseqid); + oprot_->writeMessageBegin("get_current_notificationEventId", ::apache::thrift::protocol::T_CALL, cseqid); - ThriftHiveMetastore_getCurrentNotificationEventId_pargs args; + ThriftHiveMetastore_get_current_notificationEventId_pargs args; args.write(oprot_); oprot_->writeMessageEnd(); @@ -34985,7 +34985,7 @@ void ThriftHiveMetastoreClient::send_get oprot_->getTransport()->flush(); } -void ThriftHiveMetastoreClient::recv_getCurrentNotificationEventId(CurrentNotificationEventId& _return) +void ThriftHiveMetastoreClient::recv_get_current_notificationEventId(CurrentNotificationEventId& _return) { int32_t rseqid = 0; @@ -35005,12 +35005,12 @@ void ThriftHiveMetastoreClient::recv_get iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - if (fname.compare("getCurrentNotificationEventId") != 0) { + if (fname.compare("get_current_notificationEventId") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } - ThriftHiveMetastore_getCurrentNotificationEventId_presult result; + ThriftHiveMetastore_get_current_notificationEventId_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); @@ -35020,7 +35020,7 @@ void ThriftHiveMetastoreClient::recv_get // _return pointer has now been filled return; } - throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getCurrentNotificationEventId failed: unknown result"); + throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); } bool ThriftHiveMetastoreProcessor::dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext) { @@ -42033,38 +42033,38 @@ void ThriftHiveMetastoreProcessor::proce } } -void ThriftHiveMetastoreProcessor::process_getNextNotification(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) +void ThriftHiveMetastoreProcessor::process_get_next_notification(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { - ctx = this->eventHandler_->getContext("ThriftHiveMetastore.getNextNotification", callContext); + ctx = this->eventHandler_->getContext("ThriftHiveMetastore.get_next_notification", callContext); } - ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHiveMetastore.getNextNotification"); + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHiveMetastore.get_next_notification"); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preRead(ctx, "ThriftHiveMetastore.getNextNotification"); + this->eventHandler_->preRead(ctx, "ThriftHiveMetastore.get_next_notification"); } - ThriftHiveMetastore_getNextNotification_args args; + ThriftHiveMetastore_get_next_notification_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postRead(ctx, "ThriftHiveMetastore.getNextNotification", bytes); + this->eventHandler_->postRead(ctx, "ThriftHiveMetastore.get_next_notification", bytes); } - ThriftHiveMetastore_getNextNotification_result result; + ThriftHiveMetastore_get_next_notification_result result; try { - iface_->getNextNotification(result.success, args.rqst); + iface_->get_next_notification(result.success, args.rqst); result.__isset.success = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { - this->eventHandler_->handlerError(ctx, "ThriftHiveMetastore.getNextNotification"); + this->eventHandler_->handlerError(ctx, "ThriftHiveMetastore.get_next_notification"); } ::apache::thrift::TApplicationException x(e.what()); - oprot->writeMessageBegin("getNextNotification", ::apache::thrift::protocol::T_EXCEPTION, seqid); + oprot->writeMessageBegin("get_next_notification", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); @@ -42073,52 +42073,52 @@ void ThriftHiveMetastoreProcessor::proce } if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preWrite(ctx, "ThriftHiveMetastore.getNextNotification"); + this->eventHandler_->preWrite(ctx, "ThriftHiveMetastore.get_next_notification"); } - oprot->writeMessageBegin("getNextNotification", ::apache::thrift::protocol::T_REPLY, seqid); + oprot->writeMessageBegin("get_next_notification", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postWrite(ctx, "ThriftHiveMetastore.getNextNotification", bytes); + this->eventHandler_->postWrite(ctx, "ThriftHiveMetastore.get_next_notification", bytes); } } -void ThriftHiveMetastoreProcessor::process_getCurrentNotificationEventId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) +void ThriftHiveMetastoreProcessor::process_get_current_notificationEventId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { - ctx = this->eventHandler_->getContext("ThriftHiveMetastore.getCurrentNotificationEventId", callContext); + ctx = this->eventHandler_->getContext("ThriftHiveMetastore.get_current_notificationEventId", callContext); } - ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHiveMetastore.getCurrentNotificationEventId"); + ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "ThriftHiveMetastore.get_current_notificationEventId"); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preRead(ctx, "ThriftHiveMetastore.getCurrentNotificationEventId"); + this->eventHandler_->preRead(ctx, "ThriftHiveMetastore.get_current_notificationEventId"); } - ThriftHiveMetastore_getCurrentNotificationEventId_args args; + ThriftHiveMetastore_get_current_notificationEventId_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postRead(ctx, "ThriftHiveMetastore.getCurrentNotificationEventId", bytes); + this->eventHandler_->postRead(ctx, "ThriftHiveMetastore.get_current_notificationEventId", bytes); } - ThriftHiveMetastore_getCurrentNotificationEventId_result result; + ThriftHiveMetastore_get_current_notificationEventId_result result; try { - iface_->getCurrentNotificationEventId(result.success); + iface_->get_current_notificationEventId(result.success); result.__isset.success = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { - this->eventHandler_->handlerError(ctx, "ThriftHiveMetastore.getCurrentNotificationEventId"); + this->eventHandler_->handlerError(ctx, "ThriftHiveMetastore.get_current_notificationEventId"); } ::apache::thrift::TApplicationException x(e.what()); - oprot->writeMessageBegin("getCurrentNotificationEventId", ::apache::thrift::protocol::T_EXCEPTION, seqid); + oprot->writeMessageBegin("get_current_notificationEventId", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); @@ -42127,17 +42127,17 @@ void ThriftHiveMetastoreProcessor::proce } if (this->eventHandler_.get() != NULL) { - this->eventHandler_->preWrite(ctx, "ThriftHiveMetastore.getCurrentNotificationEventId"); + this->eventHandler_->preWrite(ctx, "ThriftHiveMetastore.get_current_notificationEventId"); } - oprot->writeMessageBegin("getCurrentNotificationEventId", ::apache::thrift::protocol::T_REPLY, seqid); + oprot->writeMessageBegin("get_current_notificationEventId", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { - this->eventHandler_->postWrite(ctx, "ThriftHiveMetastore.getCurrentNotificationEventId", bytes); + this->eventHandler_->postWrite(ctx, "ThriftHiveMetastore.get_current_notificationEventId", bytes); } } Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h (original) +++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h Fri Jan 9 22:09:50 2015 @@ -133,8 +133,8 @@ class ThriftHiveMetastoreIf : virtual pu virtual void heartbeat_txn_range(HeartbeatTxnRangeResponse& _return, const HeartbeatTxnRangeRequest& txns) = 0; virtual void compact(const CompactionRequest& rqst) = 0; virtual void show_compact(ShowCompactResponse& _return, const ShowCompactRequest& rqst) = 0; - virtual void getNextNotification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) = 0; - virtual void getCurrentNotificationEventId(CurrentNotificationEventId& _return) = 0; + virtual void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) = 0; + virtual void get_current_notificationEventId(CurrentNotificationEventId& _return) = 0; }; class ThriftHiveMetastoreIfFactory : virtual public ::facebook::fb303::FacebookServiceIfFactory { @@ -538,10 +538,10 @@ class ThriftHiveMetastoreNull : virtual void show_compact(ShowCompactResponse& /* _return */, const ShowCompactRequest& /* rqst */) { return; } - void getNextNotification(NotificationEventResponse& /* _return */, const NotificationEventRequest& /* rqst */) { + void get_next_notification(NotificationEventResponse& /* _return */, const NotificationEventRequest& /* rqst */) { return; } - void getCurrentNotificationEventId(CurrentNotificationEventId& /* _return */) { + void get_current_notificationEventId(CurrentNotificationEventId& /* _return */) { return; } }; @@ -16575,38 +16575,38 @@ class ThriftHiveMetastore_show_compact_p }; -typedef struct _ThriftHiveMetastore_getNextNotification_args__isset { - _ThriftHiveMetastore_getNextNotification_args__isset() : rqst(false) {} +typedef struct _ThriftHiveMetastore_get_next_notification_args__isset { + _ThriftHiveMetastore_get_next_notification_args__isset() : rqst(false) {} bool rqst; -} _ThriftHiveMetastore_getNextNotification_args__isset; +} _ThriftHiveMetastore_get_next_notification_args__isset; -class ThriftHiveMetastore_getNextNotification_args { +class ThriftHiveMetastore_get_next_notification_args { public: - ThriftHiveMetastore_getNextNotification_args() { + ThriftHiveMetastore_get_next_notification_args() { } - virtual ~ThriftHiveMetastore_getNextNotification_args() throw() {} + virtual ~ThriftHiveMetastore_get_next_notification_args() throw() {} NotificationEventRequest rqst; - _ThriftHiveMetastore_getNextNotification_args__isset __isset; + _ThriftHiveMetastore_get_next_notification_args__isset __isset; void __set_rqst(const NotificationEventRequest& val) { rqst = val; } - bool operator == (const ThriftHiveMetastore_getNextNotification_args & rhs) const + bool operator == (const ThriftHiveMetastore_get_next_notification_args & rhs) const { if (!(rqst == rhs.rqst)) return false; return true; } - bool operator != (const ThriftHiveMetastore_getNextNotification_args &rhs) const { + bool operator != (const ThriftHiveMetastore_get_next_notification_args &rhs) const { return !(*this == rhs); } - bool operator < (const ThriftHiveMetastore_getNextNotification_args & ) const; + bool operator < (const ThriftHiveMetastore_get_next_notification_args & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; @@ -16614,11 +16614,11 @@ class ThriftHiveMetastore_getNextNotific }; -class ThriftHiveMetastore_getNextNotification_pargs { +class ThriftHiveMetastore_get_next_notification_pargs { public: - virtual ~ThriftHiveMetastore_getNextNotification_pargs() throw() {} + virtual ~ThriftHiveMetastore_get_next_notification_pargs() throw() {} const NotificationEventRequest* rqst; @@ -16626,82 +16626,82 @@ class ThriftHiveMetastore_getNextNotific }; -typedef struct _ThriftHiveMetastore_getNextNotification_result__isset { - _ThriftHiveMetastore_getNextNotification_result__isset() : success(false) {} +typedef struct _ThriftHiveMetastore_get_next_notification_result__isset { + _ThriftHiveMetastore_get_next_notification_result__isset() : success(false) {} bool success; -} _ThriftHiveMetastore_getNextNotification_result__isset; +} _ThriftHiveMetastore_get_next_notification_result__isset; -class ThriftHiveMetastore_getNextNotification_result { +class ThriftHiveMetastore_get_next_notification_result { public: - ThriftHiveMetastore_getNextNotification_result() { + ThriftHiveMetastore_get_next_notification_result() { } - virtual ~ThriftHiveMetastore_getNextNotification_result() throw() {} + virtual ~ThriftHiveMetastore_get_next_notification_result() throw() {} NotificationEventResponse success; - _ThriftHiveMetastore_getNextNotification_result__isset __isset; + _ThriftHiveMetastore_get_next_notification_result__isset __isset; void __set_success(const NotificationEventResponse& val) { success = val; } - bool operator == (const ThriftHiveMetastore_getNextNotification_result & rhs) const + bool operator == (const ThriftHiveMetastore_get_next_notification_result & rhs) const { if (!(success == rhs.success)) return false; return true; } - bool operator != (const ThriftHiveMetastore_getNextNotification_result &rhs) const { + bool operator != (const ThriftHiveMetastore_get_next_notification_result &rhs) const { return !(*this == rhs); } - bool operator < (const ThriftHiveMetastore_getNextNotification_result & ) const; + bool operator < (const ThriftHiveMetastore_get_next_notification_result & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _ThriftHiveMetastore_getNextNotification_presult__isset { - _ThriftHiveMetastore_getNextNotification_presult__isset() : success(false) {} +typedef struct _ThriftHiveMetastore_get_next_notification_presult__isset { + _ThriftHiveMetastore_get_next_notification_presult__isset() : success(false) {} bool success; -} _ThriftHiveMetastore_getNextNotification_presult__isset; +} _ThriftHiveMetastore_get_next_notification_presult__isset; -class ThriftHiveMetastore_getNextNotification_presult { +class ThriftHiveMetastore_get_next_notification_presult { public: - virtual ~ThriftHiveMetastore_getNextNotification_presult() throw() {} + virtual ~ThriftHiveMetastore_get_next_notification_presult() throw() {} NotificationEventResponse* success; - _ThriftHiveMetastore_getNextNotification_presult__isset __isset; + _ThriftHiveMetastore_get_next_notification_presult__isset __isset; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); }; -class ThriftHiveMetastore_getCurrentNotificationEventId_args { +class ThriftHiveMetastore_get_current_notificationEventId_args { public: - ThriftHiveMetastore_getCurrentNotificationEventId_args() { + ThriftHiveMetastore_get_current_notificationEventId_args() { } - virtual ~ThriftHiveMetastore_getCurrentNotificationEventId_args() throw() {} + virtual ~ThriftHiveMetastore_get_current_notificationEventId_args() throw() {} - bool operator == (const ThriftHiveMetastore_getCurrentNotificationEventId_args & /* rhs */) const + bool operator == (const ThriftHiveMetastore_get_current_notificationEventId_args & /* rhs */) const { return true; } - bool operator != (const ThriftHiveMetastore_getCurrentNotificationEventId_args &rhs) const { + bool operator != (const ThriftHiveMetastore_get_current_notificationEventId_args &rhs) const { return !(*this == rhs); } - bool operator < (const ThriftHiveMetastore_getCurrentNotificationEventId_args & ) const; + bool operator < (const ThriftHiveMetastore_get_current_notificationEventId_args & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; @@ -16709,69 +16709,69 @@ class ThriftHiveMetastore_getCurrentNoti }; -class ThriftHiveMetastore_getCurrentNotificationEventId_pargs { +class ThriftHiveMetastore_get_current_notificationEventId_pargs { public: - virtual ~ThriftHiveMetastore_getCurrentNotificationEventId_pargs() throw() {} + virtual ~ThriftHiveMetastore_get_current_notificationEventId_pargs() throw() {} uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _ThriftHiveMetastore_getCurrentNotificationEventId_result__isset { - _ThriftHiveMetastore_getCurrentNotificationEventId_result__isset() : success(false) {} +typedef struct _ThriftHiveMetastore_get_current_notificationEventId_result__isset { + _ThriftHiveMetastore_get_current_notificationEventId_result__isset() : success(false) {} bool success; -} _ThriftHiveMetastore_getCurrentNotificationEventId_result__isset; +} _ThriftHiveMetastore_get_current_notificationEventId_result__isset; -class ThriftHiveMetastore_getCurrentNotificationEventId_result { +class ThriftHiveMetastore_get_current_notificationEventId_result { public: - ThriftHiveMetastore_getCurrentNotificationEventId_result() { + ThriftHiveMetastore_get_current_notificationEventId_result() { } - virtual ~ThriftHiveMetastore_getCurrentNotificationEventId_result() throw() {} + virtual ~ThriftHiveMetastore_get_current_notificationEventId_result() throw() {} CurrentNotificationEventId success; - _ThriftHiveMetastore_getCurrentNotificationEventId_result__isset __isset; + _ThriftHiveMetastore_get_current_notificationEventId_result__isset __isset; void __set_success(const CurrentNotificationEventId& val) { success = val; } - bool operator == (const ThriftHiveMetastore_getCurrentNotificationEventId_result & rhs) const + bool operator == (const ThriftHiveMetastore_get_current_notificationEventId_result & rhs) const { if (!(success == rhs.success)) return false; return true; } - bool operator != (const ThriftHiveMetastore_getCurrentNotificationEventId_result &rhs) const { + bool operator != (const ThriftHiveMetastore_get_current_notificationEventId_result &rhs) const { return !(*this == rhs); } - bool operator < (const ThriftHiveMetastore_getCurrentNotificationEventId_result & ) const; + bool operator < (const ThriftHiveMetastore_get_current_notificationEventId_result & ) const; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; }; -typedef struct _ThriftHiveMetastore_getCurrentNotificationEventId_presult__isset { - _ThriftHiveMetastore_getCurrentNotificationEventId_presult__isset() : success(false) {} +typedef struct _ThriftHiveMetastore_get_current_notificationEventId_presult__isset { + _ThriftHiveMetastore_get_current_notificationEventId_presult__isset() : success(false) {} bool success; -} _ThriftHiveMetastore_getCurrentNotificationEventId_presult__isset; +} _ThriftHiveMetastore_get_current_notificationEventId_presult__isset; -class ThriftHiveMetastore_getCurrentNotificationEventId_presult { +class ThriftHiveMetastore_get_current_notificationEventId_presult { public: - virtual ~ThriftHiveMetastore_getCurrentNotificationEventId_presult() throw() {} + virtual ~ThriftHiveMetastore_get_current_notificationEventId_presult() throw() {} CurrentNotificationEventId* success; - _ThriftHiveMetastore_getCurrentNotificationEventId_presult__isset __isset; + _ThriftHiveMetastore_get_current_notificationEventId_presult__isset __isset; uint32_t read(::apache::thrift::protocol::TProtocol* iprot); @@ -17140,12 +17140,12 @@ class ThriftHiveMetastoreClient : virtua void show_compact(ShowCompactResponse& _return, const ShowCompactRequest& rqst); void send_show_compact(const ShowCompactRequest& rqst); void recv_show_compact(ShowCompactResponse& _return); - void getNextNotification(NotificationEventResponse& _return, const NotificationEventRequest& rqst); - void send_getNextNotification(const NotificationEventRequest& rqst); - void recv_getNextNotification(NotificationEventResponse& _return); - void getCurrentNotificationEventId(CurrentNotificationEventId& _return); - void send_getCurrentNotificationEventId(); - void recv_getCurrentNotificationEventId(CurrentNotificationEventId& _return); + void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst); + void send_get_next_notification(const NotificationEventRequest& rqst); + void recv_get_next_notification(NotificationEventResponse& _return); + void get_current_notificationEventId(CurrentNotificationEventId& _return); + void send_get_current_notificationEventId(); + void recv_get_current_notificationEventId(CurrentNotificationEventId& _return); }; class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceProcessor { @@ -17273,8 +17273,8 @@ class ThriftHiveMetastoreProcessor : pub void process_heartbeat_txn_range(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_compact(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); void process_show_compact(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_getNextNotification(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); - void process_getCurrentNotificationEventId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_get_next_notification(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); + void process_get_current_notificationEventId(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext); public: ThriftHiveMetastoreProcessor(boost::shared_ptr<ThriftHiveMetastoreIf> iface) : ::facebook::fb303::FacebookServiceProcessor(iface), @@ -17396,8 +17396,8 @@ class ThriftHiveMetastoreProcessor : pub processMap_["heartbeat_txn_range"] = &ThriftHiveMetastoreProcessor::process_heartbeat_txn_range; processMap_["compact"] = &ThriftHiveMetastoreProcessor::process_compact; processMap_["show_compact"] = &ThriftHiveMetastoreProcessor::process_show_compact; - processMap_["getNextNotification"] = &ThriftHiveMetastoreProcessor::process_getNextNotification; - processMap_["getCurrentNotificationEventId"] = &ThriftHiveMetastoreProcessor::process_getCurrentNotificationEventId; + processMap_["get_next_notification"] = &ThriftHiveMetastoreProcessor::process_get_next_notification; + processMap_["get_current_notificationEventId"] = &ThriftHiveMetastoreProcessor::process_get_current_notificationEventId; } virtual ~ThriftHiveMetastoreProcessor() {} @@ -18552,23 +18552,23 @@ class ThriftHiveMetastoreMultiface : vir return; } - void getNextNotification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) { + void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->getNextNotification(_return, rqst); + ifaces_[i]->get_next_notification(_return, rqst); } - ifaces_[i]->getNextNotification(_return, rqst); + ifaces_[i]->get_next_notification(_return, rqst); return; } - void getCurrentNotificationEventId(CurrentNotificationEventId& _return) { + void get_current_notificationEventId(CurrentNotificationEventId& _return) { size_t sz = ifaces_.size(); size_t i = 0; for (; i < (sz - 1); ++i) { - ifaces_[i]->getCurrentNotificationEventId(_return); + ifaces_[i]->get_current_notificationEventId(_return); } - ifaces_[i]->getCurrentNotificationEventId(_return); + ifaces_[i]->get_current_notificationEventId(_return); return; } Modified: hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp?rev=1650682&r1=1650681&r2=1650682&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp (original) +++ hive/trunk/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp Fri Jan 9 22:09:50 2015 @@ -607,14 +607,14 @@ class ThriftHiveMetastoreHandler : virtu printf("show_compact\n"); } - void getNextNotification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) { + void get_next_notification(NotificationEventResponse& _return, const NotificationEventRequest& rqst) { // Your implementation goes here - printf("getNextNotification\n"); + printf("get_next_notification\n"); } - void getCurrentNotificationEventId(CurrentNotificationEventId& _return) { + void get_current_notificationEventId(CurrentNotificationEventId& _return) { // Your implementation goes here - printf("getCurrentNotificationEventId\n"); + printf("get_current_notificationEventId\n"); } };