You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kh...@apache.org on 2015/01/09 23:09:51 UTC
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...
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");
}
};