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 6B8F9200D01 for ; Thu, 3 Aug 2017 18:56:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6A1E316AB89; 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 0BFBA16AB8E for ; Thu, 3 Aug 2017 18:56:28 +0200 (CEST) Received: (qmail 77338 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 74567 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 55DF9F5543; 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:41 -0000 Message-Id: <7a0c6f920ea94e9fafbf0c58fa787ce0@git.apache.org> In-Reply-To: <3168ec5d9aa6432cbd79c835fb89c71e@git.apache.org> References: <3168ec5d9aa6432cbd79c835fb89c71e@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [20/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:31 -0000 http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpec.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpec.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpec.java deleted file mode 100644 index e8188a9..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpec.java +++ /dev/null @@ -1,826 +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 PartitionSpec 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("PartitionSpec"); - - 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)1); - 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)2); - private static final org.apache.thrift.protocol.TField ROOT_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("rootPath", org.apache.thrift.protocol.TType.STRING, (short)3); - private static final org.apache.thrift.protocol.TField SHARED_SDPARTITION_SPEC_FIELD_DESC = new org.apache.thrift.protocol.TField("sharedSDPartitionSpec", org.apache.thrift.protocol.TType.STRUCT, (short)4); - private static final org.apache.thrift.protocol.TField PARTITION_LIST_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionList", org.apache.thrift.protocol.TType.STRUCT, (short)5); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new PartitionSpecStandardSchemeFactory()); - schemes.put(TupleScheme.class, new PartitionSpecTupleSchemeFactory()); - } - - private String dbName; // required - private String tableName; // required - private String rootPath; // required - private PartitionSpecWithSharedSD sharedSDPartitionSpec; // optional - private PartitionListComposingSpec partitionList; // 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 { - DB_NAME((short)1, "dbName"), - TABLE_NAME((short)2, "tableName"), - ROOT_PATH((short)3, "rootPath"), - SHARED_SDPARTITION_SPEC((short)4, "sharedSDPartitionSpec"), - PARTITION_LIST((short)5, "partitionList"); - - 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: // DB_NAME - return DB_NAME; - case 2: // TABLE_NAME - return TABLE_NAME; - case 3: // ROOT_PATH - return ROOT_PATH; - case 4: // SHARED_SDPARTITION_SPEC - return SHARED_SDPARTITION_SPEC; - case 5: // PARTITION_LIST - return PARTITION_LIST; - 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 _Fields optionals[] = {_Fields.SHARED_SDPARTITION_SPEC,_Fields.PARTITION_LIST}; - 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.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("dbName", org.apache.thrift.TFieldRequirementType.DEFAULT, - 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.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.ROOT_PATH, new org.apache.thrift.meta_data.FieldMetaData("rootPath", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.SHARED_SDPARTITION_SPEC, new org.apache.thrift.meta_data.FieldMetaData("sharedSDPartitionSpec", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PartitionSpecWithSharedSD.class))); - tmpMap.put(_Fields.PARTITION_LIST, new org.apache.thrift.meta_data.FieldMetaData("partitionList", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PartitionListComposingSpec.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionSpec.class, metaDataMap); - } - - public PartitionSpec() { - } - - public PartitionSpec( - String dbName, - String tableName, - String rootPath) - { - this(); - this.dbName = dbName; - this.tableName = tableName; - this.rootPath = rootPath; - } - - /** - * Performs a deep copy on other. - */ - public PartitionSpec(PartitionSpec other) { - if (other.isSetDbName()) { - this.dbName = other.dbName; - } - if (other.isSetTableName()) { - this.tableName = other.tableName; - } - if (other.isSetRootPath()) { - this.rootPath = other.rootPath; - } - if (other.isSetSharedSDPartitionSpec()) { - this.sharedSDPartitionSpec = new PartitionSpecWithSharedSD(other.sharedSDPartitionSpec); - } - if (other.isSetPartitionList()) { - this.partitionList = new PartitionListComposingSpec(other.partitionList); - } - } - - public PartitionSpec deepCopy() { - return new PartitionSpec(this); - } - - @Override - public void clear() { - this.dbName = null; - this.tableName = null; - this.rootPath = null; - this.sharedSDPartitionSpec = null; - this.partitionList = 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 getRootPath() { - return this.rootPath; - } - - public void setRootPath(String rootPath) { - this.rootPath = rootPath; - } - - public void unsetRootPath() { - this.rootPath = null; - } - - /** Returns true if field rootPath is set (has been assigned a value) and false otherwise */ - public boolean isSetRootPath() { - return this.rootPath != null; - } - - public void setRootPathIsSet(boolean value) { - if (!value) { - this.rootPath = null; - } - } - - public PartitionSpecWithSharedSD getSharedSDPartitionSpec() { - return this.sharedSDPartitionSpec; - } - - public void setSharedSDPartitionSpec(PartitionSpecWithSharedSD sharedSDPartitionSpec) { - this.sharedSDPartitionSpec = sharedSDPartitionSpec; - } - - public void unsetSharedSDPartitionSpec() { - this.sharedSDPartitionSpec = null; - } - - /** Returns true if field sharedSDPartitionSpec is set (has been assigned a value) and false otherwise */ - public boolean isSetSharedSDPartitionSpec() { - return this.sharedSDPartitionSpec != null; - } - - public void setSharedSDPartitionSpecIsSet(boolean value) { - if (!value) { - this.sharedSDPartitionSpec = null; - } - } - - public PartitionListComposingSpec getPartitionList() { - return this.partitionList; - } - - public void setPartitionList(PartitionListComposingSpec partitionList) { - this.partitionList = partitionList; - } - - public void unsetPartitionList() { - this.partitionList = null; - } - - /** Returns true if field partitionList is set (has been assigned a value) and false otherwise */ - public boolean isSetPartitionList() { - return this.partitionList != null; - } - - public void setPartitionListIsSet(boolean value) { - if (!value) { - this.partitionList = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - 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 ROOT_PATH: - if (value == null) { - unsetRootPath(); - } else { - setRootPath((String)value); - } - break; - - case SHARED_SDPARTITION_SPEC: - if (value == null) { - unsetSharedSDPartitionSpec(); - } else { - setSharedSDPartitionSpec((PartitionSpecWithSharedSD)value); - } - break; - - case PARTITION_LIST: - if (value == null) { - unsetPartitionList(); - } else { - setPartitionList((PartitionListComposingSpec)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case DB_NAME: - return getDbName(); - - case TABLE_NAME: - return getTableName(); - - case ROOT_PATH: - return getRootPath(); - - case SHARED_SDPARTITION_SPEC: - return getSharedSDPartitionSpec(); - - case PARTITION_LIST: - return getPartitionList(); - - } - 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 DB_NAME: - return isSetDbName(); - case TABLE_NAME: - return isSetTableName(); - case ROOT_PATH: - return isSetRootPath(); - case SHARED_SDPARTITION_SPEC: - return isSetSharedSDPartitionSpec(); - case PARTITION_LIST: - return isSetPartitionList(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof PartitionSpec) - return this.equals((PartitionSpec)that); - return false; - } - - public boolean equals(PartitionSpec that) { - if (that == null) - 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_rootPath = true && this.isSetRootPath(); - boolean that_present_rootPath = true && that.isSetRootPath(); - if (this_present_rootPath || that_present_rootPath) { - if (!(this_present_rootPath && that_present_rootPath)) - return false; - if (!this.rootPath.equals(that.rootPath)) - return false; - } - - boolean this_present_sharedSDPartitionSpec = true && this.isSetSharedSDPartitionSpec(); - boolean that_present_sharedSDPartitionSpec = true && that.isSetSharedSDPartitionSpec(); - if (this_present_sharedSDPartitionSpec || that_present_sharedSDPartitionSpec) { - if (!(this_present_sharedSDPartitionSpec && that_present_sharedSDPartitionSpec)) - return false; - if (!this.sharedSDPartitionSpec.equals(that.sharedSDPartitionSpec)) - return false; - } - - boolean this_present_partitionList = true && this.isSetPartitionList(); - boolean that_present_partitionList = true && that.isSetPartitionList(); - if (this_present_partitionList || that_present_partitionList) { - if (!(this_present_partitionList && that_present_partitionList)) - return false; - if (!this.partitionList.equals(that.partitionList)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - 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_rootPath = true && (isSetRootPath()); - list.add(present_rootPath); - if (present_rootPath) - list.add(rootPath); - - boolean present_sharedSDPartitionSpec = true && (isSetSharedSDPartitionSpec()); - list.add(present_sharedSDPartitionSpec); - if (present_sharedSDPartitionSpec) - list.add(sharedSDPartitionSpec); - - boolean present_partitionList = true && (isSetPartitionList()); - list.add(present_partitionList); - if (present_partitionList) - list.add(partitionList); - - return list.hashCode(); - } - - @Override - public int compareTo(PartitionSpec other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - 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(isSetRootPath()).compareTo(other.isSetRootPath()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRootPath()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.rootPath, other.rootPath); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetSharedSDPartitionSpec()).compareTo(other.isSetSharedSDPartitionSpec()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSharedSDPartitionSpec()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sharedSDPartitionSpec, other.sharedSDPartitionSpec); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetPartitionList()).compareTo(other.isSetPartitionList()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPartitionList()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitionList, other.partitionList); - 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("PartitionSpec("); - boolean first = true; - - sb.append("dbName:"); - if (this.dbName == null) { - sb.append("null"); - } else { - sb.append(this.dbName); - } - first = false; - 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("rootPath:"); - if (this.rootPath == null) { - sb.append("null"); - } else { - sb.append(this.rootPath); - } - first = false; - if (isSetSharedSDPartitionSpec()) { - if (!first) sb.append(", "); - sb.append("sharedSDPartitionSpec:"); - if (this.sharedSDPartitionSpec == null) { - sb.append("null"); - } else { - sb.append(this.sharedSDPartitionSpec); - } - first = false; - } - if (isSetPartitionList()) { - if (!first) sb.append(", "); - sb.append("partitionList:"); - if (this.partitionList == null) { - sb.append("null"); - } else { - sb.append(this.partitionList); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (sharedSDPartitionSpec != null) { - sharedSDPartitionSpec.validate(); - } - if (partitionList != null) { - partitionList.validate(); - } - } - - 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 PartitionSpecStandardSchemeFactory implements SchemeFactory { - public PartitionSpecStandardScheme getScheme() { - return new PartitionSpecStandardScheme(); - } - } - - private static class PartitionSpecStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionSpec 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: // 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 2: // 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 3: // ROOT_PATH - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.rootPath = iprot.readString(); - struct.setRootPathIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // SHARED_SDPARTITION_SPEC - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.sharedSDPartitionSpec = new PartitionSpecWithSharedSD(); - struct.sharedSDPartitionSpec.read(iprot); - struct.setSharedSDPartitionSpecIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // PARTITION_LIST - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.partitionList = new PartitionListComposingSpec(); - struct.partitionList.read(iprot); - struct.setPartitionListIsSet(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, PartitionSpec struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.dbName != null) { - oprot.writeFieldBegin(DB_NAME_FIELD_DESC); - oprot.writeString(struct.dbName); - oprot.writeFieldEnd(); - } - if (struct.tableName != null) { - oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC); - oprot.writeString(struct.tableName); - oprot.writeFieldEnd(); - } - if (struct.rootPath != null) { - oprot.writeFieldBegin(ROOT_PATH_FIELD_DESC); - oprot.writeString(struct.rootPath); - oprot.writeFieldEnd(); - } - if (struct.sharedSDPartitionSpec != null) { - if (struct.isSetSharedSDPartitionSpec()) { - oprot.writeFieldBegin(SHARED_SDPARTITION_SPEC_FIELD_DESC); - struct.sharedSDPartitionSpec.write(oprot); - oprot.writeFieldEnd(); - } - } - if (struct.partitionList != null) { - if (struct.isSetPartitionList()) { - oprot.writeFieldBegin(PARTITION_LIST_FIELD_DESC); - struct.partitionList.write(oprot); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class PartitionSpecTupleSchemeFactory implements SchemeFactory { - public PartitionSpecTupleScheme getScheme() { - return new PartitionSpecTupleScheme(); - } - } - - private static class PartitionSpecTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, PartitionSpec struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetDbName()) { - optionals.set(0); - } - if (struct.isSetTableName()) { - optionals.set(1); - } - if (struct.isSetRootPath()) { - optionals.set(2); - } - if (struct.isSetSharedSDPartitionSpec()) { - optionals.set(3); - } - if (struct.isSetPartitionList()) { - optionals.set(4); - } - oprot.writeBitSet(optionals, 5); - if (struct.isSetDbName()) { - oprot.writeString(struct.dbName); - } - if (struct.isSetTableName()) { - oprot.writeString(struct.tableName); - } - if (struct.isSetRootPath()) { - oprot.writeString(struct.rootPath); - } - if (struct.isSetSharedSDPartitionSpec()) { - struct.sharedSDPartitionSpec.write(oprot); - } - if (struct.isSetPartitionList()) { - struct.partitionList.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, PartitionSpec struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(5); - 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.rootPath = iprot.readString(); - struct.setRootPathIsSet(true); - } - if (incoming.get(3)) { - struct.sharedSDPartitionSpec = new PartitionSpecWithSharedSD(); - struct.sharedSDPartitionSpec.read(iprot); - struct.setSharedSDPartitionSpecIsSet(true); - } - if (incoming.get(4)) { - struct.partitionList = new PartitionListComposingSpec(); - struct.partitionList.read(iprot); - struct.setPartitionListIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java deleted file mode 100644 index 2c41912..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java +++ /dev/null @@ -1,558 +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 PartitionSpecWithSharedSD 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("PartitionSpecWithSharedSD"); - - private static final org.apache.thrift.protocol.TField PARTITIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("partitions", org.apache.thrift.protocol.TType.LIST, (short)1); - private static final org.apache.thrift.protocol.TField SD_FIELD_DESC = new org.apache.thrift.protocol.TField("sd", org.apache.thrift.protocol.TType.STRUCT, (short)2); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new PartitionSpecWithSharedSDStandardSchemeFactory()); - schemes.put(TupleScheme.class, new PartitionSpecWithSharedSDTupleSchemeFactory()); - } - - private List partitions; // required - private StorageDescriptor sd; // 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 { - PARTITIONS((short)1, "partitions"), - SD((short)2, "sd"); - - 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: // PARTITIONS - return PARTITIONS; - case 2: // SD - return SD; - 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.PARTITIONS, new org.apache.thrift.meta_data.FieldMetaData("partitions", org.apache.thrift.TFieldRequirementType.DEFAULT, - 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, PartitionWithoutSD.class)))); - tmpMap.put(_Fields.SD, new org.apache.thrift.meta_data.FieldMetaData("sd", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, StorageDescriptor.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionSpecWithSharedSD.class, metaDataMap); - } - - public PartitionSpecWithSharedSD() { - } - - public PartitionSpecWithSharedSD( - List partitions, - StorageDescriptor sd) - { - this(); - this.partitions = partitions; - this.sd = sd; - } - - /** - * Performs a deep copy on other. - */ - public PartitionSpecWithSharedSD(PartitionSpecWithSharedSD other) { - if (other.isSetPartitions()) { - List __this__partitions = new ArrayList(other.partitions.size()); - for (PartitionWithoutSD other_element : other.partitions) { - __this__partitions.add(new PartitionWithoutSD(other_element)); - } - this.partitions = __this__partitions; - } - if (other.isSetSd()) { - this.sd = new StorageDescriptor(other.sd); - } - } - - public PartitionSpecWithSharedSD deepCopy() { - return new PartitionSpecWithSharedSD(this); - } - - @Override - public void clear() { - this.partitions = null; - this.sd = null; - } - - public int getPartitionsSize() { - return (this.partitions == null) ? 0 : this.partitions.size(); - } - - public java.util.Iterator getPartitionsIterator() { - return (this.partitions == null) ? null : this.partitions.iterator(); - } - - public void addToPartitions(PartitionWithoutSD elem) { - if (this.partitions == null) { - this.partitions = new ArrayList(); - } - this.partitions.add(elem); - } - - public List getPartitions() { - return this.partitions; - } - - public void setPartitions(List partitions) { - this.partitions = partitions; - } - - public void unsetPartitions() { - this.partitions = null; - } - - /** Returns true if field partitions is set (has been assigned a value) and false otherwise */ - public boolean isSetPartitions() { - return this.partitions != null; - } - - public void setPartitionsIsSet(boolean value) { - if (!value) { - this.partitions = null; - } - } - - public StorageDescriptor getSd() { - return this.sd; - } - - public void setSd(StorageDescriptor sd) { - this.sd = sd; - } - - public void unsetSd() { - this.sd = null; - } - - /** Returns true if field sd is set (has been assigned a value) and false otherwise */ - public boolean isSetSd() { - return this.sd != null; - } - - public void setSdIsSet(boolean value) { - if (!value) { - this.sd = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case PARTITIONS: - if (value == null) { - unsetPartitions(); - } else { - setPartitions((List)value); - } - break; - - case SD: - if (value == null) { - unsetSd(); - } else { - setSd((StorageDescriptor)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case PARTITIONS: - return getPartitions(); - - case SD: - return getSd(); - - } - 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 PARTITIONS: - return isSetPartitions(); - case SD: - return isSetSd(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof PartitionSpecWithSharedSD) - return this.equals((PartitionSpecWithSharedSD)that); - return false; - } - - public boolean equals(PartitionSpecWithSharedSD that) { - if (that == null) - return false; - - boolean this_present_partitions = true && this.isSetPartitions(); - boolean that_present_partitions = true && that.isSetPartitions(); - if (this_present_partitions || that_present_partitions) { - if (!(this_present_partitions && that_present_partitions)) - return false; - if (!this.partitions.equals(that.partitions)) - return false; - } - - boolean this_present_sd = true && this.isSetSd(); - boolean that_present_sd = true && that.isSetSd(); - if (this_present_sd || that_present_sd) { - if (!(this_present_sd && that_present_sd)) - return false; - if (!this.sd.equals(that.sd)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_partitions = true && (isSetPartitions()); - list.add(present_partitions); - if (present_partitions) - list.add(partitions); - - boolean present_sd = true && (isSetSd()); - list.add(present_sd); - if (present_sd) - list.add(sd); - - return list.hashCode(); - } - - @Override - public int compareTo(PartitionSpecWithSharedSD other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetPartitions()).compareTo(other.isSetPartitions()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPartitions()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitions, other.partitions); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetSd()).compareTo(other.isSetSd()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSd()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sd, other.sd); - 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("PartitionSpecWithSharedSD("); - boolean first = true; - - sb.append("partitions:"); - if (this.partitions == null) { - sb.append("null"); - } else { - sb.append(this.partitions); - } - first = false; - if (!first) sb.append(", "); - sb.append("sd:"); - if (this.sd == null) { - sb.append("null"); - } else { - sb.append(this.sd); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (sd != null) { - sd.validate(); - } - } - - 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 PartitionSpecWithSharedSDStandardSchemeFactory implements SchemeFactory { - public PartitionSpecWithSharedSDStandardScheme getScheme() { - return new PartitionSpecWithSharedSDStandardScheme(); - } - } - - private static class PartitionSpecWithSharedSDStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionSpecWithSharedSD 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: // PARTITIONS - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list244 = iprot.readListBegin(); - struct.partitions = new ArrayList(_list244.size); - PartitionWithoutSD _elem245; - for (int _i246 = 0; _i246 < _list244.size; ++_i246) - { - _elem245 = new PartitionWithoutSD(); - _elem245.read(iprot); - struct.partitions.add(_elem245); - } - iprot.readListEnd(); - } - struct.setPartitionsIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // SD - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.sd = new StorageDescriptor(); - struct.sd.read(iprot); - struct.setSdIsSet(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, PartitionSpecWithSharedSD struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.partitions != null) { - oprot.writeFieldBegin(PARTITIONS_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size())); - for (PartitionWithoutSD _iter247 : struct.partitions) - { - _iter247.write(oprot); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.sd != null) { - oprot.writeFieldBegin(SD_FIELD_DESC); - struct.sd.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class PartitionSpecWithSharedSDTupleSchemeFactory implements SchemeFactory { - public PartitionSpecWithSharedSDTupleScheme getScheme() { - return new PartitionSpecWithSharedSDTupleScheme(); - } - } - - private static class PartitionSpecWithSharedSDTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, PartitionSpecWithSharedSD struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetPartitions()) { - optionals.set(0); - } - if (struct.isSetSd()) { - optionals.set(1); - } - oprot.writeBitSet(optionals, 2); - if (struct.isSetPartitions()) { - { - oprot.writeI32(struct.partitions.size()); - for (PartitionWithoutSD _iter248 : struct.partitions) - { - _iter248.write(oprot); - } - } - } - if (struct.isSetSd()) { - struct.sd.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, PartitionSpecWithSharedSD struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(2); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TList _list249 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.partitions = new ArrayList(_list249.size); - PartitionWithoutSD _elem250; - for (int _i251 = 0; _i251 < _list249.size; ++_i251) - { - _elem250 = new PartitionWithoutSD(); - _elem250.read(iprot); - struct.partitions.add(_elem250); - } - } - struct.setPartitionsIsSet(true); - } - if (incoming.get(1)) { - struct.sd = new StorageDescriptor(); - struct.sd.read(iprot); - struct.setSdIsSet(true); - } - } - } - -} - http://git-wip-us.apache.org/repos/asf/hive/blob/453c8ed4/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java deleted file mode 100644 index f0c5ce1..0000000 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java +++ /dev/null @@ -1,1016 +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 PartitionWithoutSD 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("PartitionWithoutSD"); - - private static final org.apache.thrift.protocol.TField VALUES_FIELD_DESC = new org.apache.thrift.protocol.TField("values", org.apache.thrift.protocol.TType.LIST, (short)1); - private static final org.apache.thrift.protocol.TField CREATE_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("createTime", org.apache.thrift.protocol.TType.I32, (short)2); - private static final org.apache.thrift.protocol.TField LAST_ACCESS_TIME_FIELD_DESC = new org.apache.thrift.protocol.TField("lastAccessTime", org.apache.thrift.protocol.TType.I32, (short)3); - private static final org.apache.thrift.protocol.TField RELATIVE_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("relativePath", org.apache.thrift.protocol.TType.STRING, (short)4); - private static final org.apache.thrift.protocol.TField PARAMETERS_FIELD_DESC = new org.apache.thrift.protocol.TField("parameters", org.apache.thrift.protocol.TType.MAP, (short)5); - private static final org.apache.thrift.protocol.TField PRIVILEGES_FIELD_DESC = new org.apache.thrift.protocol.TField("privileges", org.apache.thrift.protocol.TType.STRUCT, (short)6); - - private static final Map, SchemeFactory> schemes = new HashMap, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new PartitionWithoutSDStandardSchemeFactory()); - schemes.put(TupleScheme.class, new PartitionWithoutSDTupleSchemeFactory()); - } - - private List values; // required - private int createTime; // required - private int lastAccessTime; // required - private String relativePath; // required - private Map parameters; // required - private PrincipalPrivilegeSet privileges; // 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 { - VALUES((short)1, "values"), - CREATE_TIME((short)2, "createTime"), - LAST_ACCESS_TIME((short)3, "lastAccessTime"), - RELATIVE_PATH((short)4, "relativePath"), - PARAMETERS((short)5, "parameters"), - PRIVILEGES((short)6, "privileges"); - - 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: // VALUES - return VALUES; - case 2: // CREATE_TIME - return CREATE_TIME; - case 3: // LAST_ACCESS_TIME - return LAST_ACCESS_TIME; - case 4: // RELATIVE_PATH - return RELATIVE_PATH; - case 5: // PARAMETERS - return PARAMETERS; - case 6: // PRIVILEGES - return PRIVILEGES; - 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 __CREATETIME_ISSET_ID = 0; - private static final int __LASTACCESSTIME_ISSET_ID = 1; - private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.PRIVILEGES}; - 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.VALUES, new org.apache.thrift.meta_data.FieldMetaData("values", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - tmpMap.put(_Fields.CREATE_TIME, new org.apache.thrift.meta_data.FieldMetaData("createTime", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.LAST_ACCESS_TIME, new org.apache.thrift.meta_data.FieldMetaData("lastAccessTime", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); - tmpMap.put(_Fields.RELATIVE_PATH, new org.apache.thrift.meta_data.FieldMetaData("relativePath", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.PARAMETERS, new org.apache.thrift.meta_data.FieldMetaData("parameters", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); - tmpMap.put(_Fields.PRIVILEGES, new org.apache.thrift.meta_data.FieldMetaData("privileges", org.apache.thrift.TFieldRequirementType.OPTIONAL, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, PrincipalPrivilegeSet.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PartitionWithoutSD.class, metaDataMap); - } - - public PartitionWithoutSD() { - } - - public PartitionWithoutSD( - List values, - int createTime, - int lastAccessTime, - String relativePath, - Map parameters) - { - this(); - this.values = values; - this.createTime = createTime; - setCreateTimeIsSet(true); - this.lastAccessTime = lastAccessTime; - setLastAccessTimeIsSet(true); - this.relativePath = relativePath; - this.parameters = parameters; - } - - /** - * Performs a deep copy on other. - */ - public PartitionWithoutSD(PartitionWithoutSD other) { - __isset_bitfield = other.__isset_bitfield; - if (other.isSetValues()) { - List __this__values = new ArrayList(other.values); - this.values = __this__values; - } - this.createTime = other.createTime; - this.lastAccessTime = other.lastAccessTime; - if (other.isSetRelativePath()) { - this.relativePath = other.relativePath; - } - if (other.isSetParameters()) { - Map __this__parameters = new HashMap(other.parameters); - this.parameters = __this__parameters; - } - if (other.isSetPrivileges()) { - this.privileges = new PrincipalPrivilegeSet(other.privileges); - } - } - - public PartitionWithoutSD deepCopy() { - return new PartitionWithoutSD(this); - } - - @Override - public void clear() { - this.values = null; - setCreateTimeIsSet(false); - this.createTime = 0; - setLastAccessTimeIsSet(false); - this.lastAccessTime = 0; - this.relativePath = null; - this.parameters = null; - this.privileges = null; - } - - public int getValuesSize() { - return (this.values == null) ? 0 : this.values.size(); - } - - public java.util.Iterator getValuesIterator() { - return (this.values == null) ? null : this.values.iterator(); - } - - public void addToValues(String elem) { - if (this.values == null) { - this.values = new ArrayList(); - } - this.values.add(elem); - } - - public List getValues() { - return this.values; - } - - public void setValues(List values) { - this.values = values; - } - - public void unsetValues() { - this.values = null; - } - - /** Returns true if field values is set (has been assigned a value) and false otherwise */ - public boolean isSetValues() { - return this.values != null; - } - - public void setValuesIsSet(boolean value) { - if (!value) { - this.values = null; - } - } - - public int getCreateTime() { - return this.createTime; - } - - public void setCreateTime(int createTime) { - this.createTime = createTime; - setCreateTimeIsSet(true); - } - - public void unsetCreateTime() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __CREATETIME_ISSET_ID); - } - - /** Returns true if field createTime is set (has been assigned a value) and false otherwise */ - public boolean isSetCreateTime() { - return EncodingUtils.testBit(__isset_bitfield, __CREATETIME_ISSET_ID); - } - - public void setCreateTimeIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __CREATETIME_ISSET_ID, value); - } - - public int getLastAccessTime() { - return this.lastAccessTime; - } - - public void setLastAccessTime(int lastAccessTime) { - this.lastAccessTime = lastAccessTime; - setLastAccessTimeIsSet(true); - } - - public void unsetLastAccessTime() { - __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID); - } - - /** Returns true if field lastAccessTime is set (has been assigned a value) and false otherwise */ - public boolean isSetLastAccessTime() { - return EncodingUtils.testBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID); - } - - public void setLastAccessTimeIsSet(boolean value) { - __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LASTACCESSTIME_ISSET_ID, value); - } - - public String getRelativePath() { - return this.relativePath; - } - - public void setRelativePath(String relativePath) { - this.relativePath = relativePath; - } - - public void unsetRelativePath() { - this.relativePath = null; - } - - /** Returns true if field relativePath is set (has been assigned a value) and false otherwise */ - public boolean isSetRelativePath() { - return this.relativePath != null; - } - - public void setRelativePathIsSet(boolean value) { - if (!value) { - this.relativePath = null; - } - } - - public int getParametersSize() { - return (this.parameters == null) ? 0 : this.parameters.size(); - } - - public void putToParameters(String key, String val) { - if (this.parameters == null) { - this.parameters = new HashMap(); - } - this.parameters.put(key, val); - } - - public Map getParameters() { - return this.parameters; - } - - public void setParameters(Map parameters) { - this.parameters = parameters; - } - - public void unsetParameters() { - this.parameters = null; - } - - /** Returns true if field parameters is set (has been assigned a value) and false otherwise */ - public boolean isSetParameters() { - return this.parameters != null; - } - - public void setParametersIsSet(boolean value) { - if (!value) { - this.parameters = null; - } - } - - public PrincipalPrivilegeSet getPrivileges() { - return this.privileges; - } - - public void setPrivileges(PrincipalPrivilegeSet privileges) { - this.privileges = privileges; - } - - public void unsetPrivileges() { - this.privileges = null; - } - - /** Returns true if field privileges is set (has been assigned a value) and false otherwise */ - public boolean isSetPrivileges() { - return this.privileges != null; - } - - public void setPrivilegesIsSet(boolean value) { - if (!value) { - this.privileges = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case VALUES: - if (value == null) { - unsetValues(); - } else { - setValues((List)value); - } - break; - - case CREATE_TIME: - if (value == null) { - unsetCreateTime(); - } else { - setCreateTime((Integer)value); - } - break; - - case LAST_ACCESS_TIME: - if (value == null) { - unsetLastAccessTime(); - } else { - setLastAccessTime((Integer)value); - } - break; - - case RELATIVE_PATH: - if (value == null) { - unsetRelativePath(); - } else { - setRelativePath((String)value); - } - break; - - case PARAMETERS: - if (value == null) { - unsetParameters(); - } else { - setParameters((Map)value); - } - break; - - case PRIVILEGES: - if (value == null) { - unsetPrivileges(); - } else { - setPrivileges((PrincipalPrivilegeSet)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case VALUES: - return getValues(); - - case CREATE_TIME: - return getCreateTime(); - - case LAST_ACCESS_TIME: - return getLastAccessTime(); - - case RELATIVE_PATH: - return getRelativePath(); - - case PARAMETERS: - return getParameters(); - - case PRIVILEGES: - return getPrivileges(); - - } - 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 VALUES: - return isSetValues(); - case CREATE_TIME: - return isSetCreateTime(); - case LAST_ACCESS_TIME: - return isSetLastAccessTime(); - case RELATIVE_PATH: - return isSetRelativePath(); - case PARAMETERS: - return isSetParameters(); - case PRIVILEGES: - return isSetPrivileges(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof PartitionWithoutSD) - return this.equals((PartitionWithoutSD)that); - return false; - } - - public boolean equals(PartitionWithoutSD that) { - if (that == null) - return false; - - boolean this_present_values = true && this.isSetValues(); - boolean that_present_values = true && that.isSetValues(); - if (this_present_values || that_present_values) { - if (!(this_present_values && that_present_values)) - return false; - if (!this.values.equals(that.values)) - return false; - } - - boolean this_present_createTime = true; - boolean that_present_createTime = true; - if (this_present_createTime || that_present_createTime) { - if (!(this_present_createTime && that_present_createTime)) - return false; - if (this.createTime != that.createTime) - return false; - } - - boolean this_present_lastAccessTime = true; - boolean that_present_lastAccessTime = true; - if (this_present_lastAccessTime || that_present_lastAccessTime) { - if (!(this_present_lastAccessTime && that_present_lastAccessTime)) - return false; - if (this.lastAccessTime != that.lastAccessTime) - return false; - } - - boolean this_present_relativePath = true && this.isSetRelativePath(); - boolean that_present_relativePath = true && that.isSetRelativePath(); - if (this_present_relativePath || that_present_relativePath) { - if (!(this_present_relativePath && that_present_relativePath)) - return false; - if (!this.relativePath.equals(that.relativePath)) - return false; - } - - boolean this_present_parameters = true && this.isSetParameters(); - boolean that_present_parameters = true && that.isSetParameters(); - if (this_present_parameters || that_present_parameters) { - if (!(this_present_parameters && that_present_parameters)) - return false; - if (!this.parameters.equals(that.parameters)) - return false; - } - - boolean this_present_privileges = true && this.isSetPrivileges(); - boolean that_present_privileges = true && that.isSetPrivileges(); - if (this_present_privileges || that_present_privileges) { - if (!(this_present_privileges && that_present_privileges)) - return false; - if (!this.privileges.equals(that.privileges)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List list = new ArrayList(); - - boolean present_values = true && (isSetValues()); - list.add(present_values); - if (present_values) - list.add(values); - - boolean present_createTime = true; - list.add(present_createTime); - if (present_createTime) - list.add(createTime); - - boolean present_lastAccessTime = true; - list.add(present_lastAccessTime); - if (present_lastAccessTime) - list.add(lastAccessTime); - - boolean present_relativePath = true && (isSetRelativePath()); - list.add(present_relativePath); - if (present_relativePath) - list.add(relativePath); - - boolean present_parameters = true && (isSetParameters()); - list.add(present_parameters); - if (present_parameters) - list.add(parameters); - - boolean present_privileges = true && (isSetPrivileges()); - list.add(present_privileges); - if (present_privileges) - list.add(privileges); - - return list.hashCode(); - } - - @Override - public int compareTo(PartitionWithoutSD other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetValues()).compareTo(other.isSetValues()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetValues()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.values, other.values); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetCreateTime()).compareTo(other.isSetCreateTime()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetCreateTime()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.createTime, other.createTime); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetLastAccessTime()).compareTo(other.isSetLastAccessTime()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetLastAccessTime()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.lastAccessTime, other.lastAccessTime); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetRelativePath()).compareTo(other.isSetRelativePath()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetRelativePath()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.relativePath, other.relativePath); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetParameters()).compareTo(other.isSetParameters()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetParameters()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.parameters, other.parameters); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetPrivileges()).compareTo(other.isSetPrivileges()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetPrivileges()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.privileges, other.privileges); - 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("PartitionWithoutSD("); - boolean first = true; - - sb.append("values:"); - if (this.values == null) { - sb.append("null"); - } else { - sb.append(this.values); - } - first = false; - if (!first) sb.append(", "); - sb.append("createTime:"); - sb.append(this.createTime); - first = false; - if (!first) sb.append(", "); - sb.append("lastAccessTime:"); - sb.append(this.lastAccessTime); - first = false; - if (!first) sb.append(", "); - sb.append("relativePath:"); - if (this.relativePath == null) { - sb.append("null"); - } else { - sb.append(this.relativePath); - } - first = false; - if (!first) sb.append(", "); - sb.append("parameters:"); - if (this.parameters == null) { - sb.append("null"); - } else { - sb.append(this.parameters); - } - first = false; - if (isSetPrivileges()) { - if (!first) sb.append(", "); - sb.append("privileges:"); - if (this.privileges == null) { - sb.append("null"); - } else { - sb.append(this.privileges); - } - first = false; - } - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - if (privileges != null) { - privileges.validate(); - } - } - - 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 PartitionWithoutSDStandardSchemeFactory implements SchemeFactory { - public PartitionWithoutSDStandardScheme getScheme() { - return new PartitionWithoutSDStandardScheme(); - } - } - - private static class PartitionWithoutSDStandardScheme extends StandardScheme { - - public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionWithoutSD 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: // VALUES - if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { - { - org.apache.thrift.protocol.TList _list226 = iprot.readListBegin(); - struct.values = new ArrayList(_list226.size); - String _elem227; - for (int _i228 = 0; _i228 < _list226.size; ++_i228) - { - _elem227 = iprot.readString(); - struct.values.add(_elem227); - } - iprot.readListEnd(); - } - struct.setValuesIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 2: // CREATE_TIME - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.createTime = iprot.readI32(); - struct.setCreateTimeIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 3: // LAST_ACCESS_TIME - if (schemeField.type == org.apache.thrift.protocol.TType.I32) { - struct.lastAccessTime = iprot.readI32(); - struct.setLastAccessTimeIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 4: // RELATIVE_PATH - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.relativePath = iprot.readString(); - struct.setRelativePathIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 5: // PARAMETERS - if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { - { - org.apache.thrift.protocol.TMap _map229 = iprot.readMapBegin(); - struct.parameters = new HashMap(2*_map229.size); - String _key230; - String _val231; - for (int _i232 = 0; _i232 < _map229.size; ++_i232) - { - _key230 = iprot.readString(); - _val231 = iprot.readString(); - struct.parameters.put(_key230, _val231); - } - iprot.readMapEnd(); - } - struct.setParametersIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 6: // PRIVILEGES - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.privileges = new PrincipalPrivilegeSet(); - struct.privileges.read(iprot); - struct.setPrivilegesIsSet(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, PartitionWithoutSD struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.values != null) { - oprot.writeFieldBegin(VALUES_FIELD_DESC); - { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.values.size())); - for (String _iter233 : struct.values) - { - oprot.writeString(_iter233); - } - oprot.writeListEnd(); - } - oprot.writeFieldEnd(); - } - oprot.writeFieldBegin(CREATE_TIME_FIELD_DESC); - oprot.writeI32(struct.createTime); - oprot.writeFieldEnd(); - oprot.writeFieldBegin(LAST_ACCESS_TIME_FIELD_DESC); - oprot.writeI32(struct.lastAccessTime); - oprot.writeFieldEnd(); - if (struct.relativePath != null) { - oprot.writeFieldBegin(RELATIVE_PATH_FIELD_DESC); - oprot.writeString(struct.relativePath); - oprot.writeFieldEnd(); - } - if (struct.parameters != null) { - oprot.writeFieldBegin(PARAMETERS_FIELD_DESC); - { - oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size())); - for (Map.Entry _iter234 : struct.parameters.entrySet()) - { - oprot.writeString(_iter234.getKey()); - oprot.writeString(_iter234.getValue()); - } - oprot.writeMapEnd(); - } - oprot.writeFieldEnd(); - } - if (struct.privileges != null) { - if (struct.isSetPrivileges()) { - oprot.writeFieldBegin(PRIVILEGES_FIELD_DESC); - struct.privileges.write(oprot); - oprot.writeFieldEnd(); - } - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class PartitionWithoutSDTupleSchemeFactory implements SchemeFactory { - public PartitionWithoutSDTupleScheme getScheme() { - return new PartitionWithoutSDTupleScheme(); - } - } - - private static class PartitionWithoutSDTupleScheme extends TupleScheme { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, PartitionWithoutSD struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetValues()) { - optionals.set(0); - } - if (struct.isSetCreateTime()) { - optionals.set(1); - } - if (struct.isSetLastAccessTime()) { - optionals.set(2); - } - if (struct.isSetRelativePath()) { - optionals.set(3); - } - if (struct.isSetParameters()) { - optionals.set(4); - } - if (struct.isSetPrivileges()) { - optionals.set(5); - } - oprot.writeBitSet(optionals, 6); - if (struct.isSetValues()) { - { - oprot.writeI32(struct.values.size()); - for (String _iter235 : struct.values) - { - oprot.writeString(_iter235); - } - } - } - if (struct.isSetCreateTime()) { - oprot.writeI32(struct.createTime); - } - if (struct.isSetLastAccessTime()) { - oprot.writeI32(struct.lastAccessTime); - } - if (struct.isSetRelativePath()) { - oprot.writeString(struct.relativePath); - } - if (struct.isSetParameters()) { - { - oprot.writeI32(struct.parameters.size()); - for (Map.Entry _iter236 : struct.parameters.entrySet()) - { - oprot.writeString(_iter236.getKey()); - oprot.writeString(_iter236.getValue()); - } - } - } - if (struct.isSetPrivileges()) { - struct.privileges.write(oprot); - } - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, PartitionWithoutSD struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(6); - if (incoming.get(0)) { - { - org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.values = new ArrayList(_list237.size); - String _elem238; - for (int _i239 = 0; _i239 < _list237.size; ++_i239) - { - _elem238 = iprot.readString(); - struct.values.add(_elem238); - } - } - struct.setValuesIsSet(true); - } - if (incoming.get(1)) { - struct.createTime = iprot.readI32(); - struct.setCreateTimeIsSet(true); - } - if (incoming.get(2)) { - struct.lastAccessTime = iprot.readI32(); - struct.setLastAccessTimeIsSet(true); - } - if (incoming.get(3)) { - struct.relativePath = iprot.readString(); - struct.setRelativePathIsSet(true); - } - if (incoming.get(4)) { - { - org.apache.thrift.protocol.TMap _map240 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.parameters = new HashMap(2*_map240.size); - String _key241; - String _val242; - for (int _i243 = 0; _i243 < _map240.size; ++_i243) - { - _key241 = iprot.readString(); - _val242 = iprot.readString(); - struct.parameters.put(_key241, _val242); - } - } - struct.setParametersIsSet(true); - } - if (incoming.get(5)) { - struct.privileges = new PrincipalPrivilegeSet(); - struct.privileges.read(iprot); - struct.setPrivilegesIsSet(true); - } - } - } - -} -