diff --git metastore/if/hive_metastore.thrift metastore/if/hive_metastore.thrift index 820c49d..8c50bf8 100755 --- metastore/if/hive_metastore.thrift +++ metastore/if/hive_metastore.thrift @@ -1132,8 +1132,8 @@ service ThriftHiveMetastore extends fb303.FacebookService 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, diff --git metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql new file mode 100644 index 0000000..2f83da2 --- /dev/null +++ metastore/scripts/upgrade/derby/020-HIVE-9296.derby.sql @@ -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"); diff --git metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql index a239f32..3f76066 100644 --- metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql +++ metastore/scripts/upgrade/derby/hive-schema-0.15.0.derby.sql @@ -104,6 +104,10 @@ CREATE TABLE "APP"."FUNCS" ("FUNC_ID" BIGINT NOT NULL, "CLASS_NAME" VARCHAR(4000 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 "FUNCS_PK" PRIMARY KEY ("FUNC_ID"); 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; diff --git metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql index cce9133..a5c0dc9 100644 --- metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql +++ metastore/scripts/upgrade/derby/upgrade-0.14.0-to-0.15.0.derby.sql @@ -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; diff --git metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql new file mode 100644 index 0000000..502123f --- /dev/null +++ metastore/scripts/upgrade/mssql/005-HIVE-9296.mssql.sql @@ -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 + + diff --git metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql index 62cc962..3530c46 100644 --- metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql +++ metastore/scripts/upgrade/mssql/hive-schema-0.15.0.mssql.sql @@ -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] diff --git metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql index 81a27d0..36a5210 100644 --- metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql +++ metastore/scripts/upgrade/mssql/upgrade-0.14.0-to-0.15.0.mssql.sql @@ -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; diff --git metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql new file mode 100644 index 0000000..9c0e683 --- /dev/null +++ metastore/scripts/upgrade/mysql/020-HIVE-9296.mysql.sql @@ -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; diff --git metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql index a811bb6..43b08bb 100644 --- metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql +++ metastore/scripts/upgrade/mysql/hive-schema-0.15.0.mysql.sql @@ -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 diff --git metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql index 7484b83..1535e8a 100644 --- metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql +++ metastore/scripts/upgrade/mysql/upgrade-0.14.0-to-0.15.0.mysql.sql @@ -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 ' '; diff --git metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql new file mode 100644 index 0000000..5cd9002 --- /dev/null +++ metastore/scripts/upgrade/oracle/021-HIVE-9296.oracle.sql @@ -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 +); diff --git metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql index ec468bb..4d3c644 100644 --- metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql +++ metastore/scripts/upgrade/oracle/hive-schema-0.15.0.oracle.sql @@ -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 ; diff --git metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql index 54b0766..4b7f2f8 100644 --- metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql +++ metastore/scripts/upgrade/oracle/upgrade-0.14.0-to-0.15.0.oracle.sql @@ -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; diff --git metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql new file mode 100644 index 0000000..83b23f4 --- /dev/null +++ metastore/scripts/upgrade/postgres/020-HIVE-9296.postgres.sql @@ -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") +); diff --git metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql index dd4fe12..148f917 100644 --- metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql +++ metastore/scripts/upgrade/postgres/hive-schema-0.15.0.postgres.sql @@ -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: -- diff --git metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql index ded09cd..2cb5895 100644 --- metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql +++ metastore/scripts/upgrade/postgres/upgrade-0.14.0-to-0.15.0.postgres.sql @@ -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'; diff --git metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp index b1ffb7c..4c0efc6 100644 --- metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp +++ metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp @@ -27094,7 +27094,7 @@ uint32_t ThriftHiveMetastore_show_compact_presult::read(::apache::thrift::protoc 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_getNextNotification_args::read(::apache::thrift::pr 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_getNextNotification_args::write(::apache::thrift::p 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_getNextNotification_pargs::write(::apache::thrift:: 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_getNextNotification_result::read(::apache::thrift:: 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_getNextNotification_result::write(::apache::thrift: 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_getNextNotification_presult::read(::apache::thrift: 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_getCurrentNotificationEventId_args::read(::apache:: 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_getCurrentNotificationEventId_result::read(::apache 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_getCurrentNotificationEventId_result::write(::apach 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_show_compact(ShowCompactResponse& _return) 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_getNextNotification(const NotificationEvent 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_getNextNotification(NotificationEventRespon 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_getNextNotification(NotificationEventRespon // _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_getCurrentNotificationEventId() 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_getCurrentNotificationEventId(CurrentNotifi 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_getCurrentNotificationEventId(CurrentNotifi // _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::process_show_compact(int32_t seqid, ::apache: } } -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::process_getNextNotification(int32_t seqid, :: } 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::process_getCurrentNotificationEventId(int32_t } 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); } } diff --git metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h index adfaccf..488c746 100644 --- metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h +++ metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h @@ -133,8 +133,8 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService 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 public ThriftHiveMetastoreIf , virtual p 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_presult { }; -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_getNextNotification_args { }; -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_getNextNotification_pargs { }; -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_getCurrentNotificationEventId_args { }; -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 : virtual public ThriftHiveMetastoreIf, public 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 : public ::facebook::fb303::FacebookServiceP 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 iface) : ::facebook::fb303::FacebookServiceProcessor(iface), @@ -17396,8 +17396,8 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP 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 : virtual public ThriftHiveMetastoreIf, publi 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; } diff --git metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp index fa77140..e2d41c1 100644 --- metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp +++ metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp @@ -607,14 +607,14 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf { 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"); } }; diff --git metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java index e129ea4..a72061e 100644 --- metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java +++ metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java @@ -272,9 +272,9 @@ public ShowCompactResponse show_compact(ShowCompactRequest rqst) throws org.apache.thrift.TException; - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException; + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException; - public CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException; + public CurrentNotificationEventId get_current_notificationEventId() throws org.apache.thrift.TException; } @@ -514,9 +514,9 @@ public void show_compact(ShowCompactRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getNextNotification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void get_next_notification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getCurrentNotificationEventId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void get_current_notificationEventId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; } @@ -4008,49 +4008,49 @@ public ShowCompactResponse recv_show_compact() throws org.apache.thrift.TExcepti throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); } - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException { - send_getNextNotification(rqst); - return recv_getNextNotification(); + send_get_next_notification(rqst); + return recv_get_next_notification(); } - public void send_getNextNotification(NotificationEventRequest rqst) throws org.apache.thrift.TException + public void send_get_next_notification(NotificationEventRequest rqst) throws org.apache.thrift.TException { - getNextNotification_args args = new getNextNotification_args(); + get_next_notification_args args = new get_next_notification_args(); args.setRqst(rqst); - sendBase("getNextNotification", args); + sendBase("get_next_notification", args); } - public NotificationEventResponse recv_getNextNotification() throws org.apache.thrift.TException + public NotificationEventResponse recv_get_next_notification() throws org.apache.thrift.TException { - getNextNotification_result result = new getNextNotification_result(); - receiveBase(result, "getNextNotification"); + get_next_notification_result result = new get_next_notification_result(); + receiveBase(result, "get_next_notification"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNextNotification failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); } - public CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException + public CurrentNotificationEventId get_current_notificationEventId() throws org.apache.thrift.TException { - send_getCurrentNotificationEventId(); - return recv_getCurrentNotificationEventId(); + send_get_current_notificationEventId(); + return recv_get_current_notificationEventId(); } - public void send_getCurrentNotificationEventId() throws org.apache.thrift.TException + public void send_get_current_notificationEventId() throws org.apache.thrift.TException { - getCurrentNotificationEventId_args args = new getCurrentNotificationEventId_args(); - sendBase("getCurrentNotificationEventId", args); + get_current_notificationEventId_args args = new get_current_notificationEventId_args(); + sendBase("get_current_notificationEventId", args); } - public CurrentNotificationEventId recv_getCurrentNotificationEventId() throws org.apache.thrift.TException + public CurrentNotificationEventId recv_get_current_notificationEventId() throws org.apache.thrift.TException { - getCurrentNotificationEventId_result result = new getCurrentNotificationEventId_result(); - receiveBase(result, "getCurrentNotificationEventId"); + get_current_notificationEventId_result result = new get_current_notificationEventId_result(); + receiveBase(result, "get_current_notificationEventId"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getCurrentNotificationEventId failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); } } @@ -8256,23 +8256,23 @@ public ShowCompactResponse getResult() throws org.apache.thrift.TException { } } - public void getNextNotification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void get_next_notification(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getNextNotification_call method_call = new getNextNotification_call(rqst, resultHandler, this, ___protocolFactory, ___transport); + get_next_notification_call method_call = new get_next_notification_call(rqst, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } - public static class getNextNotification_call extends org.apache.thrift.async.TAsyncMethodCall { + public static class get_next_notification_call extends org.apache.thrift.async.TAsyncMethodCall { private NotificationEventRequest rqst; - public getNextNotification_call(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public get_next_notification_call(NotificationEventRequest rqst, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.rqst = rqst; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getNextNotification", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getNextNotification_args args = new getNextNotification_args(); + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_next_notification", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_next_notification_args args = new get_next_notification_args(); args.setRqst(rqst); args.write(prot); prot.writeMessageEnd(); @@ -8284,25 +8284,25 @@ public NotificationEventResponse getResult() throws org.apache.thrift.TException } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getNextNotification(); + return (new Client(prot)).recv_get_next_notification(); } } - public void getCurrentNotificationEventId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void get_current_notificationEventId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getCurrentNotificationEventId_call method_call = new getCurrentNotificationEventId_call(resultHandler, this, ___protocolFactory, ___transport); + get_current_notificationEventId_call method_call = new get_current_notificationEventId_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } - public static class getCurrentNotificationEventId_call extends org.apache.thrift.async.TAsyncMethodCall { - public getCurrentNotificationEventId_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public static class get_current_notificationEventId_call extends org.apache.thrift.async.TAsyncMethodCall { + public get_current_notificationEventId_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getCurrentNotificationEventId", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getCurrentNotificationEventId_args args = new getCurrentNotificationEventId_args(); + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_current_notificationEventId", org.apache.thrift.protocol.TMessageType.CALL, 0)); + get_current_notificationEventId_args args = new get_current_notificationEventId_args(); args.write(prot); prot.writeMessageEnd(); } @@ -8313,7 +8313,7 @@ public CurrentNotificationEventId getResult() throws org.apache.thrift.TExceptio } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_getCurrentNotificationEventId(); + return (new Client(prot)).recv_get_current_notificationEventId(); } } @@ -8447,8 +8447,8 @@ protected Processor(I iface, Map extends org.apache.thrift.ProcessFunction { - public getNextNotification() { - super("getNextNotification"); + public static class get_next_notification extends org.apache.thrift.ProcessFunction { + public get_next_notification() { + super("get_next_notification"); } - public getNextNotification_args getEmptyArgsInstance() { - return new getNextNotification_args(); + public get_next_notification_args getEmptyArgsInstance() { + return new get_next_notification_args(); } protected boolean isOneway() { return false; } - public getNextNotification_result getResult(I iface, getNextNotification_args args) throws org.apache.thrift.TException { - getNextNotification_result result = new getNextNotification_result(); - result.success = iface.getNextNotification(args.rqst); + public get_next_notification_result getResult(I iface, get_next_notification_args args) throws org.apache.thrift.TException { + get_next_notification_result result = new get_next_notification_result(); + result.success = iface.get_next_notification(args.rqst); return result; } } - public static class getCurrentNotificationEventId extends org.apache.thrift.ProcessFunction { - public getCurrentNotificationEventId() { - super("getCurrentNotificationEventId"); + public static class get_current_notificationEventId extends org.apache.thrift.ProcessFunction { + public get_current_notificationEventId() { + super("get_current_notificationEventId"); } - public getCurrentNotificationEventId_args getEmptyArgsInstance() { - return new getCurrentNotificationEventId_args(); + public get_current_notificationEventId_args getEmptyArgsInstance() { + return new get_current_notificationEventId_args(); } protected boolean isOneway() { return false; } - public getCurrentNotificationEventId_result getResult(I iface, getCurrentNotificationEventId_args args) throws org.apache.thrift.TException { - getCurrentNotificationEventId_result result = new getCurrentNotificationEventId_result(); - result.success = iface.getCurrentNotificationEventId(); + public get_current_notificationEventId_result getResult(I iface, get_current_notificationEventId_args args) throws org.apache.thrift.TException { + get_current_notificationEventId_result result = new get_current_notificationEventId_result(); + result.success = iface.get_current_notificationEventId(); return result; } } @@ -136197,15 +136197,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, show_compact_result } - public static class getNextNotification_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getNextNotification_args"); + public static class get_next_notification_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_next_notification_args"); private static final org.apache.thrift.protocol.TField RQST_FIELD_DESC = new org.apache.thrift.protocol.TField("rqst", org.apache.thrift.protocol.TType.STRUCT, (short)1); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getNextNotification_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getNextNotification_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_next_notification_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_next_notification_argsTupleSchemeFactory()); } private NotificationEventRequest rqst; // required @@ -136275,13 +136275,13 @@ public String getFieldName() { tmpMap.put(_Fields.RQST, new org.apache.thrift.meta_data.FieldMetaData("rqst", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NotificationEventRequest.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNextNotification_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_next_notification_args.class, metaDataMap); } - public getNextNotification_args() { + public get_next_notification_args() { } - public getNextNotification_args( + public get_next_notification_args( NotificationEventRequest rqst) { this(); @@ -136291,14 +136291,14 @@ public getNextNotification_args( /** * Performs a deep copy on other. */ - public getNextNotification_args(getNextNotification_args other) { + public get_next_notification_args(get_next_notification_args other) { if (other.isSetRqst()) { this.rqst = new NotificationEventRequest(other.rqst); } } - public getNextNotification_args deepCopy() { - return new getNextNotification_args(this); + public get_next_notification_args deepCopy() { + return new get_next_notification_args(this); } @Override @@ -136368,12 +136368,12 @@ public boolean isSet(_Fields field) { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getNextNotification_args) - return this.equals((getNextNotification_args)that); + if (that instanceof get_next_notification_args) + return this.equals((get_next_notification_args)that); return false; } - public boolean equals(getNextNotification_args that) { + public boolean equals(get_next_notification_args that) { if (that == null) return false; @@ -136401,13 +136401,13 @@ public int hashCode() { return builder.toHashCode(); } - public int compareTo(getNextNotification_args other) { + public int compareTo(get_next_notification_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getNextNotification_args typedOther = (getNextNotification_args)other; + get_next_notification_args typedOther = (get_next_notification_args)other; lastComparison = Boolean.valueOf(isSetRqst()).compareTo(typedOther.isSetRqst()); if (lastComparison != 0) { @@ -136436,7 +136436,7 @@ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache. @Override public String toString() { - StringBuilder sb = new StringBuilder("getNextNotification_args("); + StringBuilder sb = new StringBuilder("get_next_notification_args("); boolean first = true; sb.append("rqst:"); @@ -136474,15 +136474,15 @@ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException } } - private static class getNextNotification_argsStandardSchemeFactory implements SchemeFactory { - public getNextNotification_argsStandardScheme getScheme() { - return new getNextNotification_argsStandardScheme(); + private static class get_next_notification_argsStandardSchemeFactory implements SchemeFactory { + public get_next_notification_argsStandardScheme getScheme() { + return new get_next_notification_argsStandardScheme(); } } - private static class getNextNotification_argsStandardScheme extends StandardScheme { + private static class get_next_notification_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_next_notification_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -136510,7 +136510,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_next_notification_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -136525,16 +136525,16 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotificatio } - private static class getNextNotification_argsTupleSchemeFactory implements SchemeFactory { - public getNextNotification_argsTupleScheme getScheme() { - return new getNextNotification_argsTupleScheme(); + private static class get_next_notification_argsTupleSchemeFactory implements SchemeFactory { + public get_next_notification_argsTupleScheme getScheme() { + return new get_next_notification_argsTupleScheme(); } } - private static class getNextNotification_argsTupleScheme extends TupleScheme { + private static class get_next_notification_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_next_notification_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetRqst()) { @@ -136547,7 +136547,7 @@ public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_next_notification_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { @@ -136560,15 +136560,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_ } - public static class getNextNotification_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getNextNotification_result"); + public static class get_next_notification_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_next_notification_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getNextNotification_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getNextNotification_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_next_notification_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_next_notification_resultTupleSchemeFactory()); } private NotificationEventResponse success; // required @@ -136638,13 +136638,13 @@ public String getFieldName() { tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NotificationEventResponse.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getNextNotification_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_next_notification_result.class, metaDataMap); } - public getNextNotification_result() { + public get_next_notification_result() { } - public getNextNotification_result( + public get_next_notification_result( NotificationEventResponse success) { this(); @@ -136654,14 +136654,14 @@ public getNextNotification_result( /** * Performs a deep copy on other. */ - public getNextNotification_result(getNextNotification_result other) { + public get_next_notification_result(get_next_notification_result other) { if (other.isSetSuccess()) { this.success = new NotificationEventResponse(other.success); } } - public getNextNotification_result deepCopy() { - return new getNextNotification_result(this); + public get_next_notification_result deepCopy() { + return new get_next_notification_result(this); } @Override @@ -136731,12 +136731,12 @@ public boolean isSet(_Fields field) { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getNextNotification_result) - return this.equals((getNextNotification_result)that); + if (that instanceof get_next_notification_result) + return this.equals((get_next_notification_result)that); return false; } - public boolean equals(getNextNotification_result that) { + public boolean equals(get_next_notification_result that) { if (that == null) return false; @@ -136764,13 +136764,13 @@ public int hashCode() { return builder.toHashCode(); } - public int compareTo(getNextNotification_result other) { + public int compareTo(get_next_notification_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getNextNotification_result typedOther = (getNextNotification_result)other; + get_next_notification_result typedOther = (get_next_notification_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -136799,7 +136799,7 @@ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache. @Override public String toString() { - StringBuilder sb = new StringBuilder("getNextNotification_result("); + StringBuilder sb = new StringBuilder("get_next_notification_result("); boolean first = true; sb.append("success:"); @@ -136837,15 +136837,15 @@ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException } } - private static class getNextNotification_resultStandardSchemeFactory implements SchemeFactory { - public getNextNotification_resultStandardScheme getScheme() { - return new getNextNotification_resultStandardScheme(); + private static class get_next_notification_resultStandardSchemeFactory implements SchemeFactory { + public get_next_notification_resultStandardScheme getScheme() { + return new get_next_notification_resultStandardScheme(); } } - private static class getNextNotification_resultStandardScheme extends StandardScheme { + private static class get_next_notification_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_next_notification_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -136873,7 +136873,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, getNextNotification struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_next_notification_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -136888,16 +136888,16 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getNextNotificatio } - private static class getNextNotification_resultTupleSchemeFactory implements SchemeFactory { - public getNextNotification_resultTupleScheme getScheme() { - return new getNextNotification_resultTupleScheme(); + private static class get_next_notification_resultTupleSchemeFactory implements SchemeFactory { + public get_next_notification_resultTupleScheme getScheme() { + return new get_next_notification_resultTupleScheme(); } } - private static class getNextNotification_resultTupleScheme extends TupleScheme { + private static class get_next_notification_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_next_notification_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -136910,7 +136910,7 @@ public void write(org.apache.thrift.protocol.TProtocol prot, getNextNotification } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_next_notification_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { @@ -136923,14 +136923,14 @@ public void read(org.apache.thrift.protocol.TProtocol prot, getNextNotification_ } - public static class getCurrentNotificationEventId_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getCurrentNotificationEventId_args"); + public static class get_current_notificationEventId_args implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_current_notificationEventId_args"); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getCurrentNotificationEventId_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getCurrentNotificationEventId_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_current_notificationEventId_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_current_notificationEventId_argsTupleSchemeFactory()); } @@ -136993,20 +136993,20 @@ public String getFieldName() { static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCurrentNotificationEventId_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_current_notificationEventId_args.class, metaDataMap); } - public getCurrentNotificationEventId_args() { + public get_current_notificationEventId_args() { } /** * Performs a deep copy on other. */ - public getCurrentNotificationEventId_args(getCurrentNotificationEventId_args other) { + public get_current_notificationEventId_args(get_current_notificationEventId_args other) { } - public getCurrentNotificationEventId_args deepCopy() { - return new getCurrentNotificationEventId_args(this); + public get_current_notificationEventId_args deepCopy() { + return new get_current_notificationEventId_args(this); } @Override @@ -137039,12 +137039,12 @@ public boolean isSet(_Fields field) { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getCurrentNotificationEventId_args) - return this.equals((getCurrentNotificationEventId_args)that); + if (that instanceof get_current_notificationEventId_args) + return this.equals((get_current_notificationEventId_args)that); return false; } - public boolean equals(getCurrentNotificationEventId_args that) { + public boolean equals(get_current_notificationEventId_args that) { if (that == null) return false; @@ -137058,13 +137058,13 @@ public int hashCode() { return builder.toHashCode(); } - public int compareTo(getCurrentNotificationEventId_args other) { + public int compareTo(get_current_notificationEventId_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getCurrentNotificationEventId_args typedOther = (getCurrentNotificationEventId_args)other; + get_current_notificationEventId_args typedOther = (get_current_notificationEventId_args)other; return 0; } @@ -137083,7 +137083,7 @@ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache. @Override public String toString() { - StringBuilder sb = new StringBuilder("getCurrentNotificationEventId_args("); + StringBuilder sb = new StringBuilder("get_current_notificationEventId_args("); boolean first = true; sb.append(")"); @@ -137111,15 +137111,15 @@ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException } } - private static class getCurrentNotificationEventId_argsStandardSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_argsStandardScheme getScheme() { - return new getCurrentNotificationEventId_argsStandardScheme(); + private static class get_current_notificationEventId_argsStandardSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_argsStandardScheme getScheme() { + return new get_current_notificationEventId_argsStandardScheme(); } } - private static class getCurrentNotificationEventId_argsStandardScheme extends StandardScheme { + private static class get_current_notificationEventId_argsStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -137138,7 +137138,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificat struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -137148,36 +137148,36 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotifica } - private static class getCurrentNotificationEventId_argsTupleSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_argsTupleScheme getScheme() { - return new getCurrentNotificationEventId_argsTupleScheme(); + private static class get_current_notificationEventId_argsTupleSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_argsTupleScheme getScheme() { + return new get_current_notificationEventId_argsTupleScheme(); } } - private static class getCurrentNotificationEventId_argsTupleScheme extends TupleScheme { + private static class get_current_notificationEventId_argsTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_args struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; } } } - public static class getCurrentNotificationEventId_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getCurrentNotificationEventId_result"); + public static class get_current_notificationEventId_result implements org.apache.thrift.TBase, java.io.Serializable, Cloneable { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_current_notificationEventId_result"); private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new getCurrentNotificationEventId_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new getCurrentNotificationEventId_resultTupleSchemeFactory()); + schemes.put(StandardScheme.class, new get_current_notificationEventId_resultStandardSchemeFactory()); + schemes.put(TupleScheme.class, new get_current_notificationEventId_resultTupleSchemeFactory()); } private CurrentNotificationEventId success; // required @@ -137247,13 +137247,13 @@ public String getFieldName() { tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CurrentNotificationEventId.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getCurrentNotificationEventId_result.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_current_notificationEventId_result.class, metaDataMap); } - public getCurrentNotificationEventId_result() { + public get_current_notificationEventId_result() { } - public getCurrentNotificationEventId_result( + public get_current_notificationEventId_result( CurrentNotificationEventId success) { this(); @@ -137263,14 +137263,14 @@ public getCurrentNotificationEventId_result( /** * Performs a deep copy on other. */ - public getCurrentNotificationEventId_result(getCurrentNotificationEventId_result other) { + public get_current_notificationEventId_result(get_current_notificationEventId_result other) { if (other.isSetSuccess()) { this.success = new CurrentNotificationEventId(other.success); } } - public getCurrentNotificationEventId_result deepCopy() { - return new getCurrentNotificationEventId_result(this); + public get_current_notificationEventId_result deepCopy() { + return new get_current_notificationEventId_result(this); } @Override @@ -137340,12 +137340,12 @@ public boolean isSet(_Fields field) { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof getCurrentNotificationEventId_result) - return this.equals((getCurrentNotificationEventId_result)that); + if (that instanceof get_current_notificationEventId_result) + return this.equals((get_current_notificationEventId_result)that); return false; } - public boolean equals(getCurrentNotificationEventId_result that) { + public boolean equals(get_current_notificationEventId_result that) { if (that == null) return false; @@ -137373,13 +137373,13 @@ public int hashCode() { return builder.toHashCode(); } - public int compareTo(getCurrentNotificationEventId_result other) { + public int compareTo(get_current_notificationEventId_result other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } int lastComparison = 0; - getCurrentNotificationEventId_result typedOther = (getCurrentNotificationEventId_result)other; + get_current_notificationEventId_result typedOther = (get_current_notificationEventId_result)other; lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess()); if (lastComparison != 0) { @@ -137408,7 +137408,7 @@ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache. @Override public String toString() { - StringBuilder sb = new StringBuilder("getCurrentNotificationEventId_result("); + StringBuilder sb = new StringBuilder("get_current_notificationEventId_result("); boolean first = true; sb.append("success:"); @@ -137446,15 +137446,15 @@ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException } } - private static class getCurrentNotificationEventId_resultStandardSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_resultStandardScheme getScheme() { - return new getCurrentNotificationEventId_resultStandardScheme(); + private static class get_current_notificationEventId_resultStandardSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_resultStandardScheme getScheme() { + return new get_current_notificationEventId_resultStandardScheme(); } } - private static class getCurrentNotificationEventId_resultStandardScheme extends StandardScheme { + private static class get_current_notificationEventId_resultStandardScheme extends StandardScheme { - public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -137482,7 +137482,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, getCurrentNotificat struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -137497,16 +137497,16 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, getCurrentNotifica } - private static class getCurrentNotificationEventId_resultTupleSchemeFactory implements SchemeFactory { - public getCurrentNotificationEventId_resultTupleScheme getScheme() { - return new getCurrentNotificationEventId_resultTupleScheme(); + private static class get_current_notificationEventId_resultTupleSchemeFactory implements SchemeFactory { + public get_current_notificationEventId_resultTupleScheme getScheme() { + return new get_current_notificationEventId_resultTupleScheme(); } } - private static class getCurrentNotificationEventId_resultTupleScheme extends TupleScheme { + private static class get_current_notificationEventId_resultTupleScheme extends TupleScheme { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -137519,7 +137519,7 @@ public void write(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificat } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getCurrentNotificationEventId_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, get_current_notificationEventId_result struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { diff --git metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php index 2d13d04..2d1f935 100644 --- metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php +++ metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php @@ -133,8 +133,8 @@ interface ThriftHiveMetastoreIf extends \FacebookServiceIf { public function heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns); public function compact(\metastore\CompactionRequest $rqst); public function show_compact(\metastore\ShowCompactRequest $rqst); - public function getNextNotification(\metastore\NotificationEventRequest $rqst); - public function getCurrentNotificationEventId(); + public function get_next_notification(\metastore\NotificationEventRequest $rqst); + public function get_current_notificationEventId(); } class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metastore\ThriftHiveMetastoreIf { @@ -6886,34 +6886,34 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas throw new \Exception("show_compact failed: unknown result"); } - public function getNextNotification(\metastore\NotificationEventRequest $rqst) + public function get_next_notification(\metastore\NotificationEventRequest $rqst) { - $this->send_getNextNotification($rqst); - return $this->recv_getNextNotification(); + $this->send_get_next_notification($rqst); + return $this->recv_get_next_notification(); } - public function send_getNextNotification(\metastore\NotificationEventRequest $rqst) + public function send_get_next_notification(\metastore\NotificationEventRequest $rqst) { - $args = new \metastore\ThriftHiveMetastore_getNextNotification_args(); + $args = new \metastore\ThriftHiveMetastore_get_next_notification_args(); $args->rqst = $rqst; $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getNextNotification', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'get_next_notification', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getNextNotification', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('get_next_notification', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getNextNotification() + public function recv_get_next_notification() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_getNextNotification_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_next_notification_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6927,43 +6927,43 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas $this->input_->readMessageEnd(); throw $x; } - $result = new \metastore\ThriftHiveMetastore_getNextNotification_result(); + $result = new \metastore\ThriftHiveMetastore_get_next_notification_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } if ($result->success !== null) { return $result->success; } - throw new \Exception("getNextNotification failed: unknown result"); + throw new \Exception("get_next_notification failed: unknown result"); } - public function getCurrentNotificationEventId() + public function get_current_notificationEventId() { - $this->send_getCurrentNotificationEventId(); - return $this->recv_getCurrentNotificationEventId(); + $this->send_get_current_notificationEventId(); + return $this->recv_get_current_notificationEventId(); } - public function send_getCurrentNotificationEventId() + public function send_get_current_notificationEventId() { - $args = new \metastore\ThriftHiveMetastore_getCurrentNotificationEventId_args(); + $args = new \metastore\ThriftHiveMetastore_get_current_notificationEventId_args(); $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { - thrift_protocol_write_binary($this->output_, 'getCurrentNotificationEventId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); + thrift_protocol_write_binary($this->output_, 'get_current_notificationEventId', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { - $this->output_->writeMessageBegin('getCurrentNotificationEventId', TMessageType::CALL, $this->seqid_); + $this->output_->writeMessageBegin('get_current_notificationEventId', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } - public function recv_getCurrentNotificationEventId() + public function recv_get_current_notificationEventId() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); - if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_getCurrentNotificationEventId_result', $this->input_->isStrictRead()); + if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_current_notificationEventId_result', $this->input_->isStrictRead()); else { $rseqid = 0; @@ -6977,14 +6977,14 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas $this->input_->readMessageEnd(); throw $x; } - $result = new \metastore\ThriftHiveMetastore_getCurrentNotificationEventId_result(); + $result = new \metastore\ThriftHiveMetastore_get_current_notificationEventId_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } if ($result->success !== null) { return $result->success; } - throw new \Exception("getCurrentNotificationEventId failed: unknown result"); + throw new \Exception("get_current_notificationEventId failed: unknown result"); } } @@ -33334,7 +33334,7 @@ class ThriftHiveMetastore_show_compact_result { } -class ThriftHiveMetastore_getNextNotification_args { +class ThriftHiveMetastore_get_next_notification_args { static $_TSPEC; public $rqst = null; @@ -33357,7 +33357,7 @@ class ThriftHiveMetastore_getNextNotification_args { } public function getName() { - return 'ThriftHiveMetastore_getNextNotification_args'; + return 'ThriftHiveMetastore_get_next_notification_args'; } public function read($input) @@ -33395,7 +33395,7 @@ class ThriftHiveMetastore_getNextNotification_args { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getNextNotification_args'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_next_notification_args'); if ($this->rqst !== null) { if (!is_object($this->rqst)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -33411,7 +33411,7 @@ class ThriftHiveMetastore_getNextNotification_args { } -class ThriftHiveMetastore_getNextNotification_result { +class ThriftHiveMetastore_get_next_notification_result { static $_TSPEC; public $success = null; @@ -33434,7 +33434,7 @@ class ThriftHiveMetastore_getNextNotification_result { } public function getName() { - return 'ThriftHiveMetastore_getNextNotification_result'; + return 'ThriftHiveMetastore_get_next_notification_result'; } public function read($input) @@ -33472,7 +33472,7 @@ class ThriftHiveMetastore_getNextNotification_result { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getNextNotification_result'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_next_notification_result'); if ($this->success !== null) { if (!is_object($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); @@ -33488,7 +33488,7 @@ class ThriftHiveMetastore_getNextNotification_result { } -class ThriftHiveMetastore_getCurrentNotificationEventId_args { +class ThriftHiveMetastore_get_current_notificationEventId_args { static $_TSPEC; @@ -33500,7 +33500,7 @@ class ThriftHiveMetastore_getCurrentNotificationEventId_args { } public function getName() { - return 'ThriftHiveMetastore_getCurrentNotificationEventId_args'; + return 'ThriftHiveMetastore_get_current_notificationEventId_args'; } public function read($input) @@ -33530,7 +33530,7 @@ class ThriftHiveMetastore_getCurrentNotificationEventId_args { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getCurrentNotificationEventId_args'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_current_notificationEventId_args'); $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -33538,7 +33538,7 @@ class ThriftHiveMetastore_getCurrentNotificationEventId_args { } -class ThriftHiveMetastore_getCurrentNotificationEventId_result { +class ThriftHiveMetastore_get_current_notificationEventId_result { static $_TSPEC; public $success = null; @@ -33561,7 +33561,7 @@ class ThriftHiveMetastore_getCurrentNotificationEventId_result { } public function getName() { - return 'ThriftHiveMetastore_getCurrentNotificationEventId_result'; + return 'ThriftHiveMetastore_get_current_notificationEventId_result'; } public function read($input) @@ -33599,7 +33599,7 @@ class ThriftHiveMetastore_getCurrentNotificationEventId_result { public function write($output) { $xfer = 0; - $xfer += $output->writeStructBegin('ThriftHiveMetastore_getCurrentNotificationEventId_result'); + $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_current_notificationEventId_result'); if ($this->success !== null) { if (!is_object($this->success)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); diff --git metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote old mode 100644 new mode 100755 index abb6c81..197b35e --- metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote +++ metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote @@ -140,8 +140,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)' print ' void compact(CompactionRequest rqst)' print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)' - print ' NotificationEventResponse getNextNotification(NotificationEventRequest rqst)' - print ' CurrentNotificationEventId getCurrentNotificationEventId()' + print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)' + print ' CurrentNotificationEventId get_current_notificationEventId()' print '' sys.exit(0) @@ -895,17 +895,17 @@ elif cmd == 'show_compact': sys.exit(1) pp.pprint(client.show_compact(eval(args[0]),)) -elif cmd == 'getNextNotification': +elif cmd == 'get_next_notification': if len(args) != 1: - print 'getNextNotification requires 1 args' + print 'get_next_notification requires 1 args' sys.exit(1) - pp.pprint(client.getNextNotification(eval(args[0]),)) + pp.pprint(client.get_next_notification(eval(args[0]),)) -elif cmd == 'getCurrentNotificationEventId': +elif cmd == 'get_current_notificationEventId': if len(args) != 0: - print 'getCurrentNotificationEventId requires 0 args' + print 'get_current_notificationEventId requires 0 args' sys.exit(1) - pp.pprint(client.getCurrentNotificationEventId()) + pp.pprint(client.get_current_notificationEventId()) else: print 'Unrecognized method %s' % cmd diff --git metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 9db398c..1357e41 100644 --- metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -976,14 +976,14 @@ def show_compact(self, rqst): """ pass - def getNextNotification(self, rqst): + def get_next_notification(self, rqst): """ Parameters: - rqst """ pass - def getCurrentNotificationEventId(self, ): + def get_current_notificationEventId(self, ): pass @@ -5206,60 +5206,60 @@ def recv_show_compact(self, ): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); - def getNextNotification(self, rqst): + def get_next_notification(self, rqst): """ Parameters: - rqst """ - self.send_getNextNotification(rqst) - return self.recv_getNextNotification() + self.send_get_next_notification(rqst) + return self.recv_get_next_notification() - def send_getNextNotification(self, rqst): - self._oprot.writeMessageBegin('getNextNotification', TMessageType.CALL, self._seqid) - args = getNextNotification_args() + def send_get_next_notification(self, rqst): + self._oprot.writeMessageBegin('get_next_notification', TMessageType.CALL, self._seqid) + args = get_next_notification_args() args.rqst = rqst args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getNextNotification(self, ): + def recv_get_next_notification(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getNextNotification_result() + result = get_next_notification_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getNextNotification failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); - def getCurrentNotificationEventId(self, ): - self.send_getCurrentNotificationEventId() - return self.recv_getCurrentNotificationEventId() + def get_current_notificationEventId(self, ): + self.send_get_current_notificationEventId() + return self.recv_get_current_notificationEventId() - def send_getCurrentNotificationEventId(self, ): - self._oprot.writeMessageBegin('getCurrentNotificationEventId', TMessageType.CALL, self._seqid) - args = getCurrentNotificationEventId_args() + def send_get_current_notificationEventId(self, ): + self._oprot.writeMessageBegin('get_current_notificationEventId', TMessageType.CALL, self._seqid) + args = get_current_notificationEventId_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCurrentNotificationEventId(self, ): + def recv_get_current_notificationEventId(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCurrentNotificationEventId_result() + result = get_current_notificationEventId_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCurrentNotificationEventId failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); class Processor(fb303.FacebookService.Processor, Iface, TProcessor): @@ -5382,8 +5382,8 @@ def __init__(self, handler): self._processMap["heartbeat_txn_range"] = Processor.process_heartbeat_txn_range self._processMap["compact"] = Processor.process_compact self._processMap["show_compact"] = Processor.process_show_compact - self._processMap["getNextNotification"] = Processor.process_getNextNotification - self._processMap["getCurrentNotificationEventId"] = Processor.process_getCurrentNotificationEventId + self._processMap["get_next_notification"] = Processor.process_get_next_notification + self._processMap["get_current_notificationEventId"] = Processor.process_get_current_notificationEventId def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -7269,24 +7269,24 @@ def process_show_compact(self, seqid, iprot, oprot): oprot.writeMessageEnd() oprot.trans.flush() - def process_getNextNotification(self, seqid, iprot, oprot): - args = getNextNotification_args() + def process_get_next_notification(self, seqid, iprot, oprot): + args = get_next_notification_args() args.read(iprot) iprot.readMessageEnd() - result = getNextNotification_result() - result.success = self._handler.getNextNotification(args.rqst) - oprot.writeMessageBegin("getNextNotification", TMessageType.REPLY, seqid) + result = get_next_notification_result() + result.success = self._handler.get_next_notification(args.rqst) + oprot.writeMessageBegin("get_next_notification", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getCurrentNotificationEventId(self, seqid, iprot, oprot): - args = getCurrentNotificationEventId_args() + def process_get_current_notificationEventId(self, seqid, iprot, oprot): + args = get_current_notificationEventId_args() args.read(iprot) iprot.readMessageEnd() - result = getCurrentNotificationEventId_result() - result.success = self._handler.getCurrentNotificationEventId() - oprot.writeMessageBegin("getCurrentNotificationEventId", TMessageType.REPLY, seqid) + result = get_current_notificationEventId_result() + result.success = self._handler.get_current_notificationEventId() + oprot.writeMessageBegin("get_current_notificationEventId", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -26270,7 +26270,7 @@ def __eq__(self, other): def __ne__(self, other): return not (self == other) -class getNextNotification_args: +class get_next_notification_args: """ Attributes: - rqst @@ -26308,7 +26308,7 @@ def write(self, oprot): if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getNextNotification_args') + oprot.writeStructBegin('get_next_notification_args') if self.rqst is not None: oprot.writeFieldBegin('rqst', TType.STRUCT, 1) self.rqst.write(oprot) @@ -26331,7 +26331,7 @@ def __eq__(self, other): def __ne__(self, other): return not (self == other) -class getNextNotification_result: +class get_next_notification_result: """ Attributes: - success @@ -26368,7 +26368,7 @@ def write(self, oprot): if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getNextNotification_result') + oprot.writeStructBegin('get_next_notification_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) @@ -26391,7 +26391,7 @@ def __eq__(self, other): def __ne__(self, other): return not (self == other) -class getCurrentNotificationEventId_args: +class get_current_notificationEventId_args: thrift_spec = ( ) @@ -26414,7 +26414,7 @@ def write(self, oprot): if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getCurrentNotificationEventId_args') + oprot.writeStructBegin('get_current_notificationEventId_args') oprot.writeFieldStop() oprot.writeStructEnd() @@ -26433,7 +26433,7 @@ def __eq__(self, other): def __ne__(self, other): return not (self == other) -class getCurrentNotificationEventId_result: +class get_current_notificationEventId_result: """ Attributes: - success @@ -26470,7 +26470,7 @@ def write(self, oprot): if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getCurrentNotificationEventId_result') + oprot.writeStructBegin('get_current_notificationEventId_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) diff --git metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb index ad8ca28..a383e0b 100644 --- metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb +++ metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb @@ -1977,34 +1977,34 @@ module ThriftHiveMetastore raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'show_compact failed: unknown result') end - def getNextNotification(rqst) - send_getNextNotification(rqst) - return recv_getNextNotification() + def get_next_notification(rqst) + send_get_next_notification(rqst) + return recv_get_next_notification() end - def send_getNextNotification(rqst) - send_message('getNextNotification', GetNextNotification_args, :rqst => rqst) + def send_get_next_notification(rqst) + send_message('get_next_notification', Get_next_notification_args, :rqst => rqst) end - def recv_getNextNotification() - result = receive_message(GetNextNotification_result) + def recv_get_next_notification() + result = receive_message(Get_next_notification_result) return result.success unless result.success.nil? - raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getNextNotification failed: unknown result') + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_next_notification failed: unknown result') end - def getCurrentNotificationEventId() - send_getCurrentNotificationEventId() - return recv_getCurrentNotificationEventId() + def get_current_notificationEventId() + send_get_current_notificationEventId() + return recv_get_current_notificationEventId() end - def send_getCurrentNotificationEventId() - send_message('getCurrentNotificationEventId', GetCurrentNotificationEventId_args) + def send_get_current_notificationEventId() + send_message('get_current_notificationEventId', Get_current_notificationEventId_args) end - def recv_getCurrentNotificationEventId() - result = receive_message(GetCurrentNotificationEventId_result) + def recv_get_current_notificationEventId() + result = receive_message(Get_current_notificationEventId_result) return result.success unless result.success.nil? - raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getCurrentNotificationEventId failed: unknown result') + raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_current_notificationEventId failed: unknown result') end end @@ -3523,18 +3523,18 @@ module ThriftHiveMetastore write_result(result, oprot, 'show_compact', seqid) end - def process_getNextNotification(seqid, iprot, oprot) - args = read_args(iprot, GetNextNotification_args) - result = GetNextNotification_result.new() - result.success = @handler.getNextNotification(args.rqst) - write_result(result, oprot, 'getNextNotification', seqid) + def process_get_next_notification(seqid, iprot, oprot) + args = read_args(iprot, Get_next_notification_args) + result = Get_next_notification_result.new() + result.success = @handler.get_next_notification(args.rqst) + write_result(result, oprot, 'get_next_notification', seqid) end - def process_getCurrentNotificationEventId(seqid, iprot, oprot) - args = read_args(iprot, GetCurrentNotificationEventId_args) - result = GetCurrentNotificationEventId_result.new() - result.success = @handler.getCurrentNotificationEventId() - write_result(result, oprot, 'getCurrentNotificationEventId', seqid) + def process_get_current_notificationEventId(seqid, iprot, oprot) + args = read_args(iprot, Get_current_notificationEventId_args) + result = Get_current_notificationEventId_result.new() + result.success = @handler.get_current_notificationEventId() + write_result(result, oprot, 'get_current_notificationEventId', seqid) end end @@ -8025,7 +8025,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetNextNotification_args + class Get_next_notification_args include ::Thrift::Struct, ::Thrift::Struct_Union RQST = 1 @@ -8041,7 +8041,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetNextNotification_result + class Get_next_notification_result include ::Thrift::Struct, ::Thrift::Struct_Union SUCCESS = 0 @@ -8057,7 +8057,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetCurrentNotificationEventId_args + class Get_current_notificationEventId_args include ::Thrift::Struct, ::Thrift::Struct_Union FIELDS = { @@ -8072,7 +8072,7 @@ module ThriftHiveMetastore ::Thrift::Struct.generate_accessors self end - class GetCurrentNotificationEventId_result + class Get_current_notificationEventId_result include ::Thrift::Struct, ::Thrift::Struct_Union SUCCESS = 0 diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 271b4ad..6f4235b 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -5584,14 +5584,14 @@ public boolean set_aggr_stats_for(SetPartitionsStatsRequest request) } @Override - public NotificationEventResponse getNextNotification(NotificationEventRequest rqst) + public NotificationEventResponse get_next_notification(NotificationEventRequest rqst) throws TException { RawStore ms = getMS(); return ms.getNextNotification(rqst); } @Override - public CurrentNotificationEventId getCurrentNotificationEventId() throws TException { + public CurrentNotificationEventId get_current_notificationEventId() throws TException { RawStore ms = getMS(); return ms.getCurrentNotificationEventId(); } diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index b18cd1e..e4cf6b8 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -1839,7 +1839,7 @@ public NotificationEventResponse getNextNotification(long lastEventId, int maxEv NotificationFilter filter) throws TException { NotificationEventRequest rqst = new NotificationEventRequest(lastEventId); rqst.setMaxEvents(maxEvents); - NotificationEventResponse rsp = client.getNextNotification(rqst); + NotificationEventResponse rsp = client.get_next_notification(rqst); LOG.debug("Got back " + rsp.getEventsSize() + " events"); if (filter == null) { return rsp; @@ -1856,7 +1856,7 @@ public NotificationEventResponse getNextNotification(long lastEventId, int maxEv @Override public CurrentNotificationEventId getCurrentNotificationEventId() throws TException { - return client.getCurrentNotificationEventId(); + return client.get_current_notificationEventId(); } /**