http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/ComponentPageInfo.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/generated/ComponentPageInfo.java b/storm-core/src/jvm/org/apache/storm/generated/ComponentPageInfo.java index ff02aca..55bb200 100644 --- a/storm-core/src/jvm/org/apache/storm/generated/ComponentPageInfo.java +++ b/storm-core/src/jvm/org/apache/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 _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) + org.apache.thrift.protocol.TMap _map456 = iprot.readMapBegin(); + struct.window_to_stats = new HashMap<String,ComponentAggregateStats>(2*_map456.size); + String _key457; + ComponentAggregateStats _val458; + for (int _i459 = 0; _i459 < _map456.size; ++_i459) { - _key423 = iprot.readString(); - _val424 = new ComponentAggregateStats(); - _val424.read(iprot); - struct.window_to_stats.put(_key423, _val424); + _key457 = iprot.readString(); + _val458 = new ComponentAggregateStats(); + _val458.read(iprot); + struct.window_to_stats.put(_key457, _val458); } 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 _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) + org.apache.thrift.protocol.TMap _map460 = iprot.readMapBegin(); + struct.gsid_to_input_stats = new HashMap<GlobalStreamId,ComponentAggregateStats>(2*_map460.size); + GlobalStreamId _key461; + ComponentAggregateStats _val462; + for (int _i463 = 0; _i463 < _map460.size; ++_i463) { - _key427 = new GlobalStreamId(); - _key427.read(iprot); - _val428 = new ComponentAggregateStats(); - _val428.read(iprot); - struct.gsid_to_input_stats.put(_key427, _val428); + _key461 = new GlobalStreamId(); + _key461.read(iprot); + _val462 = new ComponentAggregateStats(); + _val462.read(iprot); + struct.gsid_to_input_stats.put(_key461, _val462); } 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 _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) + org.apache.thrift.protocol.TMap _map464 = iprot.readMapBegin(); + struct.sid_to_output_stats = new HashMap<String,ComponentAggregateStats>(2*_map464.size); + String _key465; + ComponentAggregateStats _val466; + for (int _i467 = 0; _i467 < _map464.size; ++_i467) { - _key431 = iprot.readString(); - _val432 = new ComponentAggregateStats(); - _val432.read(iprot); - struct.sid_to_output_stats.put(_key431, _val432); + _key465 = iprot.readString(); + _val466 = new ComponentAggregateStats(); + _val466.read(iprot); + struct.sid_to_output_stats.put(_key465, _val466); } 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 _list434 = iprot.readListBegin(); - struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list434.size); - ExecutorAggregateStats _elem435; - for (int _i436 = 0; _i436 < _list434.size; ++_i436) + org.apache.thrift.protocol.TList _list468 = iprot.readListBegin(); + struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list468.size); + ExecutorAggregateStats _elem469; + for (int _i470 = 0; _i470 < _list468.size; ++_i470) { - _elem435 = new ExecutorAggregateStats(); - _elem435.read(iprot); - struct.exec_stats.add(_elem435); + _elem469 = new ExecutorAggregateStats(); + _elem469.read(iprot); + struct.exec_stats.add(_elem469); } 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 _list437 = iprot.readListBegin(); - struct.errors = new ArrayList<ErrorInfo>(_list437.size); - ErrorInfo _elem438; - for (int _i439 = 0; _i439 < _list437.size; ++_i439) + org.apache.thrift.protocol.TList _list471 = iprot.readListBegin(); + struct.errors = new ArrayList<ErrorInfo>(_list471.size); + ErrorInfo _elem472; + for (int _i473 = 0; _i473 < _list471.size; ++_i473) { - _elem438 = new ErrorInfo(); - _elem438.read(iprot); - struct.errors.add(_elem438); + _elem472 = new ErrorInfo(); + _elem472.read(iprot); + struct.errors.add(_elem472); } 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> _iter440 : struct.window_to_stats.entrySet()) + for (Map.Entry<String, ComponentAggregateStats> _iter474 : struct.window_to_stats.entrySet()) { - oprot.writeString(_iter440.getKey()); - _iter440.getValue().write(oprot); + oprot.writeString(_iter474.getKey()); + _iter474.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> _iter441 : struct.gsid_to_input_stats.entrySet()) + for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter475 : struct.gsid_to_input_stats.entrySet()) { - _iter441.getKey().write(oprot); - _iter441.getValue().write(oprot); + _iter475.getKey().write(oprot); + _iter475.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> _iter442 : struct.sid_to_output_stats.entrySet()) + for (Map.Entry<String, ComponentAggregateStats> _iter476 : struct.sid_to_output_stats.entrySet()) { - oprot.writeString(_iter442.getKey()); - _iter442.getValue().write(oprot); + oprot.writeString(_iter476.getKey()); + _iter476.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 _iter443 : struct.exec_stats) + for (ExecutorAggregateStats _iter477 : struct.exec_stats) { - _iter443.write(oprot); + _iter477.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 _iter444 : struct.errors) + for (ErrorInfo _iter478 : struct.errors) { - _iter444.write(oprot); + _iter478.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> _iter445 : struct.window_to_stats.entrySet()) + for (Map.Entry<String, ComponentAggregateStats> _iter479 : struct.window_to_stats.entrySet()) { - oprot.writeString(_iter445.getKey()); - _iter445.getValue().write(oprot); + oprot.writeString(_iter479.getKey()); + _iter479.getValue().write(oprot); } } } if (struct.is_set_gsid_to_input_stats()) { { oprot.writeI32(struct.gsid_to_input_stats.size()); - for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter446 : struct.gsid_to_input_stats.entrySet()) + for (Map.Entry<GlobalStreamId, ComponentAggregateStats> _iter480 : struct.gsid_to_input_stats.entrySet()) { - _iter446.getKey().write(oprot); - _iter446.getValue().write(oprot); + _iter480.getKey().write(oprot); + _iter480.getValue().write(oprot); } } } if (struct.is_set_sid_to_output_stats()) { { oprot.writeI32(struct.sid_to_output_stats.size()); - for (Map.Entry<String, ComponentAggregateStats> _iter447 : struct.sid_to_output_stats.entrySet()) + for (Map.Entry<String, ComponentAggregateStats> _iter481 : struct.sid_to_output_stats.entrySet()) { - oprot.writeString(_iter447.getKey()); - _iter447.getValue().write(oprot); + oprot.writeString(_iter481.getKey()); + _iter481.getValue().write(oprot); } } } if (struct.is_set_exec_stats()) { { oprot.writeI32(struct.exec_stats.size()); - for (ExecutorAggregateStats _iter448 : struct.exec_stats) + for (ExecutorAggregateStats _iter482 : struct.exec_stats) { - _iter448.write(oprot); + _iter482.write(oprot); } } } if (struct.is_set_errors()) { { oprot.writeI32(struct.errors.size()); - for (ErrorInfo _iter449 : struct.errors) + for (ErrorInfo _iter483 : struct.errors) { - _iter449.write(oprot); + _iter483.write(oprot); } } } @@ -2095,77 +2095,77 @@ public class ComponentPageInfo implements org.apache.thrift.TBase<ComponentPageI } if (incoming.get(4)) { { - 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) + org.apache.thrift.protocol.TMap _map484 = 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*_map484.size); + String _key485; + ComponentAggregateStats _val486; + for (int _i487 = 0; _i487 < _map484.size; ++_i487) { - _key451 = iprot.readString(); - _val452 = new ComponentAggregateStats(); - _val452.read(iprot); - struct.window_to_stats.put(_key451, _val452); + _key485 = iprot.readString(); + _val486 = new ComponentAggregateStats(); + _val486.read(iprot); + struct.window_to_stats.put(_key485, _val486); } } struct.set_window_to_stats_isSet(true); } if (incoming.get(5)) { { - 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) + org.apache.thrift.protocol.TMap _map488 = 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*_map488.size); + GlobalStreamId _key489; + ComponentAggregateStats _val490; + for (int _i491 = 0; _i491 < _map488.size; ++_i491) { - _key455 = new GlobalStreamId(); - _key455.read(iprot); - _val456 = new ComponentAggregateStats(); - _val456.read(iprot); - struct.gsid_to_input_stats.put(_key455, _val456); + _key489 = new GlobalStreamId(); + _key489.read(iprot); + _val490 = new ComponentAggregateStats(); + _val490.read(iprot); + struct.gsid_to_input_stats.put(_key489, _val490); } } struct.set_gsid_to_input_stats_isSet(true); } if (incoming.get(6)) { { - 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) + org.apache.thrift.protocol.TMap _map492 = 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*_map492.size); + String _key493; + ComponentAggregateStats _val494; + for (int _i495 = 0; _i495 < _map492.size; ++_i495) { - _key459 = iprot.readString(); - _val460 = new ComponentAggregateStats(); - _val460.read(iprot); - struct.sid_to_output_stats.put(_key459, _val460); + _key493 = iprot.readString(); + _val494 = new ComponentAggregateStats(); + _val494.read(iprot); + struct.sid_to_output_stats.put(_key493, _val494); } } struct.set_sid_to_output_stats_isSet(true); } if (incoming.get(7)) { { - 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) + org.apache.thrift.protocol.TList _list496 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.exec_stats = new ArrayList<ExecutorAggregateStats>(_list496.size); + ExecutorAggregateStats _elem497; + for (int _i498 = 0; _i498 < _list496.size; ++_i498) { - _elem463 = new ExecutorAggregateStats(); - _elem463.read(iprot); - struct.exec_stats.add(_elem463); + _elem497 = new ExecutorAggregateStats(); + _elem497.read(iprot); + struct.exec_stats.add(_elem497); } } struct.set_exec_stats_isSet(true); } if (incoming.get(8)) { { - 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) + org.apache.thrift.protocol.TList _list499 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.errors = new ArrayList<ErrorInfo>(_list499.size); + ErrorInfo _elem500; + for (int _i501 = 0; _i501 < _list499.size; ++_i501) { - _elem466 = new ErrorInfo(); - _elem466.read(iprot); - struct.errors.add(_elem466); + _elem500 = new ErrorInfo(); + _elem500.read(iprot); + struct.errors.add(_elem500); } } struct.set_errors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 117865c..5319f76 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 _map478 = iprot.readMapBegin(); - struct.creds = new HashMap<String,String>(2*_map478.size); - String _key479; - String _val480; - for (int _i481 = 0; _i481 < _map478.size; ++_i481) + 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) { - _key479 = iprot.readString(); - _val480 = iprot.readString(); - struct.creds.put(_key479, _val480); + _key513 = iprot.readString(); + _val514 = iprot.readString(); + struct.creds.put(_key513, _val514); } 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> _iter482 : struct.creds.entrySet()) + for (Map.Entry<String, String> _iter516 : struct.creds.entrySet()) { - oprot.writeString(_iter482.getKey()); - oprot.writeString(_iter482.getValue()); + oprot.writeString(_iter516.getKey()); + oprot.writeString(_iter516.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> _iter483 : struct.creds.entrySet()) + for (Map.Entry<String, String> _iter517 : struct.creds.entrySet()) { - oprot.writeString(_iter483.getKey()); - oprot.writeString(_iter483.getValue()); + oprot.writeString(_iter517.getKey()); + oprot.writeString(_iter517.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 _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) + 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) { - _key485 = iprot.readString(); - _val486 = iprot.readString(); - struct.creds.put(_key485, _val486); + _key519 = iprot.readString(); + _val520 = iprot.readString(); + struct.creds.put(_key519, _val520); } } struct.set_creds_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 0f0ae15..5435af2 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 _list730 = iprot.readListBegin(); - struct.pulseIds = new ArrayList<String>(_list730.size); - String _elem731; - for (int _i732 = 0; _i732 < _list730.size; ++_i732) + 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) { - _elem731 = iprot.readString(); - struct.pulseIds.add(_elem731); + _elem765 = iprot.readString(); + struct.pulseIds.add(_elem765); } 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 _iter733 : struct.pulseIds) + for (String _iter767 : struct.pulseIds) { - oprot.writeString(_iter733); + oprot.writeString(_iter767); } 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 _iter734 : struct.pulseIds) + for (String _iter768 : struct.pulseIds) { - oprot.writeString(_iter734); + oprot.writeString(_iter768); } } } @@ -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 _list735 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.pulseIds = new ArrayList<String>(_list735.size); - String _elem736; - for (int _i737 = 0; _i737 < _list735.size; ++_i737) + 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) { - _elem736 = iprot.readString(); - struct.pulseIds.add(_elem736); + _elem770 = iprot.readString(); + struct.pulseIds.add(_elem770); } } struct.set_pulseIds_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 c92b49a..d21dcc8 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 _list722 = iprot.readListBegin(); - struct.pulses = new ArrayList<HBPulse>(_list722.size); - HBPulse _elem723; - for (int _i724 = 0; _i724 < _list722.size; ++_i724) + 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) { - _elem723 = new HBPulse(); - _elem723.read(iprot); - struct.pulses.add(_elem723); + _elem757 = new HBPulse(); + _elem757.read(iprot); + struct.pulses.add(_elem757); } 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 _iter725 : struct.pulses) + for (HBPulse _iter759 : struct.pulses) { - _iter725.write(oprot); + _iter759.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 _iter726 : struct.pulses) + for (HBPulse _iter760 : struct.pulses) { - _iter726.write(oprot); + _iter760.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 _list727 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.pulses = new ArrayList<HBPulse>(_list727.size); - HBPulse _elem728; - for (int _i729 = 0; _i729 < _list727.size; ++_i729) + 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) { - _elem728 = new HBPulse(); - _elem728.read(iprot); - struct.pulses.add(_elem728); + _elem762 = new HBPulse(); + _elem762.read(iprot); + struct.pulses.add(_elem762); } } struct.set_pulses_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 130a643..41c8a7d 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 _map652 = iprot.readMapBegin(); - struct.approved_workers = new HashMap<String,Integer>(2*_map652.size); - String _key653; - int _val654; - for (int _i655 = 0; _i655 < _map652.size; ++_i655) + 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) { - _key653 = iprot.readString(); - _val654 = iprot.readI32(); - struct.approved_workers.put(_key653, _val654); + _key687 = iprot.readString(); + _val688 = iprot.readI32(); + struct.approved_workers.put(_key687, _val688); } 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> _iter656 : struct.approved_workers.entrySet()) + for (Map.Entry<String, Integer> _iter690 : struct.approved_workers.entrySet()) { - oprot.writeString(_iter656.getKey()); - oprot.writeI32(_iter656.getValue()); + oprot.writeString(_iter690.getKey()); + oprot.writeI32(_iter690.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> _iter657 : struct.approved_workers.entrySet()) + for (Map.Entry<String, Integer> _iter691 : struct.approved_workers.entrySet()) { - oprot.writeString(_iter657.getKey()); - oprot.writeI32(_iter657.getValue()); + oprot.writeString(_iter691.getKey()); + oprot.writeI32(_iter691.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 _map658 = 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*_map658.size); - String _key659; - int _val660; - for (int _i661 = 0; _i661 < _map658.size; ++_i661) + 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) { - _key659 = iprot.readString(); - _val660 = iprot.readI32(); - struct.approved_workers.put(_key659, _val660); + _key693 = iprot.readString(); + _val694 = iprot.readI32(); + struct.approved_workers.put(_key693, _val694); } } struct.set_approved_workers_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 da1e4df..682425e 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 _map662 = iprot.readMapBegin(); - struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map662.size); - int _key663; - LocalAssignment _val664; - for (int _i665 = 0; _i665 < _map662.size; ++_i665) + 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) { - _key663 = iprot.readI32(); - _val664 = new LocalAssignment(); - _val664.read(iprot); - struct.assignments.put(_key663, _val664); + _key697 = iprot.readI32(); + _val698 = new LocalAssignment(); + _val698.read(iprot); + struct.assignments.put(_key697, _val698); } 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> _iter666 : struct.assignments.entrySet()) + for (Map.Entry<Integer, LocalAssignment> _iter700 : struct.assignments.entrySet()) { - oprot.writeI32(_iter666.getKey()); - _iter666.getValue().write(oprot); + oprot.writeI32(_iter700.getKey()); + _iter700.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> _iter667 : struct.assignments.entrySet()) + for (Map.Entry<Integer, LocalAssignment> _iter701 : struct.assignments.entrySet()) { - oprot.writeI32(_iter667.getKey()); - _iter667.getValue().write(oprot); + oprot.writeI32(_iter701.getKey()); + _iter701.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 _map668 = 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*_map668.size); - int _key669; - LocalAssignment _val670; - for (int _i671 = 0; _i671 < _map668.size; ++_i671) + 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) { - _key669 = iprot.readI32(); - _val670 = new LocalAssignment(); - _val670.read(iprot); - struct.assignments.put(_key669, _val670); + _key703 = iprot.readI32(); + _val704 = new LocalAssignment(); + _val704.read(iprot); + struct.assignments.put(_key703, _val704); } } struct.set_assignments_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 05f5222..68f5066 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 _list680 = iprot.readListBegin(); - struct.users = new ArrayList<String>(_list680.size); - String _elem681; - for (int _i682 = 0; _i682 < _list680.size; ++_i682) + 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) { - _elem681 = iprot.readString(); - struct.users.add(_elem681); + _elem715 = iprot.readString(); + struct.users.add(_elem715); } 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 _list683 = iprot.readListBegin(); - struct.groups = new ArrayList<String>(_list683.size); - String _elem684; - for (int _i685 = 0; _i685 < _list683.size; ++_i685) + 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) { - _elem684 = iprot.readString(); - struct.groups.add(_elem684); + _elem718 = iprot.readString(); + struct.groups.add(_elem718); } 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 _iter686 : struct.users) + for (String _iter720 : struct.users) { - oprot.writeString(_iter686); + oprot.writeString(_iter720); } 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 _iter687 : struct.groups) + for (String _iter721 : struct.groups) { - oprot.writeString(_iter687); + oprot.writeString(_iter721); } 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 _iter688 : struct.users) + for (String _iter722 : struct.users) { - oprot.writeString(_iter688); + oprot.writeString(_iter722); } } { oprot.writeI32(struct.groups.size()); - for (String _iter689 : struct.groups) + for (String _iter723 : struct.groups) { - oprot.writeString(_iter689); + oprot.writeString(_iter723); } } } @@ -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 _list690 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.users = new ArrayList<String>(_list690.size); - String _elem691; - for (int _i692 = 0; _i692 < _list690.size; ++_i692) + 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) { - _elem691 = iprot.readString(); - struct.users.add(_elem691); + _elem725 = iprot.readString(); + struct.users.add(_elem725); } } struct.set_users_isSet(true); { - org.apache.thrift.protocol.TList _list693 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.groups = new ArrayList<String>(_list693.size); - String _elem694; - for (int _i695 = 0; _i695 < _list693.size; ++_i695) + 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) { - _elem694 = iprot.readString(); - struct.groups.add(_elem694); + _elem728 = iprot.readString(); + struct.groups.add(_elem728); } } struct.set_groups_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 bc227f7..a2bf370 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 _list696 = iprot.readListBegin(); - struct.topo_history = new ArrayList<LSTopoHistory>(_list696.size); - LSTopoHistory _elem697; - for (int _i698 = 0; _i698 < _list696.size; ++_i698) + 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) { - _elem697 = new LSTopoHistory(); - _elem697.read(iprot); - struct.topo_history.add(_elem697); + _elem731 = new LSTopoHistory(); + _elem731.read(iprot); + struct.topo_history.add(_elem731); } 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 _iter699 : struct.topo_history) + for (LSTopoHistory _iter733 : struct.topo_history) { - _iter699.write(oprot); + _iter733.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 _iter700 : struct.topo_history) + for (LSTopoHistory _iter734 : struct.topo_history) { - _iter700.write(oprot); + _iter734.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 _list701 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.topo_history = new ArrayList<LSTopoHistory>(_list701.size); - LSTopoHistory _elem702; - for (int _i703 = 0; _i703 < _list701.size; ++_i703) + 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) { - _elem702 = new LSTopoHistory(); - _elem702.read(iprot); - struct.topo_history.add(_elem702); + _elem736 = new LSTopoHistory(); + _elem736.read(iprot); + struct.topo_history.add(_elem736); } } struct.set_topo_history_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 2bc8b0a..968b9cc 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 _list672 = iprot.readListBegin(); - struct.executors = new ArrayList<ExecutorInfo>(_list672.size); - ExecutorInfo _elem673; - for (int _i674 = 0; _i674 < _list672.size; ++_i674) + 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) { - _elem673 = new ExecutorInfo(); - _elem673.read(iprot); - struct.executors.add(_elem673); + _elem707 = new ExecutorInfo(); + _elem707.read(iprot); + struct.executors.add(_elem707); } 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 _iter675 : struct.executors) + for (ExecutorInfo _iter709 : struct.executors) { - _iter675.write(oprot); + _iter709.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 _iter676 : struct.executors) + for (ExecutorInfo _iter710 : struct.executors) { - _iter676.write(oprot); + _iter710.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 _list677 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executors = new ArrayList<ExecutorInfo>(_list677.size); - ExecutorInfo _elem678; - for (int _i679 = 0; _i679 < _list677.size; ++_i679) + 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) { - _elem678 = new ExecutorInfo(); - _elem678.read(iprot); - struct.executors.add(_elem678); + _elem712 = new ExecutorInfo(); + _elem712.read(iprot); + struct.executors.add(_elem712); } } struct.set_executors_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 854b49d..43f7dc2 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 _list496 = iprot.readListBegin(); - struct.keys = new ArrayList<String>(_list496.size); - String _elem497; - for (int _i498 = 0; _i498 < _list496.size; ++_i498) + 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) { - _elem497 = iprot.readString(); - struct.keys.add(_elem497); + _elem531 = iprot.readString(); + struct.keys.add(_elem531); } 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 _iter499 : struct.keys) + for (String _iter533 : struct.keys) { - oprot.writeString(_iter499); + oprot.writeString(_iter533); } 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 _iter500 : struct.keys) + for (String _iter534 : struct.keys) { - oprot.writeString(_iter500); + oprot.writeString(_iter534); } } 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 _list501 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.keys = new ArrayList<String>(_list501.size); - String _elem502; - for (int _i503 = 0; _i503 < _list501.size; ++_i503) + 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) { - _elem502 = iprot.readString(); - struct.keys.add(_elem502); + _elem536 = iprot.readString(); + struct.keys.add(_elem536); } } struct.set_keys_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 19404cc..717014c 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 _list644 = iprot.readListBegin(); - struct.executors = new ArrayList<ExecutorInfo>(_list644.size); - ExecutorInfo _elem645; - for (int _i646 = 0; _i646 < _list644.size; ++_i646) + 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) { - _elem645 = new ExecutorInfo(); - _elem645.read(iprot); - struct.executors.add(_elem645); + _elem679 = new ExecutorInfo(); + _elem679.read(iprot); + struct.executors.add(_elem679); } 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 _iter647 : struct.executors) + for (ExecutorInfo _iter681 : struct.executors) { - _iter647.write(oprot); + _iter681.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 _iter648 : struct.executors) + for (ExecutorInfo _iter682 : struct.executors) { - _iter648.write(oprot); + _iter682.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 _list649 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.executors = new ArrayList<ExecutorInfo>(_list649.size); - ExecutorInfo _elem650; - for (int _i651 = 0; _i651 < _list649.size; ++_i651) + 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) { - _elem650 = new ExecutorInfo(); - _elem650.read(iprot); - struct.executors.add(_elem650); + _elem684 = new ExecutorInfo(); + _elem684.read(iprot); + struct.executors.add(_elem684); } } struct.set_executors_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 e85a55d..dd28764 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 _map634 = iprot.readMapBegin(); - struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map634.size); - String _key635; - ThriftSerializedObject _val636; - for (int _i637 = 0; _i637 < _map634.size; ++_i637) + 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) { - _key635 = iprot.readString(); - _val636 = new ThriftSerializedObject(); - _val636.read(iprot); - struct.serialized_parts.put(_key635, _val636); + _key669 = iprot.readString(); + _val670 = new ThriftSerializedObject(); + _val670.read(iprot); + struct.serialized_parts.put(_key669, _val670); } 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> _iter638 : struct.serialized_parts.entrySet()) + for (Map.Entry<String, ThriftSerializedObject> _iter672 : struct.serialized_parts.entrySet()) { - oprot.writeString(_iter638.getKey()); - _iter638.getValue().write(oprot); + oprot.writeString(_iter672.getKey()); + _iter672.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> _iter639 : struct.serialized_parts.entrySet()) + for (Map.Entry<String, ThriftSerializedObject> _iter673 : struct.serialized_parts.entrySet()) { - oprot.writeString(_iter639.getKey()); - _iter639.getValue().write(oprot); + oprot.writeString(_iter673.getKey()); + _iter673.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 _map640 = 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*_map640.size); - String _key641; - ThriftSerializedObject _val642; - for (int _i643 = 0; _i643 < _map640.size; ++_i643) + 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) { - _key641 = iprot.readString(); - _val642 = new ThriftSerializedObject(); - _val642.read(iprot); - struct.serialized_parts.put(_key641, _val642); + _key675 = iprot.readString(); + _val676 = new ThriftSerializedObject(); + _val676.read(iprot); + struct.serialized_parts.put(_key675, _val676); } } struct.set_serialized_parts_isSet(true); http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/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 a797523..95230de 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 _map704 = iprot.readMapBegin(); - struct.named_logger_level = new HashMap<String,LogLevel>(2*_map704.size); - String _key705; - LogLevel _val706; - for (int _i707 = 0; _i707 < _map704.size; ++_i707) + 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) { - _key705 = iprot.readString(); - _val706 = new LogLevel(); - _val706.read(iprot); - struct.named_logger_level.put(_key705, _val706); + _key739 = iprot.readString(); + _val740 = new LogLevel(); + _val740.read(iprot); + struct.named_logger_level.put(_key739, _val740); } 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> _iter708 : struct.named_logger_level.entrySet()) + for (Map.Entry<String, LogLevel> _iter742 : struct.named_logger_level.entrySet()) { - oprot.writeString(_iter708.getKey()); - _iter708.getValue().write(oprot); + oprot.writeString(_iter742.getKey()); + _iter742.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> _iter709 : struct.named_logger_level.entrySet()) + for (Map.Entry<String, LogLevel> _iter743 : struct.named_logger_level.entrySet()) { - oprot.writeString(_iter709.getKey()); - _iter709.getValue().write(oprot); + oprot.writeString(_iter743.getKey()); + _iter743.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 _map710 = 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*_map710.size); - String _key711; - LogLevel _val712; - for (int _i713 = 0; _i713 < _map710.size; ++_i713) + 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) { - _key711 = iprot.readString(); - _val712 = new LogLevel(); - _val712.read(iprot); - struct.named_logger_level.put(_key711, _val712); + _key745 = iprot.readString(); + _val746 = new LogLevel(); + _val746.read(iprot); + struct.named_logger_level.put(_key745, _val746); } } struct.set_named_logger_level_isSet(true);
