You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2017/08/03 16:56:46 UTC
[25/51] [partial] hive git commit: HIVE-17170 Move thrift generated
code to stand alone metastore (Alan Gates reviewed by Vihang Karajgaonkar)
http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InvalidPartitionException.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InvalidPartitionException.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InvalidPartitionException.java
deleted file mode 100644
index ef71511..0000000
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InvalidPartitionException.java
+++ /dev/null
@@ -1,395 +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 InvalidPartitionException extends TException implements org.apache.thrift.TBase<InvalidPartitionException, InvalidPartitionException._Fields>, java.io.Serializable, Cloneable, Comparable<InvalidPartitionException> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("InvalidPartitionException");
-
- 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)1);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new InvalidPartitionExceptionStandardSchemeFactory());
- schemes.put(TupleScheme.class, new InvalidPartitionExceptionTupleSchemeFactory());
- }
-
- private String message; // 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 {
- MESSAGE((short)1, "message");
-
- 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: // MESSAGE
- return MESSAGE;
- 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.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(InvalidPartitionException.class, metaDataMap);
- }
-
- public InvalidPartitionException() {
- }
-
- public InvalidPartitionException(
- String message)
- {
- this();
- this.message = message;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public InvalidPartitionException(InvalidPartitionException other) {
- if (other.isSetMessage()) {
- this.message = other.message;
- }
- }
-
- public InvalidPartitionException deepCopy() {
- return new InvalidPartitionException(this);
- }
-
- @Override
- public void clear() {
- this.message = 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 void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case MESSAGE:
- if (value == null) {
- unsetMessage();
- } else {
- setMessage((String)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case MESSAGE:
- return getMessage();
-
- }
- 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 MESSAGE:
- return isSetMessage();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof InvalidPartitionException)
- return this.equals((InvalidPartitionException)that);
- return false;
- }
-
- public boolean equals(InvalidPartitionException that) {
- if (that == null)
- 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;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_message = true && (isSetMessage());
- list.add(present_message);
- if (present_message)
- list.add(message);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(InvalidPartitionException other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- 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;
- }
- }
- 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("InvalidPartitionException(");
- boolean first = true;
-
- sb.append("message:");
- if (this.message == null) {
- sb.append("null");
- } else {
- sb.append(this.message);
- }
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- // 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 InvalidPartitionExceptionStandardSchemeFactory implements SchemeFactory {
- public InvalidPartitionExceptionStandardScheme getScheme() {
- return new InvalidPartitionExceptionStandardScheme();
- }
- }
-
- private static class InvalidPartitionExceptionStandardScheme extends StandardScheme<InvalidPartitionException> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, InvalidPartitionException 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: // 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;
- 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, InvalidPartitionException struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.message != null) {
- oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
- oprot.writeString(struct.message);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class InvalidPartitionExceptionTupleSchemeFactory implements SchemeFactory {
- public InvalidPartitionExceptionTupleScheme getScheme() {
- return new InvalidPartitionExceptionTupleScheme();
- }
- }
-
- private static class InvalidPartitionExceptionTupleScheme extends TupleScheme<InvalidPartitionException> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, InvalidPartitionException struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.isSetMessage()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.isSetMessage()) {
- oprot.writeString(struct.message);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, InvalidPartitionException struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.message = iprot.readString();
- struct.setMessageIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockComponent.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockComponent.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockComponent.java
deleted file mode 100644
index d349508..0000000
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockComponent.java
+++ /dev/null
@@ -1,1158 +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 LockComponent implements org.apache.thrift.TBase<LockComponent, LockComponent._Fields>, java.io.Serializable, Cloneable, Comparable<LockComponent> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LockComponent");
-
- private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)1);
- private static final org.apache.thrift.protocol.TField LEVEL_FIELD_DESC = new org.apache.thrift.protocol.TField("level", org.apache.thrift.protocol.TType.I32, (short)2);
- private static final org.apache.thrift.protocol.TField DBNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbname", org.apache.thrift.protocol.TType.STRING, (short)3);
- private static final org.apache.thrift.protocol.TField TABLENAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tablename", org.apache.thrift.protocol.TType.STRING, (short)4);
- private static final org.apache.thrift.protocol.TField PARTITIONNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionname", org.apache.thrift.protocol.TType.STRING, (short)5);
- private static final org.apache.thrift.protocol.TField OPERATION_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("operationType", org.apache.thrift.protocol.TType.I32, (short)6);
- private static final org.apache.thrift.protocol.TField IS_ACID_FIELD_DESC = new org.apache.thrift.protocol.TField("isAcid", org.apache.thrift.protocol.TType.BOOL, (short)7);
- private static final org.apache.thrift.protocol.TField IS_DYNAMIC_PARTITION_WRITE_FIELD_DESC = new org.apache.thrift.protocol.TField("isDynamicPartitionWrite", org.apache.thrift.protocol.TType.BOOL, (short)8);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new LockComponentStandardSchemeFactory());
- schemes.put(TupleScheme.class, new LockComponentTupleSchemeFactory());
- }
-
- private LockType type; // required
- private LockLevel level; // required
- private String dbname; // required
- private String tablename; // optional
- private String partitionname; // optional
- private DataOperationType operationType; // optional
- private boolean isAcid; // optional
- private boolean isDynamicPartitionWrite; // 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 {
- /**
- *
- * @see LockType
- */
- TYPE((short)1, "type"),
- /**
- *
- * @see LockLevel
- */
- LEVEL((short)2, "level"),
- DBNAME((short)3, "dbname"),
- TABLENAME((short)4, "tablename"),
- PARTITIONNAME((short)5, "partitionname"),
- /**
- *
- * @see DataOperationType
- */
- OPERATION_TYPE((short)6, "operationType"),
- IS_ACID((short)7, "isAcid"),
- IS_DYNAMIC_PARTITION_WRITE((short)8, "isDynamicPartitionWrite");
-
- 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: // TYPE
- return TYPE;
- case 2: // LEVEL
- return LEVEL;
- case 3: // DBNAME
- return DBNAME;
- case 4: // TABLENAME
- return TABLENAME;
- case 5: // PARTITIONNAME
- return PARTITIONNAME;
- case 6: // OPERATION_TYPE
- return OPERATION_TYPE;
- case 7: // IS_ACID
- return IS_ACID;
- case 8: // IS_DYNAMIC_PARTITION_WRITE
- return IS_DYNAMIC_PARTITION_WRITE;
- 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 __ISACID_ISSET_ID = 0;
- private static final int __ISDYNAMICPARTITIONWRITE_ISSET_ID = 1;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.TABLENAME,_Fields.PARTITIONNAME,_Fields.OPERATION_TYPE,_Fields.IS_ACID,_Fields.IS_DYNAMIC_PARTITION_WRITE};
- 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.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, LockType.class)));
- tmpMap.put(_Fields.LEVEL, new org.apache.thrift.meta_data.FieldMetaData("level", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, LockLevel.class)));
- tmpMap.put(_Fields.DBNAME, new org.apache.thrift.meta_data.FieldMetaData("dbname", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.TABLENAME, 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.PARTITIONNAME, new org.apache.thrift.meta_data.FieldMetaData("partitionname", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.OPERATION_TYPE, new org.apache.thrift.meta_data.FieldMetaData("operationType", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, DataOperationType.class)));
- tmpMap.put(_Fields.IS_ACID, new org.apache.thrift.meta_data.FieldMetaData("isAcid", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
- tmpMap.put(_Fields.IS_DYNAMIC_PARTITION_WRITE, new org.apache.thrift.meta_data.FieldMetaData("isDynamicPartitionWrite", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(LockComponent.class, metaDataMap);
- }
-
- public LockComponent() {
- this.operationType = org.apache.hadoop.hive.metastore.api.DataOperationType.UNSET;
-
- this.isAcid = false;
-
- this.isDynamicPartitionWrite = false;
-
- }
-
- public LockComponent(
- LockType type,
- LockLevel level,
- String dbname)
- {
- this();
- this.type = type;
- this.level = level;
- this.dbname = dbname;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public LockComponent(LockComponent other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.isSetType()) {
- this.type = other.type;
- }
- if (other.isSetLevel()) {
- this.level = other.level;
- }
- if (other.isSetDbname()) {
- this.dbname = other.dbname;
- }
- if (other.isSetTablename()) {
- this.tablename = other.tablename;
- }
- if (other.isSetPartitionname()) {
- this.partitionname = other.partitionname;
- }
- if (other.isSetOperationType()) {
- this.operationType = other.operationType;
- }
- this.isAcid = other.isAcid;
- this.isDynamicPartitionWrite = other.isDynamicPartitionWrite;
- }
-
- public LockComponent deepCopy() {
- return new LockComponent(this);
- }
-
- @Override
- public void clear() {
- this.type = null;
- this.level = null;
- this.dbname = null;
- this.tablename = null;
- this.partitionname = null;
- this.operationType = org.apache.hadoop.hive.metastore.api.DataOperationType.UNSET;
-
- this.isAcid = false;
-
- this.isDynamicPartitionWrite = false;
-
- }
-
- /**
- *
- * @see LockType
- */
- public LockType getType() {
- return this.type;
- }
-
- /**
- *
- * @see LockType
- */
- public void setType(LockType type) {
- this.type = type;
- }
-
- public void unsetType() {
- this.type = null;
- }
-
- /** Returns true if field type is set (has been assigned a value) and false otherwise */
- public boolean isSetType() {
- return this.type != null;
- }
-
- public void setTypeIsSet(boolean value) {
- if (!value) {
- this.type = null;
- }
- }
-
- /**
- *
- * @see LockLevel
- */
- public LockLevel getLevel() {
- return this.level;
- }
-
- /**
- *
- * @see LockLevel
- */
- public void setLevel(LockLevel level) {
- this.level = level;
- }
-
- public void unsetLevel() {
- this.level = null;
- }
-
- /** Returns true if field level is set (has been assigned a value) and false otherwise */
- public boolean isSetLevel() {
- return this.level != null;
- }
-
- public void setLevelIsSet(boolean value) {
- if (!value) {
- this.level = 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 getPartitionname() {
- return this.partitionname;
- }
-
- public void setPartitionname(String partitionname) {
- this.partitionname = partitionname;
- }
-
- public void unsetPartitionname() {
- this.partitionname = null;
- }
-
- /** Returns true if field partitionname is set (has been assigned a value) and false otherwise */
- public boolean isSetPartitionname() {
- return this.partitionname != null;
- }
-
- public void setPartitionnameIsSet(boolean value) {
- if (!value) {
- this.partitionname = null;
- }
- }
-
- /**
- *
- * @see DataOperationType
- */
- public DataOperationType getOperationType() {
- return this.operationType;
- }
-
- /**
- *
- * @see DataOperationType
- */
- public void setOperationType(DataOperationType operationType) {
- this.operationType = operationType;
- }
-
- public void unsetOperationType() {
- this.operationType = null;
- }
-
- /** Returns true if field operationType is set (has been assigned a value) and false otherwise */
- public boolean isSetOperationType() {
- return this.operationType != null;
- }
-
- public void setOperationTypeIsSet(boolean value) {
- if (!value) {
- this.operationType = null;
- }
- }
-
- public boolean isIsAcid() {
- return this.isAcid;
- }
-
- public void setIsAcid(boolean isAcid) {
- this.isAcid = isAcid;
- setIsAcidIsSet(true);
- }
-
- public void unsetIsAcid() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISACID_ISSET_ID);
- }
-
- /** Returns true if field isAcid is set (has been assigned a value) and false otherwise */
- public boolean isSetIsAcid() {
- return EncodingUtils.testBit(__isset_bitfield, __ISACID_ISSET_ID);
- }
-
- public void setIsAcidIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISACID_ISSET_ID, value);
- }
-
- public boolean isIsDynamicPartitionWrite() {
- return this.isDynamicPartitionWrite;
- }
-
- public void setIsDynamicPartitionWrite(boolean isDynamicPartitionWrite) {
- this.isDynamicPartitionWrite = isDynamicPartitionWrite;
- setIsDynamicPartitionWriteIsSet(true);
- }
-
- public void unsetIsDynamicPartitionWrite() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __ISDYNAMICPARTITIONWRITE_ISSET_ID);
- }
-
- /** Returns true if field isDynamicPartitionWrite is set (has been assigned a value) and false otherwise */
- public boolean isSetIsDynamicPartitionWrite() {
- return EncodingUtils.testBit(__isset_bitfield, __ISDYNAMICPARTITIONWRITE_ISSET_ID);
- }
-
- public void setIsDynamicPartitionWriteIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __ISDYNAMICPARTITIONWRITE_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case TYPE:
- if (value == null) {
- unsetType();
- } else {
- setType((LockType)value);
- }
- break;
-
- case LEVEL:
- if (value == null) {
- unsetLevel();
- } else {
- setLevel((LockLevel)value);
- }
- break;
-
- case DBNAME:
- if (value == null) {
- unsetDbname();
- } else {
- setDbname((String)value);
- }
- break;
-
- case TABLENAME:
- if (value == null) {
- unsetTablename();
- } else {
- setTablename((String)value);
- }
- break;
-
- case PARTITIONNAME:
- if (value == null) {
- unsetPartitionname();
- } else {
- setPartitionname((String)value);
- }
- break;
-
- case OPERATION_TYPE:
- if (value == null) {
- unsetOperationType();
- } else {
- setOperationType((DataOperationType)value);
- }
- break;
-
- case IS_ACID:
- if (value == null) {
- unsetIsAcid();
- } else {
- setIsAcid((Boolean)value);
- }
- break;
-
- case IS_DYNAMIC_PARTITION_WRITE:
- if (value == null) {
- unsetIsDynamicPartitionWrite();
- } else {
- setIsDynamicPartitionWrite((Boolean)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case TYPE:
- return getType();
-
- case LEVEL:
- return getLevel();
-
- case DBNAME:
- return getDbname();
-
- case TABLENAME:
- return getTablename();
-
- case PARTITIONNAME:
- return getPartitionname();
-
- case OPERATION_TYPE:
- return getOperationType();
-
- case IS_ACID:
- return isIsAcid();
-
- case IS_DYNAMIC_PARTITION_WRITE:
- return isIsDynamicPartitionWrite();
-
- }
- 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 TYPE:
- return isSetType();
- case LEVEL:
- return isSetLevel();
- case DBNAME:
- return isSetDbname();
- case TABLENAME:
- return isSetTablename();
- case PARTITIONNAME:
- return isSetPartitionname();
- case OPERATION_TYPE:
- return isSetOperationType();
- case IS_ACID:
- return isSetIsAcid();
- case IS_DYNAMIC_PARTITION_WRITE:
- return isSetIsDynamicPartitionWrite();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof LockComponent)
- return this.equals((LockComponent)that);
- return false;
- }
-
- public boolean equals(LockComponent that) {
- if (that == null)
- return false;
-
- boolean this_present_type = true && this.isSetType();
- boolean that_present_type = true && that.isSetType();
- if (this_present_type || that_present_type) {
- if (!(this_present_type && that_present_type))
- return false;
- if (!this.type.equals(that.type))
- return false;
- }
-
- boolean this_present_level = true && this.isSetLevel();
- boolean that_present_level = true && that.isSetLevel();
- if (this_present_level || that_present_level) {
- if (!(this_present_level && that_present_level))
- return false;
- if (!this.level.equals(that.level))
- 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_partitionname = true && this.isSetPartitionname();
- boolean that_present_partitionname = true && that.isSetPartitionname();
- if (this_present_partitionname || that_present_partitionname) {
- if (!(this_present_partitionname && that_present_partitionname))
- return false;
- if (!this.partitionname.equals(that.partitionname))
- return false;
- }
-
- boolean this_present_operationType = true && this.isSetOperationType();
- boolean that_present_operationType = true && that.isSetOperationType();
- if (this_present_operationType || that_present_operationType) {
- if (!(this_present_operationType && that_present_operationType))
- return false;
- if (!this.operationType.equals(that.operationType))
- return false;
- }
-
- boolean this_present_isAcid = true && this.isSetIsAcid();
- boolean that_present_isAcid = true && that.isSetIsAcid();
- if (this_present_isAcid || that_present_isAcid) {
- if (!(this_present_isAcid && that_present_isAcid))
- return false;
- if (this.isAcid != that.isAcid)
- return false;
- }
-
- boolean this_present_isDynamicPartitionWrite = true && this.isSetIsDynamicPartitionWrite();
- boolean that_present_isDynamicPartitionWrite = true && that.isSetIsDynamicPartitionWrite();
- if (this_present_isDynamicPartitionWrite || that_present_isDynamicPartitionWrite) {
- if (!(this_present_isDynamicPartitionWrite && that_present_isDynamicPartitionWrite))
- return false;
- if (this.isDynamicPartitionWrite != that.isDynamicPartitionWrite)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_type = true && (isSetType());
- list.add(present_type);
- if (present_type)
- list.add(type.getValue());
-
- boolean present_level = true && (isSetLevel());
- list.add(present_level);
- if (present_level)
- list.add(level.getValue());
-
- 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_partitionname = true && (isSetPartitionname());
- list.add(present_partitionname);
- if (present_partitionname)
- list.add(partitionname);
-
- boolean present_operationType = true && (isSetOperationType());
- list.add(present_operationType);
- if (present_operationType)
- list.add(operationType.getValue());
-
- boolean present_isAcid = true && (isSetIsAcid());
- list.add(present_isAcid);
- if (present_isAcid)
- list.add(isAcid);
-
- boolean present_isDynamicPartitionWrite = true && (isSetIsDynamicPartitionWrite());
- list.add(present_isDynamicPartitionWrite);
- if (present_isDynamicPartitionWrite)
- list.add(isDynamicPartitionWrite);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(LockComponent other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(isSetType()).compareTo(other.isSetType());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetType()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, other.type);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetLevel()).compareTo(other.isSetLevel());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetLevel()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.level, other.level);
- 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(isSetPartitionname()).compareTo(other.isSetPartitionname());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetPartitionname()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitionname, other.partitionname);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetOperationType()).compareTo(other.isSetOperationType());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetOperationType()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.operationType, other.operationType);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetIsAcid()).compareTo(other.isSetIsAcid());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetIsAcid()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isAcid, other.isAcid);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetIsDynamicPartitionWrite()).compareTo(other.isSetIsDynamicPartitionWrite());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetIsDynamicPartitionWrite()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.isDynamicPartitionWrite, other.isDynamicPartitionWrite);
- 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("LockComponent(");
- boolean first = true;
-
- sb.append("type:");
- if (this.type == null) {
- sb.append("null");
- } else {
- sb.append(this.type);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("level:");
- if (this.level == null) {
- sb.append("null");
- } else {
- sb.append(this.level);
- }
- first = false;
- 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 (isSetPartitionname()) {
- if (!first) sb.append(", ");
- sb.append("partitionname:");
- if (this.partitionname == null) {
- sb.append("null");
- } else {
- sb.append(this.partitionname);
- }
- first = false;
- }
- if (isSetOperationType()) {
- if (!first) sb.append(", ");
- sb.append("operationType:");
- if (this.operationType == null) {
- sb.append("null");
- } else {
- sb.append(this.operationType);
- }
- first = false;
- }
- if (isSetIsAcid()) {
- if (!first) sb.append(", ");
- sb.append("isAcid:");
- sb.append(this.isAcid);
- first = false;
- }
- if (isSetIsDynamicPartitionWrite()) {
- if (!first) sb.append(", ");
- sb.append("isDynamicPartitionWrite:");
- sb.append(this.isDynamicPartitionWrite);
- first = false;
- }
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- if (!isSetType()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'type' is unset! Struct:" + toString());
- }
-
- if (!isSetLevel()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'level' is unset! Struct:" + toString());
- }
-
- if (!isSetDbname()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'dbname' 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 LockComponentStandardSchemeFactory implements SchemeFactory {
- public LockComponentStandardScheme getScheme() {
- return new LockComponentStandardScheme();
- }
- }
-
- private static class LockComponentStandardScheme extends StandardScheme<LockComponent> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, LockComponent 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: // TYPE
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.type = org.apache.hadoop.hive.metastore.api.LockType.findByValue(iprot.readI32());
- struct.setTypeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // LEVEL
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.level = org.apache.hadoop.hive.metastore.api.LockLevel.findByValue(iprot.readI32());
- struct.setLevelIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // DBNAME
- 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 4: // TABLENAME
- 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 5: // PARTITIONNAME
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.partitionname = iprot.readString();
- struct.setPartitionnameIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 6: // OPERATION_TYPE
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.operationType = org.apache.hadoop.hive.metastore.api.DataOperationType.findByValue(iprot.readI32());
- struct.setOperationTypeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 7: // IS_ACID
- if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
- struct.isAcid = iprot.readBool();
- struct.setIsAcidIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 8: // IS_DYNAMIC_PARTITION_WRITE
- if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
- struct.isDynamicPartitionWrite = iprot.readBool();
- struct.setIsDynamicPartitionWriteIsSet(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, LockComponent struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.type != null) {
- oprot.writeFieldBegin(TYPE_FIELD_DESC);
- oprot.writeI32(struct.type.getValue());
- oprot.writeFieldEnd();
- }
- if (struct.level != null) {
- oprot.writeFieldBegin(LEVEL_FIELD_DESC);
- oprot.writeI32(struct.level.getValue());
- oprot.writeFieldEnd();
- }
- if (struct.dbname != null) {
- oprot.writeFieldBegin(DBNAME_FIELD_DESC);
- oprot.writeString(struct.dbname);
- oprot.writeFieldEnd();
- }
- if (struct.tablename != null) {
- if (struct.isSetTablename()) {
- oprot.writeFieldBegin(TABLENAME_FIELD_DESC);
- oprot.writeString(struct.tablename);
- oprot.writeFieldEnd();
- }
- }
- if (struct.partitionname != null) {
- if (struct.isSetPartitionname()) {
- oprot.writeFieldBegin(PARTITIONNAME_FIELD_DESC);
- oprot.writeString(struct.partitionname);
- oprot.writeFieldEnd();
- }
- }
- if (struct.operationType != null) {
- if (struct.isSetOperationType()) {
- oprot.writeFieldBegin(OPERATION_TYPE_FIELD_DESC);
- oprot.writeI32(struct.operationType.getValue());
- oprot.writeFieldEnd();
- }
- }
- if (struct.isSetIsAcid()) {
- oprot.writeFieldBegin(IS_ACID_FIELD_DESC);
- oprot.writeBool(struct.isAcid);
- oprot.writeFieldEnd();
- }
- if (struct.isSetIsDynamicPartitionWrite()) {
- oprot.writeFieldBegin(IS_DYNAMIC_PARTITION_WRITE_FIELD_DESC);
- oprot.writeBool(struct.isDynamicPartitionWrite);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class LockComponentTupleSchemeFactory implements SchemeFactory {
- public LockComponentTupleScheme getScheme() {
- return new LockComponentTupleScheme();
- }
- }
-
- private static class LockComponentTupleScheme extends TupleScheme<LockComponent> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, LockComponent struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- oprot.writeI32(struct.type.getValue());
- oprot.writeI32(struct.level.getValue());
- oprot.writeString(struct.dbname);
- BitSet optionals = new BitSet();
- if (struct.isSetTablename()) {
- optionals.set(0);
- }
- if (struct.isSetPartitionname()) {
- optionals.set(1);
- }
- if (struct.isSetOperationType()) {
- optionals.set(2);
- }
- if (struct.isSetIsAcid()) {
- optionals.set(3);
- }
- if (struct.isSetIsDynamicPartitionWrite()) {
- optionals.set(4);
- }
- oprot.writeBitSet(optionals, 5);
- if (struct.isSetTablename()) {
- oprot.writeString(struct.tablename);
- }
- if (struct.isSetPartitionname()) {
- oprot.writeString(struct.partitionname);
- }
- if (struct.isSetOperationType()) {
- oprot.writeI32(struct.operationType.getValue());
- }
- if (struct.isSetIsAcid()) {
- oprot.writeBool(struct.isAcid);
- }
- if (struct.isSetIsDynamicPartitionWrite()) {
- oprot.writeBool(struct.isDynamicPartitionWrite);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, LockComponent struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- struct.type = org.apache.hadoop.hive.metastore.api.LockType.findByValue(iprot.readI32());
- struct.setTypeIsSet(true);
- struct.level = org.apache.hadoop.hive.metastore.api.LockLevel.findByValue(iprot.readI32());
- struct.setLevelIsSet(true);
- struct.dbname = iprot.readString();
- struct.setDbnameIsSet(true);
- BitSet incoming = iprot.readBitSet(5);
- if (incoming.get(0)) {
- struct.tablename = iprot.readString();
- struct.setTablenameIsSet(true);
- }
- if (incoming.get(1)) {
- struct.partitionname = iprot.readString();
- struct.setPartitionnameIsSet(true);
- }
- if (incoming.get(2)) {
- struct.operationType = org.apache.hadoop.hive.metastore.api.DataOperationType.findByValue(iprot.readI32());
- struct.setOperationTypeIsSet(true);
- }
- if (incoming.get(3)) {
- struct.isAcid = iprot.readBool();
- struct.setIsAcidIsSet(true);
- }
- if (incoming.get(4)) {
- struct.isDynamicPartitionWrite = iprot.readBool();
- struct.setIsDynamicPartitionWriteIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockLevel.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockLevel.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockLevel.java
deleted file mode 100644
index e58ea46..0000000
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockLevel.java
+++ /dev/null
@@ -1,48 +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 java.util.Map;
-import java.util.HashMap;
-import org.apache.thrift.TEnum;
-
-public enum LockLevel implements org.apache.thrift.TEnum {
- DB(1),
- TABLE(2),
- PARTITION(3);
-
- private final int value;
-
- private LockLevel(int value) {
- this.value = value;
- }
-
- /**
- * Get the integer value of this enum value, as defined in the Thrift IDL.
- */
- public int getValue() {
- return value;
- }
-
- /**
- * Find a the enum type by its integer value, as defined in the Thrift IDL.
- * @return null if the value is not found.
- */
- public static LockLevel findByValue(int value) {
- switch (value) {
- case 1:
- return DB;
- case 2:
- return TABLE;
- case 3:
- return PARTITION;
- default:
- return null;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
deleted file mode 100644
index 833adbb..0000000
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ /dev/null
@@ -1,861 +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 LockRequest implements org.apache.thrift.TBase<LockRequest, LockRequest._Fields>, java.io.Serializable, Cloneable, Comparable<LockRequest> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("LockRequest");
-
- private static final org.apache.thrift.protocol.TField COMPONENT_FIELD_DESC = new org.apache.thrift.protocol.TField("component", org.apache.thrift.protocol.TType.LIST, (short)1);
- private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)2);
- 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)3);
- 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)4);
- 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)5);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new LockRequestStandardSchemeFactory());
- schemes.put(TupleScheme.class, new LockRequestTupleSchemeFactory());
- }
-
- private List<LockComponent> component; // required
- private long txnid; // optional
- 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 {
- COMPONENT((short)1, "component"),
- TXNID((short)2, "txnid"),
- USER((short)3, "user"),
- HOSTNAME((short)4, "hostname"),
- AGENT_INFO((short)5, "agentInfo");
-
- 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: // COMPONENT
- return COMPONENT;
- case 2: // TXNID
- return TXNID;
- case 3: // USER
- return USER;
- case 4: // HOSTNAME
- return HOSTNAME;
- case 5: // 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 __TXNID_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.TXNID,_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.COMPONENT, new org.apache.thrift.meta_data.FieldMetaData("component", 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, LockComponent.class))));
- tmpMap.put(_Fields.TXNID, new org.apache.thrift.meta_data.FieldMetaData("txnid", org.apache.thrift.TFieldRequirementType.OPTIONAL,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- 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(LockRequest.class, metaDataMap);
- }
-
- public LockRequest() {
- this.agentInfo = "Unknown";
-
- }
-
- public LockRequest(
- List<LockComponent> component,
- String user,
- String hostname)
- {
- this();
- this.component = component;
- this.user = user;
- this.hostname = hostname;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public LockRequest(LockRequest other) {
- __isset_bitfield = other.__isset_bitfield;
- if (other.isSetComponent()) {
- List<LockComponent> __this__component = new ArrayList<LockComponent>(other.component.size());
- for (LockComponent other_element : other.component) {
- __this__component.add(new LockComponent(other_element));
- }
- this.component = __this__component;
- }
- this.txnid = other.txnid;
- if (other.isSetUser()) {
- this.user = other.user;
- }
- if (other.isSetHostname()) {
- this.hostname = other.hostname;
- }
- if (other.isSetAgentInfo()) {
- this.agentInfo = other.agentInfo;
- }
- }
-
- public LockRequest deepCopy() {
- return new LockRequest(this);
- }
-
- @Override
- public void clear() {
- this.component = null;
- setTxnidIsSet(false);
- this.txnid = 0;
- this.user = null;
- this.hostname = null;
- this.agentInfo = "Unknown";
-
- }
-
- public int getComponentSize() {
- return (this.component == null) ? 0 : this.component.size();
- }
-
- public java.util.Iterator<LockComponent> getComponentIterator() {
- return (this.component == null) ? null : this.component.iterator();
- }
-
- public void addToComponent(LockComponent elem) {
- if (this.component == null) {
- this.component = new ArrayList<LockComponent>();
- }
- this.component.add(elem);
- }
-
- public List<LockComponent> getComponent() {
- return this.component;
- }
-
- public void setComponent(List<LockComponent> component) {
- this.component = component;
- }
-
- public void unsetComponent() {
- this.component = null;
- }
-
- /** Returns true if field component is set (has been assigned a value) and false otherwise */
- public boolean isSetComponent() {
- return this.component != null;
- }
-
- public void setComponentIsSet(boolean value) {
- if (!value) {
- this.component = null;
- }
- }
-
- public long getTxnid() {
- return this.txnid;
- }
-
- public void setTxnid(long txnid) {
- this.txnid = txnid;
- setTxnidIsSet(true);
- }
-
- public void unsetTxnid() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TXNID_ISSET_ID);
- }
-
- /** Returns true if field txnid is set (has been assigned a value) and false otherwise */
- public boolean isSetTxnid() {
- return EncodingUtils.testBit(__isset_bitfield, __TXNID_ISSET_ID);
- }
-
- public void setTxnidIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TXNID_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 COMPONENT:
- if (value == null) {
- unsetComponent();
- } else {
- setComponent((List<LockComponent>)value);
- }
- break;
-
- case TXNID:
- if (value == null) {
- unsetTxnid();
- } else {
- setTxnid((Long)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 COMPONENT:
- return getComponent();
-
- case TXNID:
- return getTxnid();
-
- 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 COMPONENT:
- return isSetComponent();
- case TXNID:
- return isSetTxnid();
- 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 LockRequest)
- return this.equals((LockRequest)that);
- return false;
- }
-
- public boolean equals(LockRequest that) {
- if (that == null)
- return false;
-
- boolean this_present_component = true && this.isSetComponent();
- boolean that_present_component = true && that.isSetComponent();
- if (this_present_component || that_present_component) {
- if (!(this_present_component && that_present_component))
- return false;
- if (!this.component.equals(that.component))
- return false;
- }
-
- boolean this_present_txnid = true && this.isSetTxnid();
- boolean that_present_txnid = true && that.isSetTxnid();
- if (this_present_txnid || that_present_txnid) {
- if (!(this_present_txnid && that_present_txnid))
- return false;
- if (this.txnid != that.txnid)
- 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<Object> list = new ArrayList<Object>();
-
- boolean present_component = true && (isSetComponent());
- list.add(present_component);
- if (present_component)
- list.add(component);
-
- boolean present_txnid = true && (isSetTxnid());
- list.add(present_txnid);
- if (present_txnid)
- list.add(txnid);
-
- 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(LockRequest other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(isSetComponent()).compareTo(other.isSetComponent());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetComponent()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.component, other.component);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetTxnid()).compareTo(other.isSetTxnid());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetTxnid()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.txnid, other.txnid);
- 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("LockRequest(");
- boolean first = true;
-
- sb.append("component:");
- if (this.component == null) {
- sb.append("null");
- } else {
- sb.append(this.component);
- }
- first = false;
- if (isSetTxnid()) {
- if (!first) sb.append(", ");
- sb.append("txnid:");
- sb.append(this.txnid);
- 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 (!isSetComponent()) {
- throw new org.apache.thrift.protocol.TProtocolException("Required field 'component' 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 LockRequestStandardSchemeFactory implements SchemeFactory {
- public LockRequestStandardScheme getScheme() {
- return new LockRequestStandardScheme();
- }
- }
-
- private static class LockRequestStandardScheme extends StandardScheme<LockRequest> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, LockRequest 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: // COMPONENT
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list524 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list524.size);
- LockComponent _elem525;
- for (int _i526 = 0; _i526 < _list524.size; ++_i526)
- {
- _elem525 = new LockComponent();
- _elem525.read(iprot);
- struct.component.add(_elem525);
- }
- iprot.readListEnd();
- }
- struct.setComponentIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // TXNID
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.txnid = iprot.readI64();
- struct.setTxnidIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // 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 4: // 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 5: // 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, LockRequest struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.component != null) {
- oprot.writeFieldBegin(COMPONENT_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size()));
- for (LockComponent _iter527 : struct.component)
- {
- _iter527.write(oprot);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- if (struct.isSetTxnid()) {
- oprot.writeFieldBegin(TXNID_FIELD_DESC);
- oprot.writeI64(struct.txnid);
- 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 LockRequestTupleSchemeFactory implements SchemeFactory {
- public LockRequestTupleScheme getScheme() {
- return new LockRequestTupleScheme();
- }
- }
-
- private static class LockRequestTupleScheme extends TupleScheme<LockRequest> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- {
- oprot.writeI32(struct.component.size());
- for (LockComponent _iter528 : struct.component)
- {
- _iter528.write(oprot);
- }
- }
- oprot.writeString(struct.user);
- oprot.writeString(struct.hostname);
- BitSet optionals = new BitSet();
- if (struct.isSetTxnid()) {
- optionals.set(0);
- }
- if (struct.isSetAgentInfo()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
- if (struct.isSetTxnid()) {
- oprot.writeI64(struct.txnid);
- }
- if (struct.isSetAgentInfo()) {
- oprot.writeString(struct.agentInfo);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- {
- org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list529.size);
- LockComponent _elem530;
- for (int _i531 = 0; _i531 < _list529.size; ++_i531)
- {
- _elem530 = new LockComponent();
- _elem530.read(iprot);
- struct.component.add(_elem530);
- }
- }
- struct.setComponentIsSet(true);
- struct.user = iprot.readString();
- struct.setUserIsSet(true);
- struct.hostname = iprot.readString();
- struct.setHostnameIsSet(true);
- BitSet incoming = iprot.readBitSet(2);
- if (incoming.get(0)) {
- struct.txnid = iprot.readI64();
- struct.setTxnidIsSet(true);
- }
- if (incoming.get(1)) {
- struct.agentInfo = iprot.readString();
- struct.setAgentInfoIsSet(true);
- }
- }
- }
-
-}
-