You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ek...@apache.org on 2018/12/22 04:39:25 UTC
[5/9] hive git commit: HIVE-20936 Allow the Worker thread in the
metastore to run outside of it (Jaume Marhuenda via Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
index 6d3ac0c..f92e23e 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMFullResourcePlan.java
+++ b/standalone-metastore/metastore-common/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 _list880 = iprot.readListBegin();
- struct.pools = new ArrayList<WMPool>(_list880.size);
- WMPool _elem881;
- for (int _i882 = 0; _i882 < _list880.size; ++_i882)
+ org.apache.thrift.protocol.TList _list888 = iprot.readListBegin();
+ struct.pools = new ArrayList<WMPool>(_list888.size);
+ WMPool _elem889;
+ for (int _i890 = 0; _i890 < _list888.size; ++_i890)
{
- _elem881 = new WMPool();
- _elem881.read(iprot);
- struct.pools.add(_elem881);
+ _elem889 = new WMPool();
+ _elem889.read(iprot);
+ struct.pools.add(_elem889);
}
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 _list883 = iprot.readListBegin();
- struct.mappings = new ArrayList<WMMapping>(_list883.size);
- WMMapping _elem884;
- for (int _i885 = 0; _i885 < _list883.size; ++_i885)
+ org.apache.thrift.protocol.TList _list891 = iprot.readListBegin();
+ struct.mappings = new ArrayList<WMMapping>(_list891.size);
+ WMMapping _elem892;
+ for (int _i893 = 0; _i893 < _list891.size; ++_i893)
{
- _elem884 = new WMMapping();
- _elem884.read(iprot);
- struct.mappings.add(_elem884);
+ _elem892 = new WMMapping();
+ _elem892.read(iprot);
+ struct.mappings.add(_elem892);
}
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 _list886 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list886.size);
- WMTrigger _elem887;
- for (int _i888 = 0; _i888 < _list886.size; ++_i888)
+ org.apache.thrift.protocol.TList _list894 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list894.size);
+ WMTrigger _elem895;
+ for (int _i896 = 0; _i896 < _list894.size; ++_i896)
{
- _elem887 = new WMTrigger();
- _elem887.read(iprot);
- struct.triggers.add(_elem887);
+ _elem895 = new WMTrigger();
+ _elem895.read(iprot);
+ struct.triggers.add(_elem895);
}
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 _list889 = iprot.readListBegin();
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list889.size);
- WMPoolTrigger _elem890;
- for (int _i891 = 0; _i891 < _list889.size; ++_i891)
+ org.apache.thrift.protocol.TList _list897 = iprot.readListBegin();
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list897.size);
+ WMPoolTrigger _elem898;
+ for (int _i899 = 0; _i899 < _list897.size; ++_i899)
{
- _elem890 = new WMPoolTrigger();
- _elem890.read(iprot);
- struct.poolTriggers.add(_elem890);
+ _elem898 = new WMPoolTrigger();
+ _elem898.read(iprot);
+ struct.poolTriggers.add(_elem898);
}
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 _iter892 : struct.pools)
+ for (WMPool _iter900 : struct.pools)
{
- _iter892.write(oprot);
+ _iter900.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 _iter893 : struct.mappings)
+ for (WMMapping _iter901 : struct.mappings)
{
- _iter893.write(oprot);
+ _iter901.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 _iter894 : struct.triggers)
+ for (WMTrigger _iter902 : struct.triggers)
{
- _iter894.write(oprot);
+ _iter902.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 _iter895 : struct.poolTriggers)
+ for (WMPoolTrigger _iter903 : struct.poolTriggers)
{
- _iter895.write(oprot);
+ _iter903.write(oprot);
}
oprot.writeListEnd();
}
@@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory;
struct.plan.write(oprot);
{
oprot.writeI32(struct.pools.size());
- for (WMPool _iter896 : struct.pools)
+ for (WMPool _iter904 : struct.pools)
{
- _iter896.write(oprot);
+ _iter904.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory;
if (struct.isSetMappings()) {
{
oprot.writeI32(struct.mappings.size());
- for (WMMapping _iter897 : struct.mappings)
+ for (WMMapping _iter905 : struct.mappings)
{
- _iter897.write(oprot);
+ _iter905.write(oprot);
}
}
}
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter898 : struct.triggers)
+ for (WMTrigger _iter906 : struct.triggers)
{
- _iter898.write(oprot);
+ _iter906.write(oprot);
}
}
}
if (struct.isSetPoolTriggers()) {
{
oprot.writeI32(struct.poolTriggers.size());
- for (WMPoolTrigger _iter899 : struct.poolTriggers)
+ for (WMPoolTrigger _iter907 : struct.poolTriggers)
{
- _iter899.write(oprot);
+ _iter907.write(oprot);
}
}
}
@@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory;
struct.plan.read(iprot);
struct.setPlanIsSet(true);
{
- org.apache.thrift.protocol.TList _list900 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pools = new ArrayList<WMPool>(_list900.size);
- WMPool _elem901;
- for (int _i902 = 0; _i902 < _list900.size; ++_i902)
+ org.apache.thrift.protocol.TList _list908 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pools = new ArrayList<WMPool>(_list908.size);
+ WMPool _elem909;
+ for (int _i910 = 0; _i910 < _list908.size; ++_i910)
{
- _elem901 = new WMPool();
- _elem901.read(iprot);
- struct.pools.add(_elem901);
+ _elem909 = new WMPool();
+ _elem909.read(iprot);
+ struct.pools.add(_elem909);
}
}
struct.setPoolsIsSet(true);
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list903 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.mappings = new ArrayList<WMMapping>(_list903.size);
- WMMapping _elem904;
- for (int _i905 = 0; _i905 < _list903.size; ++_i905)
+ org.apache.thrift.protocol.TList _list911 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.mappings = new ArrayList<WMMapping>(_list911.size);
+ WMMapping _elem912;
+ for (int _i913 = 0; _i913 < _list911.size; ++_i913)
{
- _elem904 = new WMMapping();
- _elem904.read(iprot);
- struct.mappings.add(_elem904);
+ _elem912 = new WMMapping();
+ _elem912.read(iprot);
+ struct.mappings.add(_elem912);
}
}
struct.setMappingsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list906 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list906.size);
- WMTrigger _elem907;
- for (int _i908 = 0; _i908 < _list906.size; ++_i908)
+ org.apache.thrift.protocol.TList _list914 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list914.size);
+ WMTrigger _elem915;
+ for (int _i916 = 0; _i916 < _list914.size; ++_i916)
{
- _elem907 = new WMTrigger();
- _elem907.read(iprot);
- struct.triggers.add(_elem907);
+ _elem915 = new WMTrigger();
+ _elem915.read(iprot);
+ struct.triggers.add(_elem915);
}
}
struct.setTriggersIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list909.size);
- WMPoolTrigger _elem910;
- for (int _i911 = 0; _i911 < _list909.size; ++_i911)
+ org.apache.thrift.protocol.TList _list917 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list917.size);
+ WMPoolTrigger _elem918;
+ for (int _i919 = 0; _i919 < _list917.size; ++_i919)
{
- _elem910 = new WMPoolTrigger();
- _elem910.read(iprot);
- struct.poolTriggers.add(_elem910);
+ _elem918 = new WMPoolTrigger();
+ _elem918.read(iprot);
+ struct.poolTriggers.add(_elem918);
}
}
struct.setPoolTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
index 2c427b9..cd20b15 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetAllResourcePlanResponse.java
+++ b/standalone-metastore/metastore-common/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 _list912 = iprot.readListBegin();
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list912.size);
- WMResourcePlan _elem913;
- for (int _i914 = 0; _i914 < _list912.size; ++_i914)
+ org.apache.thrift.protocol.TList _list920 = iprot.readListBegin();
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list920.size);
+ WMResourcePlan _elem921;
+ for (int _i922 = 0; _i922 < _list920.size; ++_i922)
{
- _elem913 = new WMResourcePlan();
- _elem913.read(iprot);
- struct.resourcePlans.add(_elem913);
+ _elem921 = new WMResourcePlan();
+ _elem921.read(iprot);
+ struct.resourcePlans.add(_elem921);
}
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 _iter915 : struct.resourcePlans)
+ for (WMResourcePlan _iter923 : struct.resourcePlans)
{
- _iter915.write(oprot);
+ _iter923.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetResourcePlans()) {
{
oprot.writeI32(struct.resourcePlans.size());
- for (WMResourcePlan _iter916 : struct.resourcePlans)
+ for (WMResourcePlan _iter924 : struct.resourcePlans)
{
- _iter916.write(oprot);
+ _iter924.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list917 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list917.size);
- WMResourcePlan _elem918;
- for (int _i919 = 0; _i919 < _list917.size; ++_i919)
+ org.apache.thrift.protocol.TList _list925 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list925.size);
+ WMResourcePlan _elem926;
+ for (int _i927 = 0; _i927 < _list925.size; ++_i927)
{
- _elem918 = new WMResourcePlan();
- _elem918.read(iprot);
- struct.resourcePlans.add(_elem918);
+ _elem926 = new WMResourcePlan();
+ _elem926.read(iprot);
+ struct.resourcePlans.add(_elem926);
}
}
struct.setResourcePlansIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
index 57615c0..0fc76b9 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMGetTriggersForResourePlanResponse.java
+++ b/standalone-metastore/metastore-common/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 _list936 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list936.size);
- WMTrigger _elem937;
- for (int _i938 = 0; _i938 < _list936.size; ++_i938)
+ org.apache.thrift.protocol.TList _list944 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list944.size);
+ WMTrigger _elem945;
+ for (int _i946 = 0; _i946 < _list944.size; ++_i946)
{
- _elem937 = new WMTrigger();
- _elem937.read(iprot);
- struct.triggers.add(_elem937);
+ _elem945 = new WMTrigger();
+ _elem945.read(iprot);
+ struct.triggers.add(_elem945);
}
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 _iter939 : struct.triggers)
+ for (WMTrigger _iter947 : struct.triggers)
{
- _iter939.write(oprot);
+ _iter947.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter940 : struct.triggers)
+ for (WMTrigger _iter948 : struct.triggers)
{
- _iter940.write(oprot);
+ _iter948.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list941 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list941.size);
- WMTrigger _elem942;
- for (int _i943 = 0; _i943 < _list941.size; ++_i943)
+ org.apache.thrift.protocol.TList _list949 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list949.size);
+ WMTrigger _elem950;
+ for (int _i951 = 0; _i951 < _list949.size; ++_i951)
{
- _elem942 = new WMTrigger();
- _elem942.read(iprot);
- struct.triggers.add(_elem942);
+ _elem950 = new WMTrigger();
+ _elem950.read(iprot);
+ struct.triggers.add(_elem950);
}
}
struct.setTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
index 3f7f953..deb1569 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WMValidateResourcePlanResponse.java
+++ b/standalone-metastore/metastore-common/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 _list920 = iprot.readListBegin();
- struct.errors = new ArrayList<String>(_list920.size);
- String _elem921;
- for (int _i922 = 0; _i922 < _list920.size; ++_i922)
+ org.apache.thrift.protocol.TList _list928 = iprot.readListBegin();
+ struct.errors = new ArrayList<String>(_list928.size);
+ String _elem929;
+ for (int _i930 = 0; _i930 < _list928.size; ++_i930)
{
- _elem921 = iprot.readString();
- struct.errors.add(_elem921);
+ _elem929 = iprot.readString();
+ struct.errors.add(_elem929);
}
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 _list923 = iprot.readListBegin();
- struct.warnings = new ArrayList<String>(_list923.size);
- String _elem924;
- for (int _i925 = 0; _i925 < _list923.size; ++_i925)
+ org.apache.thrift.protocol.TList _list931 = iprot.readListBegin();
+ struct.warnings = new ArrayList<String>(_list931.size);
+ String _elem932;
+ for (int _i933 = 0; _i933 < _list931.size; ++_i933)
{
- _elem924 = iprot.readString();
- struct.warnings.add(_elem924);
+ _elem932 = iprot.readString();
+ struct.warnings.add(_elem932);
}
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 _iter926 : struct.errors)
+ for (String _iter934 : struct.errors)
{
- oprot.writeString(_iter926);
+ oprot.writeString(_iter934);
}
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 _iter927 : struct.warnings)
+ for (String _iter935 : struct.warnings)
{
- oprot.writeString(_iter927);
+ oprot.writeString(_iter935);
}
oprot.writeListEnd();
}
@@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetErrors()) {
{
oprot.writeI32(struct.errors.size());
- for (String _iter928 : struct.errors)
+ for (String _iter936 : struct.errors)
{
- oprot.writeString(_iter928);
+ oprot.writeString(_iter936);
}
}
}
if (struct.isSetWarnings()) {
{
oprot.writeI32(struct.warnings.size());
- for (String _iter929 : struct.warnings)
+ for (String _iter937 : struct.warnings)
{
- oprot.writeString(_iter929);
+ oprot.writeString(_iter937);
}
}
}
@@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list930 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.errors = new ArrayList<String>(_list930.size);
- String _elem931;
- for (int _i932 = 0; _i932 < _list930.size; ++_i932)
+ org.apache.thrift.protocol.TList _list938 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.errors = new ArrayList<String>(_list938.size);
+ String _elem939;
+ for (int _i940 = 0; _i940 < _list938.size; ++_i940)
{
- _elem931 = iprot.readString();
- struct.errors.add(_elem931);
+ _elem939 = iprot.readString();
+ struct.errors.add(_elem939);
}
}
struct.setErrorsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list933 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.warnings = new ArrayList<String>(_list933.size);
- String _elem934;
- for (int _i935 = 0; _i935 < _list933.size; ++_i935)
+ org.apache.thrift.protocol.TList _list941 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.warnings = new ArrayList<String>(_list941.size);
+ String _elem942;
+ for (int _i943 = 0; _i943 < _list941.size; ++_i943)
{
- _elem934 = iprot.readString();
- struct.warnings.add(_elem934);
+ _elem942 = iprot.readString();
+ struct.warnings.add(_elem942);
}
}
struct.setWarningsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteNotificationLogRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteNotificationLogRequest.java b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteNotificationLogRequest.java
index a897141..57f50b7 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteNotificationLogRequest.java
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteNotificationLogRequest.java
@@ -813,13 +813,13 @@ import org.slf4j.LoggerFactory;
case 6: // PARTITION_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
- struct.partitionVals = new ArrayList<String>(_list780.size);
- String _elem781;
- for (int _i782 = 0; _i782 < _list780.size; ++_i782)
+ org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
+ struct.partitionVals = new ArrayList<String>(_list788.size);
+ String _elem789;
+ for (int _i790 = 0; _i790 < _list788.size; ++_i790)
{
- _elem781 = iprot.readString();
- struct.partitionVals.add(_elem781);
+ _elem789 = iprot.readString();
+ struct.partitionVals.add(_elem789);
}
iprot.readListEnd();
}
@@ -867,9 +867,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(PARTITION_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partitionVals.size()));
- for (String _iter783 : struct.partitionVals)
+ for (String _iter791 : struct.partitionVals)
{
- oprot.writeString(_iter783);
+ oprot.writeString(_iter791);
}
oprot.writeListEnd();
}
@@ -906,9 +906,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetPartitionVals()) {
{
oprot.writeI32(struct.partitionVals.size());
- for (String _iter784 : struct.partitionVals)
+ for (String _iter792 : struct.partitionVals)
{
- oprot.writeString(_iter784);
+ oprot.writeString(_iter792);
}
}
}
@@ -931,13 +931,13 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.partitionVals = new ArrayList<String>(_list785.size);
- String _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.STRING, iprot.readI32());
+ struct.partitionVals = new ArrayList<String>(_list793.size);
+ String _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem786 = iprot.readString();
- struct.partitionVals.add(_elem786);
+ _elem794 = iprot.readString();
+ struct.partitionVals.add(_elem794);
}
}
struct.setPartitionValsIsSet(true);