You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/11/24 18:57:14 UTC
[07/16] storm git commit: add support for worker lifecycle hooks
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
index e2a538b..6152d02 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
+++ b/storm-core/src/jvm/backtype/storm/generated/ComponentPageInfo.java
@@ -1657,16 +1657,16 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
case 7: // WINDOW_TO_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map414 = iprot.readMapBegin();
- struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map414.size);
- String _key415;
- ComponentAggregateStats _val416;
- for (int _i417 = 0; _i417 < _map414.size; ++_i417)
+ org.apache.thrift.protocol.TMap _map422 = iprot.readMapBegin();
+ struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map422.size);
+ String _key423;
+ ComponentAggregateStats _val424;
+ for (int _i425 = 0; _i425 < _map422.size; ++_i425)
{
- _key415 = iprot.readString();
- _val416 = new ComponentAggregateStats();
- _val416.read(iprot);
- struct.window_to_stats.put(_key415, _val416);
+ _key423 = iprot.readString();
+ _val424 = new ComponentAggregateStats();
+ _val424.read(iprot);
+ struct.window_to_stats.put(_key423, _val424);
}
iprot.readMapEnd();
}
@@ -1678,17 +1678,17 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
case 8: // GSID_TO_INPUT_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map418 = iprot.readMapBegin();
- struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map418.size);
- GlobalStreamId _key419;
- ComponentAggregateStats _val420;
- for (int _i421 = 0; _i421 < _map418.size; ++_i421)
+ org.apache.thrift.protocol.TMap _map426 = iprot.readMapBegin();
+ struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map426.size);
+ GlobalStreamId _key427;
+ ComponentAggregateStats _val428;
+ for (int _i429 = 0; _i429 < _map426.size; ++_i429)
{
- _key419 = new GlobalStreamId();
- _key419.read(iprot);
- _val420 = new ComponentAggregateStats();
- _val420.read(iprot);
- struct.gsid_to_input_stats.put(_key419, _val420);
+ _key427 = new GlobalStreamId();
+ _key427.read(iprot);
+ _val428 = new ComponentAggregateStats();
+ _val428.read(iprot);
+ struct.gsid_to_input_stats.put(_key427, _val428);
}
iprot.readMapEnd();
}
@@ -1700,16 +1700,16 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
case 9: // SID_TO_OUTPUT_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map422 = iprot.readMapBegin();
- struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map422.size);
- String _key423;
- ComponentAggregateStats _val424;
- for (int _i425 = 0; _i425 < _map422.size; ++_i425)
+ org.apache.thrift.protocol.TMap _map430 = iprot.readMapBegin();
+ struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map430.size);
+ String _key431;
+ ComponentAggregateStats _val432;
+ for (int _i433 = 0; _i433 < _map430.size; ++_i433)
{
- _key423 = iprot.readString();
- _val424 = new ComponentAggregateStats();
- _val424.read(iprot);
- struct.sid_to_output_stats.put(_key423, _val424);
+ _key431 = iprot.readString();
+ _val432 = new ComponentAggregateStats();
+ _val432.read(iprot);
+ struct.sid_to_output_stats.put(_key431, _val432);
}
iprot.readMapEnd();
}
@@ -1721,14 +1721,14 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
case 10: // EXEC_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list426 = iprot.readListBegin();
- struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list426.size);
- ExecutorAggregateStats _elem427;
- for (int _i428 = 0; _i428 < _list426.size; ++_i428)
+ org.apache.thrift.protocol.TList _list434 = iprot.readListBegin();
+ struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list434.size);
+ ExecutorAggregateStats _elem435;
+ for (int _i436 = 0; _i436 < _list434.size; ++_i436)
{
- _elem427 = new ExecutorAggregateStats();
- _elem427.read(iprot);
- struct.exec_stats.add(_elem427);
+ _elem435 = new ExecutorAggregateStats();
+ _elem435.read(iprot);
+ struct.exec_stats.add(_elem435);
}
iprot.readListEnd();
}
@@ -1740,14 +1740,14 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
case 11: // ERRORS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list429 = iprot.readListBegin();
- struct.errors = new ArrayList<ErrorInfo>(_list429.size);
- ErrorInfo _elem430;
- for (int _i431 = 0; _i431 < _list429.size; ++_i431)
+ org.apache.thrift.protocol.TList _list437 = iprot.readListBegin();
+ struct.errors = new ArrayList<ErrorInfo>(_list437.size);
+ ErrorInfo _elem438;
+ for (int _i439 = 0; _i439 < _list437.size; ++_i439)
{
- _elem430 = new ErrorInfo();
- _elem430.read(iprot);
- struct.errors.add(_elem430);
+ _elem438 = new ErrorInfo();
+ _elem438.read(iprot);
+ struct.errors.add(_elem438);
}
iprot.readListEnd();
}
@@ -1841,10 +1841,10 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
oprot.writeFieldBegin(WINDOW_TO_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.window_to_stats.size()));
- for (Map.Entry<String, ComponentAggregateStats> _iter432 : struct.window_to_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter440 : struct.window_to_stats.entrySet())
{
- oprot.writeString(_iter432.getKey());
- _iter432.getValue().write(oprot);
+ oprot.writeString(_iter440.getKey());
+ _iter440.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -1856,10 +1856,10 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
oprot.writeFieldBegin(GSID_TO_INPUT_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, struct.gsid_to_input_stats.size()));
- for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter433 : struct.gsid_to_input_stats.entrySet())
+ for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter441 : struct.gsid_to_input_stats.entrySet())
{
- _iter433.getKey().write(oprot);
- _iter433.getValue().write(oprot);
+ _iter441.getKey().write(oprot);
+ _iter441.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -1871,10 +1871,10 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
oprot.writeFieldBegin(SID_TO_OUTPUT_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.sid_to_output_stats.size()));
- for (Map.Entry<String, ComponentAggregateStats> _iter434 : struct.sid_to_output_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter442 : struct.sid_to_output_stats.entrySet())
{
- oprot.writeString(_iter434.getKey());
- _iter434.getValue().write(oprot);
+ oprot.writeString(_iter442.getKey());
+ _iter442.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -1886,9 +1886,9 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
oprot.writeFieldBegin(EXEC_STATS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.exec_stats.size()));
- for (ExecutorAggregateStats _iter435 : struct.exec_stats)
+ for (ExecutorAggregateStats _iter443 : struct.exec_stats)
{
- _iter435.write(oprot);
+ _iter443.write(oprot);
}
oprot.writeListEnd();
}
@@ -1900,9 +1900,9 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
oprot.writeFieldBegin(ERRORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.errors.size()));
- for (ErrorInfo _iter436 : struct.errors)
+ for (ErrorInfo _iter444 : struct.errors)
{
- _iter436.write(oprot);
+ _iter444.write(oprot);
}
oprot.writeListEnd();
}
@@ -2010,48 +2010,48 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
if (struct.is_set_window_to_stats()) {
{
oprot.writeI32(struct.window_to_stats.size());
- for (Map.Entry<String, ComponentAggregateStats> _iter437 : struct.window_to_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter445 : struct.window_to_stats.entrySet())
{
- oprot.writeString(_iter437.getKey());
- _iter437.getValue().write(oprot);
+ oprot.writeString(_iter445.getKey());
+ _iter445.getValue().write(oprot);
}
}
}
if (struct.is_set_gsid_to_input_stats()) {
{
oprot.writeI32(struct.gsid_to_input_stats.size());
- for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter438 : struct.gsid_to_input_stats.entrySet())
+ for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter446 : struct.gsid_to_input_stats.entrySet())
{
- _iter438.getKey().write(oprot);
- _iter438.getValue().write(oprot);
+ _iter446.getKey().write(oprot);
+ _iter446.getValue().write(oprot);
}
}
}
if (struct.is_set_sid_to_output_stats()) {
{
oprot.writeI32(struct.sid_to_output_stats.size());
- for (Map.Entry<String, ComponentAggregateStats> _iter439 : struct.sid_to_output_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter447 : struct.sid_to_output_stats.entrySet())
{
- oprot.writeString(_iter439.getKey());
- _iter439.getValue().write(oprot);
+ oprot.writeString(_iter447.getKey());
+ _iter447.getValue().write(oprot);
}
}
}
if (struct.is_set_exec_stats()) {
{
oprot.writeI32(struct.exec_stats.size());
- for (ExecutorAggregateStats _iter440 : struct.exec_stats)
+ for (ExecutorAggregateStats _iter448 : struct.exec_stats)
{
- _iter440.write(oprot);
+ _iter448.write(oprot);
}
}
}
if (struct.is_set_errors()) {
{
oprot.writeI32(struct.errors.size());
- for (ErrorInfo _iter441 : struct.errors)
+ for (ErrorInfo _iter449 : struct.errors)
{
- _iter441.write(oprot);
+ _iter449.write(oprot);
}
}
}
@@ -2095,77 +2095,77 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI
}
if (incoming.get(4)) {
{
- org.apache.thrift.protocol.TMap _map442 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map442.size);
- String _key443;
- ComponentAggregateStats _val444;
- for (int _i445 = 0; _i445 < _map442.size; ++_i445)
+ org.apache.thrift.protocol.TMap _map450 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map450.size);
+ String _key451;
+ ComponentAggregateStats _val452;
+ for (int _i453 = 0; _i453 < _map450.size; ++_i453)
{
- _key443 = iprot.readString();
- _val444 = new ComponentAggregateStats();
- _val444.read(iprot);
- struct.window_to_stats.put(_key443, _val444);
+ _key451 = iprot.readString();
+ _val452 = new ComponentAggregateStats();
+ _val452.read(iprot);
+ struct.window_to_stats.put(_key451, _val452);
}
}
struct.set_window_to_stats_isSet(true);
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TMap _map446 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map446.size);
- GlobalStreamId _key447;
- ComponentAggregateStats _val448;
- for (int _i449 = 0; _i449 < _map446.size; ++_i449)
+ org.apache.thrift.protocol.TMap _map454 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRUCT, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map454.size);
+ GlobalStreamId _key455;
+ ComponentAggregateStats _val456;
+ for (int _i457 = 0; _i457 < _map454.size; ++_i457)
{
- _key447 = new GlobalStreamId();
- _key447.read(iprot);
- _val448 = new ComponentAggregateStats();
- _val448.read(iprot);
- struct.gsid_to_input_stats.put(_key447, _val448);
+ _key455 = new GlobalStreamId();
+ _key455.read(iprot);
+ _val456 = new ComponentAggregateStats();
+ _val456.read(iprot);
+ struct.gsid_to_input_stats.put(_key455, _val456);
}
}
struct.set_gsid_to_input_stats_isSet(true);
}
if (incoming.get(6)) {
{
- org.apache.thrift.protocol.TMap _map450 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map450.size);
- String _key451;
- ComponentAggregateStats _val452;
- for (int _i453 = 0; _i453 < _map450.size; ++_i453)
+ org.apache.thrift.protocol.TMap _map458 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map458.size);
+ String _key459;
+ ComponentAggregateStats _val460;
+ for (int _i461 = 0; _i461 < _map458.size; ++_i461)
{
- _key451 = iprot.readString();
- _val452 = new ComponentAggregateStats();
- _val452.read(iprot);
- struct.sid_to_output_stats.put(_key451, _val452);
+ _key459 = iprot.readString();
+ _val460 = new ComponentAggregateStats();
+ _val460.read(iprot);
+ struct.sid_to_output_stats.put(_key459, _val460);
}
}
struct.set_sid_to_output_stats_isSet(true);
}
if (incoming.get(7)) {
{
- org.apache.thrift.protocol.TList _list454 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list454.size);
- ExecutorAggregateStats _elem455;
- for (int _i456 = 0; _i456 < _list454.size; ++_i456)
+ org.apache.thrift.protocol.TList _list462 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list462.size);
+ ExecutorAggregateStats _elem463;
+ for (int _i464 = 0; _i464 < _list462.size; ++_i464)
{
- _elem455 = new ExecutorAggregateStats();
- _elem455.read(iprot);
- struct.exec_stats.add(_elem455);
+ _elem463 = new ExecutorAggregateStats();
+ _elem463.read(iprot);
+ struct.exec_stats.add(_elem463);
}
}
struct.set_exec_stats_isSet(true);
}
if (incoming.get(8)) {
{
- org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.errors = new ArrayList<ErrorInfo>(_list457.size);
- ErrorInfo _elem458;
- for (int _i459 = 0; _i459 < _list457.size; ++_i459)
+ org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.errors = new ArrayList<ErrorInfo>(_list465.size);
+ ErrorInfo _elem466;
+ for (int _i467 = 0; _i467 < _list465.size; ++_i467)
{
- _elem458 = new ErrorInfo();
- _elem458.read(iprot);
- struct.errors.add(_elem458);
+ _elem466 = new ErrorInfo();
+ _elem466.read(iprot);
+ struct.errors.add(_elem466);
}
}
struct.set_errors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/Credentials.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Credentials.java b/storm-core/src/jvm/backtype/storm/generated/Credentials.java
index 1f8f00c..75cc5b6 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Credentials.java
+++ b/storm-core/src/jvm/backtype/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 _map470 = iprot.readMapBegin();
- struct.creds = new HashMap<String,String>(2*_map470.size);
- String _key471;
- String _val472;
- for (int _i473 = 0; _i473 < _map470.size; ++_i473)
+ org.apache.thrift.protocol.TMap _map478 = iprot.readMapBegin();
+ struct.creds = new HashMap<String,String>(2*_map478.size);
+ String _key479;
+ String _val480;
+ for (int _i481 = 0; _i481 < _map478.size; ++_i481)
{
- _key471 = iprot.readString();
- _val472 = iprot.readString();
- struct.creds.put(_key471, _val472);
+ _key479 = iprot.readString();
+ _val480 = iprot.readString();
+ struct.creds.put(_key479, _val480);
}
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> _iter474 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter482 : struct.creds.entrySet())
{
- oprot.writeString(_iter474.getKey());
- oprot.writeString(_iter474.getValue());
+ oprot.writeString(_iter482.getKey());
+ oprot.writeString(_iter482.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> _iter475 : struct.creds.entrySet())
+ for (Map.Entry<String, String> _iter483 : struct.creds.entrySet())
{
- oprot.writeString(_iter475.getKey());
- oprot.writeString(_iter475.getValue());
+ oprot.writeString(_iter483.getKey());
+ oprot.writeString(_iter483.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 _map476 = 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*_map476.size);
- String _key477;
- String _val478;
- for (int _i479 = 0; _i479 < _map476.size; ++_i479)
+ org.apache.thrift.protocol.TMap _map484 = 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*_map484.size);
+ String _key485;
+ String _val486;
+ for (int _i487 = 0; _i487 < _map484.size; ++_i487)
{
- _key477 = iprot.readString();
- _val478 = iprot.readString();
- struct.creds.put(_key477, _val478);
+ _key485 = iprot.readString();
+ _val486 = iprot.readString();
+ struct.creds.put(_key485, _val486);
}
}
struct.set_creds_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java b/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
index ec6cad4..8a2a796 100644
--- a/storm-core/src/jvm/backtype/storm/generated/ExecutorStats.java
+++ b/storm-core/src/jvm/backtype/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 _map268 = iprot.readMapBegin();
- struct.emitted = new HashMap<String,Map<String,Long>>(2*_map268.size);
- String _key269;
- Map<String,Long> _val270;
- for (int _i271 = 0; _i271 < _map268.size; ++_i271)
+ 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)
{
- _key269 = iprot.readString();
+ _key277 = iprot.readString();
{
- org.apache.thrift.protocol.TMap _map272 = iprot.readMapBegin();
- _val270 = new HashMap<String,Long>(2*_map272.size);
- String _key273;
- long _val274;
- for (int _i275 = 0; _i275 < _map272.size; ++_i275)
+ 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)
{
- _key273 = iprot.readString();
- _val274 = iprot.readI64();
- _val270.put(_key273, _val274);
+ _key281 = iprot.readString();
+ _val282 = iprot.readI64();
+ _val278.put(_key281, _val282);
}
iprot.readMapEnd();
}
- struct.emitted.put(_key269, _val270);
+ struct.emitted.put(_key277, _val278);
}
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 _map276 = iprot.readMapBegin();
- struct.transferred = 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 _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)
{
- _key277 = iprot.readString();
+ _key285 = 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 _map288 = iprot.readMapBegin();
+ _val286 = new HashMap<String,Long>(2*_map288.size);
+ String _key289;
+ long _val290;
+ for (int _i291 = 0; _i291 < _map288.size; ++_i291)
{
- _key281 = iprot.readString();
- _val282 = iprot.readI64();
- _val278.put(_key281, _val282);
+ _key289 = iprot.readString();
+ _val290 = iprot.readI64();
+ _val286.put(_key289, _val290);
}
iprot.readMapEnd();
}
- struct.transferred.put(_key277, _val278);
+ struct.transferred.put(_key285, _val286);
}
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>> _iter284 : struct.emitted.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter292 : struct.emitted.entrySet())
{
- oprot.writeString(_iter284.getKey());
+ oprot.writeString(_iter292.getKey());
{
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter284.getValue().size()));
- for (Map.Entry<String, Long> _iter285 : _iter284.getValue().entrySet())
+ 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.writeString(_iter285.getKey());
- oprot.writeI64(_iter285.getValue());
+ oprot.writeString(_iter293.getKey());
+ oprot.writeI64(_iter293.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>> _iter286 : struct.transferred.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter294 : struct.transferred.entrySet())
{
- oprot.writeString(_iter286.getKey());
+ oprot.writeString(_iter294.getKey());
{
- oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, _iter286.getValue().size()));
- for (Map.Entry<String, Long> _iter287 : _iter286.getValue().entrySet())
+ 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.writeString(_iter287.getKey());
- oprot.writeI64(_iter287.getValue());
+ oprot.writeString(_iter295.getKey());
+ oprot.writeI64(_iter295.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>> _iter288 : struct.emitted.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter296 : struct.emitted.entrySet())
{
- oprot.writeString(_iter288.getKey());
+ oprot.writeString(_iter296.getKey());
{
- oprot.writeI32(_iter288.getValue().size());
- for (Map.Entry<String, Long> _iter289 : _iter288.getValue().entrySet())
+ oprot.writeI32(_iter296.getValue().size());
+ for (Map.Entry<String, Long> _iter297 : _iter296.getValue().entrySet())
{
- oprot.writeString(_iter289.getKey());
- oprot.writeI64(_iter289.getValue());
+ oprot.writeString(_iter297.getKey());
+ oprot.writeI64(_iter297.getValue());
}
}
}
}
{
oprot.writeI32(struct.transferred.size());
- for (Map.Entry<String, Map<String,Long>> _iter290 : struct.transferred.entrySet())
+ for (Map.Entry<String, Map<String,Long>> _iter298 : struct.transferred.entrySet())
{
- oprot.writeString(_iter290.getKey());
+ oprot.writeString(_iter298.getKey());
{
- oprot.writeI32(_iter290.getValue().size());
- for (Map.Entry<String, Long> _iter291 : _iter290.getValue().entrySet())
+ oprot.writeI32(_iter298.getValue().size());
+ for (Map.Entry<String, Long> _iter299 : _iter298.getValue().entrySet())
{
- oprot.writeString(_iter291.getKey());
- oprot.writeI64(_iter291.getValue());
+ oprot.writeString(_iter299.getKey());
+ oprot.writeI64(_iter299.getValue());
}
}
}
@@ -856,32 +856,8 @@ 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 _map292 = 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*_map292.size);
- String _key293;
- Map<String,Long> _val294;
- for (int _i295 = 0; _i295 < _map292.size; ++_i295)
- {
- _key293 = iprot.readString();
- {
- org.apache.thrift.protocol.TMap _map296 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I64, iprot.readI32());
- _val294 = new HashMap<String,Long>(2*_map296.size);
- String _key297;
- long _val298;
- for (int _i299 = 0; _i299 < _map296.size; ++_i299)
- {
- _key297 = iprot.readString();
- _val298 = iprot.readI64();
- _val294.put(_key297, _val298);
- }
- }
- struct.emitted.put(_key293, _val294);
- }
- }
- struct.set_emitted_isSet(true);
- {
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.transferred = new HashMap<String,Map<String,Long>>(2*_map300.size);
+ 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)
@@ -899,7 +875,31 @@ public class ExecutorStats implements org.apache.thrift.TBase<ExecutorStats, Exe
_val302.put(_key305, _val306);
}
}
- struct.transferred.put(_key301, _val302);
+ struct.emitted.put(_key301, _val302);
+ }
+ }
+ 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)
+ {
+ _key309 = 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)
+ {
+ _key313 = iprot.readString();
+ _val314 = iprot.readI64();
+ _val310.put(_key313, _val314);
+ }
+ }
+ struct.transferred.put(_key309, _val310);
}
}
struct.set_transferred_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java b/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
index bf801bc..20f0d10 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSApprovedWorkers.java
+++ b/storm-core/src/jvm/backtype/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 _map628 = iprot.readMapBegin();
- struct.approved_workers = new HashMap<String,Integer>(2*_map628.size);
- String _key629;
- int _val630;
- for (int _i631 = 0; _i631 < _map628.size; ++_i631)
+ org.apache.thrift.protocol.TMap _map636 = iprot.readMapBegin();
+ struct.approved_workers = new HashMap<String,Integer>(2*_map636.size);
+ String _key637;
+ int _val638;
+ for (int _i639 = 0; _i639 < _map636.size; ++_i639)
{
- _key629 = iprot.readString();
- _val630 = iprot.readI32();
- struct.approved_workers.put(_key629, _val630);
+ _key637 = iprot.readString();
+ _val638 = iprot.readI32();
+ struct.approved_workers.put(_key637, _val638);
}
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> _iter632 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter640 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter632.getKey());
- oprot.writeI32(_iter632.getValue());
+ oprot.writeString(_iter640.getKey());
+ oprot.writeI32(_iter640.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> _iter633 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter641 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter633.getKey());
- oprot.writeI32(_iter633.getValue());
+ oprot.writeString(_iter641.getKey());
+ oprot.writeI32(_iter641.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 _map634 = 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*_map634.size);
- String _key635;
- int _val636;
- for (int _i637 = 0; _i637 < _map634.size; ++_i637)
+ org.apache.thrift.protocol.TMap _map642 = 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*_map642.size);
+ String _key643;
+ int _val644;
+ for (int _i645 = 0; _i645 < _map642.size; ++_i645)
{
- _key635 = iprot.readString();
- _val636 = iprot.readI32();
- struct.approved_workers.put(_key635, _val636);
+ _key643 = iprot.readString();
+ _val644 = iprot.readI32();
+ struct.approved_workers.put(_key643, _val644);
}
}
struct.set_approved_workers_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java b/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
index 1ee0e6c..de4c803 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSSupervisorAssignments.java
+++ b/storm-core/src/jvm/backtype/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 _map638 = iprot.readMapBegin();
- struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map638.size);
- int _key639;
- LocalAssignment _val640;
- for (int _i641 = 0; _i641 < _map638.size; ++_i641)
+ org.apache.thrift.protocol.TMap _map646 = iprot.readMapBegin();
+ struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map646.size);
+ int _key647;
+ LocalAssignment _val648;
+ for (int _i649 = 0; _i649 < _map646.size; ++_i649)
{
- _key639 = iprot.readI32();
- _val640 = new LocalAssignment();
- _val640.read(iprot);
- struct.assignments.put(_key639, _val640);
+ _key647 = iprot.readI32();
+ _val648 = new LocalAssignment();
+ _val648.read(iprot);
+ struct.assignments.put(_key647, _val648);
}
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> _iter642 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter650 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter642.getKey());
- _iter642.getValue().write(oprot);
+ oprot.writeI32(_iter650.getKey());
+ _iter650.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> _iter643 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter651 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter643.getKey());
- _iter643.getValue().write(oprot);
+ oprot.writeI32(_iter651.getKey());
+ _iter651.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 _map644 = 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*_map644.size);
- int _key645;
- LocalAssignment _val646;
- for (int _i647 = 0; _i647 < _map644.size; ++_i647)
+ org.apache.thrift.protocol.TMap _map652 = 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*_map652.size);
+ int _key653;
+ LocalAssignment _val654;
+ for (int _i655 = 0; _i655 < _map652.size; ++_i655)
{
- _key645 = iprot.readI32();
- _val646 = new LocalAssignment();
- _val646.read(iprot);
- struct.assignments.put(_key645, _val646);
+ _key653 = iprot.readI32();
+ _val654 = new LocalAssignment();
+ _val654.read(iprot);
+ struct.assignments.put(_key653, _val654);
}
}
struct.set_assignments_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
index cb890b4..79fea1e 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistory.java
+++ b/storm-core/src/jvm/backtype/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 _list656 = iprot.readListBegin();
- struct.users = new ArrayList<String>(_list656.size);
- String _elem657;
- for (int _i658 = 0; _i658 < _list656.size; ++_i658)
+ org.apache.thrift.protocol.TList _list664 = iprot.readListBegin();
+ struct.users = new ArrayList<String>(_list664.size);
+ String _elem665;
+ for (int _i666 = 0; _i666 < _list664.size; ++_i666)
{
- _elem657 = iprot.readString();
- struct.users.add(_elem657);
+ _elem665 = iprot.readString();
+ struct.users.add(_elem665);
}
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 _list659 = iprot.readListBegin();
- struct.groups = new ArrayList<String>(_list659.size);
- String _elem660;
- for (int _i661 = 0; _i661 < _list659.size; ++_i661)
+ org.apache.thrift.protocol.TList _list667 = iprot.readListBegin();
+ struct.groups = new ArrayList<String>(_list667.size);
+ String _elem668;
+ for (int _i669 = 0; _i669 < _list667.size; ++_i669)
{
- _elem660 = iprot.readString();
- struct.groups.add(_elem660);
+ _elem668 = iprot.readString();
+ struct.groups.add(_elem668);
}
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 _iter662 : struct.users)
+ for (String _iter670 : struct.users)
{
- oprot.writeString(_iter662);
+ oprot.writeString(_iter670);
}
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 _iter663 : struct.groups)
+ for (String _iter671 : struct.groups)
{
- oprot.writeString(_iter663);
+ oprot.writeString(_iter671);
}
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 _iter664 : struct.users)
+ for (String _iter672 : struct.users)
{
- oprot.writeString(_iter664);
+ oprot.writeString(_iter672);
}
}
{
oprot.writeI32(struct.groups.size());
- for (String _iter665 : struct.groups)
+ for (String _iter673 : struct.groups)
{
- oprot.writeString(_iter665);
+ oprot.writeString(_iter673);
}
}
}
@@ -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 _list666 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.users = new ArrayList<String>(_list666.size);
- String _elem667;
- for (int _i668 = 0; _i668 < _list666.size; ++_i668)
+ org.apache.thrift.protocol.TList _list674 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.users = new ArrayList<String>(_list674.size);
+ String _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem667 = iprot.readString();
- struct.users.add(_elem667);
+ _elem675 = iprot.readString();
+ struct.users.add(_elem675);
}
}
struct.set_users_isSet(true);
{
- org.apache.thrift.protocol.TList _list669 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.groups = new ArrayList<String>(_list669.size);
- String _elem670;
- for (int _i671 = 0; _i671 < _list669.size; ++_i671)
+ org.apache.thrift.protocol.TList _list677 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.groups = new ArrayList<String>(_list677.size);
+ String _elem678;
+ for (int _i679 = 0; _i679 < _list677.size; ++_i679)
{
- _elem670 = iprot.readString();
- struct.groups.add(_elem670);
+ _elem678 = iprot.readString();
+ struct.groups.add(_elem678);
}
}
struct.set_groups_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java b/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
index ffb1d9e..962ece6 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSTopoHistoryList.java
+++ b/storm-core/src/jvm/backtype/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 _list672 = iprot.readListBegin();
- struct.topo_history = new ArrayList<LSTopoHistory>(_list672.size);
- LSTopoHistory _elem673;
- for (int _i674 = 0; _i674 < _list672.size; ++_i674)
+ org.apache.thrift.protocol.TList _list680 = iprot.readListBegin();
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list680.size);
+ LSTopoHistory _elem681;
+ for (int _i682 = 0; _i682 < _list680.size; ++_i682)
{
- _elem673 = new LSTopoHistory();
- _elem673.read(iprot);
- struct.topo_history.add(_elem673);
+ _elem681 = new LSTopoHistory();
+ _elem681.read(iprot);
+ struct.topo_history.add(_elem681);
}
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 _iter675 : struct.topo_history)
+ for (LSTopoHistory _iter683 : struct.topo_history)
{
- _iter675.write(oprot);
+ _iter683.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 _iter676 : struct.topo_history)
+ for (LSTopoHistory _iter684 : struct.topo_history)
{
- _iter676.write(oprot);
+ _iter684.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 _list677 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.topo_history = new ArrayList<LSTopoHistory>(_list677.size);
- LSTopoHistory _elem678;
- for (int _i679 = 0; _i679 < _list677.size; ++_i679)
+ org.apache.thrift.protocol.TList _list685 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list685.size);
+ LSTopoHistory _elem686;
+ for (int _i687 = 0; _i687 < _list685.size; ++_i687)
{
- _elem678 = new LSTopoHistory();
- _elem678.read(iprot);
- struct.topo_history.add(_elem678);
+ _elem686 = new LSTopoHistory();
+ _elem686.read(iprot);
+ struct.topo_history.add(_elem686);
}
}
struct.set_topo_history_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java b/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
index 0f123f1..d6e7c36 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LSWorkerHeartbeat.java
+++ b/storm-core/src/jvm/backtype/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 _list648 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list648.size);
- ExecutorInfo _elem649;
- for (int _i650 = 0; _i650 < _list648.size; ++_i650)
+ org.apache.thrift.protocol.TList _list656 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list656.size);
+ ExecutorInfo _elem657;
+ for (int _i658 = 0; _i658 < _list656.size; ++_i658)
{
- _elem649 = new ExecutorInfo();
- _elem649.read(iprot);
- struct.executors.add(_elem649);
+ _elem657 = new ExecutorInfo();
+ _elem657.read(iprot);
+ struct.executors.add(_elem657);
}
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 _iter651 : struct.executors)
+ for (ExecutorInfo _iter659 : struct.executors)
{
- _iter651.write(oprot);
+ _iter659.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 _iter652 : struct.executors)
+ for (ExecutorInfo _iter660 : struct.executors)
{
- _iter652.write(oprot);
+ _iter660.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 _list653 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list653.size);
- ExecutorInfo _elem654;
- for (int _i655 = 0; _i655 < _list653.size; ++_i655)
+ org.apache.thrift.protocol.TList _list661 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list661.size);
+ ExecutorInfo _elem662;
+ for (int _i663 = 0; _i663 < _list661.size; ++_i663)
{
- _elem654 = new ExecutorInfo();
- _elem654.read(iprot);
- struct.executors.add(_elem654);
+ _elem662 = new ExecutorInfo();
+ _elem662.read(iprot);
+ struct.executors.add(_elem662);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java b/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
index abfb4a4..a36e654 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LocalAssignment.java
+++ b/storm-core/src/jvm/backtype/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 _list620 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list620.size);
- ExecutorInfo _elem621;
- for (int _i622 = 0; _i622 < _list620.size; ++_i622)
+ org.apache.thrift.protocol.TList _list628 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list628.size);
+ ExecutorInfo _elem629;
+ for (int _i630 = 0; _i630 < _list628.size; ++_i630)
{
- _elem621 = new ExecutorInfo();
- _elem621.read(iprot);
- struct.executors.add(_elem621);
+ _elem629 = new ExecutorInfo();
+ _elem629.read(iprot);
+ struct.executors.add(_elem629);
}
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 _iter623 : struct.executors)
+ for (ExecutorInfo _iter631 : struct.executors)
{
- _iter623.write(oprot);
+ _iter631.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 _iter624 : struct.executors)
+ for (ExecutorInfo _iter632 : struct.executors)
{
- _iter624.write(oprot);
+ _iter632.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 _list625 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list625.size);
- ExecutorInfo _elem626;
- for (int _i627 = 0; _i627 < _list625.size; ++_i627)
+ org.apache.thrift.protocol.TList _list633 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list633.size);
+ ExecutorInfo _elem634;
+ for (int _i635 = 0; _i635 < _list633.size; ++_i635)
{
- _elem626 = new ExecutorInfo();
- _elem626.read(iprot);
- struct.executors.add(_elem626);
+ _elem634 = new ExecutorInfo();
+ _elem634.read(iprot);
+ struct.executors.add(_elem634);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java b/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
index 384cab5..7340926 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LocalStateData.java
+++ b/storm-core/src/jvm/backtype/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 _map610 = iprot.readMapBegin();
- struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map610.size);
- String _key611;
- ThriftSerializedObject _val612;
- for (int _i613 = 0; _i613 < _map610.size; ++_i613)
+ org.apache.thrift.protocol.TMap _map618 = iprot.readMapBegin();
+ struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map618.size);
+ String _key619;
+ ThriftSerializedObject _val620;
+ for (int _i621 = 0; _i621 < _map618.size; ++_i621)
{
- _key611 = iprot.readString();
- _val612 = new ThriftSerializedObject();
- _val612.read(iprot);
- struct.serialized_parts.put(_key611, _val612);
+ _key619 = iprot.readString();
+ _val620 = new ThriftSerializedObject();
+ _val620.read(iprot);
+ struct.serialized_parts.put(_key619, _val620);
}
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> _iter614 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter622 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter614.getKey());
- _iter614.getValue().write(oprot);
+ oprot.writeString(_iter622.getKey());
+ _iter622.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> _iter615 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter623 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter615.getKey());
- _iter615.getValue().write(oprot);
+ oprot.writeString(_iter623.getKey());
+ _iter623.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 _map616 = 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*_map616.size);
- String _key617;
- ThriftSerializedObject _val618;
- for (int _i619 = 0; _i619 < _map616.size; ++_i619)
+ org.apache.thrift.protocol.TMap _map624 = 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*_map624.size);
+ String _key625;
+ ThriftSerializedObject _val626;
+ for (int _i627 = 0; _i627 < _map624.size; ++_i627)
{
- _key617 = iprot.readString();
- _val618 = new ThriftSerializedObject();
- _val618.read(iprot);
- struct.serialized_parts.put(_key617, _val618);
+ _key625 = iprot.readString();
+ _val626 = new ThriftSerializedObject();
+ _val626.read(iprot);
+ struct.serialized_parts.put(_key625, _val626);
}
}
struct.set_serialized_parts_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java b/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
index b74b17f..53bc326 100644
--- a/storm-core/src/jvm/backtype/storm/generated/LogConfig.java
+++ b/storm-core/src/jvm/backtype/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 _map680 = iprot.readMapBegin();
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map680.size);
- String _key681;
- LogLevel _val682;
- for (int _i683 = 0; _i683 < _map680.size; ++_i683)
+ org.apache.thrift.protocol.TMap _map688 = iprot.readMapBegin();
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map688.size);
+ String _key689;
+ LogLevel _val690;
+ for (int _i691 = 0; _i691 < _map688.size; ++_i691)
{
- _key681 = iprot.readString();
- _val682 = new LogLevel();
- _val682.read(iprot);
- struct.named_logger_level.put(_key681, _val682);
+ _key689 = iprot.readString();
+ _val690 = new LogLevel();
+ _val690.read(iprot);
+ struct.named_logger_level.put(_key689, _val690);
}
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> _iter684 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter692 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter684.getKey());
- _iter684.getValue().write(oprot);
+ oprot.writeString(_iter692.getKey());
+ _iter692.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> _iter685 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter693 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter685.getKey());
- _iter685.getValue().write(oprot);
+ oprot.writeString(_iter693.getKey());
+ _iter693.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 _map686 = 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*_map686.size);
- String _key687;
- LogLevel _val688;
- for (int _i689 = 0; _i689 < _map686.size; ++_i689)
+ org.apache.thrift.protocol.TMap _map694 = 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*_map694.size);
+ String _key695;
+ LogLevel _val696;
+ for (int _i697 = 0; _i697 < _map694.size; ++_i697)
{
- _key687 = iprot.readString();
- _val688 = new LogLevel();
- _val688.read(iprot);
- struct.named_logger_level.put(_key687, _val688);
+ _key695 = iprot.readString();
+ _val696 = new LogLevel();
+ _val696.read(iprot);
+ struct.named_logger_level.put(_key695, _val696);
}
}
struct.set_named_logger_level_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
index 360dba5..98d2d1c 100644
--- a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java
@@ -15611,14 +15611,14 @@ public class Nimbus {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list714 = iprot.readListBegin();
- struct.success = new ArrayList<ProfileRequest>(_list714.size);
- ProfileRequest _elem715;
- for (int _i716 = 0; _i716 < _list714.size; ++_i716)
+ org.apache.thrift.protocol.TList _list722 = iprot.readListBegin();
+ struct.success = new ArrayList<ProfileRequest>(_list722.size);
+ ProfileRequest _elem723;
+ for (int _i724 = 0; _i724 < _list722.size; ++_i724)
{
- _elem715 = new ProfileRequest();
- _elem715.read(iprot);
- struct.success.add(_elem715);
+ _elem723 = new ProfileRequest();
+ _elem723.read(iprot);
+ struct.success.add(_elem723);
}
iprot.readListEnd();
}
@@ -15644,9 +15644,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 _iter717 : struct.success)
+ for (ProfileRequest _iter725 : struct.success)
{
- _iter717.write(oprot);
+ _iter725.write(oprot);
}
oprot.writeListEnd();
}
@@ -15677,9 +15677,9 @@ public class Nimbus {
if (struct.is_set_success()) {
{
oprot.writeI32(struct.success.size());
- for (ProfileRequest _iter718 : struct.success)
+ for (ProfileRequest _iter726 : struct.success)
{
- _iter718.write(oprot);
+ _iter726.write(oprot);
}
}
}
@@ -15691,14 +15691,14 @@ public class Nimbus {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list719 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<ProfileRequest>(_list719.size);
- ProfileRequest _elem720;
- for (int _i721 = 0; _i721 < _list719.size; ++_i721)
+ org.apache.thrift.protocol.TList _list727 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<ProfileRequest>(_list727.size);
+ ProfileRequest _elem728;
+ for (int _i729 = 0; _i729 < _list727.size; ++_i729)
{
- _elem720 = new ProfileRequest();
- _elem720.read(iprot);
- struct.success.add(_elem720);
+ _elem728 = new ProfileRequest();
+ _elem728.read(iprot);
+ struct.success.add(_elem728);
}
}
struct.set_success_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java b/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
index a99ecb3..5ef4b5b 100644
--- a/storm-core/src/jvm/backtype/storm/generated/NodeInfo.java
+++ b/storm-core/src/jvm/backtype/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 _set516 = iprot.readSetBegin();
- struct.port = new HashSet<Long>(2*_set516.size);
- long _elem517;
- for (int _i518 = 0; _i518 < _set516.size; ++_i518)
+ org.apache.thrift.protocol.TSet _set524 = iprot.readSetBegin();
+ struct.port = new HashSet<Long>(2*_set524.size);
+ long _elem525;
+ for (int _i526 = 0; _i526 < _set524.size; ++_i526)
{
- _elem517 = iprot.readI64();
- struct.port.add(_elem517);
+ _elem525 = iprot.readI64();
+ struct.port.add(_elem525);
}
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 _iter519 : struct.port)
+ for (long _iter527 : struct.port)
{
- oprot.writeI64(_iter519);
+ oprot.writeI64(_iter527);
}
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 _iter520 : struct.port)
+ for (long _iter528 : struct.port)
{
- oprot.writeI64(_iter520);
+ oprot.writeI64(_iter528);
}
}
}
@@ -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 _set521 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.port = new HashSet<Long>(2*_set521.size);
- long _elem522;
- for (int _i523 = 0; _i523 < _set521.size; ++_i523)
+ org.apache.thrift.protocol.TSet _set529 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.port = new HashSet<Long>(2*_set529.size);
+ long _elem530;
+ for (int _i531 = 0; _i531 < _set529.size; ++_i531)
{
- _elem522 = iprot.readI64();
- struct.port.add(_elem522);
+ _elem530 = iprot.readI64();
+ struct.port.add(_elem530);
}
}
struct.set_port_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/b03ce6b2/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java b/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
index 03c36da..49a5631 100644
--- a/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java
+++ b/storm-core/src/jvm/backtype/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 _map460 = iprot.readMapBegin();
- struct.num_executors = new HashMap<String,Integer>(2*_map460.size);
- String _key461;
- int _val462;
- for (int _i463 = 0; _i463 < _map460.size; ++_i463)
+ org.apache.thrift.protocol.TMap _map468 = iprot.readMapBegin();
+ struct.num_executors = new HashMap<String,Integer>(2*_map468.size);
+ String _key469;
+ int _val470;
+ for (int _i471 = 0; _i471 < _map468.size; ++_i471)
{
- _key461 = iprot.readString();
- _val462 = iprot.readI32();
- struct.num_executors.put(_key461, _val462);
+ _key469 = iprot.readString();
+ _val470 = iprot.readI32();
+ struct.num_executors.put(_key469, _val470);
}
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> _iter464 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter472 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter464.getKey());
- oprot.writeI32(_iter464.getValue());
+ oprot.writeString(_iter472.getKey());
+ oprot.writeI32(_iter472.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> _iter465 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter473 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter465.getKey());
- oprot.writeI32(_iter465.getValue());
+ oprot.writeString(_iter473.getKey());
+ oprot.writeI32(_iter473.getValue());
}
}
}
@@ -644,15 +644,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map466 = 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*_map466.size);
- String _key467;
- int _val468;
- for (int _i469 = 0; _i469 < _map466.size; ++_i469)
+ org.apache.thrift.protocol.TMap _map474 = 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*_map474.size);
+ String _key475;
+ int _val476;
+ for (int _i477 = 0; _i477 < _map474.size; ++_i477)
{
- _key467 = iprot.readString();
- _val468 = iprot.readI32();
- struct.num_executors.put(_key467, _val468);
+ _key475 = iprot.readString();
+ _val476 = iprot.readI32();
+ struct.num_executors.put(_key475, _val476);
}
}
struct.set_num_executors_isSet(true);