You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/07/24 11:43:07 UTC
[11/19] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 f4e30f0..f0c308d 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 _list840 = iprot.readListBegin();
- struct.pools = new ArrayList<WMPool>(_list840.size);
- WMPool _elem841;
- for (int _i842 = 0; _i842 < _list840.size; ++_i842)
+ org.apache.thrift.protocol.TList _list864 = iprot.readListBegin();
+ struct.pools = new ArrayList<WMPool>(_list864.size);
+ WMPool _elem865;
+ for (int _i866 = 0; _i866 < _list864.size; ++_i866)
{
- _elem841 = new WMPool();
- _elem841.read(iprot);
- struct.pools.add(_elem841);
+ _elem865 = new WMPool();
+ _elem865.read(iprot);
+ struct.pools.add(_elem865);
}
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 _list843 = iprot.readListBegin();
- struct.mappings = new ArrayList<WMMapping>(_list843.size);
- WMMapping _elem844;
- for (int _i845 = 0; _i845 < _list843.size; ++_i845)
+ org.apache.thrift.protocol.TList _list867 = iprot.readListBegin();
+ struct.mappings = new ArrayList<WMMapping>(_list867.size);
+ WMMapping _elem868;
+ for (int _i869 = 0; _i869 < _list867.size; ++_i869)
{
- _elem844 = new WMMapping();
- _elem844.read(iprot);
- struct.mappings.add(_elem844);
+ _elem868 = new WMMapping();
+ _elem868.read(iprot);
+ struct.mappings.add(_elem868);
}
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 _list846 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list846.size);
- WMTrigger _elem847;
- for (int _i848 = 0; _i848 < _list846.size; ++_i848)
+ org.apache.thrift.protocol.TList _list870 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list870.size);
+ WMTrigger _elem871;
+ for (int _i872 = 0; _i872 < _list870.size; ++_i872)
{
- _elem847 = new WMTrigger();
- _elem847.read(iprot);
- struct.triggers.add(_elem847);
+ _elem871 = new WMTrigger();
+ _elem871.read(iprot);
+ struct.triggers.add(_elem871);
}
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 _list849 = iprot.readListBegin();
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list849.size);
- WMPoolTrigger _elem850;
- for (int _i851 = 0; _i851 < _list849.size; ++_i851)
+ org.apache.thrift.protocol.TList _list873 = iprot.readListBegin();
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list873.size);
+ WMPoolTrigger _elem874;
+ for (int _i875 = 0; _i875 < _list873.size; ++_i875)
{
- _elem850 = new WMPoolTrigger();
- _elem850.read(iprot);
- struct.poolTriggers.add(_elem850);
+ _elem874 = new WMPoolTrigger();
+ _elem874.read(iprot);
+ struct.poolTriggers.add(_elem874);
}
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 _iter852 : struct.pools)
+ for (WMPool _iter876 : struct.pools)
{
- _iter852.write(oprot);
+ _iter876.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 _iter853 : struct.mappings)
+ for (WMMapping _iter877 : struct.mappings)
{
- _iter853.write(oprot);
+ _iter877.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 _iter854 : struct.triggers)
+ for (WMTrigger _iter878 : struct.triggers)
{
- _iter854.write(oprot);
+ _iter878.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 _iter855 : struct.poolTriggers)
+ for (WMPoolTrigger _iter879 : struct.poolTriggers)
{
- _iter855.write(oprot);
+ _iter879.write(oprot);
}
oprot.writeListEnd();
}
@@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory;
struct.plan.write(oprot);
{
oprot.writeI32(struct.pools.size());
- for (WMPool _iter856 : struct.pools)
+ for (WMPool _iter880 : struct.pools)
{
- _iter856.write(oprot);
+ _iter880.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory;
if (struct.isSetMappings()) {
{
oprot.writeI32(struct.mappings.size());
- for (WMMapping _iter857 : struct.mappings)
+ for (WMMapping _iter881 : struct.mappings)
{
- _iter857.write(oprot);
+ _iter881.write(oprot);
}
}
}
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter858 : struct.triggers)
+ for (WMTrigger _iter882 : struct.triggers)
{
- _iter858.write(oprot);
+ _iter882.write(oprot);
}
}
}
if (struct.isSetPoolTriggers()) {
{
oprot.writeI32(struct.poolTriggers.size());
- for (WMPoolTrigger _iter859 : struct.poolTriggers)
+ for (WMPoolTrigger _iter883 : struct.poolTriggers)
{
- _iter859.write(oprot);
+ _iter883.write(oprot);
}
}
}
@@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory;
struct.plan.read(iprot);
struct.setPlanIsSet(true);
{
- org.apache.thrift.protocol.TList _list860 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pools = new ArrayList<WMPool>(_list860.size);
- WMPool _elem861;
- for (int _i862 = 0; _i862 < _list860.size; ++_i862)
+ org.apache.thrift.protocol.TList _list884 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pools = new ArrayList<WMPool>(_list884.size);
+ WMPool _elem885;
+ for (int _i886 = 0; _i886 < _list884.size; ++_i886)
{
- _elem861 = new WMPool();
- _elem861.read(iprot);
- struct.pools.add(_elem861);
+ _elem885 = new WMPool();
+ _elem885.read(iprot);
+ struct.pools.add(_elem885);
}
}
struct.setPoolsIsSet(true);
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list863 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.mappings = new ArrayList<WMMapping>(_list863.size);
- WMMapping _elem864;
- for (int _i865 = 0; _i865 < _list863.size; ++_i865)
+ org.apache.thrift.protocol.TList _list887 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.mappings = new ArrayList<WMMapping>(_list887.size);
+ WMMapping _elem888;
+ for (int _i889 = 0; _i889 < _list887.size; ++_i889)
{
- _elem864 = new WMMapping();
- _elem864.read(iprot);
- struct.mappings.add(_elem864);
+ _elem888 = new WMMapping();
+ _elem888.read(iprot);
+ struct.mappings.add(_elem888);
}
}
struct.setMappingsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list866 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list866.size);
- WMTrigger _elem867;
- for (int _i868 = 0; _i868 < _list866.size; ++_i868)
+ org.apache.thrift.protocol.TList _list890 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list890.size);
+ WMTrigger _elem891;
+ for (int _i892 = 0; _i892 < _list890.size; ++_i892)
{
- _elem867 = new WMTrigger();
- _elem867.read(iprot);
- struct.triggers.add(_elem867);
+ _elem891 = new WMTrigger();
+ _elem891.read(iprot);
+ struct.triggers.add(_elem891);
}
}
struct.setTriggersIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list869 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list869.size);
- WMPoolTrigger _elem870;
- for (int _i871 = 0; _i871 < _list869.size; ++_i871)
+ org.apache.thrift.protocol.TList _list893 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list893.size);
+ WMPoolTrigger _elem894;
+ for (int _i895 = 0; _i895 < _list893.size; ++_i895)
{
- _elem870 = new WMPoolTrigger();
- _elem870.read(iprot);
- struct.poolTriggers.add(_elem870);
+ _elem894 = new WMPoolTrigger();
+ _elem894.read(iprot);
+ struct.poolTriggers.add(_elem894);
}
}
struct.setPoolTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 ba81ce9..6eed84b 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 _list872 = iprot.readListBegin();
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list872.size);
- WMResourcePlan _elem873;
- for (int _i874 = 0; _i874 < _list872.size; ++_i874)
+ org.apache.thrift.protocol.TList _list896 = iprot.readListBegin();
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list896.size);
+ WMResourcePlan _elem897;
+ for (int _i898 = 0; _i898 < _list896.size; ++_i898)
{
- _elem873 = new WMResourcePlan();
- _elem873.read(iprot);
- struct.resourcePlans.add(_elem873);
+ _elem897 = new WMResourcePlan();
+ _elem897.read(iprot);
+ struct.resourcePlans.add(_elem897);
}
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 _iter875 : struct.resourcePlans)
+ for (WMResourcePlan _iter899 : struct.resourcePlans)
{
- _iter875.write(oprot);
+ _iter899.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetResourcePlans()) {
{
oprot.writeI32(struct.resourcePlans.size());
- for (WMResourcePlan _iter876 : struct.resourcePlans)
+ for (WMResourcePlan _iter900 : struct.resourcePlans)
{
- _iter876.write(oprot);
+ _iter900.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.resourcePlans = new ArrayList<WMResourcePlan>(_list877.size);
- WMResourcePlan _elem878;
- for (int _i879 = 0; _i879 < _list877.size; ++_i879)
+ org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list901.size);
+ WMResourcePlan _elem902;
+ for (int _i903 = 0; _i903 < _list901.size; ++_i903)
{
- _elem878 = new WMResourcePlan();
- _elem878.read(iprot);
- struct.resourcePlans.add(_elem878);
+ _elem902 = new WMResourcePlan();
+ _elem902.read(iprot);
+ struct.resourcePlans.add(_elem902);
}
}
struct.setResourcePlansIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 10ed67c..53ea5d5 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 _list896 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list896.size);
- WMTrigger _elem897;
- for (int _i898 = 0; _i898 < _list896.size; ++_i898)
+ org.apache.thrift.protocol.TList _list920 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list920.size);
+ WMTrigger _elem921;
+ for (int _i922 = 0; _i922 < _list920.size; ++_i922)
{
- _elem897 = new WMTrigger();
- _elem897.read(iprot);
- struct.triggers.add(_elem897);
+ _elem921 = new WMTrigger();
+ _elem921.read(iprot);
+ struct.triggers.add(_elem921);
}
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 _iter899 : struct.triggers)
+ for (WMTrigger _iter923 : struct.triggers)
{
- _iter899.write(oprot);
+ _iter923.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter900 : struct.triggers)
+ for (WMTrigger _iter924 : struct.triggers)
{
- _iter900.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 _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list901.size);
- WMTrigger _elem902;
- for (int _i903 = 0; _i903 < _list901.size; ++_i903)
+ org.apache.thrift.protocol.TList _list925 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list925.size);
+ WMTrigger _elem926;
+ for (int _i927 = 0; _i927 < _list925.size; ++_i927)
{
- _elem902 = new WMTrigger();
- _elem902.read(iprot);
- struct.triggers.add(_elem902);
+ _elem926 = new WMTrigger();
+ _elem926.read(iprot);
+ struct.triggers.add(_elem926);
}
}
struct.setTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 86d7d5c..0dd8a5e 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 _list880 = iprot.readListBegin();
- struct.errors = new ArrayList<String>(_list880.size);
- String _elem881;
- for (int _i882 = 0; _i882 < _list880.size; ++_i882)
+ org.apache.thrift.protocol.TList _list904 = iprot.readListBegin();
+ struct.errors = new ArrayList<String>(_list904.size);
+ String _elem905;
+ for (int _i906 = 0; _i906 < _list904.size; ++_i906)
{
- _elem881 = iprot.readString();
- struct.errors.add(_elem881);
+ _elem905 = iprot.readString();
+ struct.errors.add(_elem905);
}
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 _list883 = iprot.readListBegin();
- struct.warnings = new ArrayList<String>(_list883.size);
- String _elem884;
- for (int _i885 = 0; _i885 < _list883.size; ++_i885)
+ org.apache.thrift.protocol.TList _list907 = iprot.readListBegin();
+ struct.warnings = new ArrayList<String>(_list907.size);
+ String _elem908;
+ for (int _i909 = 0; _i909 < _list907.size; ++_i909)
{
- _elem884 = iprot.readString();
- struct.warnings.add(_elem884);
+ _elem908 = iprot.readString();
+ struct.warnings.add(_elem908);
}
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 _iter886 : struct.errors)
+ for (String _iter910 : struct.errors)
{
- oprot.writeString(_iter886);
+ oprot.writeString(_iter910);
}
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 _iter887 : struct.warnings)
+ for (String _iter911 : struct.warnings)
{
- oprot.writeString(_iter887);
+ oprot.writeString(_iter911);
}
oprot.writeListEnd();
}
@@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetErrors()) {
{
oprot.writeI32(struct.errors.size());
- for (String _iter888 : struct.errors)
+ for (String _iter912 : struct.errors)
{
- oprot.writeString(_iter888);
+ oprot.writeString(_iter912);
}
}
}
if (struct.isSetWarnings()) {
{
oprot.writeI32(struct.warnings.size());
- for (String _iter889 : struct.warnings)
+ for (String _iter913 : struct.warnings)
{
- oprot.writeString(_iter889);
+ oprot.writeString(_iter913);
}
}
}
@@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list890 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.errors = new ArrayList<String>(_list890.size);
- String _elem891;
- for (int _i892 = 0; _i892 < _list890.size; ++_i892)
+ org.apache.thrift.protocol.TList _list914 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.errors = new ArrayList<String>(_list914.size);
+ String _elem915;
+ for (int _i916 = 0; _i916 < _list914.size; ++_i916)
{
- _elem891 = iprot.readString();
- struct.errors.add(_elem891);
+ _elem915 = iprot.readString();
+ struct.errors.add(_elem915);
}
}
struct.setErrorsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list893 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.warnings = new ArrayList<String>(_list893.size);
- String _elem894;
- for (int _i895 = 0; _i895 < _list893.size; ++_i895)
+ org.apache.thrift.protocol.TList _list917 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.warnings = new ArrayList<String>(_list917.size);
+ String _elem918;
+ for (int _i919 = 0; _i919 < _list917.size; ++_i919)
{
- _elem894 = iprot.readString();
- struct.warnings.add(_elem894);
+ _elem918 = iprot.readString();
+ struct.warnings.add(_elem918);
}
}
struct.setWarningsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteEventInfo.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteEventInfo.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteEventInfo.java
new file mode 100644
index 0000000..22f2609
--- /dev/null
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/WriteEventInfo.java
@@ -0,0 +1,1012 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hadoop.hive.metastore.api;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@org.apache.hadoop.classification.InterfaceAudience.Public @org.apache.hadoop.classification.InterfaceStability.Stable public class WriteEventInfo implements org.apache.thrift.TBase<WriteEventInfo, WriteEventInfo._Fields>, java.io.Serializable, Cloneable, Comparable<WriteEventInfo> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WriteEventInfo");
+
+ private static final org.apache.thrift.protocol.TField WRITE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("writeId", org.apache.thrift.protocol.TType.I64, (short)1);
+ private static final org.apache.thrift.protocol.TField DATABASE_FIELD_DESC = new org.apache.thrift.protocol.TField("database", org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)3);
+ private static final org.apache.thrift.protocol.TField FILES_FIELD_DESC = new org.apache.thrift.protocol.TField("files", org.apache.thrift.protocol.TType.STRING, (short)4);
+ private static final org.apache.thrift.protocol.TField PARTITION_FIELD_DESC = new org.apache.thrift.protocol.TField("partition", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField TABLE_OBJ_FIELD_DESC = new org.apache.thrift.protocol.TField("tableObj", org.apache.thrift.protocol.TType.STRING, (short)6);
+ private static final org.apache.thrift.protocol.TField PARTITION_OBJ_FIELD_DESC = new org.apache.thrift.protocol.TField("partitionObj", org.apache.thrift.protocol.TType.STRING, (short)7);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new WriteEventInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new WriteEventInfoTupleSchemeFactory());
+ }
+
+ private long writeId; // required
+ private String database; // required
+ private String table; // required
+ private String files; // required
+ private String partition; // optional
+ private String tableObj; // optional
+ private String partitionObj; // optional
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ WRITE_ID((short)1, "writeId"),
+ DATABASE((short)2, "database"),
+ TABLE((short)3, "table"),
+ FILES((short)4, "files"),
+ PARTITION((short)5, "partition"),
+ TABLE_OBJ((short)6, "tableObj"),
+ PARTITION_OBJ((short)7, "partitionObj");
+
+ 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: // WRITE_ID
+ return WRITE_ID;
+ case 2: // DATABASE
+ return DATABASE;
+ case 3: // TABLE
+ return TABLE;
+ case 4: // FILES
+ return FILES;
+ case 5: // PARTITION
+ return PARTITION;
+ case 6: // TABLE_OBJ
+ return TABLE_OBJ;
+ case 7: // PARTITION_OBJ
+ return PARTITION_OBJ;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final int __WRITEID_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ private static final _Fields optionals[] = {_Fields.PARTITION,_Fields.TABLE_OBJ,_Fields.PARTITION_OBJ};
+ 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.WRITE_ID, new org.apache.thrift.meta_data.FieldMetaData("writeId", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
+ tmpMap.put(_Fields.DATABASE, new org.apache.thrift.meta_data.FieldMetaData("database", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.FILES, new org.apache.thrift.meta_data.FieldMetaData("files", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PARTITION, new org.apache.thrift.meta_data.FieldMetaData("partition", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.TABLE_OBJ, new org.apache.thrift.meta_data.FieldMetaData("tableObj", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.PARTITION_OBJ, new org.apache.thrift.meta_data.FieldMetaData("partitionObj", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(WriteEventInfo.class, metaDataMap);
+ }
+
+ public WriteEventInfo() {
+ }
+
+ public WriteEventInfo(
+ long writeId,
+ String database,
+ String table,
+ String files)
+ {
+ this();
+ this.writeId = writeId;
+ setWriteIdIsSet(true);
+ this.database = database;
+ this.table = table;
+ this.files = files;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public WriteEventInfo(WriteEventInfo other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.writeId = other.writeId;
+ if (other.isSetDatabase()) {
+ this.database = other.database;
+ }
+ if (other.isSetTable()) {
+ this.table = other.table;
+ }
+ if (other.isSetFiles()) {
+ this.files = other.files;
+ }
+ if (other.isSetPartition()) {
+ this.partition = other.partition;
+ }
+ if (other.isSetTableObj()) {
+ this.tableObj = other.tableObj;
+ }
+ if (other.isSetPartitionObj()) {
+ this.partitionObj = other.partitionObj;
+ }
+ }
+
+ public WriteEventInfo deepCopy() {
+ return new WriteEventInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ setWriteIdIsSet(false);
+ this.writeId = 0;
+ this.database = null;
+ this.table = null;
+ this.files = null;
+ this.partition = null;
+ this.tableObj = null;
+ this.partitionObj = null;
+ }
+
+ public long getWriteId() {
+ return this.writeId;
+ }
+
+ public void setWriteId(long writeId) {
+ this.writeId = writeId;
+ setWriteIdIsSet(true);
+ }
+
+ public void unsetWriteId() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITEID_ISSET_ID);
+ }
+
+ /** Returns true if field writeId is set (has been assigned a value) and false otherwise */
+ public boolean isSetWriteId() {
+ return EncodingUtils.testBit(__isset_bitfield, __WRITEID_ISSET_ID);
+ }
+
+ public void setWriteIdIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITEID_ISSET_ID, value);
+ }
+
+ public String getDatabase() {
+ return this.database;
+ }
+
+ public void setDatabase(String database) {
+ this.database = database;
+ }
+
+ public void unsetDatabase() {
+ this.database = null;
+ }
+
+ /** Returns true if field database is set (has been assigned a value) and false otherwise */
+ public boolean isSetDatabase() {
+ return this.database != null;
+ }
+
+ public void setDatabaseIsSet(boolean value) {
+ if (!value) {
+ this.database = null;
+ }
+ }
+
+ public String getTable() {
+ return this.table;
+ }
+
+ public void setTable(String table) {
+ this.table = table;
+ }
+
+ public void unsetTable() {
+ this.table = null;
+ }
+
+ /** Returns true if field table is set (has been assigned a value) and false otherwise */
+ public boolean isSetTable() {
+ return this.table != null;
+ }
+
+ public void setTableIsSet(boolean value) {
+ if (!value) {
+ this.table = null;
+ }
+ }
+
+ public String getFiles() {
+ return this.files;
+ }
+
+ public void setFiles(String files) {
+ this.files = files;
+ }
+
+ public void unsetFiles() {
+ this.files = null;
+ }
+
+ /** Returns true if field files is set (has been assigned a value) and false otherwise */
+ public boolean isSetFiles() {
+ return this.files != null;
+ }
+
+ public void setFilesIsSet(boolean value) {
+ if (!value) {
+ this.files = null;
+ }
+ }
+
+ public String getPartition() {
+ return this.partition;
+ }
+
+ public void setPartition(String partition) {
+ this.partition = partition;
+ }
+
+ public void unsetPartition() {
+ this.partition = null;
+ }
+
+ /** Returns true if field partition is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartition() {
+ return this.partition != null;
+ }
+
+ public void setPartitionIsSet(boolean value) {
+ if (!value) {
+ this.partition = null;
+ }
+ }
+
+ public String getTableObj() {
+ return this.tableObj;
+ }
+
+ public void setTableObj(String tableObj) {
+ this.tableObj = tableObj;
+ }
+
+ public void unsetTableObj() {
+ this.tableObj = null;
+ }
+
+ /** Returns true if field tableObj is set (has been assigned a value) and false otherwise */
+ public boolean isSetTableObj() {
+ return this.tableObj != null;
+ }
+
+ public void setTableObjIsSet(boolean value) {
+ if (!value) {
+ this.tableObj = null;
+ }
+ }
+
+ public String getPartitionObj() {
+ return this.partitionObj;
+ }
+
+ public void setPartitionObj(String partitionObj) {
+ this.partitionObj = partitionObj;
+ }
+
+ public void unsetPartitionObj() {
+ this.partitionObj = null;
+ }
+
+ /** Returns true if field partitionObj is set (has been assigned a value) and false otherwise */
+ public boolean isSetPartitionObj() {
+ return this.partitionObj != null;
+ }
+
+ public void setPartitionObjIsSet(boolean value) {
+ if (!value) {
+ this.partitionObj = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case WRITE_ID:
+ if (value == null) {
+ unsetWriteId();
+ } else {
+ setWriteId((Long)value);
+ }
+ break;
+
+ case DATABASE:
+ if (value == null) {
+ unsetDatabase();
+ } else {
+ setDatabase((String)value);
+ }
+ break;
+
+ case TABLE:
+ if (value == null) {
+ unsetTable();
+ } else {
+ setTable((String)value);
+ }
+ break;
+
+ case FILES:
+ if (value == null) {
+ unsetFiles();
+ } else {
+ setFiles((String)value);
+ }
+ break;
+
+ case PARTITION:
+ if (value == null) {
+ unsetPartition();
+ } else {
+ setPartition((String)value);
+ }
+ break;
+
+ case TABLE_OBJ:
+ if (value == null) {
+ unsetTableObj();
+ } else {
+ setTableObj((String)value);
+ }
+ break;
+
+ case PARTITION_OBJ:
+ if (value == null) {
+ unsetPartitionObj();
+ } else {
+ setPartitionObj((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case WRITE_ID:
+ return getWriteId();
+
+ case DATABASE:
+ return getDatabase();
+
+ case TABLE:
+ return getTable();
+
+ case FILES:
+ return getFiles();
+
+ case PARTITION:
+ return getPartition();
+
+ case TABLE_OBJ:
+ return getTableObj();
+
+ case PARTITION_OBJ:
+ return getPartitionObj();
+
+ }
+ 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 WRITE_ID:
+ return isSetWriteId();
+ case DATABASE:
+ return isSetDatabase();
+ case TABLE:
+ return isSetTable();
+ case FILES:
+ return isSetFiles();
+ case PARTITION:
+ return isSetPartition();
+ case TABLE_OBJ:
+ return isSetTableObj();
+ case PARTITION_OBJ:
+ return isSetPartitionObj();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof WriteEventInfo)
+ return this.equals((WriteEventInfo)that);
+ return false;
+ }
+
+ public boolean equals(WriteEventInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_writeId = true;
+ boolean that_present_writeId = true;
+ if (this_present_writeId || that_present_writeId) {
+ if (!(this_present_writeId && that_present_writeId))
+ return false;
+ if (this.writeId != that.writeId)
+ return false;
+ }
+
+ boolean this_present_database = true && this.isSetDatabase();
+ boolean that_present_database = true && that.isSetDatabase();
+ if (this_present_database || that_present_database) {
+ if (!(this_present_database && that_present_database))
+ return false;
+ if (!this.database.equals(that.database))
+ return false;
+ }
+
+ boolean this_present_table = true && this.isSetTable();
+ boolean that_present_table = true && that.isSetTable();
+ if (this_present_table || that_present_table) {
+ if (!(this_present_table && that_present_table))
+ return false;
+ if (!this.table.equals(that.table))
+ return false;
+ }
+
+ boolean this_present_files = true && this.isSetFiles();
+ boolean that_present_files = true && that.isSetFiles();
+ if (this_present_files || that_present_files) {
+ if (!(this_present_files && that_present_files))
+ return false;
+ if (!this.files.equals(that.files))
+ return false;
+ }
+
+ boolean this_present_partition = true && this.isSetPartition();
+ boolean that_present_partition = true && that.isSetPartition();
+ if (this_present_partition || that_present_partition) {
+ if (!(this_present_partition && that_present_partition))
+ return false;
+ if (!this.partition.equals(that.partition))
+ return false;
+ }
+
+ boolean this_present_tableObj = true && this.isSetTableObj();
+ boolean that_present_tableObj = true && that.isSetTableObj();
+ if (this_present_tableObj || that_present_tableObj) {
+ if (!(this_present_tableObj && that_present_tableObj))
+ return false;
+ if (!this.tableObj.equals(that.tableObj))
+ return false;
+ }
+
+ boolean this_present_partitionObj = true && this.isSetPartitionObj();
+ boolean that_present_partitionObj = true && that.isSetPartitionObj();
+ if (this_present_partitionObj || that_present_partitionObj) {
+ if (!(this_present_partitionObj && that_present_partitionObj))
+ return false;
+ if (!this.partitionObj.equals(that.partitionObj))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_writeId = true;
+ list.add(present_writeId);
+ if (present_writeId)
+ list.add(writeId);
+
+ boolean present_database = true && (isSetDatabase());
+ list.add(present_database);
+ if (present_database)
+ list.add(database);
+
+ boolean present_table = true && (isSetTable());
+ list.add(present_table);
+ if (present_table)
+ list.add(table);
+
+ boolean present_files = true && (isSetFiles());
+ list.add(present_files);
+ if (present_files)
+ list.add(files);
+
+ boolean present_partition = true && (isSetPartition());
+ list.add(present_partition);
+ if (present_partition)
+ list.add(partition);
+
+ boolean present_tableObj = true && (isSetTableObj());
+ list.add(present_tableObj);
+ if (present_tableObj)
+ list.add(tableObj);
+
+ boolean present_partitionObj = true && (isSetPartitionObj());
+ list.add(present_partitionObj);
+ if (present_partitionObj)
+ list.add(partitionObj);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(WriteEventInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetWriteId()).compareTo(other.isSetWriteId());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetWriteId()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.writeId, other.writeId);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetDatabase()).compareTo(other.isSetDatabase());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetDatabase()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.database, other.database);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTable()).compareTo(other.isSetTable());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTable()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table, other.table);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetFiles()).compareTo(other.isSetFiles());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetFiles()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.files, other.files);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartition()).compareTo(other.isSetPartition());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartition()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partition, other.partition);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetTableObj()).compareTo(other.isSetTableObj());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetTableObj()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableObj, other.tableObj);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetPartitionObj()).compareTo(other.isSetPartitionObj());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetPartitionObj()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.partitionObj, other.partitionObj);
+ 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("WriteEventInfo(");
+ boolean first = true;
+
+ sb.append("writeId:");
+ sb.append(this.writeId);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("database:");
+ if (this.database == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.database);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("table:");
+ if (this.table == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.table);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("files:");
+ if (this.files == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.files);
+ }
+ first = false;
+ if (isSetPartition()) {
+ if (!first) sb.append(", ");
+ sb.append("partition:");
+ if (this.partition == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partition);
+ }
+ first = false;
+ }
+ if (isSetTableObj()) {
+ if (!first) sb.append(", ");
+ sb.append("tableObj:");
+ if (this.tableObj == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.tableObj);
+ }
+ first = false;
+ }
+ if (isSetPartitionObj()) {
+ if (!first) sb.append(", ");
+ sb.append("partitionObj:");
+ if (this.partitionObj == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.partitionObj);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ if (!isSetWriteId()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'writeId' is unset! Struct:" + toString());
+ }
+
+ if (!isSetDatabase()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'database' is unset! Struct:" + toString());
+ }
+
+ if (!isSetTable()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' is unset! Struct:" + toString());
+ }
+
+ if (!isSetFiles()) {
+ throw new org.apache.thrift.protocol.TProtocolException("Required field 'files' is unset! Struct:" + toString());
+ }
+
+ // 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 {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class WriteEventInfoStandardSchemeFactory implements SchemeFactory {
+ public WriteEventInfoStandardScheme getScheme() {
+ return new WriteEventInfoStandardScheme();
+ }
+ }
+
+ private static class WriteEventInfoStandardScheme extends StandardScheme<WriteEventInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, WriteEventInfo 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: // WRITE_ID
+ if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
+ struct.writeId = iprot.readI64();
+ struct.setWriteIdIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // DATABASE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.database = iprot.readString();
+ struct.setDatabaseIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 3: // TABLE
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.table = iprot.readString();
+ struct.setTableIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 4: // FILES
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.files = iprot.readString();
+ struct.setFilesIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 5: // PARTITION
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.partition = iprot.readString();
+ struct.setPartitionIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // TABLE_OBJ
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.tableObj = iprot.readString();
+ struct.setTableObjIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 7: // PARTITION_OBJ
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.partitionObj = iprot.readString();
+ struct.setPartitionObjIsSet(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, WriteEventInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldBegin(WRITE_ID_FIELD_DESC);
+ oprot.writeI64(struct.writeId);
+ oprot.writeFieldEnd();
+ if (struct.database != null) {
+ oprot.writeFieldBegin(DATABASE_FIELD_DESC);
+ oprot.writeString(struct.database);
+ oprot.writeFieldEnd();
+ }
+ if (struct.table != null) {
+ oprot.writeFieldBegin(TABLE_FIELD_DESC);
+ oprot.writeString(struct.table);
+ oprot.writeFieldEnd();
+ }
+ if (struct.files != null) {
+ oprot.writeFieldBegin(FILES_FIELD_DESC);
+ oprot.writeString(struct.files);
+ oprot.writeFieldEnd();
+ }
+ if (struct.partition != null) {
+ if (struct.isSetPartition()) {
+ oprot.writeFieldBegin(PARTITION_FIELD_DESC);
+ oprot.writeString(struct.partition);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.tableObj != null) {
+ if (struct.isSetTableObj()) {
+ oprot.writeFieldBegin(TABLE_OBJ_FIELD_DESC);
+ oprot.writeString(struct.tableObj);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.partitionObj != null) {
+ if (struct.isSetPartitionObj()) {
+ oprot.writeFieldBegin(PARTITION_OBJ_FIELD_DESC);
+ oprot.writeString(struct.partitionObj);
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class WriteEventInfoTupleSchemeFactory implements SchemeFactory {
+ public WriteEventInfoTupleScheme getScheme() {
+ return new WriteEventInfoTupleScheme();
+ }
+ }
+
+ private static class WriteEventInfoTupleScheme extends TupleScheme<WriteEventInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, WriteEventInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ oprot.writeI64(struct.writeId);
+ oprot.writeString(struct.database);
+ oprot.writeString(struct.table);
+ oprot.writeString(struct.files);
+ BitSet optionals = new BitSet();
+ if (struct.isSetPartition()) {
+ optionals.set(0);
+ }
+ if (struct.isSetTableObj()) {
+ optionals.set(1);
+ }
+ if (struct.isSetPartitionObj()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetPartition()) {
+ oprot.writeString(struct.partition);
+ }
+ if (struct.isSetTableObj()) {
+ oprot.writeString(struct.tableObj);
+ }
+ if (struct.isSetPartitionObj()) {
+ oprot.writeString(struct.partitionObj);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, WriteEventInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ struct.writeId = iprot.readI64();
+ struct.setWriteIdIsSet(true);
+ struct.database = iprot.readString();
+ struct.setDatabaseIsSet(true);
+ struct.table = iprot.readString();
+ struct.setTableIsSet(true);
+ struct.files = iprot.readString();
+ struct.setFilesIsSet(true);
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.partition = iprot.readString();
+ struct.setPartitionIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.tableObj = iprot.readString();
+ struct.setTableObjIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.partitionObj = iprot.readString();
+ struct.setPartitionObjIsSet(true);
+ }
+ }
+ }
+
+}
+