You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/05/05 17:32:06 UTC
[19/51] [partial] hive git commit: HIVE-14671 : merge master into
hive-14535 (Wei Zheng)
http://git-wip-us.apache.org/repos/asf/hive/blob/187eb760/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 6b80461..cb1bd59 100644
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -90,6 +90,8 @@ public class ThriftHiveMetastore {
public void drop_table_with_environment_context(String dbname, String name, boolean deleteData, EnvironmentContext environment_context) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+ public void truncate_table(String dbName, String tableName, List<String> partNames) throws MetaException, org.apache.thrift.TException;
+
public List<String> get_tables(String db_name, String pattern) throws MetaException, org.apache.thrift.TException;
public List<String> get_tables_by_type(String db_name, String pattern, String tableType) throws MetaException, org.apache.thrift.TException;
@@ -408,6 +410,8 @@ public class ThriftHiveMetastore {
public void drop_table_with_environment_context(String dbname, String name, boolean deleteData, EnvironmentContext environment_context, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void truncate_table(String dbName, String tableName, List<String> partNames, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
public void get_tables(String db_name, String pattern, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void get_tables_by_type(String db_name, String pattern, String tableType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
@@ -1397,6 +1401,31 @@ public class ThriftHiveMetastore {
return;
}
+ public void truncate_table(String dbName, String tableName, List<String> partNames) throws MetaException, org.apache.thrift.TException
+ {
+ send_truncate_table(dbName, tableName, partNames);
+ recv_truncate_table();
+ }
+
+ public void send_truncate_table(String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
+ {
+ truncate_table_args args = new truncate_table_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setPartNames(partNames);
+ sendBase("truncate_table", args);
+ }
+
+ public void recv_truncate_table() throws MetaException, org.apache.thrift.TException
+ {
+ truncate_table_result result = new truncate_table_result();
+ receiveBase(result, "truncate_table");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ return;
+ }
+
public List<String> get_tables(String db_name, String pattern) throws MetaException, org.apache.thrift.TException
{
send_get_tables(db_name, pattern);
@@ -6027,6 +6056,44 @@ public class ThriftHiveMetastore {
}
}
+ public void truncate_table(String dbName, String tableName, List<String> partNames, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ truncate_table_call method_call = new truncate_table_call(dbName, tableName, partNames, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class truncate_table_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String dbName;
+ private String tableName;
+ private List<String> partNames;
+ public truncate_table_call(String dbName, String tableName, List<String> partNames, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ super(client, protocolFactory, transport, resultHandler, false);
+ this.dbName = dbName;
+ this.tableName = tableName;
+ this.partNames = partNames;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate_table", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ truncate_table_args args = new truncate_table_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setPartNames(partNames);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_truncate_table();
+ }
+ }
+
public void get_tables(String db_name, String pattern, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
get_tables_call method_call = new get_tables_call(db_name, pattern, resultHandler, this, ___protocolFactory, ___transport);
@@ -10758,6 +10825,7 @@ public class ThriftHiveMetastore {
processMap.put("add_foreign_key", new add_foreign_key());
processMap.put("drop_table", new drop_table());
processMap.put("drop_table_with_environment_context", new drop_table_with_environment_context());
+ processMap.put("truncate_table", new truncate_table());
processMap.put("get_tables", new get_tables());
processMap.put("get_tables_by_type", new get_tables_by_type());
processMap.put("get_table_meta", new get_table_meta());
@@ -11536,6 +11604,30 @@ public class ThriftHiveMetastore {
}
}
+ public static class truncate_table<I extends Iface> extends org.apache.thrift.ProcessFunction<I, truncate_table_args> {
+ public truncate_table() {
+ super("truncate_table");
+ }
+
+ public truncate_table_args getEmptyArgsInstance() {
+ return new truncate_table_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public truncate_table_result getResult(I iface, truncate_table_args args) throws org.apache.thrift.TException {
+ truncate_table_result result = new truncate_table_result();
+ try {
+ iface.truncate_table(args.dbName, args.tableName, args.partNames);
+ } catch (MetaException o1) {
+ result.o1 = o1;
+ }
+ return result;
+ }
+ }
+
public static class get_tables<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_tables_args> {
public get_tables() {
super("get_tables");
@@ -14907,6 +14999,7 @@ public class ThriftHiveMetastore {
processMap.put("add_foreign_key", new add_foreign_key());
processMap.put("drop_table", new drop_table());
processMap.put("drop_table_with_environment_context", new drop_table_with_environment_context());
+ processMap.put("truncate_table", new truncate_table());
processMap.put("get_tables", new get_tables());
processMap.put("get_tables_by_type", new get_tables_by_type());
processMap.put("get_table_meta", new get_table_meta());
@@ -16561,6 +16654,62 @@ public class ThriftHiveMetastore {
}
}
+ public static class truncate_table<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, truncate_table_args, Void> {
+ public truncate_table() {
+ super("truncate_table");
+ }
+
+ public truncate_table_args getEmptyArgsInstance() {
+ return new truncate_table_args();
+ }
+
+ public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<Void>() {
+ public void onComplete(Void o) {
+ truncate_table_result result = new truncate_table_result();
+ try {
+ fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
+ return;
+ } catch (Exception e) {
+ LOGGER.error("Exception writing to internal frame buffer", e);
+ }
+ fb.close();
+ }
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ truncate_table_result result = new truncate_table_result();
+ if (e instanceof MetaException) {
+ result.o1 = (MetaException) e;
+ result.setO1IsSet(true);
+ msg = result;
+ }
+ else
+ {
+ msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+ }
+ try {
+ fcall.sendResponse(fb,msg,msgType,seqid);
+ return;
+ } catch (Exception ex) {
+ LOGGER.error("Exception writing to internal frame buffer", ex);
+ }
+ fb.close();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, truncate_table_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
+ iface.truncate_table(args.dbName, args.tableName, args.partNames,resultHandler);
+ }
+ }
+
public static class get_tables<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_tables_args, List<String>> {
public get_tables() {
super("get_tables");
@@ -48577,7 +48726,1015 @@ public class ThriftHiveMetastore {
@Override
public String toString() {
- StringBuilder sb = new StringBuilder("drop_table_with_environment_context_result(");
+ StringBuilder sb = new StringBuilder("drop_table_with_environment_context_result(");
+ boolean first = true;
+
+ sb.append("o1:");
+ if (this.o1 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o1);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("o3:");
+ if (this.o3 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o3);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class drop_table_with_environment_context_resultStandardSchemeFactory implements SchemeFactory {
+ public drop_table_with_environment_context_resultStandardScheme getScheme() {
+ return new drop_table_with_environment_context_resultStandardScheme();
+ }
+ }
+
+ private static class drop_table_with_environment_context_resultStandardScheme extends StandardScheme<drop_table_with_environment_context_result> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_table_with_environment_context_result 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: // O1
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.o1 = new NoSuchObjectException();
+ struct.o1.read(iprot);
+ struct.setO1IsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // O3
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.o3 = new MetaException();
+ struct.o3.read(iprot);
+ struct.setO3IsSet(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, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.o1 != null) {
+ oprot.writeFieldBegin(O1_FIELD_DESC);
+ struct.o1.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.o3 != null) {
+ oprot.writeFieldBegin(O3_FIELD_DESC);
+ struct.o3.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class drop_table_with_environment_context_resultTupleSchemeFactory implements SchemeFactory {
+ public drop_table_with_environment_context_resultTupleScheme getScheme() {
+ return new drop_table_with_environment_context_resultTupleScheme();
+ }
+ }
+
+ private static class drop_table_with_environment_context_resultTupleScheme extends TupleScheme<drop_table_with_environment_context_result> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetO1()) {
+ optionals.set(0);
+ }
+ if (struct.isSetO3()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.isSetO1()) {
+ struct.o1.write(oprot);
+ }
+ if (struct.isSetO3()) {
+ struct.o3.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ struct.o1 = new NoSuchObjectException();
+ struct.o1.read(iprot);
+ struct.setO1IsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.o3 = new MetaException();
+ struct.o3.read(iprot);
+ struct.setO3IsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class truncate_table_args implements org.apache.thrift.TBase<truncate_table_args, truncate_table_args._Fields>, java.io.Serializable, Cloneable, Comparable<truncate_table_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("truncate_table_args");
+
+ 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 PART_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("partNames", org.apache.thrift.protocol.TType.LIST, (short)3);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new truncate_table_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new truncate_table_argsTupleSchemeFactory());
+ }
+
+ private String dbName; // required
+ private String tableName; // required
+ private List<String> partNames; // 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 {
+ DB_NAME((short)1, "dbName"),
+ TABLE_NAME((short)2, "tableName"),
+ PART_NAMES((short)3, "partNames");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // DB_NAME
+ return DB_NAME;
+ case 2: // TABLE_NAME
+ return TABLE_NAME;
+ case 3: // PART_NAMES
+ return PART_NAMES;
+ 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.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.PART_NAMES, new org.apache.thrift.meta_data.FieldMetaData("partNames", 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))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(truncate_table_args.class, metaDataMap);
+ }
+
+ public truncate_table_args() {
+ }
+
+ public truncate_table_args(
+ String dbName,
+ String tableName,
+ List<String> partNames)
+ {
+ this();
+ this.dbName = dbName;
+ this.tableName = tableName;
+ this.partNames = partNames;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public truncate_table_args(truncate_table_args other) {
+ if (other.isSetDbName()) {
+ this.dbName = other.dbName;
+ }
+ if (other.isSetTableName()) {
+ this.tableName = other.tableName;
+ }
+ if (other.isSetPartNames()) {
+ List<String> __this__partNames = new ArrayList<String>(other.partNames);
+ this.partNames = __this__partNames;
+ }
+ }
+
+ public truncate_table_args deepCopy() {
+ return new truncate_table_args(this);
+ }
+
+ @Override
+ public void clear() {
+ this.dbName = null;
+ this.tableName = null;
+ this.partNames = 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 int getPartNamesSize() {
+ return (this.partNames == null) ? 0 : this.partNames.size();
+ }
+
+ public java.util.Iterator<String> getPartNamesIterator() {
+ return (this.partNames == null) ? null : this.partNames.iterator();
+ }
+
+ public void addToPartNames(String elem) {
+ if (this.partNames == null) {
+ this.partNames = new ArrayList<String>();
+ }
+ this.partNames.add(elem);
+ }
+
+ public List<String> getPartNames() {
+ return this.partNames;
+ }
+
+ public void setPartNames(List<String> partNames) {
+ this.partNames = partNames;
+ }
+
+ public void unsetPartNames() {
+ this.partNames = null;
+ }
+
+ /** Returns true if field partNames is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartNames() {
+ return this.partNames != null;
+ }
+
+ public void setPartNamesIsSet(boolean value) {
+ if (!value) {
+ this.partNames = 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 PART_NAMES:
+ if (value == null) {
+ unsetPartNames();
+ } else {
+ setPartNames((List<String>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case DB_NAME:
+ return getDbName();
+
+ case TABLE_NAME:
+ return getTableName();
+
+ case PART_NAMES:
+ return getPartNames();
+
+ }
+ 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 PART_NAMES:
+ return isSetPartNames();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof truncate_table_args)
+ return this.equals((truncate_table_args)that);
+ return false;
+ }
+
+ public boolean equals(truncate_table_args 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_partNames = true && this.isSetPartNames();
+ boolean that_present_partNames = true && that.isSetPartNames();
+ if (this_present_partNames || that_present_partNames) {
+ if (!(this_present_partNames && that_present_partNames))
+ return false;
+ if (!this.partNames.equals(that.partNames))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ 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_partNames = true && (isSetPartNames());
+ list.add(present_partNames);
+ if (present_partNames)
+ list.add(partNames);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(truncate_table_args 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(isSetPartNames()).compareTo(other.isSetPartNames());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartNames()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partNames, other.partNames);
+ 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("truncate_table_args(");
+ 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("partNames:");
+ if (this.partNames == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partNames);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class truncate_table_argsStandardSchemeFactory implements SchemeFactory {
+ public truncate_table_argsStandardScheme getScheme() {
+ return new truncate_table_argsStandardScheme();
+ }
+ }
+
+ private static class truncate_table_argsStandardScheme extends StandardScheme<truncate_table_args> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, truncate_table_args 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: // PART_NAMES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
+ struct.partNames = new ArrayList<String>(_list756.size);
+ String _elem757;
+ for (int _i758 = 0; _i758 < _list756.size; ++_i758)
+ {
+ _elem757 = iprot.readString();
+ struct.partNames.add(_elem757);
+ }
+ iprot.readListEnd();
+ }
+ struct.setPartNamesIsSet(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, truncate_table_args 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.partNames != null) {
+ oprot.writeFieldBegin(PART_NAMES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size()));
+ for (String _iter759 : struct.partNames)
+ {
+ oprot.writeString(_iter759);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class truncate_table_argsTupleSchemeFactory implements SchemeFactory {
+ public truncate_table_argsTupleScheme getScheme() {
+ return new truncate_table_argsTupleScheme();
+ }
+ }
+
+ private static class truncate_table_argsTupleScheme extends TupleScheme<truncate_table_args> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, truncate_table_args 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.isSetPartNames()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetDbName()) {
+ oprot.writeString(struct.dbName);
+ }
+ if (struct.isSetTableName()) {
+ oprot.writeString(struct.tableName);
+ }
+ if (struct.isSetPartNames()) {
+ {
+ oprot.writeI32(struct.partNames.size());
+ for (String _iter760 : struct.partNames)
+ {
+ oprot.writeString(_iter760);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, truncate_table_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.dbName = iprot.readString();
+ struct.setDbNameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.tableName = iprot.readString();
+ struct.setTableNameIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.partNames = new ArrayList<String>(_list761.size);
+ String _elem762;
+ for (int _i763 = 0; _i763 < _list761.size; ++_i763)
+ {
+ _elem762 = iprot.readString();
+ struct.partNames.add(_elem762);
+ }
+ }
+ struct.setPartNamesIsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class truncate_table_result implements org.apache.thrift.TBase<truncate_table_result, truncate_table_result._Fields>, java.io.Serializable, Cloneable, Comparable<truncate_table_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("truncate_table_result");
+
+ private static final org.apache.thrift.protocol.TField O1_FIELD_DESC = new org.apache.thrift.protocol.TField("o1", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new truncate_table_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new truncate_table_resultTupleSchemeFactory());
+ }
+
+ private MetaException o1; // 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 {
+ O1((short)1, "o1");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // O1
+ return O1;
+ 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.O1, new org.apache.thrift.meta_data.FieldMetaData("o1", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(truncate_table_result.class, metaDataMap);
+ }
+
+ public truncate_table_result() {
+ }
+
+ public truncate_table_result(
+ MetaException o1)
+ {
+ this();
+ this.o1 = o1;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public truncate_table_result(truncate_table_result other) {
+ if (other.isSetO1()) {
+ this.o1 = new MetaException(other.o1);
+ }
+ }
+
+ public truncate_table_result deepCopy() {
+ return new truncate_table_result(this);
+ }
+
+ @Override
+ public void clear() {
+ this.o1 = null;
+ }
+
+ public MetaException getO1() {
+ return this.o1;
+ }
+
+ public void setO1(MetaException o1) {
+ this.o1 = o1;
+ }
+
+ public void unsetO1() {
+ this.o1 = null;
+ }
+
+ /** Returns true if field o1 is set (has been assigned a value) and false otherwise */
+ public boolean isSetO1() {
+ return this.o1 != null;
+ }
+
+ public void setO1IsSet(boolean value) {
+ if (!value) {
+ this.o1 = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case O1:
+ if (value == null) {
+ unsetO1();
+ } else {
+ setO1((MetaException)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case O1:
+ return getO1();
+
+ }
+ 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 O1:
+ return isSetO1();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof truncate_table_result)
+ return this.equals((truncate_table_result)that);
+ return false;
+ }
+
+ public boolean equals(truncate_table_result that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_o1 = true && this.isSetO1();
+ boolean that_present_o1 = true && that.isSetO1();
+ if (this_present_o1 || that_present_o1) {
+ if (!(this_present_o1 && that_present_o1))
+ return false;
+ if (!this.o1.equals(that.o1))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_o1 = true && (isSetO1());
+ list.add(present_o1);
+ if (present_o1)
+ list.add(o1);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(truncate_table_result other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetO1()).compareTo(other.isSetO1());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetO1()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o1, other.o1);
+ 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("truncate_table_result(");
boolean first = true;
sb.append("o1:");
@@ -48587,14 +49744,6 @@ public class ThriftHiveMetastore {
sb.append(this.o1);
}
first = false;
- if (!first) sb.append(", ");
- sb.append("o3:");
- if (this.o3 == null) {
- sb.append("null");
- } else {
- sb.append(this.o3);
- }
- first = false;
sb.append(")");
return sb.toString();
}
@@ -48620,15 +49769,15 @@ public class ThriftHiveMetastore {
}
}
- private static class drop_table_with_environment_context_resultStandardSchemeFactory implements SchemeFactory {
- public drop_table_with_environment_context_resultStandardScheme getScheme() {
- return new drop_table_with_environment_context_resultStandardScheme();
+ private static class truncate_table_resultStandardSchemeFactory implements SchemeFactory {
+ public truncate_table_resultStandardScheme getScheme() {
+ return new truncate_table_resultStandardScheme();
}
}
- private static class drop_table_with_environment_context_resultStandardScheme extends StandardScheme<drop_table_with_environment_context_result> {
+ private static class truncate_table_resultStandardScheme extends StandardScheme<truncate_table_result> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol iprot, truncate_table_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@@ -48640,22 +49789,13 @@ public class ThriftHiveMetastore {
switch (schemeField.id) {
case 1: // O1
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.o1 = new NoSuchObjectException();
+ struct.o1 = new MetaException();
struct.o1.read(iprot);
struct.setO1IsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 2: // O3
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
- struct.o3 = new MetaException();
- struct.o3.read(iprot);
- struct.setO3IsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -48665,7 +49805,7 @@ public class ThriftHiveMetastore {
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol oprot, truncate_table_result struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -48674,58 +49814,42 @@ public class ThriftHiveMetastore {
struct.o1.write(oprot);
oprot.writeFieldEnd();
}
- if (struct.o3 != null) {
- oprot.writeFieldBegin(O3_FIELD_DESC);
- struct.o3.write(oprot);
- oprot.writeFieldEnd();
- }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
- private static class drop_table_with_environment_context_resultTupleSchemeFactory implements SchemeFactory {
- public drop_table_with_environment_context_resultTupleScheme getScheme() {
- return new drop_table_with_environment_context_resultTupleScheme();
+ private static class truncate_table_resultTupleSchemeFactory implements SchemeFactory {
+ public truncate_table_resultTupleScheme getScheme() {
+ return new truncate_table_resultTupleScheme();
}
}
- private static class drop_table_with_environment_context_resultTupleScheme extends TupleScheme<drop_table_with_environment_context_result> {
+ private static class truncate_table_resultTupleScheme extends TupleScheme<truncate_table_result> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.thrift.protocol.TProtocol prot, truncate_table_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
if (struct.isSetO1()) {
optionals.set(0);
}
- if (struct.isSetO3()) {
- optionals.set(1);
- }
- oprot.writeBitSet(optionals, 2);
+ oprot.writeBitSet(optionals, 1);
if (struct.isSetO1()) {
struct.o1.write(oprot);
}
- if (struct.isSetO3()) {
- struct.o3.write(oprot);
- }
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, drop_table_with_environment_context_result struct) throws org.apache.thrift.TException {
+ public void read(org.apache.thrift.protocol.TProtocol prot, truncate_table_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(2);
+ BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
- struct.o1 = new NoSuchObjectException();
+ struct.o1 = new MetaException();
struct.o1.read(iprot);
struct.setO1IsSet(true);
}
- if (incoming.get(1)) {
- struct.o3 = new MetaException();
- struct.o3.read(iprot);
- struct.setO3IsSet(true);
- }
}
}
@@ -49586,13 +50710,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list756.size);
- String _elem757;
- for (int _i758 = 0; _i758 < _list756.size; ++_i758)
+ org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list764.size);
+ String _elem765;
+ for (int _i766 = 0; _i766 < _list764.size; ++_i766)
{
- _elem757 = iprot.readString();
- struct.success.add(_elem757);
+ _elem765 = iprot.readString();
+ struct.success.add(_elem765);
}
iprot.readListEnd();
}
@@ -49627,9 +50751,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter759 : struct.success)
+ for (String _iter767 : struct.success)
{
- oprot.writeString(_iter759);
+ oprot.writeString(_iter767);
}
oprot.writeListEnd();
}
@@ -49668,9 +50792,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter760 : struct.success)
+ for (String _iter768 : struct.success)
{
- oprot.writeString(_iter760);
+ oprot.writeString(_iter768);
}
}
}
@@ -49685,13 +50809,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list761.size);
- String _elem762;
- for (int _i763 = 0; _i763 < _list761.size; ++_i763)
+ org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list769.size);
+ String _elem770;
+ for (int _i771 = 0; _i771 < _list769.size; ++_i771)
{
- _elem762 = iprot.readString();
- struct.success.add(_elem762);
+ _elem770 = iprot.readString();
+ struct.success.add(_elem770);
}
}
struct.setSuccessIsSet(true);
@@ -50665,13 +51789,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list764.size);
- String _elem765;
- for (int _i766 = 0; _i766 < _list764.size; ++_i766)
+ org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list772.size);
+ String _elem773;
+ for (int _i774 = 0; _i774 < _list772.size; ++_i774)
{
- _elem765 = iprot.readString();
- struct.success.add(_elem765);
+ _elem773 = iprot.readString();
+ struct.success.add(_elem773);
}
iprot.readListEnd();
}
@@ -50706,9 +51830,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter767 : struct.success)
+ for (String _iter775 : struct.success)
{
- oprot.writeString(_iter767);
+ oprot.writeString(_iter775);
}
oprot.writeListEnd();
}
@@ -50747,9 +51871,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter768 : struct.success)
+ for (String _iter776 : struct.success)
{
- oprot.writeString(_iter768);
+ oprot.writeString(_iter776);
}
}
}
@@ -50764,13 +51888,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list769.size);
- String _elem770;
- for (int _i771 = 0; _i771 < _list769.size; ++_i771)
+ org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list777.size);
+ String _elem778;
+ for (int _i779 = 0; _i779 < _list777.size; ++_i779)
{
- _elem770 = iprot.readString();
- struct.success.add(_elem770);
+ _elem778 = iprot.readString();
+ struct.success.add(_elem778);
}
}
struct.setSuccessIsSet(true);
@@ -51275,13 +52399,13 @@ public class ThriftHiveMetastore {
case 3: // TBL_TYPES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
- struct.tbl_types = new ArrayList<String>(_list772.size);
- String _elem773;
- for (int _i774 = 0; _i774 < _list772.size; ++_i774)
+ org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
+ struct.tbl_types = new ArrayList<String>(_list780.size);
+ String _elem781;
+ for (int _i782 = 0; _i782 < _list780.size; ++_i782)
{
- _elem773 = iprot.readString();
- struct.tbl_types.add(_elem773);
+ _elem781 = iprot.readString();
+ struct.tbl_types.add(_elem781);
}
iprot.readListEnd();
}
@@ -51317,9 +52441,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(TBL_TYPES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_types.size()));
- for (String _iter775 : struct.tbl_types)
+ for (String _iter783 : struct.tbl_types)
{
- oprot.writeString(_iter775);
+ oprot.writeString(_iter783);
}
oprot.writeListEnd();
}
@@ -51362,9 +52486,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_types()) {
{
oprot.writeI32(struct.tbl_types.size());
- for (String _iter776 : struct.tbl_types)
+ for (String _iter784 : struct.tbl_types)
{
- oprot.writeString(_iter776);
+ oprot.writeString(_iter784);
}
}
}
@@ -51384,13 +52508,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_types = new ArrayList<String>(_list777.size);
- String _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_types = new ArrayList<String>(_list785.size);
+ String _elem786;
+ for (int _i787 = 0; _i787 < _list785.size; ++_i787)
{
- _elem778 = iprot.readString();
- struct.tbl_types.add(_elem778);
+ _elem786 = iprot.readString();
+ struct.tbl_types.add(_elem786);
}
}
struct.setTbl_typesIsSet(true);
@@ -51796,14 +52920,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
- struct.success = new ArrayList<TableMeta>(_list780.size);
- TableMeta _elem781;
- for (int _i782 = 0; _i782 < _list780.size; ++_i782)
+ org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
+ struct.success = new ArrayList<TableMeta>(_list788.size);
+ TableMeta _elem789;
+ for (int _i790 = 0; _i790 < _list788.size; ++_i790)
{
- _elem781 = new TableMeta();
- _elem781.read(iprot);
- struct.success.add(_elem781);
+ _elem789 = new TableMeta();
+ _elem789.read(iprot);
+ struct.success.add(_elem789);
}
iprot.readListEnd();
}
@@ -51838,9 +52962,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (TableMeta _iter783 : struct.success)
+ for (TableMeta _iter791 : struct.success)
{
- _iter783.write(oprot);
+ _iter791.write(oprot);
}
oprot.writeListEnd();
}
@@ -51879,9 +53003,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (TableMeta _iter784 : struct.success)
+ for (TableMeta _iter792 : struct.success)
{
- _iter784.write(oprot);
+ _iter792.write(oprot);
}
}
}
@@ -51896,14 +53020,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<TableMeta>(_list785.size);
- TableMeta _elem786;
- for (int _i787 = 0; _i787 < _list785.size; ++_i787)
+ org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<TableMeta>(_list793.size);
+ TableMeta _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem786 = new TableMeta();
- _elem786.read(iprot);
- struct.success.add(_elem786);
+ _elem794 = new TableMeta();
+ _elem794.read(iprot);
+ struct.success.add(_elem794);
}
}
struct.setSuccessIsSet(true);
@@ -52669,13 +53793,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list788.size);
- String _elem789;
- for (int _i790 = 0; _i790 < _list788.size; ++_i790)
+ org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list796.size);
+ String _elem797;
+ for (int _i798 = 0; _i798 < _list796.size; ++_i798)
{
- _elem789 = iprot.readString();
- struct.success.add(_elem789);
+ _elem797 = iprot.readString();
+ struct.success.add(_elem797);
}
iprot.readListEnd();
}
@@ -52710,9 +53834,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter791 : struct.success)
+ for (String _iter799 : struct.success)
{
- oprot.writeString(_iter791);
+ oprot.writeString(_iter799);
}
oprot.writeListEnd();
}
@@ -52751,9 +53875,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter792 : struct.success)
+ for (String _iter800 : struct.success)
{
- oprot.writeString(_iter792);
+ oprot.writeString(_iter800);
}
}
}
@@ -52768,13 +53892,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list793.size);
- String _elem794;
- for (int _i795 = 0; _i795 < _list793.size; ++_i795)
+ org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list801.size);
+ String _elem802;
+ for (int _i803 = 0; _i803 < _list801.size; ++_i803)
{
- _elem794 = iprot.readString();
- struct.success.add(_elem794);
+ _elem802 = iprot.readString();
+ struct.success.add(_elem802);
}
}
struct.setSuccessIsSet(true);
@@ -54227,13 +55351,13 @@ public class ThriftHiveMetastore {
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list796 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list796.size);
- String _elem797;
- for (int _i798 = 0; _i798 < _list796.size; ++_i798)
+ org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list804.size);
+ String _elem805;
+ for (int _i806 = 0; _i806 < _list804.size; ++_i806)
{
- _elem797 = iprot.readString();
- struct.tbl_names.add(_elem797);
+ _elem805 = iprot.readString();
+ struct.tbl_names.add(_elem805);
}
iprot.readListEnd();
}
@@ -54264,9 +55388,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_names.size()));
- for (String _iter799 : struct.tbl_names)
+ for (String _iter807 : struct.tbl_names)
{
- oprot.writeString(_iter799);
+ oprot.writeString(_iter807);
}
oprot.writeListEnd();
}
@@ -54303,9 +55427,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter800 : struct.tbl_names)
+ for (String _iter808 : struct.tbl_names)
{
- oprot.writeString(_iter800);
+ oprot.writeString(_iter808);
}
}
}
@@ -54321,13 +55445,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list801 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list801.size);
- String _elem802;
- for (int _i803 = 0; _i803 < _list801.size; ++_i803)
+ org.apache.thrift.protocol.TList _list809 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list809.size);
+ String _elem810;
+ for (int _i811 = 0; _i811 < _list809.size; ++_i811)
{
- _elem802 = iprot.readString();
- struct.tbl_names.add(_elem802);
+ _elem810 = iprot.readString();
+ struct.tbl_names.add(_elem810);
}
}
struct.setTbl_namesIsSet(true);
@@ -54652,14 +55776,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list804 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list804.size);
- Table _elem805;
- for (int _i806 = 0; _i806 < _list804.size; ++_i806)
+ org.apache.thrift.protocol.TList _list812 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list812.size);
+ Table _elem813;
+ for (int _i814 = 0; _i814 < _list812.size; ++_i814)
{
- _elem805 = new Table();
- _elem805.read(iprot);
- struct.success.add(_elem805);
+ _elem813 = new Table();
+ _elem813.read(iprot);
+ struct.success.add(_elem813);
}
iprot.readListEnd();
}
@@ -54685,9 +55809,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Table _iter807 : struct.success)
+ for (Table _iter815 : struct.success)
{
- _iter807.write(oprot);
+ _iter815.write(oprot);
}
oprot.writeListEnd();
}
@@ -54718,9 +55842,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter808 : struct.success)
+ for (Table _iter816 : struct.success)
{
- _iter808.write(oprot);
+ _iter816.write(oprot);
}
}
}
@@ -54732,14 +55856,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list809 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list809.size);
- Table _elem810;
- for (int _i811 = 0; _i811 < _list809.size; ++_i811)
+ org.apache.thrift.protocol.TList _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list817.size);
+ Table _elem818;
+ for (int _i819 = 0; _i819 < _list817.size; ++_i819)
{
- _elem810 = new Table();
- _elem810.read(iprot);
- struct.success.add(_elem810);
+ _elem818 = new Table();
+ _elem818.read(iprot);
+ struct.success.add(_elem818);
}
}
struct.setSuccessIsSet(true);
@@ -57852,13 +58976,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list812 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list812.size);
- String _elem813;
- for (int _i814 = 0; _i814 < _list812.size; ++_i814)
+ org.apache.thrift.protocol.TList _list820 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list820.size);
+ String _elem821;
+ for (int _i822 = 0; _i822 < _list820.size; ++_i822)
{
- _elem813 = iprot.readString();
- struct.success.add(_elem813);
+ _elem821 = iprot.readString();
+ struct.success.add(_elem821);
}
iprot.readListEnd();
}
@@ -57911,9 +59035,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
- for (String _iter815 : struct.success)
+ for (String _iter823 : struct.success)
{
- oprot.writeString(_iter815);
+ oprot.writeString(_iter823);
}
oprot.writeListEnd();
}
@@ -57968,9 +59092,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter816 : struct.success)
+ for (String _iter824 : struct.success)
{
- oprot.writeString(_iter816);
+ oprot.writeString(_iter824);
}
}
}
@@ -57991,13 +59115,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list817 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list817.size);
- String _elem818;
- for (int _i819 = 0; _i819 < _list817.size; ++_i819)
+ org.apache.thrift.protocol.TList _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list825.size);
+ String _elem826;
+ for (int _i827 = 0; _i827 < _list825.size; ++_i827)
{
- _elem818 = iprot.readString();
- struct.success.add(_elem818);
+ _elem826 = iprot.readString();
+ struct.success.add(_elem826);
}
}
struct.setSuccessIsSet(true);
@@ -63856,14 +64980,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list820 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list820.size);
- Partition _elem821;
- for (int _i822 = 0; _i822 < _list820.size; ++_i822)
+ org.apache.thrift.protocol.TList _list828 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list828.size);
+ Partition _elem829;
+ for (int _i830 = 0; _i830 < _list828.size; ++_i830)
{
- _elem821 = new Partition();
- _elem821.read(iprot);
- struct.new_parts.add(_elem821);
+ _elem829 = new Partition();
+ _elem829.read(iprot);
+ struct.new_parts.add(_elem829);
}
iprot.readListEnd();
}
@@ -63889,9 +65013,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(NEW_PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.new_parts.size()));
- for (Partition _iter823 : struct.new_parts)
+ for (Partition _iter831 : struct.new_parts)
{
- _iter823.write(oprot);
+ _iter831.write(oprot);
}
oprot.writeListEnd();
}
@@ -63922,9 +65046,9 @@ public class ThriftHiveMetastore {
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter824 : struct.new_parts)
+ for (Partition _iter832 : struct.new_parts)
{
- _iter824.write(oprot);
+ _iter832.write(oprot);
}
}
}
@@ -63936,14 +65060,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list825 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list825.size);
- Partition _elem826;
- for (int _i827 = 0; _i827 < _list825.size; ++_i827)
+ org.apache.thrift.protocol.TList _list833 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list833.size);
+ Partition _elem834;
+ for (int _i835 = 0; _i835 < _list833.size; ++_i835)
{
- _elem826 = new Partition();
- _elem826.read(iprot);
- struct.new_parts.add(_elem826);
+ _elem834 = new Partition();
+ _elem834.read(iprot);
+ struct.new_parts.add(_elem834);
}
}
struct.setNew_partsIsSet(true);
@@ -64944,14 +66068,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list828 = iprot.readListBegin();
- struct.new_parts = new ArrayList<PartitionSpec>(_list828.size);
- PartitionSpec _elem829;
- for (int _i830 = 0; _i830 < _list828.size; ++_i830)
+ org.apache.thrift.protocol.TList _list836 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<PartitionSpec>(_list836.size);
+ PartitionSpec _elem837;
+ for (int _i838 = 0; _i838 < _list836.size; ++_i838)
{
- _elem829 = new PartitionSpec();
- _elem829.read(iprot);
- struct.new_parts.add(_elem829);
+ _elem837 = new PartitionSpec();
+ _elem837.read(iprot);
+ struct.new_parts.add(_elem837);
}
iprot.readListEnd();
}
@@ -64977,9 +66101,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(NEW_PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.new_parts.size()));
- for (PartitionSpec _iter831 : struct.new_parts)
+ for (PartitionSpec _iter839 : struct.new_parts)
{
- _iter831.write(oprot);
+ _iter839.write(oprot);
}
oprot.writeListEnd();
}
@@ -65010,9 +66134,9 @@ public class ThriftHiveMetastore {
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (PartitionSpec _iter832 : struct.new_parts)
+ for (PartitionSpec _iter840 : struct.new_parts)
{
- _iter832.write(oprot);
+ _iter840.write(oprot);
}
}
}
@@ -65024,14 +66148,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list833 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<PartitionSpec>(_list833.size);
- PartitionSpec _elem834;
- for (int _i835 = 0; _i835 < _list833.size; ++_i835)
+ org.apache.thrift.protocol.TList _list841 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<PartitionSpec>(_list841.size);
+ PartitionSpec _elem842;
+ for (int _i843 = 0; _i843 < _list841.size; ++_i843)
{
- _elem834 = new PartitionSpec();
- _elem834.read(iprot);
- struct.new_parts.add(_elem834);
+ _elem842 = new PartitionSpec();
+ _elem842.read(iprot);
+ struct.new_parts.add(_elem842);
}
}
struct.setNew_partsIsSet(true);
@@ -66207,13 +67331,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list836 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list836.size);
- String _elem837;
- for (int _i838 = 0; _i838 < _list836.size; ++_i838)
+ org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list844.size);
+ String _elem845;
+ for (int _i846 = 0; _i846 < _list844.size; ++_i846)
{
- _elem837 = iprot.readString();
- struct.part_vals.add(_elem837);
+ _elem845 = iprot.readString();
+ struct.part_vals.add(_elem845);
}
iprot.readListEnd();
}
@@ -66249,9 +67373,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter839 : struct.part_vals)
+ for (String _iter847 : struct.part_vals)
{
- oprot.writeString(_iter839);
+ oprot.writeString(_iter847);
}
oprot.writeListEnd();
}
@@ -66294,9 +67418,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter840 : struct.part_vals)
+ for (String _iter848 : struct.part_vals)
{
- oprot.writeString(_iter840);
+ oprot.writeString(_iter848);
}
}
}
@@ -66316,13 +67440,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list841 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list841.size);
- String _elem842;
- for (int _i843 = 0; _i843 < _list841.size; ++_i843)
+ org.apache.thrift.protocol.TList _list849 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list849.size);
+ String _elem850;
+ for (int _i851 = 0; _i851 < _list849.size; ++_i851)
{
- _elem842 = iprot.readString();
- struct.part_vals.add(_elem842);
+ _elem850 = iprot.readString();
+ struct.part_vals.add(_elem850);
}
}
struct.setPart_valsIsSet(true);
@@ -68631,13 +69755,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list844 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list844.size);
- String _elem845;
- for (int _i846 = 0; _i846 < _list844.size; ++_i846)
+ org.apache.thrift.protocol.TList _list852 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list852.size);
+ String _elem853;
+ for (int _i854 = 0; _i854 < _list852.size; ++_i854)
{
- _elem845 = iprot.readString();
- struct.part_vals.add(_elem845);
+ _elem853 = iprot.readString();
+ struct.part_vals.add(_elem853);
}
iprot.readListEnd();
}
@@ -68682,9 +69806,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter847 : struct.part_vals)
+ for (String _iter855 : struct.part_vals)
{
- oprot.writeString(_iter847);
+ oprot.writeString(_iter855);
}
oprot.writeListEnd();
}
@@ -68735,9 +69859,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter848 : struct.part_vals)
+ for (String _iter856 : struct.part_vals)
{
- oprot.writeString(_iter848);
+ oprot.writeString(_iter856);
}
}
}
@@ -68760,13 +69884,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list849 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list849.size);
- String _elem850;
- for (int _i851 = 0; _i851 < _list849.size; ++_i851)
+ org.apache.thrift.protocol.TList _list857 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list857.size);
+ String _elem858;
+ for (int _i859 = 0; _i859 < _list857.size; ++_i859)
{
- _elem850 = iprot.readString();
- struct.part_vals.add(_elem850);
+ _elem858 = iprot.readString();
+ struct.part_vals.add(_elem858);
}
}
struct.setPart_valsIsSet(true);
@@ -72636,13 +73760,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list852 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list852.size);
- String _elem853;
- for (int _i854 = 0; _i854 < _list852.size; ++_i854)
+ org.apache.thrift.protocol.TList _list860 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list860.size);
+ String _elem861;
+ for (int _i862 = 0; _i862 < _list860.size; ++_i862)
{
- _elem853 = iprot.readString();
- struct.part_vals.add(_elem853);
+ _elem861 = iprot.readString();
+ struct.part_vals.add(_elem861);
}
iprot.readListEnd();
}
@@ -72686,9 +73810,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter855 : struct.part_vals)
+ for (String _iter863 : struct.part_vals)
{
- oprot.writeString(_iter855);
+ oprot.writeString(_iter863);
}
oprot.writeL
<TRUNCATED>