You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/23 08:03:01 UTC
[5/9] storm git commit: STORM-2016 Topology submission improvement:
support adding local jars and maven artifacts on submission
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/Credentials.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/Credentials.java b/storm-core/src/jvm/org/apache/storm/generated/Credentials.java
index 5319f76..7bd38bb 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/Credentials.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/Credentials.java
@@ -365,15 +365,15 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
case 1: // CREDS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map512 = iprot.readMapBegin();
- struct.creds = new HashMap<String,String>(2*_map512.size);
- String _key513;
- String _val514;
- for (int _i515 = 0; _i515 < _map512.size; ++_i515)
+ org.apache.thrift.protocol.TMap _map528 = iprot.readMapBegin();
+ struct.creds = new HashMap<String,String>(2*_map528.size);
+ String _key529;
+ String _val530;
+ for (int _i531 = 0; _i531 < _map528.size; ++_i531)
{
- _key513 = iprot.readString();
- _val514 = iprot.readString();
- struct.creds.put(_key513, _val514);
+ _key529 = iprot.readString();
+ _val530 = iprot.readString();
+ struct.creds.put(_key529, _val530);
}
iprot.readMapEnd();
}
@@ -399,10 +399,10 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
oprot.writeFieldBegin(CREDS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.creds.size()));
- for (Map.Entry<String, String> _iter516 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter532 : struct.creds.entrySet())
{
- oprot.writeString(_iter516.getKey());
- oprot.writeString(_iter516.getValue());
+ oprot.writeString(_iter532.getKey());
+ oprot.writeString(_iter532.getValue());
}
oprot.writeMapEnd();
}
@@ -427,10 +427,10 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.creds.size());
- for (Map.Entry<String, String> _iter517 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter533 : struct.creds.entrySet())
{
- oprot.writeString(_iter517.getKey());
- oprot.writeString(_iter517.getValue());
+ oprot.writeString(_iter533.getKey());
+ oprot.writeString(_iter533.getValue());
}
}
}
@@ -439,15 +439,15 @@ public class Credentials implements org.apache.thrift.TBase<Credentials, Credent
public void read(org.apache.thrift.protocol.TProtocol prot, Credentials struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map518 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.creds = new HashMap<String,String>(2*_map518.size);
- String _key519;
- String _val520;
- for (int _i521 = 0; _i521 < _map518.size; ++_i521)
+ org.apache.thrift.protocol.TMap _map534 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.creds = new HashMap<String,String>(2*_map534.size);
+ String _key535;
+ String _val536;
+ for (int _i537 = 0; _i537 < _map534.size; ++_i537)
{
- _key519 = iprot.readString();
- _val520 = iprot.readString();
- struct.creds.put(_key519, _val520);
+ _key535 = iprot.readString();
+ _val536 = iprot.readString();
+ struct.creds.put(_key535, _val536);
}
}
struct.set_creds_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/ExecutorStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/ExecutorStats.java b/storm-core/src/jvm/org/apache/storm/generated/ExecutorStats.java
index 14c68ed..bbb8e7a 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/ExecutorStats.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/ExecutorStats.java
@@ -660,27 +660,27 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
case 1: // EMITTED
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map276 = iprot.readMapBegin();
- struct.emitted = new HashMap<String,Map<String,Long>>(2*_map276.size);
- String _key277;
- Map<String,Long> _val278;
- for (int _i279 = 0; _i279 < _map276.size; ++_i279)
+ org.apache.thrift.protocol.TMap _map292 = iprot.readMapBegin();
+ struct.emitted = new HashMap<String,Map<String,Long>>(2*_map292.size);
+ String _key293;
+ Map<String,Long> _val294;
+ for (int _i295 = 0; _i295 < _map292.size; ++_i295)
{
- _key277 = iprot.readString();
+ _key293 = iprot.readString();
{
- org.apache.thrift.protocol.TMap _map280 = iprot.readMapBegin();
- _val278 = new HashMap<String,Long>(2*_map280.size);
- String _key281;
- long _val282;
- for (int _i283 = 0; _i283 < _map280.size; ++_i283)
+ org.apache.thrift.protocol.TMap _map296 = iprot.readMapBegin();
+ _val294 = new HashMap<String,Long>(2*_map296.size);
+ String _key297;
+ long _val298;
+ for (int _i299 = 0; _i299 < _map296.size; ++_i299)
{
- _key281 = iprot.readString();
- _val282 = iprot.readI64();
- _val278.put(_key281, _val282);
+ _key297 = iprot.readString();
+ _val298 = iprot.readI64();
+ _val294.put(_key297, _val298);
}
iprot.readMapEnd();
}
- struct.emitted.put(_key277, _val278);
+ struct.emitted.put(_key293, _val294);
}
iprot.readMapEnd();
}
@@ -692,27 +692,27 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
case 2: // TRANSFERRED
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map284 = iprot.readMapBegin();
- struct.transferred = new HashMap<String,Map<String,Long>>(2*_map284.size);
- String _key285;
- Map<String,Long> _val286;
- for (int _i287 = 0; _i287 < _map284.size; ++_i287)
+ org.apache.thrift.protocol.TMap _map300 = iprot.readMapBegin();
+ struct.transferred = new HashMap<String,Map<String,Long>>(2*_map300.size);
+ String _key301;
+ Map<String,Long> _val302;
+ for (int _i303 = 0; _i303 < _map300.size; ++_i303)
{
- _key285 = iprot.readString();
+ _key301 = iprot.readString();
{
- org.apache.thrift.protocol.TMap _map288 = iprot.readMapBegin();
- _val286 = new HashMap<String,Long>(2*_map288.size);
- String _key289;
- long _val290;
- for (int _i291 = 0; _i291 < _map288.size; ++_i291)
+ org.apache.thrift.protocol.TMap _map304 = iprot.readMapBegin();
+ _val302 = new HashMap<String,Long>(2*_map304.size);
+ String _key305;
+ long _val306;
+ for (int _i307 = 0; _i307 < _map304.size; ++_i307)
{
- _key289 = iprot.readString();
- _val290 = iprot.readI64();
- _val286.put(_key289, _val290);
+ _key305 = iprot.readString();
+ _val306 = iprot.readI64();
+ _val302.put(_key305, _val306);
}
iprot.readMapEnd();
}
- struct.transferred.put(_key285, _val286);
+ struct.transferred.put(_key301, _val302);
}
iprot.readMapEnd();
}
@@ -755,15 +755,15 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
oprot.writeFieldBegin(EMITTED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.emitted.size()));
- for (Map.Entry<String, Map<String,Long>> _iter292 : struct.emitted.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter308 : struct.emitted.entrySet())
{
- oprot.writeString(_iter292.getKey());
+ oprot.writeString(_iter308.getKey());
{
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter292.getValue().size()));
- for (Map.Entry<String, Long> _iter293 : _iter292.getValue().entrySet())
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter308.getValue().size()));
+ for (Map.Entry<String, Long> _iter309 : _iter308.getValue().entrySet())
{
- oprot.writeString(_iter293.getKey());
- oprot.writeI64(_iter293.getValue());
+ oprot.writeString(_iter309.getKey());
+ oprot.writeI64(_iter309.getValue());
}
oprot.writeMapEnd();
}
@@ -776,15 +776,15 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
oprot.writeFieldBegin(TRANSFERRED_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, struct.transferred.size()));
- for (Map.Entry<String, Map<String,Long>> _iter294 : struct.transferred.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter310 : struct.transferred.entrySet())
{
- oprot.writeString(_iter294.getKey());
+ oprot.writeString(_iter310.getKey());
{
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter294.getValue().size()));
- for (Map.Entry<String, Long> _iter295 : _iter294.getValue().entrySet())
+ oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter310.getValue().size()));
+ for (Map.Entry<String, Long> _iter311 : _iter310.getValue().entrySet())
{
- oprot.writeString(_iter295.getKey());
- oprot.writeI64(_iter295.getValue());
+ oprot.writeString(_iter311.getKey());
+ oprot.writeI64(_iter311.getValue());
}
oprot.writeMapEnd();
}
@@ -820,30 +820,30 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.emitted.size());
- for (Map.Entry<String, Map<String,Long>> _iter296 : struct.emitted.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter312 : struct.emitted.entrySet())
{
- oprot.writeString(_iter296.getKey());
+ oprot.writeString(_iter312.getKey());
{
- oprot.writeI32(_iter296.getValue().size());
- for (Map.Entry<String, Long> _iter297 : _iter296.getValue().entrySet())
+ oprot.writeI32(_iter312.getValue().size());
+ for (Map.Entry<String, Long> _iter313 : _iter312.getValue().entrySet())
{
- oprot.writeString(_iter297.getKey());
- oprot.writeI64(_iter297.getValue());
+ oprot.writeString(_iter313.getKey());
+ oprot.writeI64(_iter313.getValue());
}
}
}
}
{
oprot.writeI32(struct.transferred.size());
- for (Map.Entry<String, Map<String,Long>> _iter298 : struct.transferred.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter314 : struct.transferred.entrySet())
{
- oprot.writeString(_iter298.getKey());
+ oprot.writeString(_iter314.getKey());
{
- oprot.writeI32(_iter298.getValue().size());
- for (Map.Entry<String, Long> _iter299 : _iter298.getValue().entrySet())
+ oprot.writeI32(_iter314.getValue().size());
+ for (Map.Entry<String, Long> _iter315 : _iter314.getValue().entrySet())
{
- oprot.writeString(_iter299.getKey());
- oprot.writeI64(_iter299.getValue());
+ oprot.writeString(_iter315.getKey());
+ oprot.writeI64(_iter315.getValue());
}
}
}
@@ -856,50 +856,50 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
public void read(org.apache.thrift.protocol.TProtocol prot, ExecutorStats struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map300 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
- struct.emitted = new HashMap<String,Map<String,Long>>(2*_map300.size);
- String _key301;
- Map<String,Long> _val302;
- for (int _i303 = 0; _i303 < _map300.size; ++_i303)
+ org.apache.thrift.protocol.TMap _map316 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.emitted = new HashMap<String,Map<String,Long>>(2*_map316.size);
+ String _key317;
+ Map<String,Long> _val318;
+ for (int _i319 = 0; _i319 < _map316.size; ++_i319)
{
- _key301 = iprot.readString();
+ _key317 = iprot.readString();
{
- org.apache.thrift.protocol.TMap _map304 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- _val302 = new HashMap<String,Long>(2*_map304.size);
- String _key305;
- long _val306;
- for (int _i307 = 0; _i307 < _map304.size; ++_i307)
+ org.apache.thrift.protocol.TMap _map320 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ _val318 = new HashMap<String,Long>(2*_map320.size);
+ String _key321;
+ long _val322;
+ for (int _i323 = 0; _i323 < _map320.size; ++_i323)
{
- _key305 = iprot.readString();
- _val306 = iprot.readI64();
- _val302.put(_key305, _val306);
+ _key321 = iprot.readString();
+ _val322 = iprot.readI64();
+ _val318.put(_key321, _val322);
}
}
- struct.emitted.put(_key301, _val302);
+ struct.emitted.put(_key317, _val318);
}
}
struct.set_emitted_isSet(true);
{
- org.apache.thrift.protocol.TMap _map308 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
- struct.transferred = new HashMap<String,Map<String,Long>>(2*_map308.size);
- String _key309;
- Map<String,Long> _val310;
- for (int _i311 = 0; _i311 < _map308.size; ++_i311)
+ org.apache.thrift.protocol.TMap _map324 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.MAP, iprot.readI32());
+ struct.transferred = new HashMap<String,Map<String,Long>>(2*_map324.size);
+ String _key325;
+ Map<String,Long> _val326;
+ for (int _i327 = 0; _i327 < _map324.size; ++_i327)
{
- _key309 = iprot.readString();
+ _key325 = iprot.readString();
{
- org.apache.thrift.protocol.TMap _map312 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- _val310 = new HashMap<String,Long>(2*_map312.size);
- String _key313;
- long _val314;
- for (int _i315 = 0; _i315 < _map312.size; ++_i315)
+ org.apache.thrift.protocol.TMap _map328 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ _val326 = new HashMap<String,Long>(2*_map328.size);
+ String _key329;
+ long _val330;
+ for (int _i331 = 0; _i331 < _map328.size; ++_i331)
{
- _key313 = iprot.readString();
- _val314 = iprot.readI64();
- _val310.put(_key313, _val314);
+ _key329 = iprot.readString();
+ _val330 = iprot.readI64();
+ _val326.put(_key329, _val330);
}
}
- struct.transferred.put(_key309, _val310);
+ struct.transferred.put(_key325, _val326);
}
}
struct.set_transferred_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/HBNodes.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/HBNodes.java b/storm-core/src/jvm/org/apache/storm/generated/HBNodes.java
index 5435af2..8b9bf08 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/HBNodes.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/HBNodes.java
@@ -364,13 +364,13 @@ public class HBNodes implements org.apache.thrift.TBase<HBNodes, HBNodes._Fields
case 1: // PULSE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list764 = iprot.readListBegin();
- struct.pulseIds = new ArrayList<String>(_list764.size);
- String _elem765;
- for (int _i766 = 0; _i766 < _list764.size; ++_i766)
+ org.apache.thrift.protocol.TList _list780 = iprot.readListBegin();
+ struct.pulseIds = new ArrayList<String>(_list780.size);
+ String _elem781;
+ for (int _i782 = 0; _i782 < _list780.size; ++_i782)
{
- _elem765 = iprot.readString();
- struct.pulseIds.add(_elem765);
+ _elem781 = iprot.readString();
+ struct.pulseIds.add(_elem781);
}
iprot.readListEnd();
}
@@ -396,9 +396,9 @@ public class HBNodes implements org.apache.thrift.TBase<HBNodes, HBNodes._Fields
oprot.writeFieldBegin(PULSE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.pulseIds.size()));
- for (String _iter767 : struct.pulseIds)
+ for (String _iter783 : struct.pulseIds)
{
- oprot.writeString(_iter767);
+ oprot.writeString(_iter783);
}
oprot.writeListEnd();
}
@@ -429,9 +429,9 @@ public class HBNodes implements org.apache.thrift.TBase<HBNodes, HBNodes._Fields
if (struct.is_set_pulseIds()) {
{
oprot.writeI32(struct.pulseIds.size());
- for (String _iter768 : struct.pulseIds)
+ for (String _iter784 : struct.pulseIds)
{
- oprot.writeString(_iter768);
+ oprot.writeString(_iter784);
}
}
}
@@ -443,13 +443,13 @@ public class HBNodes implements org.apache.thrift.TBase<HBNodes, HBNodes._Fields
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list769 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.pulseIds = new ArrayList<String>(_list769.size);
- String _elem770;
- for (int _i771 = 0; _i771 < _list769.size; ++_i771)
+ org.apache.thrift.protocol.TList _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.pulseIds = new ArrayList<String>(_list785.size);
+ String _elem786;
+ for (int _i787 = 0; _i787 < _list785.size; ++_i787)
{
- _elem770 = iprot.readString();
- struct.pulseIds.add(_elem770);
+ _elem786 = iprot.readString();
+ struct.pulseIds.add(_elem786);
}
}
struct.set_pulseIds_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/HBRecords.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/HBRecords.java b/storm-core/src/jvm/org/apache/storm/generated/HBRecords.java
index d21dcc8..de7cfbf 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/HBRecords.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/HBRecords.java
@@ -367,14 +367,14 @@ public class HBRecords implements org.apache.thrift.TBase<HBRecords, HBRecords._
case 1: // PULSES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list756 = iprot.readListBegin();
- struct.pulses = new ArrayList<HBPulse>(_list756.size);
- HBPulse _elem757;
- for (int _i758 = 0; _i758 < _list756.size; ++_i758)
+ org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
+ struct.pulses = new ArrayList<HBPulse>(_list772.size);
+ HBPulse _elem773;
+ for (int _i774 = 0; _i774 < _list772.size; ++_i774)
{
- _elem757 = new HBPulse();
- _elem757.read(iprot);
- struct.pulses.add(_elem757);
+ _elem773 = new HBPulse();
+ _elem773.read(iprot);
+ struct.pulses.add(_elem773);
}
iprot.readListEnd();
}
@@ -400,9 +400,9 @@ public class HBRecords implements org.apache.thrift.TBase<HBRecords, HBRecords._
oprot.writeFieldBegin(PULSES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.pulses.size()));
- for (HBPulse _iter759 : struct.pulses)
+ for (HBPulse _iter775 : struct.pulses)
{
- _iter759.write(oprot);
+ _iter775.write(oprot);
}
oprot.writeListEnd();
}
@@ -433,9 +433,9 @@ public class HBRecords implements org.apache.thrift.TBase<HBRecords, HBRecords._
if (struct.is_set_pulses()) {
{
oprot.writeI32(struct.pulses.size());
- for (HBPulse _iter760 : struct.pulses)
+ for (HBPulse _iter776 : struct.pulses)
{
- _iter760.write(oprot);
+ _iter776.write(oprot);
}
}
}
@@ -447,14 +447,14 @@ public class HBRecords implements org.apache.thrift.TBase<HBRecords, HBRecords._
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list761 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pulses = new ArrayList<HBPulse>(_list761.size);
- HBPulse _elem762;
- for (int _i763 = 0; _i763 < _list761.size; ++_i763)
+ org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pulses = new ArrayList<HBPulse>(_list777.size);
+ HBPulse _elem778;
+ for (int _i779 = 0; _i779 < _list777.size; ++_i779)
{
- _elem762 = new HBPulse();
- _elem762.read(iprot);
- struct.pulses.add(_elem762);
+ _elem778 = new HBPulse();
+ _elem778.read(iprot);
+ struct.pulses.add(_elem778);
}
}
struct.set_pulses_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java b/storm-core/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
index 41c8a7d..ef7a589 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
@@ -365,15 +365,15 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork
case 1: // APPROVED_WORKERS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map686 = iprot.readMapBegin();
- struct.approved_workers = new HashMap<String,Integer>(2*_map686.size);
- String _key687;
- int _val688;
- for (int _i689 = 0; _i689 < _map686.size; ++_i689)
+ org.apache.thrift.protocol.TMap _map702 = iprot.readMapBegin();
+ struct.approved_workers = new HashMap<String,Integer>(2*_map702.size);
+ String _key703;
+ int _val704;
+ for (int _i705 = 0; _i705 < _map702.size; ++_i705)
{
- _key687 = iprot.readString();
- _val688 = iprot.readI32();
- struct.approved_workers.put(_key687, _val688);
+ _key703 = iprot.readString();
+ _val704 = iprot.readI32();
+ struct.approved_workers.put(_key703, _val704);
}
iprot.readMapEnd();
}
@@ -399,10 +399,10 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork
oprot.writeFieldBegin(APPROVED_WORKERS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.approved_workers.size()));
- for (Map.Entry<String, Integer> _iter690 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter706 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter690.getKey());
- oprot.writeI32(_iter690.getValue());
+ oprot.writeString(_iter706.getKey());
+ oprot.writeI32(_iter706.getValue());
}
oprot.writeMapEnd();
}
@@ -427,10 +427,10 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.approved_workers.size());
- for (Map.Entry<String, Integer> _iter691 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter707 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter691.getKey());
- oprot.writeI32(_iter691.getValue());
+ oprot.writeString(_iter707.getKey());
+ oprot.writeI32(_iter707.getValue());
}
}
}
@@ -439,15 +439,15 @@ public class LSApprovedWorkers implements org.apache.thrift.TBase<LSApprovedWork
public void read(org.apache.thrift.protocol.TProtocol prot, LSApprovedWorkers struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map692 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.approved_workers = new HashMap<String,Integer>(2*_map692.size);
- String _key693;
- int _val694;
- for (int _i695 = 0; _i695 < _map692.size; ++_i695)
+ org.apache.thrift.protocol.TMap _map708 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.approved_workers = new HashMap<String,Integer>(2*_map708.size);
+ String _key709;
+ int _val710;
+ for (int _i711 = 0; _i711 < _map708.size; ++_i711)
{
- _key693 = iprot.readString();
- _val694 = iprot.readI32();
- struct.approved_workers.put(_key693, _val694);
+ _key709 = iprot.readString();
+ _val710 = iprot.readI32();
+ struct.approved_workers.put(_key709, _val710);
}
}
struct.set_approved_workers_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java b/storm-core/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
index 682425e..a86b7f3 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
@@ -376,16 +376,16 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv
case 1: // ASSIGNMENTS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map696 = iprot.readMapBegin();
- struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map696.size);
- int _key697;
- LocalAssignment _val698;
- for (int _i699 = 0; _i699 < _map696.size; ++_i699)
+ org.apache.thrift.protocol.TMap _map712 = iprot.readMapBegin();
+ struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map712.size);
+ int _key713;
+ LocalAssignment _val714;
+ for (int _i715 = 0; _i715 < _map712.size; ++_i715)
{
- _key697 = iprot.readI32();
- _val698 = new LocalAssignment();
- _val698.read(iprot);
- struct.assignments.put(_key697, _val698);
+ _key713 = iprot.readI32();
+ _val714 = new LocalAssignment();
+ _val714.read(iprot);
+ struct.assignments.put(_key713, _val714);
}
iprot.readMapEnd();
}
@@ -411,10 +411,10 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv
oprot.writeFieldBegin(ASSIGNMENTS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, struct.assignments.size()));
- for (Map.Entry<Integer, LocalAssignment> _iter700 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter716 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter700.getKey());
- _iter700.getValue().write(oprot);
+ oprot.writeI32(_iter716.getKey());
+ _iter716.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -439,10 +439,10 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.assignments.size());
- for (Map.Entry<Integer, LocalAssignment> _iter701 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter717 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter701.getKey());
- _iter701.getValue().write(oprot);
+ oprot.writeI32(_iter717.getKey());
+ _iter717.getValue().write(oprot);
}
}
}
@@ -451,16 +451,16 @@ public class LSSupervisorAssignments implements org.apache.thrift.TBase<LSSuperv
public void read(org.apache.thrift.protocol.TProtocol prot, LSSupervisorAssignments struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map702 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map702.size);
- int _key703;
- LocalAssignment _val704;
- for (int _i705 = 0; _i705 < _map702.size; ++_i705)
+ org.apache.thrift.protocol.TMap _map718 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map718.size);
+ int _key719;
+ LocalAssignment _val720;
+ for (int _i721 = 0; _i721 < _map718.size; ++_i721)
{
- _key703 = iprot.readI32();
- _val704 = new LocalAssignment();
- _val704.read(iprot);
- struct.assignments.put(_key703, _val704);
+ _key719 = iprot.readI32();
+ _val720 = new LocalAssignment();
+ _val720.read(iprot);
+ struct.assignments.put(_key719, _val720);
}
}
struct.set_assignments_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistory.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistory.java b/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistory.java
index 68f5066..f74d582 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistory.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistory.java
@@ -656,13 +656,13 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
case 3: // USERS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list714 = iprot.readListBegin();
- struct.users = new ArrayList<String>(_list714.size);
- String _elem715;
- for (int _i716 = 0; _i716 < _list714.size; ++_i716)
+ org.apache.thrift.protocol.TList _list730 = iprot.readListBegin();
+ struct.users = new ArrayList<String>(_list730.size);
+ String _elem731;
+ for (int _i732 = 0; _i732 < _list730.size; ++_i732)
{
- _elem715 = iprot.readString();
- struct.users.add(_elem715);
+ _elem731 = iprot.readString();
+ struct.users.add(_elem731);
}
iprot.readListEnd();
}
@@ -674,13 +674,13 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
case 4: // GROUPS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list717 = iprot.readListBegin();
- struct.groups = new ArrayList<String>(_list717.size);
- String _elem718;
- for (int _i719 = 0; _i719 < _list717.size; ++_i719)
+ org.apache.thrift.protocol.TList _list733 = iprot.readListBegin();
+ struct.groups = new ArrayList<String>(_list733.size);
+ String _elem734;
+ for (int _i735 = 0; _i735 < _list733.size; ++_i735)
{
- _elem718 = iprot.readString();
- struct.groups.add(_elem718);
+ _elem734 = iprot.readString();
+ struct.groups.add(_elem734);
}
iprot.readListEnd();
}
@@ -714,9 +714,9 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
oprot.writeFieldBegin(USERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.users.size()));
- for (String _iter720 : struct.users)
+ for (String _iter736 : struct.users)
{
- oprot.writeString(_iter720);
+ oprot.writeString(_iter736);
}
oprot.writeListEnd();
}
@@ -726,9 +726,9 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
oprot.writeFieldBegin(GROUPS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.groups.size()));
- for (String _iter721 : struct.groups)
+ for (String _iter737 : struct.groups)
{
- oprot.writeString(_iter721);
+ oprot.writeString(_iter737);
}
oprot.writeListEnd();
}
@@ -755,16 +755,16 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
oprot.writeI64(struct.time_stamp);
{
oprot.writeI32(struct.users.size());
- for (String _iter722 : struct.users)
+ for (String _iter738 : struct.users)
{
- oprot.writeString(_iter722);
+ oprot.writeString(_iter738);
}
}
{
oprot.writeI32(struct.groups.size());
- for (String _iter723 : struct.groups)
+ for (String _iter739 : struct.groups)
{
- oprot.writeString(_iter723);
+ oprot.writeString(_iter739);
}
}
}
@@ -777,24 +777,24 @@ public class LSTopoHistory implements org.apache.thrift.TBase<LSTopoHistory, LST
struct.time_stamp = iprot.readI64();
struct.set_time_stamp_isSet(true);
{
- org.apache.thrift.protocol.TList _list724 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.users = new ArrayList<String>(_list724.size);
- String _elem725;
- for (int _i726 = 0; _i726 < _list724.size; ++_i726)
+ org.apache.thrift.protocol.TList _list740 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.users = new ArrayList<String>(_list740.size);
+ String _elem741;
+ for (int _i742 = 0; _i742 < _list740.size; ++_i742)
{
- _elem725 = iprot.readString();
- struct.users.add(_elem725);
+ _elem741 = iprot.readString();
+ struct.users.add(_elem741);
}
}
struct.set_users_isSet(true);
{
- org.apache.thrift.protocol.TList _list727 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.groups = new ArrayList<String>(_list727.size);
- String _elem728;
- for (int _i729 = 0; _i729 < _list727.size; ++_i729)
+ org.apache.thrift.protocol.TList _list743 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.groups = new ArrayList<String>(_list743.size);
+ String _elem744;
+ for (int _i745 = 0; _i745 < _list743.size; ++_i745)
{
- _elem728 = iprot.readString();
- struct.groups.add(_elem728);
+ _elem744 = iprot.readString();
+ struct.groups.add(_elem744);
}
}
struct.set_groups_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java b/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
index a2bf370..1f694eb 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
@@ -371,14 +371,14 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL
case 1: // TOPO_HISTORY
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list730 = iprot.readListBegin();
- struct.topo_history = new ArrayList<LSTopoHistory>(_list730.size);
- LSTopoHistory _elem731;
- for (int _i732 = 0; _i732 < _list730.size; ++_i732)
+ org.apache.thrift.protocol.TList _list746 = iprot.readListBegin();
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list746.size);
+ LSTopoHistory _elem747;
+ for (int _i748 = 0; _i748 < _list746.size; ++_i748)
{
- _elem731 = new LSTopoHistory();
- _elem731.read(iprot);
- struct.topo_history.add(_elem731);
+ _elem747 = new LSTopoHistory();
+ _elem747.read(iprot);
+ struct.topo_history.add(_elem747);
}
iprot.readListEnd();
}
@@ -404,9 +404,9 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL
oprot.writeFieldBegin(TOPO_HISTORY_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.topo_history.size()));
- for (LSTopoHistory _iter733 : struct.topo_history)
+ for (LSTopoHistory _iter749 : struct.topo_history)
{
- _iter733.write(oprot);
+ _iter749.write(oprot);
}
oprot.writeListEnd();
}
@@ -431,9 +431,9 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.topo_history.size());
- for (LSTopoHistory _iter734 : struct.topo_history)
+ for (LSTopoHistory _iter750 : struct.topo_history)
{
- _iter734.write(oprot);
+ _iter750.write(oprot);
}
}
}
@@ -442,14 +442,14 @@ public class LSTopoHistoryList implements org.apache.thrift.TBase<LSTopoHistoryL
public void read(org.apache.thrift.protocol.TProtocol prot, LSTopoHistoryList struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list735 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.topo_history = new ArrayList<LSTopoHistory>(_list735.size);
- LSTopoHistory _elem736;
- for (int _i737 = 0; _i737 < _list735.size; ++_i737)
+ org.apache.thrift.protocol.TList _list751 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list751.size);
+ LSTopoHistory _elem752;
+ for (int _i753 = 0; _i753 < _list751.size; ++_i753)
{
- _elem736 = new LSTopoHistory();
- _elem736.read(iprot);
- struct.topo_history.add(_elem736);
+ _elem752 = new LSTopoHistory();
+ _elem752.read(iprot);
+ struct.topo_history.add(_elem752);
}
}
struct.set_topo_history_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java b/storm-core/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
index 968b9cc..77d7aab 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
@@ -638,14 +638,14 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
case 3: // EXECUTORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list706 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list706.size);
- ExecutorInfo _elem707;
- for (int _i708 = 0; _i708 < _list706.size; ++_i708)
+ org.apache.thrift.protocol.TList _list722 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list722.size);
+ ExecutorInfo _elem723;
+ for (int _i724 = 0; _i724 < _list722.size; ++_i724)
{
- _elem707 = new ExecutorInfo();
- _elem707.read(iprot);
- struct.executors.add(_elem707);
+ _elem723 = new ExecutorInfo();
+ _elem723.read(iprot);
+ struct.executors.add(_elem723);
}
iprot.readListEnd();
}
@@ -687,9 +687,9 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
oprot.writeFieldBegin(EXECUTORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.executors.size()));
- for (ExecutorInfo _iter709 : struct.executors)
+ for (ExecutorInfo _iter725 : struct.executors)
{
- _iter709.write(oprot);
+ _iter725.write(oprot);
}
oprot.writeListEnd();
}
@@ -719,9 +719,9 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
oprot.writeString(struct.topology_id);
{
oprot.writeI32(struct.executors.size());
- for (ExecutorInfo _iter710 : struct.executors)
+ for (ExecutorInfo _iter726 : struct.executors)
{
- _iter710.write(oprot);
+ _iter726.write(oprot);
}
}
oprot.writeI32(struct.port);
@@ -735,14 +735,14 @@ public class LSWorkerHeartbeat implements org.apache.thrift.TBase<LSWorkerHeartb
struct.topology_id = iprot.readString();
struct.set_topology_id_isSet(true);
{
- org.apache.thrift.protocol.TList _list711 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list711.size);
- ExecutorInfo _elem712;
- for (int _i713 = 0; _i713 < _list711.size; ++_i713)
+ org.apache.thrift.protocol.TList _list727 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list727.size);
+ ExecutorInfo _elem728;
+ for (int _i729 = 0; _i729 < _list727.size; ++_i729)
{
- _elem712 = new ExecutorInfo();
- _elem712.read(iprot);
- struct.executors.add(_elem712);
+ _elem728 = new ExecutorInfo();
+ _elem728.read(iprot);
+ struct.executors.add(_elem728);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/ListBlobsResult.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/ListBlobsResult.java b/storm-core/src/jvm/org/apache/storm/generated/ListBlobsResult.java
index 43f7dc2..244beda 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/ListBlobsResult.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/ListBlobsResult.java
@@ -453,13 +453,13 @@ public class ListBlobsResult implements org.apache.thrift.TBase<ListBlobsResult,
case 1: // KEYS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list530 = iprot.readListBegin();
- struct.keys = new ArrayList<String>(_list530.size);
- String _elem531;
- for (int _i532 = 0; _i532 < _list530.size; ++_i532)
+ org.apache.thrift.protocol.TList _list546 = iprot.readListBegin();
+ struct.keys = new ArrayList<String>(_list546.size);
+ String _elem547;
+ for (int _i548 = 0; _i548 < _list546.size; ++_i548)
{
- _elem531 = iprot.readString();
- struct.keys.add(_elem531);
+ _elem547 = iprot.readString();
+ struct.keys.add(_elem547);
}
iprot.readListEnd();
}
@@ -493,9 +493,9 @@ public class ListBlobsResult implements org.apache.thrift.TBase<ListBlobsResult,
oprot.writeFieldBegin(KEYS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.keys.size()));
- for (String _iter533 : struct.keys)
+ for (String _iter549 : struct.keys)
{
- oprot.writeString(_iter533);
+ oprot.writeString(_iter549);
}
oprot.writeListEnd();
}
@@ -525,9 +525,9 @@ public class ListBlobsResult implements org.apache.thrift.TBase<ListBlobsResult,
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.keys.size());
- for (String _iter534 : struct.keys)
+ for (String _iter550 : struct.keys)
{
- oprot.writeString(_iter534);
+ oprot.writeString(_iter550);
}
}
oprot.writeString(struct.session);
@@ -537,13 +537,13 @@ public class ListBlobsResult implements org.apache.thrift.TBase<ListBlobsResult,
public void read(org.apache.thrift.protocol.TProtocol prot, ListBlobsResult struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list535 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.keys = new ArrayList<String>(_list535.size);
- String _elem536;
- for (int _i537 = 0; _i537 < _list535.size; ++_i537)
+ org.apache.thrift.protocol.TList _list551 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.keys = new ArrayList<String>(_list551.size);
+ String _elem552;
+ for (int _i553 = 0; _i553 < _list551.size; ++_i553)
{
- _elem536 = iprot.readString();
- struct.keys.add(_elem536);
+ _elem552 = iprot.readString();
+ struct.keys.add(_elem552);
}
}
struct.set_keys_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LocalAssignment.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LocalAssignment.java b/storm-core/src/jvm/org/apache/storm/generated/LocalAssignment.java
index 717014c..471e67f 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LocalAssignment.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LocalAssignment.java
@@ -549,14 +549,14 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment,
case 2: // EXECUTORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list678 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list678.size);
- ExecutorInfo _elem679;
- for (int _i680 = 0; _i680 < _list678.size; ++_i680)
+ org.apache.thrift.protocol.TList _list694 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list694.size);
+ ExecutorInfo _elem695;
+ for (int _i696 = 0; _i696 < _list694.size; ++_i696)
{
- _elem679 = new ExecutorInfo();
- _elem679.read(iprot);
- struct.executors.add(_elem679);
+ _elem695 = new ExecutorInfo();
+ _elem695.read(iprot);
+ struct.executors.add(_elem695);
}
iprot.readListEnd();
}
@@ -596,9 +596,9 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment,
oprot.writeFieldBegin(EXECUTORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.executors.size()));
- for (ExecutorInfo _iter681 : struct.executors)
+ for (ExecutorInfo _iter697 : struct.executors)
{
- _iter681.write(oprot);
+ _iter697.write(oprot);
}
oprot.writeListEnd();
}
@@ -631,9 +631,9 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment,
oprot.writeString(struct.topology_id);
{
oprot.writeI32(struct.executors.size());
- for (ExecutorInfo _iter682 : struct.executors)
+ for (ExecutorInfo _iter698 : struct.executors)
{
- _iter682.write(oprot);
+ _iter698.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -652,14 +652,14 @@ public class LocalAssignment implements org.apache.thrift.TBase<LocalAssignment,
struct.topology_id = iprot.readString();
struct.set_topology_id_isSet(true);
{
- org.apache.thrift.protocol.TList _list683 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list683.size);
- ExecutorInfo _elem684;
- for (int _i685 = 0; _i685 < _list683.size; ++_i685)
+ org.apache.thrift.protocol.TList _list699 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list699.size);
+ ExecutorInfo _elem700;
+ for (int _i701 = 0; _i701 < _list699.size; ++_i701)
{
- _elem684 = new ExecutorInfo();
- _elem684.read(iprot);
- struct.executors.add(_elem684);
+ _elem700 = new ExecutorInfo();
+ _elem700.read(iprot);
+ struct.executors.add(_elem700);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LocalStateData.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LocalStateData.java b/storm-core/src/jvm/org/apache/storm/generated/LocalStateData.java
index dd28764..0393fa9 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LocalStateData.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LocalStateData.java
@@ -376,16 +376,16 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L
case 1: // SERIALIZED_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map668 = iprot.readMapBegin();
- struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map668.size);
- String _key669;
- ThriftSerializedObject _val670;
- for (int _i671 = 0; _i671 < _map668.size; ++_i671)
+ org.apache.thrift.protocol.TMap _map684 = iprot.readMapBegin();
+ struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map684.size);
+ String _key685;
+ ThriftSerializedObject _val686;
+ for (int _i687 = 0; _i687 < _map684.size; ++_i687)
{
- _key669 = iprot.readString();
- _val670 = new ThriftSerializedObject();
- _val670.read(iprot);
- struct.serialized_parts.put(_key669, _val670);
+ _key685 = iprot.readString();
+ _val686 = new ThriftSerializedObject();
+ _val686.read(iprot);
+ struct.serialized_parts.put(_key685, _val686);
}
iprot.readMapEnd();
}
@@ -411,10 +411,10 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L
oprot.writeFieldBegin(SERIALIZED_PARTS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.serialized_parts.size()));
- for (Map.Entry<String, ThriftSerializedObject> _iter672 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter688 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter672.getKey());
- _iter672.getValue().write(oprot);
+ oprot.writeString(_iter688.getKey());
+ _iter688.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -439,10 +439,10 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.serialized_parts.size());
- for (Map.Entry<String, ThriftSerializedObject> _iter673 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter689 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter673.getKey());
- _iter673.getValue().write(oprot);
+ oprot.writeString(_iter689.getKey());
+ _iter689.getValue().write(oprot);
}
}
}
@@ -451,16 +451,16 @@ public class LocalStateData implements org.apache.thrift.TBase<LocalStateData, L
public void read(org.apache.thrift.protocol.TProtocol prot, LocalStateData struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TMap _map674 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map674.size);
- String _key675;
- ThriftSerializedObject _val676;
- for (int _i677 = 0; _i677 < _map674.size; ++_i677)
+ org.apache.thrift.protocol.TMap _map690 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map690.size);
+ String _key691;
+ ThriftSerializedObject _val692;
+ for (int _i693 = 0; _i693 < _map690.size; ++_i693)
{
- _key675 = iprot.readString();
- _val676 = new ThriftSerializedObject();
- _val676.read(iprot);
- struct.serialized_parts.put(_key675, _val676);
+ _key691 = iprot.readString();
+ _val692 = new ThriftSerializedObject();
+ _val692.read(iprot);
+ struct.serialized_parts.put(_key691, _val692);
}
}
struct.set_serialized_parts_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/LogConfig.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/LogConfig.java b/storm-core/src/jvm/org/apache/storm/generated/LogConfig.java
index 95230de..19c4f5e 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/LogConfig.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/LogConfig.java
@@ -368,16 +368,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
case 2: // NAMED_LOGGER_LEVEL
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map738 = iprot.readMapBegin();
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map738.size);
- String _key739;
- LogLevel _val740;
- for (int _i741 = 0; _i741 < _map738.size; ++_i741)
+ org.apache.thrift.protocol.TMap _map754 = iprot.readMapBegin();
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map754.size);
+ String _key755;
+ LogLevel _val756;
+ for (int _i757 = 0; _i757 < _map754.size; ++_i757)
{
- _key739 = iprot.readString();
- _val740 = new LogLevel();
- _val740.read(iprot);
- struct.named_logger_level.put(_key739, _val740);
+ _key755 = iprot.readString();
+ _val756 = new LogLevel();
+ _val756.read(iprot);
+ struct.named_logger_level.put(_key755, _val756);
}
iprot.readMapEnd();
}
@@ -404,10 +404,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
oprot.writeFieldBegin(NAMED_LOGGER_LEVEL_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.named_logger_level.size()));
- for (Map.Entry<String, LogLevel> _iter742 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter758 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter742.getKey());
- _iter742.getValue().write(oprot);
+ oprot.writeString(_iter758.getKey());
+ _iter758.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -439,10 +439,10 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
if (struct.is_set_named_logger_level()) {
{
oprot.writeI32(struct.named_logger_level.size());
- for (Map.Entry<String, LogLevel> _iter743 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter759 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter743.getKey());
- _iter743.getValue().write(oprot);
+ oprot.writeString(_iter759.getKey());
+ _iter759.getValue().write(oprot);
}
}
}
@@ -454,16 +454,16 @@ public class LogConfig implements org.apache.thrift.TBase<LogConfig, LogConfig._
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map744 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map744.size);
- String _key745;
- LogLevel _val746;
- for (int _i747 = 0; _i747 < _map744.size; ++_i747)
+ org.apache.thrift.protocol.TMap _map760 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map760.size);
+ String _key761;
+ LogLevel _val762;
+ for (int _i763 = 0; _i763 < _map760.size; ++_i763)
{
- _key745 = iprot.readString();
- _val746 = new LogLevel();
- _val746.read(iprot);
- struct.named_logger_level.put(_key745, _val746);
+ _key761 = iprot.readString();
+ _val762 = new LogLevel();
+ _val762.read(iprot);
+ struct.named_logger_level.put(_key761, _val762);
}
}
struct.set_named_logger_level_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java b/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
index c05bf6b..8feac31 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -17854,14 +17854,14 @@ public class Nimbus {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list772 = iprot.readListBegin();
- struct.success = new ArrayList<ProfileRequest>(_list772.size);
- ProfileRequest _elem773;
- for (int _i774 = 0; _i774 < _list772.size; ++_i774)
+ org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
+ struct.success = new ArrayList<ProfileRequest>(_list788.size);
+ ProfileRequest _elem789;
+ for (int _i790 = 0; _i790 < _list788.size; ++_i790)
{
- _elem773 = new ProfileRequest();
- _elem773.read(iprot);
- struct.success.add(_elem773);
+ _elem789 = new ProfileRequest();
+ _elem789.read(iprot);
+ struct.success.add(_elem789);
}
iprot.readListEnd();
}
@@ -17887,9 +17887,9 @@ public class Nimbus {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (ProfileRequest _iter775 : struct.success)
+ for (ProfileRequest _iter791 : struct.success)
{
- _iter775.write(oprot);
+ _iter791.write(oprot);
}
oprot.writeListEnd();
}
@@ -17920,9 +17920,9 @@ public class Nimbus {
if (struct.is_set_success()) {
{
oprot.writeI32(struct.success.size());
- for (ProfileRequest _iter776 : struct.success)
+ for (ProfileRequest _iter792 : struct.success)
{
- _iter776.write(oprot);
+ _iter792.write(oprot);
}
}
}
@@ -17934,14 +17934,14 @@ public class Nimbus {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<ProfileRequest>(_list777.size);
- ProfileRequest _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<ProfileRequest>(_list793.size);
+ ProfileRequest _elem794;
+ for (int _i795 = 0; _i795 < _list793.size; ++_i795)
{
- _elem778 = new ProfileRequest();
- _elem778.read(iprot);
- struct.success.add(_elem778);
+ _elem794 = new ProfileRequest();
+ _elem794.read(iprot);
+ struct.success.add(_elem794);
}
}
struct.set_success_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java b/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
index 34c5e43..4bf0196 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
@@ -461,13 +461,13 @@ public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fie
case 2: // PORT
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set574 = iprot.readSetBegin();
- struct.port = new HashSet<Long>(2*_set574.size);
- long _elem575;
- for (int _i576 = 0; _i576 < _set574.size; ++_i576)
+ org.apache.thrift.protocol.TSet _set590 = iprot.readSetBegin();
+ struct.port = new HashSet<Long>(2*_set590.size);
+ long _elem591;
+ for (int _i592 = 0; _i592 < _set590.size; ++_i592)
{
- _elem575 = iprot.readI64();
- struct.port.add(_elem575);
+ _elem591 = iprot.readI64();
+ struct.port.add(_elem591);
}
iprot.readSetEnd();
}
@@ -498,9 +498,9 @@ public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fie
oprot.writeFieldBegin(PORT_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.port.size()));
- for (long _iter577 : struct.port)
+ for (long _iter593 : struct.port)
{
- oprot.writeI64(_iter577);
+ oprot.writeI64(_iter593);
}
oprot.writeSetEnd();
}
@@ -526,9 +526,9 @@ public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fie
oprot.writeString(struct.node);
{
oprot.writeI32(struct.port.size());
- for (long _iter578 : struct.port)
+ for (long _iter594 : struct.port)
{
- oprot.writeI64(_iter578);
+ oprot.writeI64(_iter594);
}
}
}
@@ -539,13 +539,13 @@ public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fie
struct.node = iprot.readString();
struct.set_node_isSet(true);
{
- org.apache.thrift.protocol.TSet _set579 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.port = new HashSet<Long>(2*_set579.size);
- long _elem580;
- for (int _i581 = 0; _i581 < _set579.size; ++_i581)
+ org.apache.thrift.protocol.TSet _set595 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.port = new HashSet<Long>(2*_set595.size);
+ long _elem596;
+ for (int _i597 = 0; _i597 < _set595.size; ++_i597)
{
- _elem580 = iprot.readI64();
- struct.port.add(_elem580);
+ _elem596 = iprot.readI64();
+ struct.port.add(_elem596);
}
}
struct.set_port_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java b/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
index 34d4c3b..6835cb4 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
@@ -529,15 +529,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
case 3: // NUM_EXECUTORS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map502 = iprot.readMapBegin();
- struct.num_executors = new HashMap<String,Integer>(2*_map502.size);
- String _key503;
- int _val504;
- for (int _i505 = 0; _i505 < _map502.size; ++_i505)
+ org.apache.thrift.protocol.TMap _map518 = iprot.readMapBegin();
+ struct.num_executors = new HashMap<String,Integer>(2*_map518.size);
+ String _key519;
+ int _val520;
+ for (int _i521 = 0; _i521 < _map518.size; ++_i521)
{
- _key503 = iprot.readString();
- _val504 = iprot.readI32();
- struct.num_executors.put(_key503, _val504);
+ _key519 = iprot.readString();
+ _val520 = iprot.readI32();
+ struct.num_executors.put(_key519, _val520);
}
iprot.readMapEnd();
}
@@ -574,10 +574,10 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
oprot.writeFieldBegin(NUM_EXECUTORS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.num_executors.size()));
- for (Map.Entry<String, Integer> _iter506 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter522 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter506.getKey());
- oprot.writeI32(_iter506.getValue());
+ oprot.writeString(_iter522.getKey());
+ oprot.writeI32(_iter522.getValue());
}
oprot.writeMapEnd();
}
@@ -621,10 +621,10 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
if (struct.is_set_num_executors()) {
{
oprot.writeI32(struct.num_executors.size());
- for (Map.Entry<String, Integer> _iter507 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter523 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter507.getKey());
- oprot.writeI32(_iter507.getValue());
+ oprot.writeString(_iter523.getKey());
+ oprot.writeI32(_iter523.getValue());
}
}
}
@@ -644,15 +644,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map508 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.num_executors = new HashMap<String,Integer>(2*_map508.size);
- String _key509;
- int _val510;
- for (int _i511 = 0; _i511 < _map508.size; ++_i511)
+ org.apache.thrift.protocol.TMap _map524 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.num_executors = new HashMap<String,Integer>(2*_map524.size);
+ String _key525;
+ int _val526;
+ for (int _i527 = 0; _i527 < _map524.size; ++_i527)
{
- _key509 = iprot.readString();
- _val510 = iprot.readI32();
- struct.num_executors.put(_key509, _val510);
+ _key525 = iprot.readString();
+ _val526 = iprot.readI32();
+ struct.num_executors.put(_key525, _val526);
}
}
struct.set_num_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0b9a4d03/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java b/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
index 3bd9a86..5cfea0d 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
@@ -452,14 +452,14 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
case 1: // ACL
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list522 = iprot.readListBegin();
- struct.acl = new ArrayList<AccessControl>(_list522.size);
- AccessControl _elem523;
- for (int _i524 = 0; _i524 < _list522.size; ++_i524)
+ org.apache.thrift.protocol.TList _list538 = iprot.readListBegin();
+ struct.acl = new ArrayList<AccessControl>(_list538.size);
+ AccessControl _elem539;
+ for (int _i540 = 0; _i540 < _list538.size; ++_i540)
{
- _elem523 = new AccessControl();
- _elem523.read(iprot);
- struct.acl.add(_elem523);
+ _elem539 = new AccessControl();
+ _elem539.read(iprot);
+ struct.acl.add(_elem539);
}
iprot.readListEnd();
}
@@ -493,9 +493,9 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
oprot.writeFieldBegin(ACL_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.acl.size()));
- for (AccessControl _iter525 : struct.acl)
+ for (AccessControl _iter541 : struct.acl)
{
- _iter525.write(oprot);
+ _iter541.write(oprot);
}
oprot.writeListEnd();
}
@@ -525,9 +525,9 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.acl.size());
- for (AccessControl _iter526 : struct.acl)
+ for (AccessControl _iter542 : struct.acl)
{
- _iter526.write(oprot);
+ _iter542.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -544,14 +544,14 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
public void read(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list527 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.acl = new ArrayList<AccessControl>(_list527.size);
- AccessControl _elem528;
- for (int _i529 = 0; _i529 < _list527.size; ++_i529)
+ org.apache.thrift.protocol.TList _list543 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.acl = new ArrayList<AccessControl>(_list543.size);
+ AccessControl _elem544;
+ for (int _i545 = 0; _i545 < _list543.size; ++_i545)
{
- _elem528 = new AccessControl();
- _elem528.read(iprot);
- struct.acl.add(_elem528);
+ _elem544 = new AccessControl();
+ _elem544.read(iprot);
+ struct.acl.add(_elem544);
}
}
struct.set_acl_isSet(true);