hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From khorg...@apache.org
Subject svn commit: r1650682 [1/2] - in /hive/trunk/metastore: if/ scripts/upgrade/derby/ scripts/upgrade/mssql/ scripts/upgrade/mysql/ scripts/upgrade/oracle/ scripts/upgrade/postgres/ src/gen/thrift/gen-cpp/ src/gen/thrift/gen-javabean/org/apache/hadoop/hive...
Date Fri, 09 Jan 2015 22:09:51 GMT
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");
   }
 
 };



Mime
View raw message