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/03 10:02:47 UTC
[08/16] 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/f519db7e/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 eda462e..4467479 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 _list848 = iprot.readListBegin();
- struct.pools = new ArrayList<WMPool>(_list848.size);
- WMPool _elem849;
- for (int _i850 = 0; _i850 < _list848.size; ++_i850)
+ org.apache.thrift.protocol.TList _list872 = iprot.readListBegin();
+ struct.pools = new ArrayList<WMPool>(_list872.size);
+ WMPool _elem873;
+ for (int _i874 = 0; _i874 < _list872.size; ++_i874)
{
- _elem849 = new WMPool();
- _elem849.read(iprot);
- struct.pools.add(_elem849);
+ _elem873 = new WMPool();
+ _elem873.read(iprot);
+ struct.pools.add(_elem873);
}
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 _list851 = iprot.readListBegin();
- struct.mappings = new ArrayList<WMMapping>(_list851.size);
- WMMapping _elem852;
- for (int _i853 = 0; _i853 < _list851.size; ++_i853)
+ org.apache.thrift.protocol.TList _list875 = iprot.readListBegin();
+ struct.mappings = new ArrayList<WMMapping>(_list875.size);
+ WMMapping _elem876;
+ for (int _i877 = 0; _i877 < _list875.size; ++_i877)
{
- _elem852 = new WMMapping();
- _elem852.read(iprot);
- struct.mappings.add(_elem852);
+ _elem876 = new WMMapping();
+ _elem876.read(iprot);
+ struct.mappings.add(_elem876);
}
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 _list854 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list854.size);
- WMTrigger _elem855;
- for (int _i856 = 0; _i856 < _list854.size; ++_i856)
+ org.apache.thrift.protocol.TList _list878 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list878.size);
+ WMTrigger _elem879;
+ for (int _i880 = 0; _i880 < _list878.size; ++_i880)
{
- _elem855 = new WMTrigger();
- _elem855.read(iprot);
- struct.triggers.add(_elem855);
+ _elem879 = new WMTrigger();
+ _elem879.read(iprot);
+ struct.triggers.add(_elem879);
}
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 _list857 = iprot.readListBegin();
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list857.size);
- WMPoolTrigger _elem858;
- for (int _i859 = 0; _i859 < _list857.size; ++_i859)
+ org.apache.thrift.protocol.TList _list881 = iprot.readListBegin();
+ struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list881.size);
+ WMPoolTrigger _elem882;
+ for (int _i883 = 0; _i883 < _list881.size; ++_i883)
{
- _elem858 = new WMPoolTrigger();
- _elem858.read(iprot);
- struct.poolTriggers.add(_elem858);
+ _elem882 = new WMPoolTrigger();
+ _elem882.read(iprot);
+ struct.poolTriggers.add(_elem882);
}
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 _iter860 : struct.pools)
+ for (WMPool _iter884 : struct.pools)
{
- _iter860.write(oprot);
+ _iter884.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 _iter861 : struct.mappings)
+ for (WMMapping _iter885 : struct.mappings)
{
- _iter861.write(oprot);
+ _iter885.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 _iter862 : struct.triggers)
+ for (WMTrigger _iter886 : struct.triggers)
{
- _iter862.write(oprot);
+ _iter886.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 _iter863 : struct.poolTriggers)
+ for (WMPoolTrigger _iter887 : struct.poolTriggers)
{
- _iter863.write(oprot);
+ _iter887.write(oprot);
}
oprot.writeListEnd();
}
@@ -920,9 +920,9 @@ import org.slf4j.LoggerFactory;
struct.plan.write(oprot);
{
oprot.writeI32(struct.pools.size());
- for (WMPool _iter864 : struct.pools)
+ for (WMPool _iter888 : struct.pools)
{
- _iter864.write(oprot);
+ _iter888.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -939,27 +939,27 @@ import org.slf4j.LoggerFactory;
if (struct.isSetMappings()) {
{
oprot.writeI32(struct.mappings.size());
- for (WMMapping _iter865 : struct.mappings)
+ for (WMMapping _iter889 : struct.mappings)
{
- _iter865.write(oprot);
+ _iter889.write(oprot);
}
}
}
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter866 : struct.triggers)
+ for (WMTrigger _iter890 : struct.triggers)
{
- _iter866.write(oprot);
+ _iter890.write(oprot);
}
}
}
if (struct.isSetPoolTriggers()) {
{
oprot.writeI32(struct.poolTriggers.size());
- for (WMPoolTrigger _iter867 : struct.poolTriggers)
+ for (WMPoolTrigger _iter891 : struct.poolTriggers)
{
- _iter867.write(oprot);
+ _iter891.write(oprot);
}
}
}
@@ -972,56 +972,56 @@ import org.slf4j.LoggerFactory;
struct.plan.read(iprot);
struct.setPlanIsSet(true);
{
- org.apache.thrift.protocol.TList _list868 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pools = new ArrayList<WMPool>(_list868.size);
- WMPool _elem869;
- for (int _i870 = 0; _i870 < _list868.size; ++_i870)
+ org.apache.thrift.protocol.TList _list892 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pools = new ArrayList<WMPool>(_list892.size);
+ WMPool _elem893;
+ for (int _i894 = 0; _i894 < _list892.size; ++_i894)
{
- _elem869 = new WMPool();
- _elem869.read(iprot);
- struct.pools.add(_elem869);
+ _elem893 = new WMPool();
+ _elem893.read(iprot);
+ struct.pools.add(_elem893);
}
}
struct.setPoolsIsSet(true);
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list871 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.mappings = new ArrayList<WMMapping>(_list871.size);
- WMMapping _elem872;
- for (int _i873 = 0; _i873 < _list871.size; ++_i873)
+ org.apache.thrift.protocol.TList _list895 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.mappings = new ArrayList<WMMapping>(_list895.size);
+ WMMapping _elem896;
+ for (int _i897 = 0; _i897 < _list895.size; ++_i897)
{
- _elem872 = new WMMapping();
- _elem872.read(iprot);
- struct.mappings.add(_elem872);
+ _elem896 = new WMMapping();
+ _elem896.read(iprot);
+ struct.mappings.add(_elem896);
}
}
struct.setMappingsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list874 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list874.size);
- WMTrigger _elem875;
- for (int _i876 = 0; _i876 < _list874.size; ++_i876)
+ org.apache.thrift.protocol.TList _list898 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list898.size);
+ WMTrigger _elem899;
+ for (int _i900 = 0; _i900 < _list898.size; ++_i900)
{
- _elem875 = new WMTrigger();
- _elem875.read(iprot);
- struct.triggers.add(_elem875);
+ _elem899 = new WMTrigger();
+ _elem899.read(iprot);
+ struct.triggers.add(_elem899);
}
}
struct.setTriggersIsSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list877 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.poolTriggers = new ArrayList<WMPoolTrigger>(_list877.size);
- WMPoolTrigger _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.poolTriggers = new ArrayList<WMPoolTrigger>(_list901.size);
+ WMPoolTrigger _elem902;
+ for (int _i903 = 0; _i903 < _list901.size; ++_i903)
{
- _elem878 = new WMPoolTrigger();
- _elem878.read(iprot);
- struct.poolTriggers.add(_elem878);
+ _elem902 = new WMPoolTrigger();
+ _elem902.read(iprot);
+ struct.poolTriggers.add(_elem902);
}
}
struct.setPoolTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/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 9bbc97b..c6cb845 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 _list880 = iprot.readListBegin();
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list880.size);
- WMResourcePlan _elem881;
- for (int _i882 = 0; _i882 < _list880.size; ++_i882)
+ org.apache.thrift.protocol.TList _list904 = iprot.readListBegin();
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list904.size);
+ WMResourcePlan _elem905;
+ for (int _i906 = 0; _i906 < _list904.size; ++_i906)
{
- _elem881 = new WMResourcePlan();
- _elem881.read(iprot);
- struct.resourcePlans.add(_elem881);
+ _elem905 = new WMResourcePlan();
+ _elem905.read(iprot);
+ struct.resourcePlans.add(_elem905);
}
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 _iter883 : struct.resourcePlans)
+ for (WMResourcePlan _iter907 : struct.resourcePlans)
{
- _iter883.write(oprot);
+ _iter907.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetResourcePlans()) {
{
oprot.writeI32(struct.resourcePlans.size());
- for (WMResourcePlan _iter884 : struct.resourcePlans)
+ for (WMResourcePlan _iter908 : struct.resourcePlans)
{
- _iter884.write(oprot);
+ _iter908.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list885 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.resourcePlans = new ArrayList<WMResourcePlan>(_list885.size);
- WMResourcePlan _elem886;
- for (int _i887 = 0; _i887 < _list885.size; ++_i887)
+ org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.resourcePlans = new ArrayList<WMResourcePlan>(_list909.size);
+ WMResourcePlan _elem910;
+ for (int _i911 = 0; _i911 < _list909.size; ++_i911)
{
- _elem886 = new WMResourcePlan();
- _elem886.read(iprot);
- struct.resourcePlans.add(_elem886);
+ _elem910 = new WMResourcePlan();
+ _elem910.read(iprot);
+ struct.resourcePlans.add(_elem910);
}
}
struct.setResourcePlansIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/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 6918953..9eed335 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 _list904 = iprot.readListBegin();
- struct.triggers = new ArrayList<WMTrigger>(_list904.size);
- WMTrigger _elem905;
- for (int _i906 = 0; _i906 < _list904.size; ++_i906)
+ org.apache.thrift.protocol.TList _list928 = iprot.readListBegin();
+ struct.triggers = new ArrayList<WMTrigger>(_list928.size);
+ WMTrigger _elem929;
+ for (int _i930 = 0; _i930 < _list928.size; ++_i930)
{
- _elem905 = new WMTrigger();
- _elem905.read(iprot);
- struct.triggers.add(_elem905);
+ _elem929 = new WMTrigger();
+ _elem929.read(iprot);
+ struct.triggers.add(_elem929);
}
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 _iter907 : struct.triggers)
+ for (WMTrigger _iter931 : struct.triggers)
{
- _iter907.write(oprot);
+ _iter931.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetTriggers()) {
{
oprot.writeI32(struct.triggers.size());
- for (WMTrigger _iter908 : struct.triggers)
+ for (WMTrigger _iter932 : struct.triggers)
{
- _iter908.write(oprot);
+ _iter932.write(oprot);
}
}
}
@@ -428,14 +428,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list909 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.triggers = new ArrayList<WMTrigger>(_list909.size);
- WMTrigger _elem910;
- for (int _i911 = 0; _i911 < _list909.size; ++_i911)
+ org.apache.thrift.protocol.TList _list933 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.triggers = new ArrayList<WMTrigger>(_list933.size);
+ WMTrigger _elem934;
+ for (int _i935 = 0; _i935 < _list933.size; ++_i935)
{
- _elem910 = new WMTrigger();
- _elem910.read(iprot);
- struct.triggers.add(_elem910);
+ _elem934 = new WMTrigger();
+ _elem934.read(iprot);
+ struct.triggers.add(_elem934);
}
}
struct.setTriggersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/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 66a478d..ee9251c 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 _list888 = iprot.readListBegin();
- struct.errors = new ArrayList<String>(_list888.size);
- String _elem889;
- for (int _i890 = 0; _i890 < _list888.size; ++_i890)
+ org.apache.thrift.protocol.TList _list912 = iprot.readListBegin();
+ struct.errors = new ArrayList<String>(_list912.size);
+ String _elem913;
+ for (int _i914 = 0; _i914 < _list912.size; ++_i914)
{
- _elem889 = iprot.readString();
- struct.errors.add(_elem889);
+ _elem913 = iprot.readString();
+ struct.errors.add(_elem913);
}
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 _list891 = iprot.readListBegin();
- struct.warnings = new ArrayList<String>(_list891.size);
- String _elem892;
- for (int _i893 = 0; _i893 < _list891.size; ++_i893)
+ org.apache.thrift.protocol.TList _list915 = iprot.readListBegin();
+ struct.warnings = new ArrayList<String>(_list915.size);
+ String _elem916;
+ for (int _i917 = 0; _i917 < _list915.size; ++_i917)
{
- _elem892 = iprot.readString();
- struct.warnings.add(_elem892);
+ _elem916 = iprot.readString();
+ struct.warnings.add(_elem916);
}
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 _iter894 : struct.errors)
+ for (String _iter918 : struct.errors)
{
- oprot.writeString(_iter894);
+ oprot.writeString(_iter918);
}
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 _iter895 : struct.warnings)
+ for (String _iter919 : struct.warnings)
{
- oprot.writeString(_iter895);
+ oprot.writeString(_iter919);
}
oprot.writeListEnd();
}
@@ -543,18 +543,18 @@ import org.slf4j.LoggerFactory;
if (struct.isSetErrors()) {
{
oprot.writeI32(struct.errors.size());
- for (String _iter896 : struct.errors)
+ for (String _iter920 : struct.errors)
{
- oprot.writeString(_iter896);
+ oprot.writeString(_iter920);
}
}
}
if (struct.isSetWarnings()) {
{
oprot.writeI32(struct.warnings.size());
- for (String _iter897 : struct.warnings)
+ for (String _iter921 : struct.warnings)
{
- oprot.writeString(_iter897);
+ oprot.writeString(_iter921);
}
}
}
@@ -566,26 +566,26 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list898 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.errors = new ArrayList<String>(_list898.size);
- String _elem899;
- for (int _i900 = 0; _i900 < _list898.size; ++_i900)
+ org.apache.thrift.protocol.TList _list922 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.errors = new ArrayList<String>(_list922.size);
+ String _elem923;
+ for (int _i924 = 0; _i924 < _list922.size; ++_i924)
{
- _elem899 = iprot.readString();
- struct.errors.add(_elem899);
+ _elem923 = iprot.readString();
+ struct.errors.add(_elem923);
}
}
struct.setErrorsIsSet(true);
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.warnings = new ArrayList<String>(_list901.size);
- String _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.STRING, iprot.readI32());
+ struct.warnings = new ArrayList<String>(_list925.size);
+ String _elem926;
+ for (int _i927 = 0; _i927 < _list925.size; ++_i927)
{
- _elem902 = iprot.readString();
- struct.warnings.add(_elem902);
+ _elem926 = iprot.readString();
+ struct.warnings.add(_elem926);
}
}
struct.setWarningsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/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);
+ }
+ }
+ }
+
+}
+