You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2012/11/08 10:44:29 UTC
svn commit: r1406984 [6/29] - in /hive/trunk:
contrib/src/java/org/apache/hadoop/hive/contrib/genericudf/example/
contrib/src/java/org/apache/hadoop/hive/contrib/serde2/
contrib/src/java/org/apache/hadoop/hive/contrib/util/typedbytes/
contrib/src/test/...
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,6 +38,12 @@ public class ColumnStatisticsObj impleme
private static final org.apache.thrift.protocol.TField COL_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("colType", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField STATS_DATA_FIELD_DESC = new org.apache.thrift.protocol.TField("statsData", org.apache.thrift.protocol.TType.STRUCT, (short)3);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new ColumnStatisticsObjStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ColumnStatisticsObjTupleSchemeFactory());
+ }
+
private String colName; // required
private String colType; // required
private ColumnStatisticsData statsData; // required
@@ -97,7 +113,6 @@ public class ColumnStatisticsObj impleme
}
// 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);
@@ -392,67 +407,11 @@ public class ColumnStatisticsObj impleme
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // COL_NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.colName = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // COL_TYPE
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.colType = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // STATS_DATA
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.statsData = new ColumnStatisticsData();
- this.statsData.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.colName != null) {
- oprot.writeFieldBegin(COL_NAME_FIELD_DESC);
- oprot.writeString(this.colName);
- oprot.writeFieldEnd();
- }
- if (this.colType != null) {
- oprot.writeFieldBegin(COL_TYPE_FIELD_DESC);
- oprot.writeString(this.colType);
- oprot.writeFieldEnd();
- }
- if (this.statsData != null) {
- oprot.writeFieldBegin(STATS_DATA_FIELD_DESC);
- this.statsData.write(oprot);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -501,6 +460,7 @@ public class ColumnStatisticsObj impleme
throw new org.apache.thrift.protocol.TProtocolException("Required field 'statsData' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -519,5 +479,111 @@ public class ColumnStatisticsObj impleme
}
}
+ private static class ColumnStatisticsObjStandardSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsObjStandardScheme getScheme() {
+ return new ColumnStatisticsObjStandardScheme();
+ }
+ }
+
+ private static class ColumnStatisticsObjStandardScheme extends StandardScheme<ColumnStatisticsObj> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsObj 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: // COL_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.colName = iprot.readString();
+ struct.setColNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // COL_TYPE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.colType = iprot.readString();
+ struct.setColTypeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // STATS_DATA
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.statsData = new ColumnStatisticsData();
+ struct.statsData.read(iprot);
+ struct.setStatsDataIsSet(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, ColumnStatisticsObj struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.colName != null) {
+ oprot.writeFieldBegin(COL_NAME_FIELD_DESC);
+ oprot.writeString(struct.colName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.colType != null) {
+ oprot.writeFieldBegin(COL_TYPE_FIELD_DESC);
+ oprot.writeString(struct.colType);
+ oprot.writeFieldEnd();
+ }
+ if (struct.statsData != null) {
+ oprot.writeFieldBegin(STATS_DATA_FIELD_DESC);
+ struct.statsData.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class ColumnStatisticsObjTupleSchemeFactory implements SchemeFactory {
+ public ColumnStatisticsObjTupleScheme getScheme() {
+ return new ColumnStatisticsObjTupleScheme();
+ }
+ }
+
+ private static class ColumnStatisticsObjTupleScheme extends TupleScheme<ColumnStatisticsObj> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsObj struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.colName);
+ oprot.writeString(struct.colType);
+ struct.statsData.write(oprot);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsObj struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.colName = iprot.readString();
+ struct.setColNameIsSet(true);
+ struct.colType = iprot.readString();
+ struct.setColTypeIsSet(true);
+ struct.statsData = new ColumnStatisticsData();
+ struct.statsData.read(iprot);
+ struct.setStatsDataIsSet(true);
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ConfigValSecurityException.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ConfigValSecurityException.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ConfigValSecurityException.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ConfigValSecurityException.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -21,11 +31,17 @@ import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class ConfigValSecurityException extends Exception implements org.apache.thrift.TBase<ConfigValSecurityException, ConfigValSecurityException._Fields>, java.io.Serializable, Cloneable {
+public class ConfigValSecurityException extends TException implements org.apache.thrift.TBase<ConfigValSecurityException, ConfigValSecurityException._Fields>, java.io.Serializable, Cloneable {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ConfigValSecurityException");
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 ConfigValSecurityExceptionStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new ConfigValSecurityExceptionTupleSchemeFactory());
+ }
+
private String message; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -87,7 +103,6 @@ public class ConfigValSecurityException
}
// 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);
@@ -246,42 +261,11 @@ public class ConfigValSecurityException
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // MESSAGE
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.message = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.message != null) {
- oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
- oprot.writeString(this.message);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -302,6 +286,7 @@ public class ConfigValSecurityException
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 {
@@ -320,5 +305,87 @@ public class ConfigValSecurityException
}
}
+ private static class ConfigValSecurityExceptionStandardSchemeFactory implements SchemeFactory {
+ public ConfigValSecurityExceptionStandardScheme getScheme() {
+ return new ConfigValSecurityExceptionStandardScheme();
+ }
+ }
+
+ private static class ConfigValSecurityExceptionStandardScheme extends StandardScheme<ConfigValSecurityException> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, ConfigValSecurityException 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, ConfigValSecurityException 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 ConfigValSecurityExceptionTupleSchemeFactory implements SchemeFactory {
+ public ConfigValSecurityExceptionTupleScheme getScheme() {
+ return new ConfigValSecurityExceptionTupleScheme();
+ }
+ }
+
+ private static class ConfigValSecurityExceptionTupleScheme extends TupleScheme<ConfigValSecurityException> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, ConfigValSecurityException 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, ConfigValSecurityException 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);
+ }
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Database.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Database.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Database.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Database.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -30,11 +40,17 @@ public class Database implements org.apa
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)4);
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)5);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new DatabaseStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new DatabaseTupleSchemeFactory());
+ }
+
private String name; // required
private String description; // required
private String locationUri; // required
private Map<String,String> parameters; // required
- private PrincipalPrivilegeSet privileges; // 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 {
@@ -107,7 +123,7 @@ public class Database implements org.apa
}
// isset id assignments
-
+ private _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);
@@ -561,113 +577,11 @@ public class Database implements org.apa
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.name = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // DESCRIPTION
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.description = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // LOCATION_URI
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.locationUri = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 4: // PARAMETERS
- if (field.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map39 = iprot.readMapBegin();
- this.parameters = new HashMap<String,String>(2*_map39.size);
- for (int _i40 = 0; _i40 < _map39.size; ++_i40)
- {
- String _key41; // required
- String _val42; // required
- _key41 = iprot.readString();
- _val42 = iprot.readString();
- this.parameters.put(_key41, _val42);
- }
- iprot.readMapEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 5: // PRIVILEGES
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.privileges = new PrincipalPrivilegeSet();
- this.privileges.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.name != null) {
- oprot.writeFieldBegin(NAME_FIELD_DESC);
- oprot.writeString(this.name);
- oprot.writeFieldEnd();
- }
- if (this.description != null) {
- oprot.writeFieldBegin(DESCRIPTION_FIELD_DESC);
- oprot.writeString(this.description);
- oprot.writeFieldEnd();
- }
- if (this.locationUri != null) {
- oprot.writeFieldBegin(LOCATION_URI_FIELD_DESC);
- oprot.writeString(this.locationUri);
- oprot.writeFieldEnd();
- }
- if (this.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, this.parameters.size()));
- for (Map.Entry<String, String> _iter43 : this.parameters.entrySet())
- {
- oprot.writeString(_iter43.getKey());
- oprot.writeString(_iter43.getValue());
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- if (this.privileges != null) {
- if (isSetPrivileges()) {
- oprot.writeFieldBegin(PRIVILEGES_FIELD_DESC);
- this.privileges.write(oprot);
- oprot.writeFieldEnd();
- }
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -722,6 +636,10 @@ public class Database implements org.apa
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 {
@@ -740,5 +658,221 @@ public class Database implements org.apa
}
}
+ private static class DatabaseStandardSchemeFactory implements SchemeFactory {
+ public DatabaseStandardScheme getScheme() {
+ return new DatabaseStandardScheme();
+ }
+ }
+
+ private static class DatabaseStandardScheme extends StandardScheme<Database> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, Database 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: // NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DESCRIPTION
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.description = iprot.readString();
+ struct.setDescriptionIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // LOCATION_URI
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.locationUri = iprot.readString();
+ struct.setLocationUriIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // PARAMETERS
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map78 = iprot.readMapBegin();
+ struct.parameters = new HashMap<String,String>(2*_map78.size);
+ for (int _i79 = 0; _i79 < _map78.size; ++_i79)
+ {
+ String _key80; // required
+ String _val81; // required
+ _key80 = iprot.readString();
+ _val81 = iprot.readString();
+ struct.parameters.put(_key80, _val81);
+ }
+ iprot.readMapEnd();
+ }
+ struct.setParametersIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // 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, Database struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.name != null) {
+ oprot.writeFieldBegin(NAME_FIELD_DESC);
+ oprot.writeString(struct.name);
+ oprot.writeFieldEnd();
+ }
+ if (struct.description != null) {
+ oprot.writeFieldBegin(DESCRIPTION_FIELD_DESC);
+ oprot.writeString(struct.description);
+ oprot.writeFieldEnd();
+ }
+ if (struct.locationUri != null) {
+ oprot.writeFieldBegin(LOCATION_URI_FIELD_DESC);
+ oprot.writeString(struct.locationUri);
+ 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<String, String> _iter82 : struct.parameters.entrySet())
+ {
+ oprot.writeString(_iter82.getKey());
+ oprot.writeString(_iter82.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 DatabaseTupleSchemeFactory implements SchemeFactory {
+ public DatabaseTupleScheme getScheme() {
+ return new DatabaseTupleScheme();
+ }
+ }
+
+ private static class DatabaseTupleScheme extends TupleScheme<Database> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, Database struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetName()) {
+ optionals.set(0);
+ }
+ if (struct.isSetDescription()) {
+ optionals.set(1);
+ }
+ if (struct.isSetLocationUri()) {
+ optionals.set(2);
+ }
+ if (struct.isSetParameters()) {
+ optionals.set(3);
+ }
+ if (struct.isSetPrivileges()) {
+ optionals.set(4);
+ }
+ oprot.writeBitSet(optionals, 5);
+ if (struct.isSetName()) {
+ oprot.writeString(struct.name);
+ }
+ if (struct.isSetDescription()) {
+ oprot.writeString(struct.description);
+ }
+ if (struct.isSetLocationUri()) {
+ oprot.writeString(struct.locationUri);
+ }
+ if (struct.isSetParameters()) {
+ {
+ oprot.writeI32(struct.parameters.size());
+ for (Map.Entry<String, String> _iter83 : struct.parameters.entrySet())
+ {
+ oprot.writeString(_iter83.getKey());
+ oprot.writeString(_iter83.getValue());
+ }
+ }
+ }
+ if (struct.isSetPrivileges()) {
+ struct.privileges.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, Database struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(5);
+ if (incoming.get(0)) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.description = iprot.readString();
+ struct.setDescriptionIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.locationUri = iprot.readString();
+ struct.setLocationUriIsSet(true);
+ }
+ if (incoming.get(3)) {
+ {
+ org.apache.thrift.protocol.TMap _map84 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.parameters = new HashMap<String,String>(2*_map84.size);
+ for (int _i85 = 0; _i85 < _map84.size; ++_i85)
+ {
+ String _key86; // required
+ String _val87; // required
+ _key86 = iprot.readString();
+ _val87 = iprot.readString();
+ struct.parameters.put(_key86, _val87);
+ }
+ }
+ struct.setParametersIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.privileges = new PrincipalPrivilegeSet();
+ struct.privileges.read(iprot);
+ struct.setPrivilegesIsSet(true);
+ }
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DoubleColumnStatsData.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DoubleColumnStatsData.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DoubleColumnStatsData.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DoubleColumnStatsData.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -29,6 +39,12 @@ public class DoubleColumnStatsData imple
private static final org.apache.thrift.protocol.TField NUM_NULLS_FIELD_DESC = new org.apache.thrift.protocol.TField("numNulls", org.apache.thrift.protocol.TType.I64, (short)3);
private static final org.apache.thrift.protocol.TField NUM_DVS_FIELD_DESC = new org.apache.thrift.protocol.TField("numDVs", org.apache.thrift.protocol.TType.I64, (short)4);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new DoubleColumnStatsDataStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new DoubleColumnStatsDataTupleSchemeFactory());
+ }
+
private double lowValue; // required
private double highValue; // required
private long numNulls; // required
@@ -106,8 +122,7 @@ public class DoubleColumnStatsData imple
private static final int __HIGHVALUE_ISSET_ID = 1;
private static final int __NUMNULLS_ISSET_ID = 2;
private static final int __NUMDVS_ISSET_ID = 3;
- private BitSet __isset_bit_vector = new BitSet(4);
-
+ private byte __isset_bitfield = 0;
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);
@@ -147,8 +162,7 @@ public class DoubleColumnStatsData imple
* Performs a deep copy on <i>other</i>.
*/
public DoubleColumnStatsData(DoubleColumnStatsData other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ __isset_bitfield = other.__isset_bitfield;
this.lowValue = other.lowValue;
this.highValue = other.highValue;
this.numNulls = other.numNulls;
@@ -181,16 +195,16 @@ public class DoubleColumnStatsData imple
}
public void unsetLowValue() {
- __isset_bit_vector.clear(__LOWVALUE_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LOWVALUE_ISSET_ID);
}
/** Returns true if field lowValue is set (has been assigned a value) and false otherwise */
public boolean isSetLowValue() {
- return __isset_bit_vector.get(__LOWVALUE_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __LOWVALUE_ISSET_ID);
}
public void setLowValueIsSet(boolean value) {
- __isset_bit_vector.set(__LOWVALUE_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LOWVALUE_ISSET_ID, value);
}
public double getHighValue() {
@@ -203,16 +217,16 @@ public class DoubleColumnStatsData imple
}
public void unsetHighValue() {
- __isset_bit_vector.clear(__HIGHVALUE_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __HIGHVALUE_ISSET_ID);
}
/** Returns true if field highValue is set (has been assigned a value) and false otherwise */
public boolean isSetHighValue() {
- return __isset_bit_vector.get(__HIGHVALUE_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __HIGHVALUE_ISSET_ID);
}
public void setHighValueIsSet(boolean value) {
- __isset_bit_vector.set(__HIGHVALUE_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __HIGHVALUE_ISSET_ID, value);
}
public long getNumNulls() {
@@ -225,16 +239,16 @@ public class DoubleColumnStatsData imple
}
public void unsetNumNulls() {
- __isset_bit_vector.clear(__NUMNULLS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
/** Returns true if field numNulls is set (has been assigned a value) and false otherwise */
public boolean isSetNumNulls() {
- return __isset_bit_vector.get(__NUMNULLS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMNULLS_ISSET_ID);
}
public void setNumNullsIsSet(boolean value) {
- __isset_bit_vector.set(__NUMNULLS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMNULLS_ISSET_ID, value);
}
public long getNumDVs() {
@@ -247,16 +261,16 @@ public class DoubleColumnStatsData imple
}
public void unsetNumDVs() {
- __isset_bit_vector.clear(__NUMDVS_ISSET_ID);
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __NUMDVS_ISSET_ID);
}
/** Returns true if field numDVs is set (has been assigned a value) and false otherwise */
public boolean isSetNumDVs() {
- return __isset_bit_vector.get(__NUMDVS_ISSET_ID);
+ return EncodingUtils.testBit(__isset_bitfield, __NUMDVS_ISSET_ID);
}
public void setNumDVsIsSet(boolean value) {
- __isset_bit_vector.set(__NUMDVS_ISSET_ID, value);
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __NUMDVS_ISSET_ID, value);
}
public void setFieldValue(_Fields field, Object value) {
@@ -468,74 +482,11 @@ public class DoubleColumnStatsData imple
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // LOW_VALUE
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.lowValue = iprot.readDouble();
- setLowValueIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // HIGH_VALUE
- if (field.type == org.apache.thrift.protocol.TType.DOUBLE) {
- this.highValue = iprot.readDouble();
- setHighValueIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // NUM_NULLS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numNulls = iprot.readI64();
- setNumNullsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 4: // NUM_DVS
- if (field.type == org.apache.thrift.protocol.TType.I64) {
- this.numDVs = iprot.readI64();
- setNumDVsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(LOW_VALUE_FIELD_DESC);
- oprot.writeDouble(this.lowValue);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(HIGH_VALUE_FIELD_DESC);
- oprot.writeDouble(this.highValue);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
- oprot.writeI64(this.numNulls);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(NUM_DVS_FIELD_DESC);
- oprot.writeI64(this.numDVs);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -580,6 +531,7 @@ public class DoubleColumnStatsData imple
throw new org.apache.thrift.protocol.TProtocolException("Required field 'numDVs' is unset! Struct:" + toString());
}
+ // check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -593,12 +545,124 @@ public class DoubleColumnStatsData imple
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_bit_vector = new BitSet(1);
+ __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 DoubleColumnStatsDataStandardSchemeFactory implements SchemeFactory {
+ public DoubleColumnStatsDataStandardScheme getScheme() {
+ return new DoubleColumnStatsDataStandardScheme();
+ }
+ }
+
+ private static class DoubleColumnStatsDataStandardScheme extends StandardScheme<DoubleColumnStatsData> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, DoubleColumnStatsData 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: // LOW_VALUE
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.lowValue = iprot.readDouble();
+ struct.setLowValueIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // HIGH_VALUE
+ if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
+ struct.highValue = iprot.readDouble();
+ struct.setHighValueIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // NUM_NULLS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // NUM_DVS
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.numDVs = iprot.readI64();
+ struct.setNumDVsIsSet(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, DoubleColumnStatsData struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(LOW_VALUE_FIELD_DESC);
+ oprot.writeDouble(struct.lowValue);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(HIGH_VALUE_FIELD_DESC);
+ oprot.writeDouble(struct.highValue);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_NULLS_FIELD_DESC);
+ oprot.writeI64(struct.numNulls);
+ oprot.writeFieldEnd();
+ oprot.writeFieldBegin(NUM_DVS_FIELD_DESC);
+ oprot.writeI64(struct.numDVs);
+ oprot.writeFieldEnd();
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class DoubleColumnStatsDataTupleSchemeFactory implements SchemeFactory {
+ public DoubleColumnStatsDataTupleScheme getScheme() {
+ return new DoubleColumnStatsDataTupleScheme();
+ }
+ }
+
+ private static class DoubleColumnStatsDataTupleScheme extends TupleScheme<DoubleColumnStatsData> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, DoubleColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeDouble(struct.lowValue);
+ oprot.writeDouble(struct.highValue);
+ oprot.writeI64(struct.numNulls);
+ oprot.writeI64(struct.numDVs);
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, DoubleColumnStatsData struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.lowValue = iprot.readDouble();
+ struct.setLowValueIsSet(true);
+ struct.highValue = iprot.readDouble();
+ struct.setHighValueIsSet(true);
+ struct.numNulls = iprot.readI64();
+ struct.setNumNullsIsSet(true);
+ struct.numDVs = iprot.readI64();
+ struct.setNumDVsIsSet(true);
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/EnvironmentContext.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -26,6 +36,12 @@ public class EnvironmentContext implemen
private static final org.apache.thrift.protocol.TField PROPERTIES_FIELD_DESC = new org.apache.thrift.protocol.TField("properties", org.apache.thrift.protocol.TType.MAP, (short)1);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new EnvironmentContextStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new EnvironmentContextTupleSchemeFactory());
+ }
+
private Map<String,String> properties; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -87,7 +103,6 @@ public class EnvironmentContext implemen
}
// 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);
@@ -271,62 +286,11 @@ public class EnvironmentContext implemen
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // PROPERTIES
- if (field.type == org.apache.thrift.protocol.TType.MAP) {
- {
- org.apache.thrift.protocol.TMap _map123 = iprot.readMapBegin();
- this.properties = new HashMap<String,String>(2*_map123.size);
- for (int _i124 = 0; _i124 < _map123.size; ++_i124)
- {
- String _key125; // required
- String _val126; // required
- _key125 = iprot.readString();
- _val126 = iprot.readString();
- this.properties.put(_key125, _val126);
- }
- iprot.readMapEnd();
- }
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.properties != null) {
- oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
- {
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.properties.size()));
- for (Map.Entry<String, String> _iter127 : this.properties.entrySet())
- {
- oprot.writeString(_iter127.getKey());
- oprot.writeString(_iter127.getValue());
- }
- oprot.writeMapEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -347,6 +311,7 @@ public class EnvironmentContext implemen
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 {
@@ -365,5 +330,125 @@ public class EnvironmentContext implemen
}
}
+ private static class EnvironmentContextStandardSchemeFactory implements SchemeFactory {
+ public EnvironmentContextStandardScheme getScheme() {
+ return new EnvironmentContextStandardScheme();
+ }
+ }
+
+ private static class EnvironmentContextStandardScheme extends StandardScheme<EnvironmentContext> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, EnvironmentContext 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: // PROPERTIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+ {
+ org.apache.thrift.protocol.TMap _map246 = iprot.readMapBegin();
+ struct.properties = new HashMap<String,String>(2*_map246.size);
+ for (int _i247 = 0; _i247 < _map246.size; ++_i247)
+ {
+ String _key248; // required
+ String _val249; // required
+ _key248 = iprot.readString();
+ _val249 = iprot.readString();
+ struct.properties.put(_key248, _val249);
+ }
+ iprot.readMapEnd();
+ }
+ struct.setPropertiesIsSet(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, EnvironmentContext struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.properties != null) {
+ oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
+ {
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.properties.size()));
+ for (Map.Entry<String, String> _iter250 : struct.properties.entrySet())
+ {
+ oprot.writeString(_iter250.getKey());
+ oprot.writeString(_iter250.getValue());
+ }
+ oprot.writeMapEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class EnvironmentContextTupleSchemeFactory implements SchemeFactory {
+ public EnvironmentContextTupleScheme getScheme() {
+ return new EnvironmentContextTupleScheme();
+ }
+ }
+
+ private static class EnvironmentContextTupleScheme extends TupleScheme<EnvironmentContext> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, EnvironmentContext struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetProperties()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetProperties()) {
+ {
+ oprot.writeI32(struct.properties.size());
+ for (Map.Entry<String, String> _iter251 : struct.properties.entrySet())
+ {
+ oprot.writeString(_iter251.getKey());
+ oprot.writeString(_iter251.getValue());
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, EnvironmentContext struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TMap _map252 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.properties = new HashMap<String,String>(2*_map252.size);
+ for (int _i253 = 0; _i253 < _map252.size; ++_i253)
+ {
+ String _key254; // required
+ String _val255; // required
+ _key254 = iprot.readString();
+ _val255 = iprot.readString();
+ struct.properties.put(_key254, _val255);
+ }
+ }
+ struct.setPropertiesIsSet(true);
+ }
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,6 +38,12 @@ public class FieldSchema implements org.
private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField COMMENT_FIELD_DESC = new org.apache.thrift.protocol.TField("comment", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new FieldSchemaStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new FieldSchemaTupleSchemeFactory());
+ }
+
private String name; // required
private String type; // required
private String comment; // required
@@ -97,7 +113,6 @@ public class FieldSchema implements org.
}
// 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);
@@ -392,66 +407,11 @@ public class FieldSchema implements org.
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.name = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // TYPE
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.type = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // COMMENT
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.comment = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.name != null) {
- oprot.writeFieldBegin(NAME_FIELD_DESC);
- oprot.writeString(this.name);
- oprot.writeFieldEnd();
- }
- if (this.type != null) {
- oprot.writeFieldBegin(TYPE_FIELD_DESC);
- oprot.writeString(this.type);
- oprot.writeFieldEnd();
- }
- if (this.comment != null) {
- oprot.writeFieldBegin(COMMENT_FIELD_DESC);
- oprot.writeString(this.comment);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -488,6 +448,7 @@ public class FieldSchema implements org.
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 {
@@ -506,5 +467,133 @@ public class FieldSchema implements org.
}
}
+ private static class FieldSchemaStandardSchemeFactory implements SchemeFactory {
+ public FieldSchemaStandardScheme getScheme() {
+ return new FieldSchemaStandardScheme();
+ }
+ }
+
+ private static class FieldSchemaStandardScheme extends StandardScheme<FieldSchema> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, FieldSchema 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: // NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // TYPE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.type = iprot.readString();
+ struct.setTypeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // COMMENT
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.comment = iprot.readString();
+ struct.setCommentIsSet(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, FieldSchema struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.name != null) {
+ oprot.writeFieldBegin(NAME_FIELD_DESC);
+ oprot.writeString(struct.name);
+ oprot.writeFieldEnd();
+ }
+ if (struct.type != null) {
+ oprot.writeFieldBegin(TYPE_FIELD_DESC);
+ oprot.writeString(struct.type);
+ oprot.writeFieldEnd();
+ }
+ if (struct.comment != null) {
+ oprot.writeFieldBegin(COMMENT_FIELD_DESC);
+ oprot.writeString(struct.comment);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class FieldSchemaTupleSchemeFactory implements SchemeFactory {
+ public FieldSchemaTupleScheme getScheme() {
+ return new FieldSchemaTupleScheme();
+ }
+ }
+
+ private static class FieldSchemaTupleScheme extends TupleScheme<FieldSchema> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, FieldSchema struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetName()) {
+ optionals.set(0);
+ }
+ if (struct.isSetType()) {
+ optionals.set(1);
+ }
+ if (struct.isSetComment()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetName()) {
+ oprot.writeString(struct.name);
+ }
+ if (struct.isSetType()) {
+ oprot.writeString(struct.type);
+ }
+ if (struct.isSetComment()) {
+ oprot.writeString(struct.comment);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, FieldSchema struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.name = iprot.readString();
+ struct.setNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.type = iprot.readString();
+ struct.setTypeIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.comment = iprot.readString();
+ struct.setCommentIsSet(true);
+ }
+ }
+ }
+
}
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectPrivilege.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectPrivilege.java?rev=1406984&r1=1406983&r2=1406984&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectPrivilege.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectPrivilege.java Thu Nov 8 09:44:19 2012
@@ -1,11 +1,21 @@
/**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
*
* 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.commons.lang.builder.HashCodeBuilder;
+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 java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -29,6 +39,12 @@ public class HiveObjectPrivilege impleme
private static final org.apache.thrift.protocol.TField PRINCIPAL_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("principalType", org.apache.thrift.protocol.TType.I32, (short)3);
private static final org.apache.thrift.protocol.TField GRANT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("grantInfo", org.apache.thrift.protocol.TType.STRUCT, (short)4);
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new HiveObjectPrivilegeStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new HiveObjectPrivilegeTupleSchemeFactory());
+ }
+
private HiveObjectRef hiveObject; // required
private String principalName; // required
private PrincipalType principalType; // required
@@ -106,7 +122,6 @@ public class HiveObjectPrivilege impleme
}
// 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);
@@ -477,80 +492,11 @@ public class HiveObjectPrivilege impleme
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField field;
- iprot.readStructBegin();
- while (true)
- {
- field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
- break;
- }
- switch (field.id) {
- case 1: // HIVE_OBJECT
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.hiveObject = new HiveObjectRef();
- this.hiveObject.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 2: // PRINCIPAL_NAME
- if (field.type == org.apache.thrift.protocol.TType.STRING) {
- this.principalName = iprot.readString();
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 3: // PRINCIPAL_TYPE
- if (field.type == org.apache.thrift.protocol.TType.I32) {
- this.principalType = PrincipalType.findByValue(iprot.readI32());
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case 4: // GRANT_INFO
- if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
- this.grantInfo = new PrivilegeGrantInfo();
- this.grantInfo.read(iprot);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
- }
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- validate();
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
- validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (this.hiveObject != null) {
- oprot.writeFieldBegin(HIVE_OBJECT_FIELD_DESC);
- this.hiveObject.write(oprot);
- oprot.writeFieldEnd();
- }
- if (this.principalName != null) {
- oprot.writeFieldBegin(PRINCIPAL_NAME_FIELD_DESC);
- oprot.writeString(this.principalName);
- oprot.writeFieldEnd();
- }
- if (this.principalType != null) {
- oprot.writeFieldBegin(PRINCIPAL_TYPE_FIELD_DESC);
- oprot.writeI32(this.principalType.getValue());
- oprot.writeFieldEnd();
- }
- if (this.grantInfo != null) {
- oprot.writeFieldBegin(GRANT_INFO_FIELD_DESC);
- this.grantInfo.write(oprot);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
@@ -595,6 +541,13 @@ public class HiveObjectPrivilege impleme
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ // check for sub-struct validity
+ if (hiveObject != null) {
+ hiveObject.validate();
+ }
+ if (grantInfo != null) {
+ grantInfo.validate();
+ }
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -613,5 +566,160 @@ public class HiveObjectPrivilege impleme
}
}
+ private static class HiveObjectPrivilegeStandardSchemeFactory implements SchemeFactory {
+ public HiveObjectPrivilegeStandardScheme getScheme() {
+ return new HiveObjectPrivilegeStandardScheme();
+ }
+ }
+
+ private static class HiveObjectPrivilegeStandardScheme extends StandardScheme<HiveObjectPrivilege> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, HiveObjectPrivilege 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: // HIVE_OBJECT
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.hiveObject = new HiveObjectRef();
+ struct.hiveObject.read(iprot);
+ struct.setHiveObjectIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // PRINCIPAL_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.principalName = iprot.readString();
+ struct.setPrincipalNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // PRINCIPAL_TYPE
+ if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+ struct.principalType = PrincipalType.findByValue(iprot.readI32());
+ struct.setPrincipalTypeIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // GRANT_INFO
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.grantInfo = new PrivilegeGrantInfo();
+ struct.grantInfo.read(iprot);
+ struct.setGrantInfoIsSet(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, HiveObjectPrivilege struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.hiveObject != null) {
+ oprot.writeFieldBegin(HIVE_OBJECT_FIELD_DESC);
+ struct.hiveObject.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.principalName != null) {
+ oprot.writeFieldBegin(PRINCIPAL_NAME_FIELD_DESC);
+ oprot.writeString(struct.principalName);
+ oprot.writeFieldEnd();
+ }
+ if (struct.principalType != null) {
+ oprot.writeFieldBegin(PRINCIPAL_TYPE_FIELD_DESC);
+ oprot.writeI32(struct.principalType.getValue());
+ oprot.writeFieldEnd();
+ }
+ if (struct.grantInfo != null) {
+ oprot.writeFieldBegin(GRANT_INFO_FIELD_DESC);
+ struct.grantInfo.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class HiveObjectPrivilegeTupleSchemeFactory implements SchemeFactory {
+ public HiveObjectPrivilegeTupleScheme getScheme() {
+ return new HiveObjectPrivilegeTupleScheme();
+ }
+ }
+
+ private static class HiveObjectPrivilegeTupleScheme extends TupleScheme<HiveObjectPrivilege> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, HiveObjectPrivilege struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetHiveObject()) {
+ optionals.set(0);
+ }
+ if (struct.isSetPrincipalName()) {
+ optionals.set(1);
+ }
+ if (struct.isSetPrincipalType()) {
+ optionals.set(2);
+ }
+ if (struct.isSetGrantInfo()) {
+ optionals.set(3);
+ }
+ oprot.writeBitSet(optionals, 4);
+ if (struct.isSetHiveObject()) {
+ struct.hiveObject.write(oprot);
+ }
+ if (struct.isSetPrincipalName()) {
+ oprot.writeString(struct.principalName);
+ }
+ if (struct.isSetPrincipalType()) {
+ oprot.writeI32(struct.principalType.getValue());
+ }
+ if (struct.isSetGrantInfo()) {
+ struct.grantInfo.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, HiveObjectPrivilege struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(4);
+ if (incoming.get(0)) {
+ struct.hiveObject = new HiveObjectRef();
+ struct.hiveObject.read(iprot);
+ struct.setHiveObjectIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.principalName = iprot.readString();
+ struct.setPrincipalNameIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.principalType = PrincipalType.findByValue(iprot.readI32());
+ struct.setPrincipalTypeIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.grantInfo = new PrivilegeGrantInfo();
+ struct.grantInfo.read(iprot);
+ struct.setGrantInfoIsSet(true);
+ }
+ }
+ }
+
}