You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2018/03/31 01:25:46 UTC
[27/44] hive git commit: HIVE-18755 Modifications to the metastore
for catalogs (Alan Gates, reviewed by Thejas Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java
index 9ad8728..b5d4829 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsRequest.java
@@ -38,8 +38,9 @@ import org.slf4j.LoggerFactory;
@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class UniqueConstraintsRequest implements org.apache.thrift.TBase<UniqueConstraintsRequest, UniqueConstraintsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<UniqueConstraintsRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UniqueConstraintsRequest");
- private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -47,13 +48,15 @@ import org.slf4j.LoggerFactory;
schemes.put(TupleScheme.class, new UniqueConstraintsRequestTupleSchemeFactory());
}
+ private String catName; // required
private String db_name; // required
private String tbl_name; // 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, "db_name"),
- TBL_NAME((short)2, "tbl_name");
+ CAT_NAME((short)1, "catName"),
+ DB_NAME((short)2, "db_name"),
+ TBL_NAME((short)3, "tbl_name");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -68,9 +71,11 @@ import org.slf4j.LoggerFactory;
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 1: // DB_NAME
+ case 1: // CAT_NAME
+ return CAT_NAME;
+ case 2: // DB_NAME
return DB_NAME;
- case 2: // TBL_NAME
+ case 3: // TBL_NAME
return TBL_NAME;
default:
return null;
@@ -115,6 +120,8 @@ import org.slf4j.LoggerFactory;
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.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.REQUIRED,
@@ -127,10 +134,12 @@ import org.slf4j.LoggerFactory;
}
public UniqueConstraintsRequest(
+ String catName,
String db_name,
String tbl_name)
{
this();
+ this.catName = catName;
this.db_name = db_name;
this.tbl_name = tbl_name;
}
@@ -139,6 +148,9 @@ import org.slf4j.LoggerFactory;
* Performs a deep copy on <i>other</i>.
*/
public UniqueConstraintsRequest(UniqueConstraintsRequest other) {
+ if (other.isSetCatName()) {
+ this.catName = other.catName;
+ }
if (other.isSetDb_name()) {
this.db_name = other.db_name;
}
@@ -153,10 +165,34 @@ import org.slf4j.LoggerFactory;
@Override
public void clear() {
+ this.catName = null;
this.db_name = null;
this.tbl_name = null;
}
+ public String getCatName() {
+ return this.catName;
+ }
+
+ public void setCatName(String catName) {
+ this.catName = catName;
+ }
+
+ public void unsetCatName() {
+ this.catName = null;
+ }
+
+ /** Returns true if field catName is set (has been assigned a value) and false otherwise */
+ public boolean isSetCatName() {
+ return this.catName != null;
+ }
+
+ public void setCatNameIsSet(boolean value) {
+ if (!value) {
+ this.catName = null;
+ }
+ }
+
public String getDb_name() {
return this.db_name;
}
@@ -205,6 +241,14 @@ import org.slf4j.LoggerFactory;
public void setFieldValue(_Fields field, Object value) {
switch (field) {
+ case CAT_NAME:
+ if (value == null) {
+ unsetCatName();
+ } else {
+ setCatName((String)value);
+ }
+ break;
+
case DB_NAME:
if (value == null) {
unsetDb_name();
@@ -226,6 +270,9 @@ import org.slf4j.LoggerFactory;
public Object getFieldValue(_Fields field) {
switch (field) {
+ case CAT_NAME:
+ return getCatName();
+
case DB_NAME:
return getDb_name();
@@ -243,6 +290,8 @@ import org.slf4j.LoggerFactory;
}
switch (field) {
+ case CAT_NAME:
+ return isSetCatName();
case DB_NAME:
return isSetDb_name();
case TBL_NAME:
@@ -264,6 +313,15 @@ import org.slf4j.LoggerFactory;
if (that == null)
return false;
+ boolean this_present_catName = true && this.isSetCatName();
+ boolean that_present_catName = true && that.isSetCatName();
+ if (this_present_catName || that_present_catName) {
+ if (!(this_present_catName && that_present_catName))
+ return false;
+ if (!this.catName.equals(that.catName))
+ return false;
+ }
+
boolean this_present_db_name = true && this.isSetDb_name();
boolean that_present_db_name = true && that.isSetDb_name();
if (this_present_db_name || that_present_db_name) {
@@ -289,6 +347,11 @@ import org.slf4j.LoggerFactory;
public int hashCode() {
List<Object> list = new ArrayList<Object>();
+ boolean present_catName = true && (isSetCatName());
+ list.add(present_catName);
+ if (present_catName)
+ list.add(catName);
+
boolean present_db_name = true && (isSetDb_name());
list.add(present_db_name);
if (present_db_name)
@@ -310,6 +373,16 @@ import org.slf4j.LoggerFactory;
int lastComparison = 0;
+ lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetCatName()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(isSetDb_name()).compareTo(other.isSetDb_name());
if (lastComparison != 0) {
return lastComparison;
@@ -350,6 +423,14 @@ import org.slf4j.LoggerFactory;
StringBuilder sb = new StringBuilder("UniqueConstraintsRequest(");
boolean first = true;
+ sb.append("catName:");
+ if (this.catName == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.catName);
+ }
+ first = false;
+ if (!first) sb.append(", ");
sb.append("db_name:");
if (this.db_name == null) {
sb.append("null");
@@ -371,6 +452,10 @@ import org.slf4j.LoggerFactory;
public void validate() throws org.apache.thrift.TException {
// check for required fields
+ if (!isSetCatName()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'catName' is unset! Struct:" + toString());
+ }
+
if (!isSetDb_name()) {
throw new org.apache.thrift.protocol.TProtocolException("Required field 'db_name' is unset! Struct:" + toString());
}
@@ -416,7 +501,15 @@ import org.slf4j.LoggerFactory;
break;
}
switch (schemeField.id) {
- case 1: // DB_NAME
+ case 1: // CAT_NAME
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DB_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.db_name = iprot.readString();
struct.setDb_nameIsSet(true);
@@ -424,7 +517,7 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
- case 2: // TBL_NAME
+ case 3: // TBL_NAME
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.tbl_name = iprot.readString();
struct.setTbl_nameIsSet(true);
@@ -445,6 +538,11 @@ import org.slf4j.LoggerFactory;
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.catName != null) {
+ oprot.writeFieldBegin(CAT_NAME_FIELD_DESC);
+ oprot.writeString(struct.catName);
+ oprot.writeFieldEnd();
+ }
if (struct.db_name != null) {
oprot.writeFieldBegin(DB_NAME_FIELD_DESC);
oprot.writeString(struct.db_name);
@@ -472,6 +570,7 @@ import org.slf4j.LoggerFactory;
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeString(struct.catName);
oprot.writeString(struct.db_name);
oprot.writeString(struct.tbl_name);
}
@@ -479,6 +578,8 @@ import org.slf4j.LoggerFactory;
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.catName = iprot.readString();
+ struct.setCatNameIsSet(true);
struct.db_name = iprot.readString();
struct.setDb_nameIsSet(true);
struct.tbl_name = iprot.readString();
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java
index 4d45bee..80dea83 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UniqueConstraintsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // UNIQUE_CONSTRAINTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list328 = iprot.readListBegin();
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list328.size);
- SQLUniqueConstraint _elem329;
- for (int _i330 = 0; _i330 < _list328.size; ++_i330)
+ org.apache.thrift.protocol.TList _list336 = iprot.readListBegin();
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list336.size);
+ SQLUniqueConstraint _elem337;
+ for (int _i338 = 0; _i338 < _list336.size; ++_i338)
{
- _elem329 = new SQLUniqueConstraint();
- _elem329.read(iprot);
- struct.uniqueConstraints.add(_elem329);
+ _elem337 = new SQLUniqueConstraint();
+ _elem337.read(iprot);
+ struct.uniqueConstraints.add(_elem337);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(UNIQUE_CONSTRAINTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.uniqueConstraints.size()));
- for (SQLUniqueConstraint _iter331 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter339 : struct.uniqueConstraints)
{
- _iter331.write(oprot);
+ _iter339.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.uniqueConstraints.size());
- for (SQLUniqueConstraint _iter332 : struct.uniqueConstraints)
+ for (SQLUniqueConstraint _iter340 : struct.uniqueConstraints)
{
- _iter332.write(oprot);
+ _iter340.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, UniqueConstraintsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list333 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list333.size);
- SQLUniqueConstraint _elem334;
- for (int _i335 = 0; _i335 < _list333.size; ++_i335)
+ org.apache.thrift.protocol.TList _list341 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.uniqueConstraints = new ArrayList<SQLUniqueConstraint>(_list341.size);
+ SQLUniqueConstraint _elem342;
+ for (int _i343 = 0; _i343 < _list341.size; ++_i343)
{
- _elem334 = new SQLUniqueConstraint();
- _elem334.read(iprot);
- struct.uniqueConstraints.add(_elem334);
+ _elem342 = new SQLUniqueConstraint();
+ _elem342.read(iprot);
+ struct.uniqueConstraints.add(_elem342);
}
}
struct.setUniqueConstraintsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
index a7be2ec..3560567 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
@@ -755,14 +755,14 @@ import org.slf4j.LoggerFactory;
case 2: // POOLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list816 = iprot.readListBegin();
- struct.pools = new ArrayList<WMPool>(_list816.size);
- WMPool _elem817;
- for (int _i818 = 0; _i818 < _list816.size; ++_i818)
+ org.apache.thrift.protocol.TList _list824 = iprot.readListBegin();
+ struct.pools = new ArrayList<WMPool>(_list824.size);
+ WMPool _elem825;
+ for (int _i826 = 0; _i826 < _list824.size; ++_i826)
{
- _elem817 = new WMPool();
- _elem817.read(iprot);
- struct.pools.add(_elem817);
+ _elem825 = new WMPool();
+ _elem825.read(iprot);
+ struct.pools.add(_elem825);
}
iprot.readListEnd();
}
@@ -774,14 +774,14 @@ import org.slf4j.LoggerFactory;
case 3: // MAPPINGS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list819 = iprot.readListBegin();
- struct.mappings = new ArrayList<WMMapping>(_list819.size);
- WMMapping _elem820;
- for (int _i821 = 0; _i821 < _list819.size; ++_i821)
+ org.apache.thrift.protocol.TList _list827 = iprot.readListBegin();
+ struct.mappings = new ArrayList<WMMapping>(_list827.size);
+ WMMapping _elem828;
+ for (int _i829 = 0; _i829 < _list827.size; ++_i829)
{
- _elem820 = new WMMapping();
- _elem820.read(iprot);
- struct.mappings.add(_elem820);
+ _elem828 = new WMMapping();
+ _elem828.read(iprot);
+ struct.mappings.add(_elem828);
}
iprot.readListEnd();
}
@@ -793,14 +793,14 @@ import org.slf4j.LoggerFactory;
case 4: // TRIGGERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list822 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list822.size);
- WMTrigger _elem823;
- for (int _i824 = 0; _i824 < _list822.size; ++_i824)
+ org.apache.thrift.protocol.TList _list830 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list830.size);
+ WMTrigger _elem831;
+ for (int _i832 = 0; _i832 < _list830.size; ++_i832)
{
- _elem823 = new WMTrigger();
- _elem823.read(iprot);
- struct.triggers.add(_elem823);
+ _elem831 = new WMTrigger();
+ _elem831.read(iprot);
+ struct.triggers.add(_elem831);
}
iprot.readListEnd();
}
@@ -812,14 +812,14 @@ import org.slf4j.LoggerFactory;
case 5: // POOL_TRIGGERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list825 = iprot.readListBegin();
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list825.size);
- WMPoolTrigger _elem826;
- for (int _i827 = 0; _i827 < _list825.size; ++_i827)
+ org.apache.thrift.protocol.TList _list833 = iprot.readListBegin();
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list833.size);
+ WMPoolTrigger _elem834;
+ for (int _i835 = 0; _i835 < _list833.size; ++_i835)
{
- _elem826 = new WMPoolTrigger();
- _elem826.read(iprot);
- struct.poolTriggers.add(_elem826);
+ _elem834 = new WMPoolTrigger();
+ _elem834.read(iprot);
+ struct.poolTriggers.add(_elem834);
}
iprot.readListEnd();
}
@@ -850,9 +850,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(POOLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pools.size()));
- for (WMPool _iter828 : struct.pools)
+ for (WMPool _iter836 : struct.pools)
{
- _iter828.write(oprot);
+ _iter836.write(oprot);
}
oprot.writeListEnd();
}
@@ -863,9 +863,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(MAPPINGS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mappings.size()));
- for (WMMapping _iter829 : struct.mappings)
+ for (WMMapping _iter837 : struct.mappings)
{
- _iter829.write(oprot);
+ _iter837.write(oprot);
}
oprot.writeListEnd();
}
@@ -877,9 +877,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TRIGGERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size()));
- for (WMTrigger _iter830 : struct.triggers)
+ for (WMTrigger _iter838 : struct.triggers)
{
- _iter830.write(oprot);
+ _iter838.write(oprot);
}
oprot.writeListEnd();
}
@@ -891,9 +891,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(POOL_TRIGGERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.poolTriggers.size()));
- for (WMPoolTrigger _iter831 : struct.poolTriggers)
+ for (WMPoolTrigger _iter839 : struct.poolTriggers)
{
- _iter831.write(oprot);
+ _iter839.write(oprot);
}
oprot.writeListEnd();
}
@@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory;
struct.plan.write(oprot);
{
oprot.writeI32(struct.pools.size());
- for (WMPool _iter832 : struct.pools)
+ for (WMPool _iter840 : struct.pools)
{
- _iter832.write(oprot);
+ _iter840.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory;
if (struct.isSetMappings()) {
{
oprot.writeI32(struct.mappings.size());
- for (WMMapping _iter833 : struct.mappings)
+ for (WMMapping _iter841 : struct.mappings)
{
- _iter833.write(oprot);
+ _iter841.write(oprot);
}
}
}
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter834 : struct.triggers)
+ for (WMTrigger _iter842 : struct.triggers)
{
- _iter834.write(oprot);
+ _iter842.write(oprot);
}
}
}
if (struct.isSetPoolTriggers()) {
{
oprot.writeI32(struct.poolTriggers.size());
- for (WMPoolTrigger _iter835 : struct.poolTriggers)
+ for (WMPoolTrigger _iter843 : struct.poolTriggers)
{
- _iter835.write(oprot);
+ _iter843.write(oprot);
}
}
}
@@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory;
struct.plan.read(iprot);
struct.setPlanIsSet(true);
{
- org.apache.thrift.protocol.TList _list836 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pools = new ArrayList<WMPool>(_list836.size);
- WMPool _elem837;
- for (int _i838 = 0; _i838 < _list836.size; ++_i838)
+ org.apache.thrift.protocol.TList _list844 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pools = new ArrayList<WMPool>(_list844.size);
+ WMPool _elem845;
+ for (int _i846 = 0; _i846 < _list844.size; ++_i846)
{
- _elem837 = new WMPool();
- _elem837.read(iprot);
- struct.pools.add(_elem837);
+ _elem845 = new WMPool();
+ _elem845.read(iprot);
+ struct.pools.add(_elem845);
}
}
struct.setPoolsIsSet(true);
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list839 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.mappings = new ArrayList<WMMapping>(_list839.size);
- WMMapping _elem840;
- for (int _i841 = 0; _i841 < _list839.size; ++_i841)
+ org.apache.thrift.protocol.TList _list847 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.mappings = new ArrayList<WMMapping>(_list847.size);
+ WMMapping _elem848;
+ for (int _i849 = 0; _i849 < _list847.size; ++_i849)
{
- _elem840 = new WMMapping();
- _elem840.read(iprot);
- struct.mappings.add(_elem840);
+ _elem848 = new WMMapping();
+ _elem848.read(iprot);
+ struct.mappings.add(_elem848);
}
}
struct.setMappingsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list842 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list842.size);
- WMTrigger _elem843;
- for (int _i844 = 0; _i844 < _list842.size; ++_i844)
+ org.apache.thrift.protocol.TList _list850 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list850.size);
+ WMTrigger _elem851;
+ for (int _i852 = 0; _i852 < _list850.size; ++_i852)
{
- _elem843 = new WMTrigger();
- _elem843.read(iprot);
- struct.triggers.add(_elem843);
+ _elem851 = new WMTrigger();
+ _elem851.read(iprot);
+ struct.triggers.add(_elem851);
}
}
struct.setTriggersIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list845 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list845.size);
- WMPoolTrigger _elem846;
- for (int _i847 = 0; _i847 < _list845.size; ++_i847)
+ org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list853.size);
+ WMPoolTrigger _elem854;
+ for (int _i855 = 0; _i855 < _list853.size; ++_i855)
{
- _elem846 = new WMPoolTrigger();
- _elem846.read(iprot);
- struct.poolTriggers.add(_elem846);
+ _elem854 = new WMPoolTrigger();
+ _elem854.read(iprot);
+ struct.poolTriggers.add(_elem854);
}
}
struct.setPoolTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
index d931b47..ffe8b68 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
case 1: // RESOURCE_PLANS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list848 = iprot.readListBegin();
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list848.size);
- WMResourcePlan _elem849;
- for (int _i850 = 0; _i850 < _list848.size; ++_i850)
+ org.apache.thrift.protocol.TList _list856 = iprot.readListBegin();
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list856.size);
+ WMResourcePlan _elem857;
+ for (int _i858 = 0; _i858 < _list856.size; ++_i858)
{
- _elem849 = new WMResourcePlan();
- _elem849.read(iprot);
- struct.resourcePlans.add(_elem849);
+ _elem857 = new WMResourcePlan();
+ _elem857.read(iprot);
+ struct.resourcePlans.add(_elem857);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(RESOURCE_PLANS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.resourcePlans.size()));
- for (WMResourcePlan _iter851 : struct.resourcePlans)
+ for (WMResourcePlan _iter859 : struct.resourcePlans)
{
- _iter851.write(oprot);
+ _iter859.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetResourcePlans()) {
{
oprot.writeI32(struct.resourcePlans.size());
- for (WMResourcePlan _iter852 : struct.resourcePlans)
+ for (WMResourcePlan _iter860 : struct.resourcePlans)
{
- _iter852.write(oprot);
+ _iter860.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list853 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list853.size);
- WMResourcePlan _elem854;
- for (int _i855 = 0; _i855 < _list853.size; ++_i855)
+ org.apache.thrift.protocol.TList _list861 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list861.size);
+ WMResourcePlan _elem862;
+ for (int _i863 = 0; _i863 < _list861.size; ++_i863)
{
- _elem854 = new WMResourcePlan();
- _elem854.read(iprot);
- struct.resourcePlans.add(_elem854);
+ _elem862 = new WMResourcePlan();
+ _elem862.read(iprot);
+ struct.resourcePlans.add(_elem862);
}
}
struct.setResourcePlansIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
index a674db2..9dfebf0 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
@@ -346,14 +346,14 @@ import org.slf4j.LoggerFactory;
case 1: // TRIGGERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list872 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list872.size);
- WMTrigger _elem873;
- for (int _i874 = 0; _i874 < _list872.size; ++_i874)
+ org.apache.thrift.protocol.TList _list880 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list880.size);
+ WMTrigger _elem881;
+ for (int _i882 = 0; _i882 < _list880.size; ++_i882)
{
- _elem873 = new WMTrigger();
- _elem873.read(iprot);
- struct.triggers.add(_elem873);
+ _elem881 = new WMTrigger();
+ _elem881.read(iprot);
+ struct.triggers.add(_elem881);
}
iprot.readListEnd();
}
@@ -380,9 +380,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TRIGGERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.triggers.size()));
- for (WMTrigger _iter875 : struct.triggers)
+ for (WMTrigger _iter883 : struct.triggers)
{
- _iter875.write(oprot);
+ _iter883.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter876 : struct.triggers)
+ for (WMTrigger _iter884 : struct.triggers)
{
- _iter876.write(oprot);
+ _iter884.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list877.size);
- WMTrigger _elem878;
- for (int _i879 = 0; _i879 < _list877.size; ++_i879)
+ org.apache.thrift.protocol.TList _list885 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list885.size);
+ WMTrigger _elem886;
+ for (int _i887 = 0; _i887 < _list885.size; ++_i887)
{
- _elem878 = new WMTrigger();
- _elem878.read(iprot);
- struct.triggers.add(_elem878);
+ _elem886 = new WMTrigger();
+ _elem886.read(iprot);
+ struct.triggers.add(_elem886);
}
}
struct.setTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
index db11958..8f3b065 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
@@ -441,13 +441,13 @@ import org.slf4j.LoggerFactory;
case 1: // ERRORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list856 = iprot.readListBegin();
- struct.errors = new ArrayList<String>(_list856.size);
- String _elem857;
- for (int _i858 = 0; _i858 < _list856.size; ++_i858)
+ org.apache.thrift.protocol.TList _list864 = iprot.readListBegin();
+ struct.errors = new ArrayList<String>(_list864.size);
+ String _elem865;
+ for (int _i866 = 0; _i866 < _list864.size; ++_i866)
{
- _elem857 = iprot.readString();
- struct.errors.add(_elem857);
+ _elem865 = iprot.readString();
+ struct.errors.add(_elem865);
}
iprot.readListEnd();
}
@@ -459,13 +459,13 @@ import org.slf4j.LoggerFactory;
case 2: // WARNINGS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list859 = iprot.readListBegin();
- struct.warnings = new ArrayList<String>(_list859.size);
- String _elem860;
- for (int _i861 = 0; _i861 < _list859.size; ++_i861)
+ org.apache.thrift.protocol.TList _list867 = iprot.readListBegin();
+ struct.warnings = new ArrayList<String>(_list867.size);
+ String _elem868;
+ for (int _i869 = 0; _i869 < _list867.size; ++_i869)
{
- _elem860 = iprot.readString();
- struct.warnings.add(_elem860);
+ _elem868 = iprot.readString();
+ struct.warnings.add(_elem868);
}
iprot.readListEnd();
}
@@ -492,9 +492,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(ERRORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.errors.size()));
- for (String _iter862 : struct.errors)
+ for (String _iter870 : struct.errors)
{
- oprot.writeString(_iter862);
+ oprot.writeString(_iter870);
}
oprot.writeListEnd();
}
@@ -506,9 +506,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(WARNINGS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.warnings.size()));
- for (String _iter863 : struct.warnings)
+ for (String _iter871 : struct.warnings)
{
- oprot.writeString(_iter863);
+ oprot.writeString(_iter871);
}
oprot.writeListEnd();
}
@@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetErrors()) {
{
oprot.writeI32(struct.errors.size());
- for (String _iter864 : struct.errors)
+ for (String _iter872 : struct.errors)
{
- oprot.writeString(_iter864);
+ oprot.writeString(_iter872);
}
}
}
if (struct.isSetWarnings()) {
{
oprot.writeI32(struct.warnings.size());
- for (String _iter865 : struct.warnings)
+ for (String _iter873 : struct.warnings)
{
- oprot.writeString(_iter865);
+ oprot.writeString(_iter873);
}
}
}
@@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list866 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.errors = new ArrayList<String>(_list866.size);
- String _elem867;
- for (int _i868 = 0; _i868 < _list866.size; ++_i868)
+ org.apache.thrift.protocol.TList _list874 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.errors = new ArrayList<String>(_list874.size);
+ String _elem875;
+ for (int _i876 = 0; _i876 < _list874.size; ++_i876)
{
- _elem867 = iprot.readString();
- struct.errors.add(_elem867);
+ _elem875 = iprot.readString();
+ struct.errors.add(_elem875);
}
}
struct.setErrorsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list869 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.warnings = new ArrayList<String>(_list869.size);
- String _elem870;
- for (int _i871 = 0; _i871 < _list869.size; ++_i871)
+ org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.warnings = new ArrayList<String>(_list877.size);
+ String _elem878;
+ for (int _i879 = 0; _i879 < _list877.size; ++_i879)
{
- _elem870 = iprot.readString();
- struct.warnings.add(_elem870);
+ _elem878 = iprot.readString();
+ struct.warnings.add(_elem878);
}
}
struct.setWarningsIsSet(true);