Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id D7E21200CD9 for ; Thu, 3 Aug 2017 18:56:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id D660416ABAD; Thu, 3 Aug 2017 16:56:31 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B261C16ABA7 for ; Thu, 3 Aug 2017 18:56:29 +0200 (CEST) Received: (qmail 77619 invoked by uid 500); 3 Aug 2017 16:56:27 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 74740 invoked by uid 99); 3 Aug 2017 16:56:25 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Aug 2017 16:56:25 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 5F648F5549; Thu, 3 Aug 2017 16:56:23 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: gates@apache.org To: commits@hive.apache.org Date: Thu, 03 Aug 2017 16:56:43 -0000 Message-Id: <7087702ecbcd405d832dc07cdd40bd93@git.apache.org> In-Reply-To: <3168ec5d9aa6432cbd79c835fb89c71e@git.apache.org> References: <3168ec5d9aa6432cbd79c835fb89c71e@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [22/51] [partial] hive git commit: HIVE-17170 Move thrift generated code to stand alone metastore (Alan Gates reviewed by Vihang Karajgaonkar) archived-at: Thu, 03 Aug 2017 16:56:32 -0000 http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java deleted file mode 100644 index 8e0fb40..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEvent.java +++ /dev/null @@ -1,1006 +0,0 @@ -/** - * 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)") -public class NotificationEvent implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - 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 Map, SchemeFactory> schemes = new HashMap, 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 - - /** 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"); - - private static final Map byName = new HashMap(); - - 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; - 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}; - 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))); - 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 other. - */ - 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; - } - } - - 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; - } - - 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 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; - - } - } - - 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(); - - } - 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(); - } - 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; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - 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); - - 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; - } - } - 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; - } - 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 { - - 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; - 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(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class NotificationEventTupleSchemeFactory implements SchemeFactory { - public NotificationEventTupleScheme getScheme() { - return new NotificationEventTupleScheme(); - } - } - - private static class NotificationEventTupleScheme extends TupleScheme { - - @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); - } - oprot.writeBitSet(optionals, 3); - if (struct.isSetDbName()) { - oprot.writeString(struct.dbName); - } - if (struct.isSetTableName()) { - oprot.writeString(struct.tableName); - } - if (struct.isSetMessageFormat()) { - oprot.writeString(struct.messageFormat); - } - } - - @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(3); - 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); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java deleted file mode 100644 index bafb9b6..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventRequest.java +++ /dev/null @@ -1,490 +0,0 @@ -/** - * 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)") -public class NotificationEventRequest implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - 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, SchemeFactory> schemes = new HashMap, 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 byName = new HashMap(); - - 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 other. - */ - 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 list = new ArrayList(); - - 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 { - - 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 { - - @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/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java deleted file mode 100644 index bcfc75b..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java +++ /dev/null @@ -1,443 +0,0 @@ -/** - * 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)") -public class NotificationEventResponse implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - 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, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new NotificationEventResponseStandardSchemeFactory()); - schemes.put(TupleScheme.class, new NotificationEventResponseTupleSchemeFactory()); - } - - private List 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 byName = new HashMap(); - - 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 events) - { - this(); - this.events = events; - } - - /** - * Performs a deep copy on other. - */ - public NotificationEventResponse(NotificationEventResponse other) { - if (other.isSetEvents()) { - List __this__events = new ArrayList(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 getEventsIterator() { - return (this.events == null) ? null : this.events.iterator(); - } - - public void addToEvents(NotificationEvent elem) { - if (this.events == null) { - this.events = new ArrayList(); - } - this.events.add(elem); - } - - public List getEvents() { - return this.events; - } - - public void setEvents(List 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)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 list = new ArrayList(); - - 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 { - - 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 _list582 = iprot.readListBegin(); - struct.events = new ArrayList(_list582.size); - NotificationEvent _elem583; - for (int _i584 = 0; _i584 < _list582.size; ++_i584) - { - _elem583 = new NotificationEvent(); - _elem583.read(iprot); - struct.events.add(_elem583); - } - 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 _iter585 : struct.events) - { - _iter585.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 { - - @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 _iter586 : struct.events) - { - _iter586.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 _list587 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.events = new ArrayList(_list587.size); - NotificationEvent _elem588; - for (int _i589 = 0; _i589 < _list587.size; ++_i589) - { - _elem588 = new NotificationEvent(); - _elem588.read(iprot); - struct.events.add(_elem588); - } - } - struct.setEventsIsSet(true); - } - } - -} - http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java deleted file mode 100644 index f058c0d..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java +++ /dev/null @@ -1,702 +0,0 @@ -/** - * 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)") -public class OpenTxnRequest implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("OpenTxnRequest"); - - private static final org.apache.thrift.protocol.TField NUM_TXNS_FIELD_DESC = new org.apache.thrift.protocol.TField("num_txns", org.apache.thrift.protocol.TType.I32, (short)1); - private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)2); - private static final org.apache.thrift.protocol.TField HOSTNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("hostname", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField AGENT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("agentInfo", org.apache.thrift.protocol.TType.STRING, (short)4); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new OpenTxnRequestStandardSchemeFactory()); - schemes.put(TupleScheme.class, new OpenTxnRequestTupleSchemeFactory()); - } - - private int num_txns; // required - private String user; // required - private String hostname; // required - private String agentInfo; // 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 { - NUM_TXNS((short)1, "num_txns"), - USER((short)2, "user"), - HOSTNAME((short)3, "hostname"), - AGENT_INFO((short)4, "agentInfo"); - - private static final Map byName = new HashMap(); - - 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: // NUM_TXNS - return NUM_TXNS; - case 2: // USER - return USER; - case 3: // HOSTNAME - return HOSTNAME; - case 4: // AGENT_INFO - return AGENT_INFO; - 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 __NUM_TXNS_ISSET_ID = 0; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.AGENT_INFO}; - 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.NUM_TXNS, new org.apache.thrift.meta_data.FieldMetaData("num_txns", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.USER, new org.apache.thrift.meta_data.FieldMetaData("user", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.HOSTNAME, new org.apache.thrift.meta_data.FieldMetaData("hostname", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.AGENT_INFO, new org.apache.thrift.meta_data.FieldMetaData("agentInfo", 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(OpenTxnRequest.class, metaDataMap); - } - - public OpenTxnRequest() { - this.agentInfo = "Unknown"; - - } - - public OpenTxnRequest( - int num_txns, - String user, - String hostname) - { - this(); - this.num_txns = num_txns; - setNum_txnsIsSet(true); - this.user = user; - this.hostname = hostname; - } - - /** - * Performs a deep copy on other. - */ - public OpenTxnRequest(OpenTxnRequest other) { - __isset_bitfield = other.__isset_bitfield; - this.num_txns = other.num_txns; - if (other.isSetUser()) { - this.user = other.user; - } - if (other.isSetHostname()) { - this.hostname = other.hostname; - } - if (other.isSetAgentInfo()) { - this.agentInfo = other.agentInfo; - } - } - - public OpenTxnRequest deepCopy() { - return new OpenTxnRequest(this); - } - - @Override - public void clear() { - setNum_txnsIsSet(false); - this.num_txns = 0; - this.user = null; - this.hostname = null; - this.agentInfo = "Unknown"; - - } - - public int getNum_txns() { - return this.num_txns; - } - - public void setNum_txns(int num_txns) { - this.num_txns = num_txns; - setNum_txnsIsSet(true); - } - - public void unsetNum_txns() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUM_TXNS_ISSET_ID); - } - - /** Returns true if field num_txns is set (has been assigned a value) and false otherwise */ - public boolean isSetNum_txns() { - return EncodingUtils.testBit(__isset_bitfield, __NUM_TXNS_ISSET_ID); - } - - public void setNum_txnsIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUM_TXNS_ISSET_ID, value); - } - - public String getUser() { - return this.user; - } - - public void setUser(String user) { - this.user = user; - } - - public void unsetUser() { - this.user = null; - } - - /** Returns true if field user is set (has been assigned a value) and false otherwise */ - public boolean isSetUser() { - return this.user != null; - } - - public void setUserIsSet(boolean value) { - if (!value) { - this.user = null; - } - } - - public String getHostname() { - return this.hostname; - } - - public void setHostname(String hostname) { - this.hostname = hostname; - } - - public void unsetHostname() { - this.hostname = null; - } - - /** Returns true if field hostname is set (has been assigned a value) and false otherwise */ - public boolean isSetHostname() { - return this.hostname != null; - } - - public void setHostnameIsSet(boolean value) { - if (!value) { - this.hostname = null; - } - } - - public String getAgentInfo() { - return this.agentInfo; - } - - public void setAgentInfo(String agentInfo) { - this.agentInfo = agentInfo; - } - - public void unsetAgentInfo() { - this.agentInfo = null; - } - - /** Returns true if field agentInfo is set (has been assigned a value) and false otherwise */ - public boolean isSetAgentInfo() { - return this.agentInfo != null; - } - - public void setAgentInfoIsSet(boolean value) { - if (!value) { - this.agentInfo = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case NUM_TXNS: - if (value == null) { - unsetNum_txns(); - } else { - setNum_txns((Integer)value); - } - break; - - case USER: - if (value == null) { - unsetUser(); - } else { - setUser((String)value); - } - break; - - case HOSTNAME: - if (value == null) { - unsetHostname(); - } else { - setHostname((String)value); - } - break; - - case AGENT_INFO: - if (value == null) { - unsetAgentInfo(); - } else { - setAgentInfo((String)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case NUM_TXNS: - return getNum_txns(); - - case USER: - return getUser(); - - case HOSTNAME: - return getHostname(); - - case AGENT_INFO: - return getAgentInfo(); - - } - 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 NUM_TXNS: - return isSetNum_txns(); - case USER: - return isSetUser(); - case HOSTNAME: - return isSetHostname(); - case AGENT_INFO: - return isSetAgentInfo(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof OpenTxnRequest) - return this.equals((OpenTxnRequest)that); - return false; - } - - public boolean equals(OpenTxnRequest that) { - if (that == null) - return false; - - boolean this_present_num_txns = true; - boolean that_present_num_txns = true; - if (this_present_num_txns || that_present_num_txns) { - if (!(this_present_num_txns && that_present_num_txns)) - return false; - if (this.num_txns != that.num_txns) - return false; - } - - boolean this_present_user = true && this.isSetUser(); - boolean that_present_user = true && that.isSetUser(); - if (this_present_user || that_present_user) { - if (!(this_present_user && that_present_user)) - return false; - if (!this.user.equals(that.user)) - return false; - } - - boolean this_present_hostname = true && this.isSetHostname(); - boolean that_present_hostname = true && that.isSetHostname(); - if (this_present_hostname || that_present_hostname) { - if (!(this_present_hostname && that_present_hostname)) - return false; - if (!this.hostname.equals(that.hostname)) - return false; - } - - boolean this_present_agentInfo = true && this.isSetAgentInfo(); - boolean that_present_agentInfo = true && that.isSetAgentInfo(); - if (this_present_agentInfo || that_present_agentInfo) { - if (!(this_present_agentInfo && that_present_agentInfo)) - return false; - if (!this.agentInfo.equals(that.agentInfo)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_num_txns = true; - list.add(present_num_txns); - if (present_num_txns) - list.add(num_txns); - - boolean present_user = true && (isSetUser()); - list.add(present_user); - if (present_user) - list.add(user); - - boolean present_hostname = true && (isSetHostname()); - list.add(present_hostname); - if (present_hostname) - list.add(hostname); - - boolean present_agentInfo = true && (isSetAgentInfo()); - list.add(present_agentInfo); - if (present_agentInfo) - list.add(agentInfo); - - return list.hashCode(); - } - - @Override - public int compareTo(OpenTxnRequest other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetNum_txns()).compareTo(other.isSetNum_txns()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetNum_txns()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.num_txns, other.num_txns); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetUser()).compareTo(other.isSetUser()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUser()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.user, other.user); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetHostname()).compareTo(other.isSetHostname()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetHostname()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.hostname, other.hostname); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetAgentInfo()).compareTo(other.isSetAgentInfo()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetAgentInfo()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.agentInfo, other.agentInfo); - 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("OpenTxnRequest("); - boolean first = true; - - sb.append("num_txns:"); - sb.append(this.num_txns); - first = false; - if (!first) sb.append(", "); - sb.append("user:"); - if (this.user == null) { - sb.append("null"); - } else { - sb.append(this.user); - } - first = false; - if (!first) sb.append(", "); - sb.append("hostname:"); - if (this.hostname == null) { - sb.append("null"); - } else { - sb.append(this.hostname); - } - first = false; - if (isSetAgentInfo()) { - if (!first) sb.append(", "); - sb.append("agentInfo:"); - if (this.agentInfo == null) { - sb.append("null"); - } else { - sb.append(this.agentInfo); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (!isSetNum_txns()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'num_txns' is unset! Struct:" + toString()); - } - - if (!isSetUser()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'user' is unset! Struct:" + toString()); - } - - if (!isSetHostname()) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'hostname' 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 OpenTxnRequestStandardSchemeFactory implements SchemeFactory { - public OpenTxnRequestStandardScheme getScheme() { - return new OpenTxnRequestStandardScheme(); - } - } - - private static class OpenTxnRequestStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, OpenTxnRequest 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: // NUM_TXNS - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.num_txns = iprot.readI32(); - struct.setNum_txnsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // USER - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.user = iprot.readString(); - struct.setUserIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // HOSTNAME - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.hostname = iprot.readString(); - struct.setHostnameIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // AGENT_INFO - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.agentInfo = iprot.readString(); - struct.setAgentInfoIsSet(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, OpenTxnRequest struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - oprot.writeFieldBegin(NUM_TXNS_FIELD_DESC); - oprot.writeI32(struct.num_txns); - oprot.writeFieldEnd(); - if (struct.user != null) { - oprot.writeFieldBegin(USER_FIELD_DESC); - oprot.writeString(struct.user); - oprot.writeFieldEnd(); - } - if (struct.hostname != null) { - oprot.writeFieldBegin(HOSTNAME_FIELD_DESC); - oprot.writeString(struct.hostname); - oprot.writeFieldEnd(); - } - if (struct.agentInfo != null) { - if (struct.isSetAgentInfo()) { - oprot.writeFieldBegin(AGENT_INFO_FIELD_DESC); - oprot.writeString(struct.agentInfo); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class OpenTxnRequestTupleSchemeFactory implements SchemeFactory { - public OpenTxnRequestTupleScheme getScheme() { - return new OpenTxnRequestTupleScheme(); - } - } - - private static class OpenTxnRequestTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, OpenTxnRequest struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - oprot.writeI32(struct.num_txns); - oprot.writeString(struct.user); - oprot.writeString(struct.hostname); - BitSet optionals = new BitSet(); - if (struct.isSetAgentInfo()) { - optionals.set(0); - } - oprot.writeBitSet(optionals, 1); - if (struct.isSetAgentInfo()) { - oprot.writeString(struct.agentInfo); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnRequest struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.num_txns = iprot.readI32(); - struct.setNum_txnsIsSet(true); - struct.user = iprot.readString(); - struct.setUserIsSet(true); - struct.hostname = iprot.readString(); - struct.setHostnameIsSet(true); - BitSet incoming = iprot.readBitSet(1); - if (incoming.get(0)) { - struct.agentInfo = iprot.readString(); - struct.setAgentInfoIsSet(true); - } - } - } - -} -