You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vi...@apache.org on 2018/07/13 01:09:49 UTC
[14/51] [partial] hive git commit: HIVE-20097 : Convert
standalone-metastore to a submodule (Alexander Kolbasov reviewed by Vihang
Karajgaonkar)
http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java
new file mode 100644
index 0000000..e0e1cd4
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java
@@ -0,0 +1,1112 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class NotificationEvent implements org.apache.thrift.TBase<NotificationEvent, NotificationEvent._Fields>, java.io.Serializable, Cloneable, Comparable<NotificationEvent> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotificationEvent");
+
+ private static final org.apache.thrift.protocol.TField EVENT_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("eventId", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField EVENT_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("eventTime", org.apache.thrift.protocol.TType.I32, (short)2);
+ private static final org.apache.thrift.protocol.TField EVENT_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("eventType", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)4);
+ private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)6);
+ private static final org.apache.thrift.protocol.TField MESSAGE_FORMAT_FIELD_DESC = new org.apache.thrift.protocol.TField("messageFormat", org.apache.thrift.protocol.TType.STRING, (short)7);
+ private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)8);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new NotificationEventStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new NotificationEventTupleSchemeFactory());
+ }
+
+ private long eventId; // required
+ private int eventTime; // required
+ private String eventType; // required
+ private String dbName; // optional
+ private String tableName; // optional
+ private String message; // required
+ private String messageFormat; // optional
+ private String catName; // optional
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ EVENT_ID((short)1, "eventId"),
+ EVENT_TIME((short)2, "eventTime"),
+ EVENT_TYPE((short)3, "eventType"),
+ DB_NAME((short)4, "dbName"),
+ TABLE_NAME((short)5, "tableName"),
+ MESSAGE((short)6, "message"),
+ MESSAGE_FORMAT((short)7, "messageFormat"),
+ CAT_NAME((short)8, "catName");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // EVENT_ID
+ return EVENT_ID;
+ case 2: // EVENT_TIME
+ return EVENT_TIME;
+ case 3: // EVENT_TYPE
+ return EVENT_TYPE;
+ case 4: // DB_NAME
+ return DB_NAME;
+ case 5: // TABLE_NAME
+ return TABLE_NAME;
+ case 6: // MESSAGE
+ return MESSAGE;
+ case 7: // MESSAGE_FORMAT
+ return MESSAGE_FORMAT;
+ case 8: // CAT_NAME
+ return CAT_NAME;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final int __EVENTID_ISSET_ID = 0;
+ private static final int __EVENTTIME_ISSET_ID = 1;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.DB_NAME,_Fields.TABLE_NAME,_Fields.MESSAGE_FORMAT,_Fields.CAT_NAME};
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.EVENT_ID, new org.apache.thrift.meta_data.FieldMetaData("eventId", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.EVENT_TIME, new org.apache.thrift.meta_data.FieldMetaData("eventTime", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.EVENT_TYPE, new org.apache.thrift.meta_data.FieldMetaData("eventType", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.MESSAGE_FORMAT, new org.apache.thrift.meta_data.FieldMetaData("messageFormat", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NotificationEvent.class, metaDataMap);
+ }
+
+ public NotificationEvent() {
+ }
+
+ public NotificationEvent(
+ long eventId,
+ int eventTime,
+ String eventType,
+ String message)
+ {
+ this();
+ this.eventId = eventId;
+ setEventIdIsSet(true);
+ this.eventTime = eventTime;
+ setEventTimeIsSet(true);
+ this.eventType = eventType;
+ this.message = message;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public NotificationEvent(NotificationEvent other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.eventId = other.eventId;
+ this.eventTime = other.eventTime;
+ if (other.isSetEventType()) {
+ this.eventType = other.eventType;
+ }
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetTableName()) {
+ this.tableName = other.tableName;
+ }
+ if (other.isSetMessage()) {
+ this.message = other.message;
+ }
+ if (other.isSetMessageFormat()) {
+ this.messageFormat = other.messageFormat;
+ }
+ if (other.isSetCatName()) {
+ this.catName = other.catName;
+ }
+ }
+
+ public NotificationEvent deepCopy() {
+ return new NotificationEvent(this);
+ }
+
+ @Override
+ public void clear() {
+ setEventIdIsSet(false);
+ this.eventId = 0;
+ setEventTimeIsSet(false);
+ this.eventTime = 0;
+ this.eventType = null;
+ this.dbName = null;
+ this.tableName = null;
+ this.message = null;
+ this.messageFormat = null;
+ this.catName = null;
+ }
+
+ public long getEventId() {
+ return this.eventId;
+ }
+
+ public void setEventId(long eventId) {
+ this.eventId = eventId;
+ setEventIdIsSet(true);
+ }
+
+ public void unsetEventId() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EVENTID_ISSET_ID);
+ }
+
+ /** Returns true if field eventId is set (has been assigned a value) and false otherwise */
+ public boolean isSetEventId() {
+ return EncodingUtils.testBit(__isset_bitfield, __EVENTID_ISSET_ID);
+ }
+
+ public void setEventIdIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EVENTID_ISSET_ID, value);
+ }
+
+ public int getEventTime() {
+ return this.eventTime;
+ }
+
+ public void setEventTime(int eventTime) {
+ this.eventTime = eventTime;
+ setEventTimeIsSet(true);
+ }
+
+ public void unsetEventTime() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __EVENTTIME_ISSET_ID);
+ }
+
+ /** Returns true if field eventTime is set (has been assigned a value) and false otherwise */
+ public boolean isSetEventTime() {
+ return EncodingUtils.testBit(__isset_bitfield, __EVENTTIME_ISSET_ID);
+ }
+
+ public void setEventTimeIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __EVENTTIME_ISSET_ID, value);
+ }
+
+ public String getEventType() {
+ return this.eventType;
+ }
+
+ public void setEventType(String eventType) {
+ this.eventType = eventType;
+ }
+
+ public void unsetEventType() {
+ this.eventType = null;
+ }
+
+ /** Returns true if field eventType is set (has been assigned a value) and false otherwise */
+ public boolean isSetEventType() {
+ return this.eventType != null;
+ }
+
+ public void setEventTypeIsSet(boolean value) {
+ if (!value) {
+ this.eventType = null;
+ }
+ }
+
+ public String getDbName() {
+ return this.dbName;
+ }
+
+ public void setDbName(String dbName) {
+ this.dbName = dbName;
+ }
+
+ public void unsetDbName() {
+ this.dbName = null;
+ }
+
+ /** Returns true if field dbName is set (has been assigned a value) and false otherwise */
+ public boolean isSetDbName() {
+ return this.dbName != null;
+ }
+
+ public void setDbNameIsSet(boolean value) {
+ if (!value) {
+ this.dbName = null;
+ }
+ }
+
+ public String getTableName() {
+ return this.tableName;
+ }
+
+ public void setTableName(String tableName) {
+ this.tableName = tableName;
+ }
+
+ public void unsetTableName() {
+ this.tableName = null;
+ }
+
+ /** Returns true if field tableName is set (has been assigned a value) and false otherwise */
+ public boolean isSetTableName() {
+ return this.tableName != null;
+ }
+
+ public void setTableNameIsSet(boolean value) {
+ if (!value) {
+ this.tableName = null;
+ }
+ }
+
+ public String getMessage() {
+ return this.message;
+ }
+
+ public void setMessage(String message) {
+ this.message = message;
+ }
+
+ public void unsetMessage() {
+ this.message = null;
+ }
+
+ /** Returns true if field message is set (has been assigned a value) and false otherwise */
+ public boolean isSetMessage() {
+ return this.message != null;
+ }
+
+ public void setMessageIsSet(boolean value) {
+ if (!value) {
+ this.message = null;
+ }
+ }
+
+ public String getMessageFormat() {
+ return this.messageFormat;
+ }
+
+ public void setMessageFormat(String messageFormat) {
+ this.messageFormat = messageFormat;
+ }
+
+ public void unsetMessageFormat() {
+ this.messageFormat = null;
+ }
+
+ /** Returns true if field messageFormat is set (has been assigned a value) and false otherwise */
+ public boolean isSetMessageFormat() {
+ return this.messageFormat != null;
+ }
+
+ public void setMessageFormatIsSet(boolean value) {
+ if (!value) {
+ this.messageFormat = null;
+ }
+ }
+
+ public String getCatName() {
+ return this.catName;
+ }
+
+ public void setCatName(String catName) {
+ this.catName = catName;
+ }
+
+ public void unsetCatName() {
+ this.catName = null;
+ }
+
+ /** Returns true if field catName is set (has been assigned a value) and false otherwise */
+ public boolean isSetCatName() {
+ return this.catName != null;
+ }
+
+ public void setCatNameIsSet(boolean value) {
+ if (!value) {
+ this.catName = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case EVENT_ID:
+ if (value == null) {
+ unsetEventId();
+ } else {
+ setEventId((Long)value);
+ }
+ break;
+
+ case EVENT_TIME:
+ if (value == null) {
+ unsetEventTime();
+ } else {
+ setEventTime((Integer)value);
+ }
+ break;
+
+ case EVENT_TYPE:
+ if (value == null) {
+ unsetEventType();
+ } else {
+ setEventType((String)value);
+ }
+ break;
+
+ case DB_NAME:
+ if (value == null) {
+ unsetDbName();
+ } else {
+ setDbName((String)value);
+ }
+ break;
+
+ case TABLE_NAME:
+ if (value == null) {
+ unsetTableName();
+ } else {
+ setTableName((String)value);
+ }
+ break;
+
+ case MESSAGE:
+ if (value == null) {
+ unsetMessage();
+ } else {
+ setMessage((String)value);
+ }
+ break;
+
+ case MESSAGE_FORMAT:
+ if (value == null) {
+ unsetMessageFormat();
+ } else {
+ setMessageFormat((String)value);
+ }
+ break;
+
+ case CAT_NAME:
+ if (value == null) {
+ unsetCatName();
+ } else {
+ setCatName((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case EVENT_ID:
+ return getEventId();
+
+ case EVENT_TIME:
+ return getEventTime();
+
+ case EVENT_TYPE:
+ return getEventType();
+
+ case DB_NAME:
+ return getDbName();
+
+ case TABLE_NAME:
+ return getTableName();
+
+ case MESSAGE:
+ return getMessage();
+
+ case MESSAGE_FORMAT:
+ return getMessageFormat();
+
+ case CAT_NAME:
+ return getCatName();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case EVENT_ID:
+ return isSetEventId();
+ case EVENT_TIME:
+ return isSetEventTime();
+ case EVENT_TYPE:
+ return isSetEventType();
+ case DB_NAME:
+ return isSetDbName();
+ case TABLE_NAME:
+ return isSetTableName();
+ case MESSAGE:
+ return isSetMessage();
+ case MESSAGE_FORMAT:
+ return isSetMessageFormat();
+ case CAT_NAME:
+ return isSetCatName();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof NotificationEvent)
+ return this.equals((NotificationEvent)that);
+ return false;
+ }
+
+ public boolean equals(NotificationEvent that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_eventId = true;
+ boolean that_present_eventId = true;
+ if (this_present_eventId || that_present_eventId) {
+ if (!(this_present_eventId && that_present_eventId))
+ return false;
+ if (this.eventId != that.eventId)
+ return false;
+ }
+
+ boolean this_present_eventTime = true;
+ boolean that_present_eventTime = true;
+ if (this_present_eventTime || that_present_eventTime) {
+ if (!(this_present_eventTime && that_present_eventTime))
+ return false;
+ if (this.eventTime != that.eventTime)
+ return false;
+ }
+
+ boolean this_present_eventType = true && this.isSetEventType();
+ boolean that_present_eventType = true && that.isSetEventType();
+ if (this_present_eventType || that_present_eventType) {
+ if (!(this_present_eventType && that_present_eventType))
+ return false;
+ if (!this.eventType.equals(that.eventType))
+ return false;
+ }
+
+ boolean this_present_dbName = true && this.isSetDbName();
+ boolean that_present_dbName = true && that.isSetDbName();
+ if (this_present_dbName || that_present_dbName) {
+ if (!(this_present_dbName && that_present_dbName))
+ return false;
+ if (!this.dbName.equals(that.dbName))
+ return false;
+ }
+
+ boolean this_present_tableName = true && this.isSetTableName();
+ boolean that_present_tableName = true && that.isSetTableName();
+ if (this_present_tableName || that_present_tableName) {
+ if (!(this_present_tableName && that_present_tableName))
+ return false;
+ if (!this.tableName.equals(that.tableName))
+ return false;
+ }
+
+ boolean this_present_message = true && this.isSetMessage();
+ boolean that_present_message = true && that.isSetMessage();
+ if (this_present_message || that_present_message) {
+ if (!(this_present_message && that_present_message))
+ return false;
+ if (!this.message.equals(that.message))
+ return false;
+ }
+
+ boolean this_present_messageFormat = true && this.isSetMessageFormat();
+ boolean that_present_messageFormat = true && that.isSetMessageFormat();
+ if (this_present_messageFormat || that_present_messageFormat) {
+ if (!(this_present_messageFormat && that_present_messageFormat))
+ return false;
+ if (!this.messageFormat.equals(that.messageFormat))
+ return false;
+ }
+
+ boolean this_present_catName = true && this.isSetCatName();
+ boolean that_present_catName = true && that.isSetCatName();
+ if (this_present_catName || that_present_catName) {
+ if (!(this_present_catName && that_present_catName))
+ return false;
+ if (!this.catName.equals(that.catName))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_eventId = true;
+ list.add(present_eventId);
+ if (present_eventId)
+ list.add(eventId);
+
+ boolean present_eventTime = true;
+ list.add(present_eventTime);
+ if (present_eventTime)
+ list.add(eventTime);
+
+ boolean present_eventType = true && (isSetEventType());
+ list.add(present_eventType);
+ if (present_eventType)
+ list.add(eventType);
+
+ boolean present_dbName = true && (isSetDbName());
+ list.add(present_dbName);
+ if (present_dbName)
+ list.add(dbName);
+
+ boolean present_tableName = true && (isSetTableName());
+ list.add(present_tableName);
+ if (present_tableName)
+ list.add(tableName);
+
+ boolean present_message = true && (isSetMessage());
+ list.add(present_message);
+ if (present_message)
+ list.add(message);
+
+ boolean present_messageFormat = true && (isSetMessageFormat());
+ list.add(present_messageFormat);
+ if (present_messageFormat)
+ list.add(messageFormat);
+
+ boolean present_catName = true && (isSetCatName());
+ list.add(present_catName);
+ if (present_catName)
+ list.add(catName);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(NotificationEvent other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetEventId()).compareTo(other.isSetEventId());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEventId()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventId, other.eventId);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetEventTime()).compareTo(other.isSetEventTime());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEventTime()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventTime, other.eventTime);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetEventType()).compareTo(other.isSetEventType());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEventType()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventType, other.eventType);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDbName()).compareTo(other.isSetDbName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDbName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.dbName, other.dbName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTableName()).compareTo(other.isSetTableName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTableName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, other.tableName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMessage()).compareTo(other.isSetMessage());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMessage()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, other.message);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMessageFormat()).compareTo(other.isSetMessageFormat());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMessageFormat()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.messageFormat, other.messageFormat);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCatName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("NotificationEvent(");
+ boolean first = true;
+
+ sb.append("eventId:");
+ sb.append(this.eventId);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("eventTime:");
+ sb.append(this.eventTime);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("eventType:");
+ if (this.eventType == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.eventType);
+ }
+ first = false;
+ if (isSetDbName()) {
+ if (!first) sb.append(", ");
+ sb.append("dbName:");
+ if (this.dbName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.dbName);
+ }
+ first = false;
+ }
+ if (isSetTableName()) {
+ if (!first) sb.append(", ");
+ sb.append("tableName:");
+ if (this.tableName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tableName);
+ }
+ first = false;
+ }
+ if (!first) sb.append(", ");
+ sb.append("message:");
+ if (this.message == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.message);
+ }
+ first = false;
+ if (isSetMessageFormat()) {
+ if (!first) sb.append(", ");
+ sb.append("messageFormat:");
+ if (this.messageFormat == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.messageFormat);
+ }
+ first = false;
+ }
+ if (isSetCatName()) {
+ if (!first) sb.append(", ");
+ sb.append("catName:");
+ if (this.catName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.catName);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetEventId()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'eventId' is unset! Struct:" + toString());
+ }
+
+ if (!isSetEventTime()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'eventTime' is unset! Struct:" + toString());
+ }
+
+ if (!isSetEventType()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'eventType' is unset! Struct:" + toString());
+ }
+
+ if (!isSetMessage()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'message' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class NotificationEventStandardSchemeFactory implements SchemeFactory {
+ public NotificationEventStandardScheme getScheme() {
+ return new NotificationEventStandardScheme();
+ }
+ }
+
+ private static class NotificationEventStandardScheme extends StandardScheme<NotificationEvent> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, NotificationEvent struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // EVENT_ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.eventId = iprot.readI64();
+ struct.setEventIdIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // EVENT_TIME
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.eventTime = iprot.readI32();
+ struct.setEventTimeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // EVENT_TYPE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.eventType = iprot.readString();
+ struct.setEventTypeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // DB_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // TABLE_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // MESSAGE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.message = iprot.readString();
+ struct.setMessageIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // MESSAGE_FORMAT
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.messageFormat = iprot.readString();
+ struct.setMessageFormatIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 8: // CAT_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, NotificationEvent struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(EVENT_ID_FIELD_DESC);
+ oprot.writeI64(struct.eventId);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(EVENT_TIME_FIELD_DESC);
+ oprot.writeI32(struct.eventTime);
+ oprot.writeFieldEnd();
+ if (struct.eventType != null) {
+ oprot.writeFieldBegin(EVENT_TYPE_FIELD_DESC);
+ oprot.writeString(struct.eventType);
+ oprot.writeFieldEnd();
+ }
+ if (struct.dbName != null) {
+ if (struct.isSetDbName()) {
+ oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
+ oprot.writeString(struct.dbName);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.tableName != null) {
+ if (struct.isSetTableName()) {
+ oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
+ oprot.writeString(struct.tableName);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.message != null) {
+ oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
+ oprot.writeString(struct.message);
+ oprot.writeFieldEnd();
+ }
+ if (struct.messageFormat != null) {
+ if (struct.isSetMessageFormat()) {
+ oprot.writeFieldBegin(MESSAGE_FORMAT_FIELD_DESC);
+ oprot.writeString(struct.messageFormat);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.catName != null) {
+ if (struct.isSetCatName()) {
+ oprot.writeFieldBegin(CAT_NAME_FIELD_DESC);
+ oprot.writeString(struct.catName);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class NotificationEventTupleSchemeFactory implements SchemeFactory {
+ public NotificationEventTupleScheme getScheme() {
+ return new NotificationEventTupleScheme();
+ }
+ }
+
+ private static class NotificationEventTupleScheme extends TupleScheme<NotificationEvent> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, NotificationEvent struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.eventId);
+ oprot.writeI32(struct.eventTime);
+ oprot.writeString(struct.eventType);
+ oprot.writeString(struct.message);
+ BitSet optionals = new BitSet();
+ if (struct.isSetDbName()) {
+ optionals.set(0);
+ }
+ if (struct.isSetTableName()) {
+ optionals.set(1);
+ }
+ if (struct.isSetMessageFormat()) {
+ optionals.set(2);
+ }
+ if (struct.isSetCatName()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetDbName()) {
+ oprot.writeString(struct.dbName);
+ }
+ if (struct.isSetTableName()) {
+ oprot.writeString(struct.tableName);
+ }
+ if (struct.isSetMessageFormat()) {
+ oprot.writeString(struct.messageFormat);
+ }
+ if (struct.isSetCatName()) {
+ oprot.writeString(struct.catName);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEvent struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.eventId = iprot.readI64();
+ struct.setEventIdIsSet(true);
+ struct.eventTime = iprot.readI32();
+ struct.setEventTimeIsSet(true);
+ struct.eventType = iprot.readString();
+ struct.setEventTypeIsSet(true);
+ struct.message = iprot.readString();
+ struct.setMessageIsSet(true);
+ BitSet incoming = iprot.readBitSet(4);
+ if (incoming.get(0)) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.messageFormat = iprot.readString();
+ struct.setMessageFormatIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
new file mode 100644
index 0000000..f016204
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java
@@ -0,0 +1,490 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class NotificationEventRequest implements org.apache.thrift.TBase<NotificationEventRequest, NotificationEventRequest._Fields>, java.io.Serializable, Cloneable, Comparable<NotificationEventRequest> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotificationEventRequest");
+
+ private static final org.apache.thrift.protocol.TField LAST_EVENT_FIELD_DESC = new org.apache.thrift.protocol.TField("lastEvent", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField MAX_EVENTS_FIELD_DESC = new org.apache.thrift.protocol.TField("maxEvents", org.apache.thrift.protocol.TType.I32, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new NotificationEventRequestStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new NotificationEventRequestTupleSchemeFactory());
+ }
+
+ private long lastEvent; // required
+ private int maxEvents; // optional
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ LAST_EVENT((short)1, "lastEvent"),
+ MAX_EVENTS((short)2, "maxEvents");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // LAST_EVENT
+ return LAST_EVENT;
+ case 2: // MAX_EVENTS
+ return MAX_EVENTS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final int __LASTEVENT_ISSET_ID = 0;
+ private static final int __MAXEVENTS_ISSET_ID = 1;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.MAX_EVENTS};
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.LAST_EVENT, new org.apache.thrift.meta_data.FieldMetaData("lastEvent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.MAX_EVENTS, new org.apache.thrift.meta_data.FieldMetaData("maxEvents", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NotificationEventRequest.class, metaDataMap);
+ }
+
+ public NotificationEventRequest() {
+ }
+
+ public NotificationEventRequest(
+ long lastEvent)
+ {
+ this();
+ this.lastEvent = lastEvent;
+ setLastEventIsSet(true);
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public NotificationEventRequest(NotificationEventRequest other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.lastEvent = other.lastEvent;
+ this.maxEvents = other.maxEvents;
+ }
+
+ public NotificationEventRequest deepCopy() {
+ return new NotificationEventRequest(this);
+ }
+
+ @Override
+ public void clear() {
+ setLastEventIsSet(false);
+ this.lastEvent = 0;
+ setMaxEventsIsSet(false);
+ this.maxEvents = 0;
+ }
+
+ public long getLastEvent() {
+ return this.lastEvent;
+ }
+
+ public void setLastEvent(long lastEvent) {
+ this.lastEvent = lastEvent;
+ setLastEventIsSet(true);
+ }
+
+ public void unsetLastEvent() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTEVENT_ISSET_ID);
+ }
+
+ /** Returns true if field lastEvent is set (has been assigned a value) and false otherwise */
+ public boolean isSetLastEvent() {
+ return EncodingUtils.testBit(__isset_bitfield, __LASTEVENT_ISSET_ID);
+ }
+
+ public void setLastEventIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTEVENT_ISSET_ID, value);
+ }
+
+ public int getMaxEvents() {
+ return this.maxEvents;
+ }
+
+ public void setMaxEvents(int maxEvents) {
+ this.maxEvents = maxEvents;
+ setMaxEventsIsSet(true);
+ }
+
+ public void unsetMaxEvents() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXEVENTS_ISSET_ID);
+ }
+
+ /** Returns true if field maxEvents is set (has been assigned a value) and false otherwise */
+ public boolean isSetMaxEvents() {
+ return EncodingUtils.testBit(__isset_bitfield, __MAXEVENTS_ISSET_ID);
+ }
+
+ public void setMaxEventsIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXEVENTS_ISSET_ID, value);
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case LAST_EVENT:
+ if (value == null) {
+ unsetLastEvent();
+ } else {
+ setLastEvent((Long)value);
+ }
+ break;
+
+ case MAX_EVENTS:
+ if (value == null) {
+ unsetMaxEvents();
+ } else {
+ setMaxEvents((Integer)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case LAST_EVENT:
+ return getLastEvent();
+
+ case MAX_EVENTS:
+ return getMaxEvents();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case LAST_EVENT:
+ return isSetLastEvent();
+ case MAX_EVENTS:
+ return isSetMaxEvents();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof NotificationEventRequest)
+ return this.equals((NotificationEventRequest)that);
+ return false;
+ }
+
+ public boolean equals(NotificationEventRequest that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_lastEvent = true;
+ boolean that_present_lastEvent = true;
+ if (this_present_lastEvent || that_present_lastEvent) {
+ if (!(this_present_lastEvent && that_present_lastEvent))
+ return false;
+ if (this.lastEvent != that.lastEvent)
+ return false;
+ }
+
+ boolean this_present_maxEvents = true && this.isSetMaxEvents();
+ boolean that_present_maxEvents = true && that.isSetMaxEvents();
+ if (this_present_maxEvents || that_present_maxEvents) {
+ if (!(this_present_maxEvents && that_present_maxEvents))
+ return false;
+ if (this.maxEvents != that.maxEvents)
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_lastEvent = true;
+ list.add(present_lastEvent);
+ if (present_lastEvent)
+ list.add(lastEvent);
+
+ boolean present_maxEvents = true && (isSetMaxEvents());
+ list.add(present_maxEvents);
+ if (present_maxEvents)
+ list.add(maxEvents);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(NotificationEventRequest other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetLastEvent()).compareTo(other.isSetLastEvent());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetLastEvent()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lastEvent, other.lastEvent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetMaxEvents()).compareTo(other.isSetMaxEvents());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetMaxEvents()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.maxEvents, other.maxEvents);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("NotificationEventRequest(");
+ boolean first = true;
+
+ sb.append("lastEvent:");
+ sb.append(this.lastEvent);
+ first = false;
+ if (isSetMaxEvents()) {
+ if (!first) sb.append(", ");
+ sb.append("maxEvents:");
+ sb.append(this.maxEvents);
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetLastEvent()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'lastEvent' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class NotificationEventRequestStandardSchemeFactory implements SchemeFactory {
+ public NotificationEventRequestStandardScheme getScheme() {
+ return new NotificationEventRequestStandardScheme();
+ }
+ }
+
+ private static class NotificationEventRequestStandardScheme extends StandardScheme<NotificationEventRequest> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, NotificationEventRequest struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // LAST_EVENT
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.lastEvent = iprot.readI64();
+ struct.setLastEventIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // MAX_EVENTS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.maxEvents = iprot.readI32();
+ struct.setMaxEventsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, NotificationEventRequest struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(LAST_EVENT_FIELD_DESC);
+ oprot.writeI64(struct.lastEvent);
+ oprot.writeFieldEnd();
+ if (struct.isSetMaxEvents()) {
+ oprot.writeFieldBegin(MAX_EVENTS_FIELD_DESC);
+ oprot.writeI32(struct.maxEvents);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class NotificationEventRequestTupleSchemeFactory implements SchemeFactory {
+ public NotificationEventRequestTupleScheme getScheme() {
+ return new NotificationEventRequestTupleScheme();
+ }
+ }
+
+ private static class NotificationEventRequestTupleScheme extends TupleScheme<NotificationEventRequest> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, NotificationEventRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.lastEvent);
+ BitSet optionals = new BitSet();
+ if (struct.isSetMaxEvents()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetMaxEvents()) {
+ oprot.writeI32(struct.maxEvents);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventRequest struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.lastEvent = iprot.readI64();
+ struct.setLastEventIsSet(true);
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.maxEvents = iprot.readI32();
+ struct.setMaxEventsIsSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/hive/blob/20eb7b51/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
new file mode 100644
index 0000000..9228c39
--- /dev/null
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
@@ -0,0 +1,443 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class NotificationEventResponse implements org.apache.thrift.TBase<NotificationEventResponse, NotificationEventResponse._Fields>, java.io.Serializable, Cloneable, Comparable<NotificationEventResponse> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NotificationEventResponse");
+
+ private static final org.apache.thrift.protocol.TField EVENTS_FIELD_DESC = new org.apache.thrift.protocol.TField("events", org.apache.thrift.protocol.TType.LIST, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new NotificationEventResponseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new NotificationEventResponseTupleSchemeFactory());
+ }
+
+ private List<NotificationEvent> events; // required
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ EVENTS((short)1, "events");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // EVENTS
+ return EVENTS;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.EVENTS, new org.apache.thrift.meta_data.FieldMetaData("events", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, NotificationEvent.class))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(NotificationEventResponse.class, metaDataMap);
+ }
+
+ public NotificationEventResponse() {
+ }
+
+ public NotificationEventResponse(
+ List<NotificationEvent> events)
+ {
+ this();
+ this.events = events;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public NotificationEventResponse(NotificationEventResponse other) {
+ if (other.isSetEvents()) {
+ List<NotificationEvent> __this__events = new ArrayList<NotificationEvent>(other.events.size());
+ for (NotificationEvent other_element : other.events) {
+ __this__events.add(new NotificationEvent(other_element));
+ }
+ this.events = __this__events;
+ }
+ }
+
+ public NotificationEventResponse deepCopy() {
+ return new NotificationEventResponse(this);
+ }
+
+ @Override
+ public void clear() {
+ this.events = null;
+ }
+
+ public int getEventsSize() {
+ return (this.events == null) ? 0 : this.events.size();
+ }
+
+ public java.util.Iterator<NotificationEvent> getEventsIterator() {
+ return (this.events == null) ? null : this.events.iterator();
+ }
+
+ public void addToEvents(NotificationEvent elem) {
+ if (this.events == null) {
+ this.events = new ArrayList<NotificationEvent>();
+ }
+ this.events.add(elem);
+ }
+
+ public List<NotificationEvent> getEvents() {
+ return this.events;
+ }
+
+ public void setEvents(List<NotificationEvent> events) {
+ this.events = events;
+ }
+
+ public void unsetEvents() {
+ this.events = null;
+ }
+
+ /** Returns true if field events is set (has been assigned a value) and false otherwise */
+ public boolean isSetEvents() {
+ return this.events != null;
+ }
+
+ public void setEventsIsSet(boolean value) {
+ if (!value) {
+ this.events = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case EVENTS:
+ if (value == null) {
+ unsetEvents();
+ } else {
+ setEvents((List<NotificationEvent>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case EVENTS:
+ return getEvents();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case EVENTS:
+ return isSetEvents();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof NotificationEventResponse)
+ return this.equals((NotificationEventResponse)that);
+ return false;
+ }
+
+ public boolean equals(NotificationEventResponse that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_events = true && this.isSetEvents();
+ boolean that_present_events = true && that.isSetEvents();
+ if (this_present_events || that_present_events) {
+ if (!(this_present_events && that_present_events))
+ return false;
+ if (!this.events.equals(that.events))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_events = true && (isSetEvents());
+ list.add(present_events);
+ if (present_events)
+ list.add(events);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(NotificationEventResponse other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetEvents()).compareTo(other.isSetEvents());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetEvents()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.events, other.events);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("NotificationEventResponse(");
+ boolean first = true;
+
+ sb.append("events:");
+ if (this.events == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.events);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetEvents()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'events' is unset! Struct:" + toString());
+ }
+
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class NotificationEventResponseStandardSchemeFactory implements SchemeFactory {
+ public NotificationEventResponseStandardScheme getScheme() {
+ return new NotificationEventResponseStandardScheme();
+ }
+ }
+
+ private static class NotificationEventResponseStandardScheme extends StandardScheme<NotificationEventResponse> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, NotificationEventResponse struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // EVENTS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list724 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list724.size);
+ NotificationEvent _elem725;
+ for (int _i726 = 0; _i726 < _list724.size; ++_i726)
+ {
+ _elem725 = new NotificationEvent();
+ _elem725.read(iprot);
+ struct.events.add(_elem725);
+ }
+ iprot.readListEnd();
+ }
+ struct.setEventsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, NotificationEventResponse struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.events != null) {
+ oprot.writeFieldBegin(EVENTS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
+ for (NotificationEvent _iter727 : struct.events)
+ {
+ _iter727.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class NotificationEventResponseTupleSchemeFactory implements SchemeFactory {
+ public NotificationEventResponseTupleScheme getScheme() {
+ return new NotificationEventResponseTupleScheme();
+ }
+ }
+
+ private static class NotificationEventResponseTupleScheme extends TupleScheme<NotificationEventResponse> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ {
+ oprot.writeI32(struct.events.size());
+ for (NotificationEvent _iter728 : struct.events)
+ {
+ _iter728.write(oprot);
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ {
+ org.apache.thrift.protocol.TList _list729 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list729.size);
+ NotificationEvent _elem730;
+ for (int _i731 = 0; _i731 < _list729.size; ++_i731)
+ {
+ _elem730 = new NotificationEvent();
+ _elem730.read(iprot);
+ struct.events.add(_elem730);
+ }
+ }
+ struct.setEventsIsSet(true);
+ }
+ }
+
+}
+