You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/22 08:34:43 UTC
[4/9] storm git commit: STORM-1994: Add table with per-topology and
worker resource usage and components in (new) supervisor and topology pages
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java b/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
index 0106940..34c5e43 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/NodeInfo.java
@@ -461,13 +461,13 @@ public class NodeInfo implements org.apache.thrift.TBase<NodeInfo, NodeInfo._Fie
case 2: // PORT
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set540 = iprot.readSetBegin();
- struct.port = new HashSet<Long>(2*_set540.size);
- long _elem541;
- for (int _i542 = 0; _i542 < _set540.size; ++_i542)
+ org.apache.thrift.protocol.TSet _set574 = iprot.readSetBegin();
+ struct.port = new HashSet<Long>(2*_set574.size);
+ long _elem575;
+ for (int _i576 = 0; _i576 < _set574.size; ++_i576)
{
- _elem541 = iprot.readI64();
- struct.port.add(_elem541);
+ _elem575 = iprot.readI64();
+ struct.port.add(_elem575);
}
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 _iter543 : struct.port)
+ for (long _iter577 : struct.port)
{
- oprot.writeI64(_iter543);
+ oprot.writeI64(_iter577);
}
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 _iter544 : struct.port)
+ for (long _iter578 : struct.port)
{
- oprot.writeI64(_iter544);
+ oprot.writeI64(_iter578);
}
}
}
@@ -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 _set545 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.port = new HashSet<Long>(2*_set545.size);
- long _elem546;
- for (int _i547 = 0; _i547 < _set545.size; ++_i547)
+ org.apache.thrift.protocol.TSet _set579 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.port = new HashSet<Long>(2*_set579.size);
+ long _elem580;
+ for (int _i581 = 0; _i581 < _set579.size; ++_i581)
{
- _elem546 = iprot.readI64();
- struct.port.add(_elem546);
+ _elem580 = iprot.readI64();
+ struct.port.add(_elem580);
}
}
struct.set_port_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java b/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
index 1d92dd6..34d4c3b 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/RebalanceOptions.java
@@ -529,15 +529,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
case 3: // NUM_EXECUTORS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _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)
+ org.apache.thrift.protocol.TMap _map502 = iprot.readMapBegin();
+ struct.num_executors = new HashMap<String,Integer>(2*_map502.size);
+ String _key503;
+ int _val504;
+ for (int _i505 = 0; _i505 < _map502.size; ++_i505)
{
- _key469 = iprot.readString();
- _val470 = iprot.readI32();
- struct.num_executors.put(_key469, _val470);
+ _key503 = iprot.readString();
+ _val504 = iprot.readI32();
+ struct.num_executors.put(_key503, _val504);
}
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> _iter472 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter506 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter472.getKey());
- oprot.writeI32(_iter472.getValue());
+ oprot.writeString(_iter506.getKey());
+ oprot.writeI32(_iter506.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> _iter473 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter507 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter473.getKey());
- oprot.writeI32(_iter473.getValue());
+ oprot.writeString(_iter507.getKey());
+ oprot.writeI32(_iter507.getValue());
}
}
}
@@ -644,15 +644,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
}
if (incoming.get(2)) {
{
- 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)
+ org.apache.thrift.protocol.TMap _map508 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.num_executors = new HashMap<String,Integer>(2*_map508.size);
+ String _key509;
+ int _val510;
+ for (int _i511 = 0; _i511 < _map508.size; ++_i511)
{
- _key475 = iprot.readString();
- _val476 = iprot.readI32();
- struct.num_executors.put(_key475, _val476);
+ _key509 = iprot.readString();
+ _val510 = iprot.readI32();
+ struct.num_executors.put(_key509, _val510);
}
}
struct.set_num_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java b/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
index e22fd6f..3bd9a86 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
@@ -452,14 +452,14 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
case 1: // ACL
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list488 = iprot.readListBegin();
- struct.acl = new ArrayList<AccessControl>(_list488.size);
- AccessControl _elem489;
- for (int _i490 = 0; _i490 < _list488.size; ++_i490)
+ org.apache.thrift.protocol.TList _list522 = iprot.readListBegin();
+ struct.acl = new ArrayList<AccessControl>(_list522.size);
+ AccessControl _elem523;
+ for (int _i524 = 0; _i524 < _list522.size; ++_i524)
{
- _elem489 = new AccessControl();
- _elem489.read(iprot);
- struct.acl.add(_elem489);
+ _elem523 = new AccessControl();
+ _elem523.read(iprot);
+ struct.acl.add(_elem523);
}
iprot.readListEnd();
}
@@ -493,9 +493,9 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
oprot.writeFieldBegin(ACL_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.acl.size()));
- for (AccessControl _iter491 : struct.acl)
+ for (AccessControl _iter525 : struct.acl)
{
- _iter491.write(oprot);
+ _iter525.write(oprot);
}
oprot.writeListEnd();
}
@@ -525,9 +525,9 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.acl.size());
- for (AccessControl _iter492 : struct.acl)
+ for (AccessControl _iter526 : struct.acl)
{
- _iter492.write(oprot);
+ _iter526.write(oprot);
}
}
BitSet optionals = new BitSet();
@@ -544,14 +544,14 @@ public class SettableBlobMeta implements org.apache.thrift.TBase<SettableBlobMet
public void read(org.apache.thrift.protocol.TProtocol prot, SettableBlobMeta struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list493 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.acl = new ArrayList<AccessControl>(_list493.size);
- AccessControl _elem494;
- for (int _i495 = 0; _i495 < _list493.size; ++_i495)
+ org.apache.thrift.protocol.TList _list527 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.acl = new ArrayList<AccessControl>(_list527.size);
+ AccessControl _elem528;
+ for (int _i529 = 0; _i529 < _list527.size; ++_i529)
{
- _elem494 = new AccessControl();
- _elem494.read(iprot);
- struct.acl.add(_elem494);
+ _elem528 = new AccessControl();
+ _elem528.read(iprot);
+ struct.acl.add(_elem528);
}
}
struct.set_acl_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/StormBase.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/StormBase.java b/storm-core/src/jvm/org/apache/storm/generated/StormBase.java
index 5b95144..ba4b792 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/StormBase.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/StormBase.java
@@ -1090,15 +1090,15 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
case 4: // COMPONENT_EXECUTORS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map604 = iprot.readMapBegin();
- struct.component_executors = new HashMap<String,Integer>(2*_map604.size);
- String _key605;
- int _val606;
- for (int _i607 = 0; _i607 < _map604.size; ++_i607)
+ org.apache.thrift.protocol.TMap _map638 = iprot.readMapBegin();
+ struct.component_executors = new HashMap<String,Integer>(2*_map638.size);
+ String _key639;
+ int _val640;
+ for (int _i641 = 0; _i641 < _map638.size; ++_i641)
{
- _key605 = iprot.readString();
- _val606 = iprot.readI32();
- struct.component_executors.put(_key605, _val606);
+ _key639 = iprot.readString();
+ _val640 = iprot.readI32();
+ struct.component_executors.put(_key639, _val640);
}
iprot.readMapEnd();
}
@@ -1143,16 +1143,16 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
case 9: // COMPONENT_DEBUG
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map608 = iprot.readMapBegin();
- struct.component_debug = new HashMap<String,DebugOptions>(2*_map608.size);
- String _key609;
- DebugOptions _val610;
- for (int _i611 = 0; _i611 < _map608.size; ++_i611)
+ org.apache.thrift.protocol.TMap _map642 = iprot.readMapBegin();
+ struct.component_debug = new HashMap<String,DebugOptions>(2*_map642.size);
+ String _key643;
+ DebugOptions _val644;
+ for (int _i645 = 0; _i645 < _map642.size; ++_i645)
{
- _key609 = iprot.readString();
- _val610 = new DebugOptions();
- _val610.read(iprot);
- struct.component_debug.put(_key609, _val610);
+ _key643 = iprot.readString();
+ _val644 = new DebugOptions();
+ _val644.read(iprot);
+ struct.component_debug.put(_key643, _val644);
}
iprot.readMapEnd();
}
@@ -1192,10 +1192,10 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
oprot.writeFieldBegin(COMPONENT_EXECUTORS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, struct.component_executors.size()));
- for (Map.Entry<String, Integer> _iter612 : struct.component_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter646 : struct.component_executors.entrySet())
{
- oprot.writeString(_iter612.getKey());
- oprot.writeI32(_iter612.getValue());
+ oprot.writeString(_iter646.getKey());
+ oprot.writeI32(_iter646.getValue());
}
oprot.writeMapEnd();
}
@@ -1233,10 +1233,10 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
oprot.writeFieldBegin(COMPONENT_DEBUG_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.component_debug.size()));
- for (Map.Entry<String, DebugOptions> _iter613 : struct.component_debug.entrySet())
+ for (Map.Entry<String, DebugOptions> _iter647 : struct.component_debug.entrySet())
{
- oprot.writeString(_iter613.getKey());
- _iter613.getValue().write(oprot);
+ oprot.writeString(_iter647.getKey());
+ _iter647.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -1286,10 +1286,10 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (struct.is_set_component_executors()) {
{
oprot.writeI32(struct.component_executors.size());
- for (Map.Entry<String, Integer> _iter614 : struct.component_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter648 : struct.component_executors.entrySet())
{
- oprot.writeString(_iter614.getKey());
- oprot.writeI32(_iter614.getValue());
+ oprot.writeString(_iter648.getKey());
+ oprot.writeI32(_iter648.getValue());
}
}
}
@@ -1308,10 +1308,10 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
if (struct.is_set_component_debug()) {
{
oprot.writeI32(struct.component_debug.size());
- for (Map.Entry<String, DebugOptions> _iter615 : struct.component_debug.entrySet())
+ for (Map.Entry<String, DebugOptions> _iter649 : struct.component_debug.entrySet())
{
- oprot.writeString(_iter615.getKey());
- _iter615.getValue().write(oprot);
+ oprot.writeString(_iter649.getKey());
+ _iter649.getValue().write(oprot);
}
}
}
@@ -1329,15 +1329,15 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
BitSet incoming = iprot.readBitSet(6);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map616 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.component_executors = new HashMap<String,Integer>(2*_map616.size);
- String _key617;
- int _val618;
- for (int _i619 = 0; _i619 < _map616.size; ++_i619)
+ org.apache.thrift.protocol.TMap _map650 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
+ struct.component_executors = new HashMap<String,Integer>(2*_map650.size);
+ String _key651;
+ int _val652;
+ for (int _i653 = 0; _i653 < _map650.size; ++_i653)
{
- _key617 = iprot.readString();
- _val618 = iprot.readI32();
- struct.component_executors.put(_key617, _val618);
+ _key651 = iprot.readString();
+ _val652 = iprot.readI32();
+ struct.component_executors.put(_key651, _val652);
}
}
struct.set_component_executors_isSet(true);
@@ -1361,16 +1361,16 @@ public class StormBase implements org.apache.thrift.TBase<StormBase, StormBase._
}
if (incoming.get(5)) {
{
- org.apache.thrift.protocol.TMap _map620 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component_debug = new HashMap<String,DebugOptions>(2*_map620.size);
- String _key621;
- DebugOptions _val622;
- for (int _i623 = 0; _i623 < _map620.size; ++_i623)
+ org.apache.thrift.protocol.TMap _map654 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component_debug = new HashMap<String,DebugOptions>(2*_map654.size);
+ String _key655;
+ DebugOptions _val656;
+ for (int _i657 = 0; _i657 < _map654.size; ++_i657)
{
- _key621 = iprot.readString();
- _val622 = new DebugOptions();
- _val622.read(iprot);
- struct.component_debug.put(_key621, _val622);
+ _key655 = iprot.readString();
+ _val656 = new DebugOptions();
+ _val656.read(iprot);
+ struct.component_debug.put(_key655, _val656);
}
}
struct.set_component_debug_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/SupervisorInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/SupervisorInfo.java b/storm-core/src/jvm/org/apache/storm/generated/SupervisorInfo.java
index a4d5269..18805be 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/SupervisorInfo.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/SupervisorInfo.java
@@ -1085,13 +1085,13 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
case 4: // USED_PORTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list504 = iprot.readListBegin();
- struct.used_ports = new ArrayList<Long>(_list504.size);
- long _elem505;
- for (int _i506 = 0; _i506 < _list504.size; ++_i506)
+ org.apache.thrift.protocol.TList _list538 = iprot.readListBegin();
+ struct.used_ports = new ArrayList<Long>(_list538.size);
+ long _elem539;
+ for (int _i540 = 0; _i540 < _list538.size; ++_i540)
{
- _elem505 = iprot.readI64();
- struct.used_ports.add(_elem505);
+ _elem539 = iprot.readI64();
+ struct.used_ports.add(_elem539);
}
iprot.readListEnd();
}
@@ -1103,13 +1103,13 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
case 5: // META
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list507 = iprot.readListBegin();
- struct.meta = new ArrayList<Long>(_list507.size);
- long _elem508;
- for (int _i509 = 0; _i509 < _list507.size; ++_i509)
+ org.apache.thrift.protocol.TList _list541 = iprot.readListBegin();
+ struct.meta = new ArrayList<Long>(_list541.size);
+ long _elem542;
+ for (int _i543 = 0; _i543 < _list541.size; ++_i543)
{
- _elem508 = iprot.readI64();
- struct.meta.add(_elem508);
+ _elem542 = iprot.readI64();
+ struct.meta.add(_elem542);
}
iprot.readListEnd();
}
@@ -1121,15 +1121,15 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
case 6: // SCHEDULER_META
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map510 = iprot.readMapBegin();
- struct.scheduler_meta = new HashMap<String,String>(2*_map510.size);
- String _key511;
- String _val512;
- for (int _i513 = 0; _i513 < _map510.size; ++_i513)
+ org.apache.thrift.protocol.TMap _map544 = iprot.readMapBegin();
+ struct.scheduler_meta = new HashMap<String,String>(2*_map544.size);
+ String _key545;
+ String _val546;
+ for (int _i547 = 0; _i547 < _map544.size; ++_i547)
{
- _key511 = iprot.readString();
- _val512 = iprot.readString();
- struct.scheduler_meta.put(_key511, _val512);
+ _key545 = iprot.readString();
+ _val546 = iprot.readString();
+ struct.scheduler_meta.put(_key545, _val546);
}
iprot.readMapEnd();
}
@@ -1157,15 +1157,15 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
case 9: // RESOURCES_MAP
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map514 = iprot.readMapBegin();
- struct.resources_map = new HashMap<String,Double>(2*_map514.size);
- String _key515;
- double _val516;
- for (int _i517 = 0; _i517 < _map514.size; ++_i517)
+ org.apache.thrift.protocol.TMap _map548 = iprot.readMapBegin();
+ struct.resources_map = new HashMap<String,Double>(2*_map548.size);
+ String _key549;
+ double _val550;
+ for (int _i551 = 0; _i551 < _map548.size; ++_i551)
{
- _key515 = iprot.readString();
- _val516 = iprot.readDouble();
- struct.resources_map.put(_key515, _val516);
+ _key549 = iprot.readString();
+ _val550 = iprot.readDouble();
+ struct.resources_map.put(_key549, _val550);
}
iprot.readMapEnd();
}
@@ -1207,9 +1207,9 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
oprot.writeFieldBegin(USED_PORTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.used_ports.size()));
- for (long _iter518 : struct.used_ports)
+ for (long _iter552 : struct.used_ports)
{
- oprot.writeI64(_iter518);
+ oprot.writeI64(_iter552);
}
oprot.writeListEnd();
}
@@ -1221,9 +1221,9 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
oprot.writeFieldBegin(META_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.meta.size()));
- for (long _iter519 : struct.meta)
+ for (long _iter553 : struct.meta)
{
- oprot.writeI64(_iter519);
+ oprot.writeI64(_iter553);
}
oprot.writeListEnd();
}
@@ -1235,10 +1235,10 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
oprot.writeFieldBegin(SCHEDULER_META_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.scheduler_meta.size()));
- for (Map.Entry<String, String> _iter520 : struct.scheduler_meta.entrySet())
+ for (Map.Entry<String, String> _iter554 : struct.scheduler_meta.entrySet())
{
- oprot.writeString(_iter520.getKey());
- oprot.writeString(_iter520.getValue());
+ oprot.writeString(_iter554.getKey());
+ oprot.writeString(_iter554.getValue());
}
oprot.writeMapEnd();
}
@@ -1262,10 +1262,10 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
oprot.writeFieldBegin(RESOURCES_MAP_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, struct.resources_map.size()));
- for (Map.Entry<String, Double> _iter521 : struct.resources_map.entrySet())
+ for (Map.Entry<String, Double> _iter555 : struct.resources_map.entrySet())
{
- oprot.writeString(_iter521.getKey());
- oprot.writeDouble(_iter521.getValue());
+ oprot.writeString(_iter555.getKey());
+ oprot.writeDouble(_iter555.getValue());
}
oprot.writeMapEnd();
}
@@ -1320,28 +1320,28 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
if (struct.is_set_used_ports()) {
{
oprot.writeI32(struct.used_ports.size());
- for (long _iter522 : struct.used_ports)
+ for (long _iter556 : struct.used_ports)
{
- oprot.writeI64(_iter522);
+ oprot.writeI64(_iter556);
}
}
}
if (struct.is_set_meta()) {
{
oprot.writeI32(struct.meta.size());
- for (long _iter523 : struct.meta)
+ for (long _iter557 : struct.meta)
{
- oprot.writeI64(_iter523);
+ oprot.writeI64(_iter557);
}
}
}
if (struct.is_set_scheduler_meta()) {
{
oprot.writeI32(struct.scheduler_meta.size());
- for (Map.Entry<String, String> _iter524 : struct.scheduler_meta.entrySet())
+ for (Map.Entry<String, String> _iter558 : struct.scheduler_meta.entrySet())
{
- oprot.writeString(_iter524.getKey());
- oprot.writeString(_iter524.getValue());
+ oprot.writeString(_iter558.getKey());
+ oprot.writeString(_iter558.getValue());
}
}
}
@@ -1354,10 +1354,10 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
if (struct.is_set_resources_map()) {
{
oprot.writeI32(struct.resources_map.size());
- for (Map.Entry<String, Double> _iter525 : struct.resources_map.entrySet())
+ for (Map.Entry<String, Double> _iter559 : struct.resources_map.entrySet())
{
- oprot.writeString(_iter525.getKey());
- oprot.writeDouble(_iter525.getValue());
+ oprot.writeString(_iter559.getKey());
+ oprot.writeDouble(_iter559.getValue());
}
}
}
@@ -1377,41 +1377,41 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list526 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.used_ports = new ArrayList<Long>(_list526.size);
- long _elem527;
- for (int _i528 = 0; _i528 < _list526.size; ++_i528)
+ org.apache.thrift.protocol.TList _list560 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.used_ports = new ArrayList<Long>(_list560.size);
+ long _elem561;
+ for (int _i562 = 0; _i562 < _list560.size; ++_i562)
{
- _elem527 = iprot.readI64();
- struct.used_ports.add(_elem527);
+ _elem561 = iprot.readI64();
+ struct.used_ports.add(_elem561);
}
}
struct.set_used_ports_isSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.meta = new ArrayList<Long>(_list529.size);
- long _elem530;
- for (int _i531 = 0; _i531 < _list529.size; ++_i531)
+ org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.meta = new ArrayList<Long>(_list563.size);
+ long _elem564;
+ for (int _i565 = 0; _i565 < _list563.size; ++_i565)
{
- _elem530 = iprot.readI64();
- struct.meta.add(_elem530);
+ _elem564 = iprot.readI64();
+ struct.meta.add(_elem564);
}
}
struct.set_meta_isSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TMap _map532 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.scheduler_meta = new HashMap<String,String>(2*_map532.size);
- String _key533;
- String _val534;
- for (int _i535 = 0; _i535 < _map532.size; ++_i535)
+ org.apache.thrift.protocol.TMap _map566 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.scheduler_meta = new HashMap<String,String>(2*_map566.size);
+ String _key567;
+ String _val568;
+ for (int _i569 = 0; _i569 < _map566.size; ++_i569)
{
- _key533 = iprot.readString();
- _val534 = iprot.readString();
- struct.scheduler_meta.put(_key533, _val534);
+ _key567 = iprot.readString();
+ _val568 = iprot.readString();
+ struct.scheduler_meta.put(_key567, _val568);
}
}
struct.set_scheduler_meta_isSet(true);
@@ -1426,15 +1426,15 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
}
if (incoming.get(6)) {
{
- org.apache.thrift.protocol.TMap _map536 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32());
- struct.resources_map = new HashMap<String,Double>(2*_map536.size);
- String _key537;
- double _val538;
- for (int _i539 = 0; _i539 < _map536.size; ++_i539)
+ org.apache.thrift.protocol.TMap _map570 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32());
+ struct.resources_map = new HashMap<String,Double>(2*_map570.size);
+ String _key571;
+ double _val572;
+ for (int _i573 = 0; _i573 < _map570.size; ++_i573)
{
- _key537 = iprot.readString();
- _val538 = iprot.readDouble();
- struct.resources_map.put(_key537, _val538);
+ _key571 = iprot.readString();
+ _val572 = iprot.readDouble();
+ struct.resources_map.put(_key571, _val572);
}
}
struct.set_resources_map_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java b/storm-core/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
new file mode 100644
index 0000000..d704005
--- /dev/null
+++ b/storm-core/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
@@ -0,0 +1,624 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/**
+ * Autogenerated by Thrift Compiler (0.9.3)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.storm.generated;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+public class SupervisorPageInfo implements org.apache.thrift.TBase<SupervisorPageInfo, SupervisorPageInfo._Fields>, java.io.Serializable, Cloneable, Comparable<SupervisorPageInfo> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SupervisorPageInfo");
+
+ private static final org.apache.thrift.protocol.TField SUPERVISOR_SUMMARIES_FIELD_DESC = new org.apache.thrift.protocol.TField("supervisor_summaries", org.apache.thrift.protocol.TType.LIST, (short)1);
+ private static final org.apache.thrift.protocol.TField WORKER_SUMMARIES_FIELD_DESC = new org.apache.thrift.protocol.TField("worker_summaries", org.apache.thrift.protocol.TType.LIST, (short)2);
+
+ private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new SupervisorPageInfoStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new SupervisorPageInfoTupleSchemeFactory());
+ }
+
+ private List<SupervisorSummary> supervisor_summaries; // optional
+ private List<WorkerSummary> worker_summaries; // optional
+
+ /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
+ public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ SUPERVISOR_SUMMARIES((short)1, "supervisor_summaries"),
+ WORKER_SUMMARIES((short)2, "worker_summaries");
+
+ private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+
+ static {
+ for (_Fields field : EnumSet.allOf(_Fields.class)) {
+ byName.put(field.getFieldName(), field);
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, or null if its not found.
+ */
+ public static _Fields findByThriftId(int fieldId) {
+ switch(fieldId) {
+ case 1: // SUPERVISOR_SUMMARIES
+ return SUPERVISOR_SUMMARIES;
+ case 2: // WORKER_SUMMARIES
+ return WORKER_SUMMARIES;
+ default:
+ return null;
+ }
+ }
+
+ /**
+ * Find the _Fields constant that matches fieldId, throwing an exception
+ * if it is not found.
+ */
+ public static _Fields findByThriftIdOrThrow(int fieldId) {
+ _Fields fields = findByThriftId(fieldId);
+ if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
+ return fields;
+ }
+
+ /**
+ * Find the _Fields constant that matches name, or null if its not found.
+ */
+ public static _Fields findByName(String name) {
+ return byName.get(name);
+ }
+
+ private final short _thriftId;
+ private final String _fieldName;
+
+ _Fields(short thriftId, String fieldName) {
+ _thriftId = thriftId;
+ _fieldName = fieldName;
+ }
+
+ public short getThriftFieldId() {
+ return _thriftId;
+ }
+
+ public String getFieldName() {
+ return _fieldName;
+ }
+ }
+
+ // isset id assignments
+ private static final _Fields optionals[] = {_Fields.SUPERVISOR_SUMMARIES,_Fields.WORKER_SUMMARIES};
+ public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ static {
+ Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUPERVISOR_SUMMARIES, new org.apache.thrift.meta_data.FieldMetaData("supervisor_summaries", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SupervisorSummary.class))));
+ tmpMap.put(_Fields.WORKER_SUMMARIES, new org.apache.thrift.meta_data.FieldMetaData("worker_summaries", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT , "WorkerSummary"))));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(SupervisorPageInfo.class, metaDataMap);
+ }
+
+ public SupervisorPageInfo() {
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public SupervisorPageInfo(SupervisorPageInfo other) {
+ if (other.is_set_supervisor_summaries()) {
+ List<SupervisorSummary> __this__supervisor_summaries = new ArrayList<SupervisorSummary>(other.supervisor_summaries.size());
+ for (SupervisorSummary other_element : other.supervisor_summaries) {
+ __this__supervisor_summaries.add(new SupervisorSummary(other_element));
+ }
+ this.supervisor_summaries = __this__supervisor_summaries;
+ }
+ if (other.is_set_worker_summaries()) {
+ List<WorkerSummary> __this__worker_summaries = new ArrayList<WorkerSummary>(other.worker_summaries.size());
+ for (WorkerSummary other_element : other.worker_summaries) {
+ __this__worker_summaries.add(other_element);
+ }
+ this.worker_summaries = __this__worker_summaries;
+ }
+ }
+
+ public SupervisorPageInfo deepCopy() {
+ return new SupervisorPageInfo(this);
+ }
+
+ @Override
+ public void clear() {
+ this.supervisor_summaries = null;
+ this.worker_summaries = null;
+ }
+
+ public int get_supervisor_summaries_size() {
+ return (this.supervisor_summaries == null) ? 0 : this.supervisor_summaries.size();
+ }
+
+ public java.util.Iterator<SupervisorSummary> get_supervisor_summaries_iterator() {
+ return (this.supervisor_summaries == null) ? null : this.supervisor_summaries.iterator();
+ }
+
+ public void add_to_supervisor_summaries(SupervisorSummary elem) {
+ if (this.supervisor_summaries == null) {
+ this.supervisor_summaries = new ArrayList<SupervisorSummary>();
+ }
+ this.supervisor_summaries.add(elem);
+ }
+
+ public List<SupervisorSummary> get_supervisor_summaries() {
+ return this.supervisor_summaries;
+ }
+
+ public void set_supervisor_summaries(List<SupervisorSummary> supervisor_summaries) {
+ this.supervisor_summaries = supervisor_summaries;
+ }
+
+ public void unset_supervisor_summaries() {
+ this.supervisor_summaries = null;
+ }
+
+ /** Returns true if field supervisor_summaries is set (has been assigned a value) and false otherwise */
+ public boolean is_set_supervisor_summaries() {
+ return this.supervisor_summaries != null;
+ }
+
+ public void set_supervisor_summaries_isSet(boolean value) {
+ if (!value) {
+ this.supervisor_summaries = null;
+ }
+ }
+
+ public int get_worker_summaries_size() {
+ return (this.worker_summaries == null) ? 0 : this.worker_summaries.size();
+ }
+
+ public java.util.Iterator<WorkerSummary> get_worker_summaries_iterator() {
+ return (this.worker_summaries == null) ? null : this.worker_summaries.iterator();
+ }
+
+ public void add_to_worker_summaries(WorkerSummary elem) {
+ if (this.worker_summaries == null) {
+ this.worker_summaries = new ArrayList<WorkerSummary>();
+ }
+ this.worker_summaries.add(elem);
+ }
+
+ public List<WorkerSummary> get_worker_summaries() {
+ return this.worker_summaries;
+ }
+
+ public void set_worker_summaries(List<WorkerSummary> worker_summaries) {
+ this.worker_summaries = worker_summaries;
+ }
+
+ public void unset_worker_summaries() {
+ this.worker_summaries = null;
+ }
+
+ /** Returns true if field worker_summaries is set (has been assigned a value) and false otherwise */
+ public boolean is_set_worker_summaries() {
+ return this.worker_summaries != null;
+ }
+
+ public void set_worker_summaries_isSet(boolean value) {
+ if (!value) {
+ this.worker_summaries = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SUPERVISOR_SUMMARIES:
+ if (value == null) {
+ unset_supervisor_summaries();
+ } else {
+ set_supervisor_summaries((List<SupervisorSummary>)value);
+ }
+ break;
+
+ case WORKER_SUMMARIES:
+ if (value == null) {
+ unset_worker_summaries();
+ } else {
+ set_worker_summaries((List<WorkerSummary>)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SUPERVISOR_SUMMARIES:
+ return get_supervisor_summaries();
+
+ case WORKER_SUMMARIES:
+ return get_worker_summaries();
+
+ }
+ throw new IllegalStateException();
+ }
+
+ /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
+ public boolean isSet(_Fields field) {
+ if (field == null) {
+ throw new IllegalArgumentException();
+ }
+
+ switch (field) {
+ case SUPERVISOR_SUMMARIES:
+ return is_set_supervisor_summaries();
+ case WORKER_SUMMARIES:
+ return is_set_worker_summaries();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof SupervisorPageInfo)
+ return this.equals((SupervisorPageInfo)that);
+ return false;
+ }
+
+ public boolean equals(SupervisorPageInfo that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_supervisor_summaries = true && this.is_set_supervisor_summaries();
+ boolean that_present_supervisor_summaries = true && that.is_set_supervisor_summaries();
+ if (this_present_supervisor_summaries || that_present_supervisor_summaries) {
+ if (!(this_present_supervisor_summaries && that_present_supervisor_summaries))
+ return false;
+ if (!this.supervisor_summaries.equals(that.supervisor_summaries))
+ return false;
+ }
+
+ boolean this_present_worker_summaries = true && this.is_set_worker_summaries();
+ boolean that_present_worker_summaries = true && that.is_set_worker_summaries();
+ if (this_present_worker_summaries || that_present_worker_summaries) {
+ if (!(this_present_worker_summaries && that_present_worker_summaries))
+ return false;
+ if (!this.worker_summaries.equals(that.worker_summaries))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_supervisor_summaries = true && (is_set_supervisor_summaries());
+ list.add(present_supervisor_summaries);
+ if (present_supervisor_summaries)
+ list.add(supervisor_summaries);
+
+ boolean present_worker_summaries = true && (is_set_worker_summaries());
+ list.add(present_worker_summaries);
+ if (present_worker_summaries)
+ list.add(worker_summaries);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(SupervisorPageInfo other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(is_set_supervisor_summaries()).compareTo(other.is_set_supervisor_summaries());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_supervisor_summaries()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.supervisor_summaries, other.supervisor_summaries);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(is_set_worker_summaries()).compareTo(other.is_set_worker_summaries());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_worker_summaries()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.worker_summaries, other.worker_summaries);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ return 0;
+ }
+
+ public _Fields fieldForId(int fieldId) {
+ return _Fields.findByThriftId(fieldId);
+ }
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
+ schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
+ schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("SupervisorPageInfo(");
+ boolean first = true;
+
+ if (is_set_supervisor_summaries()) {
+ sb.append("supervisor_summaries:");
+ if (this.supervisor_summaries == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.supervisor_summaries);
+ }
+ first = false;
+ }
+ if (is_set_worker_summaries()) {
+ if (!first) sb.append(", ");
+ sb.append("worker_summaries:");
+ if (this.worker_summaries == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.worker_summaries);
+ }
+ first = false;
+ }
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class SupervisorPageInfoStandardSchemeFactory implements SchemeFactory {
+ public SupervisorPageInfoStandardScheme getScheme() {
+ return new SupervisorPageInfoStandardScheme();
+ }
+ }
+
+ private static class SupervisorPageInfoStandardScheme extends StandardScheme<SupervisorPageInfo> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, SupervisorPageInfo struct) throws org.apache.thrift.TException {
+ org.apache.thrift.protocol.TField schemeField;
+ iprot.readStructBegin();
+ while (true)
+ {
+ schemeField = iprot.readFieldBegin();
+ if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ break;
+ }
+ switch (schemeField.id) {
+ case 1: // SUPERVISOR_SUMMARIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list402 = iprot.readListBegin();
+ struct.supervisor_summaries = new ArrayList<SupervisorSummary>(_list402.size);
+ SupervisorSummary _elem403;
+ for (int _i404 = 0; _i404 < _list402.size; ++_i404)
+ {
+ _elem403 = new SupervisorSummary();
+ _elem403.read(iprot);
+ struct.supervisor_summaries.add(_elem403);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_supervisor_summaries_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 2: // WORKER_SUMMARIES
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list405 = iprot.readListBegin();
+ struct.worker_summaries = new ArrayList<WorkerSummary>(_list405.size);
+ WorkerSummary _elem406;
+ for (int _i407 = 0; _i407 < _list405.size; ++_i407)
+ {
+ _elem406 = new WorkerSummary();
+ _elem406.read(iprot);
+ struct.worker_summaries.add(_elem406);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_worker_summaries_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ default:
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+ struct.validate();
+ }
+
+ public void write(org.apache.thrift.protocol.TProtocol oprot, SupervisorPageInfo struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.supervisor_summaries != null) {
+ if (struct.is_set_supervisor_summaries()) {
+ oprot.writeFieldBegin(SUPERVISOR_SUMMARIES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.supervisor_summaries.size()));
+ for (SupervisorSummary _iter408 : struct.supervisor_summaries)
+ {
+ _iter408.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.worker_summaries != null) {
+ if (struct.is_set_worker_summaries()) {
+ oprot.writeFieldBegin(WORKER_SUMMARIES_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.worker_summaries.size()));
+ for (WorkerSummary _iter409 : struct.worker_summaries)
+ {
+ _iter409.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class SupervisorPageInfoTupleSchemeFactory implements SchemeFactory {
+ public SupervisorPageInfoTupleScheme getScheme() {
+ return new SupervisorPageInfoTupleScheme();
+ }
+ }
+
+ private static class SupervisorPageInfoTupleScheme extends TupleScheme<SupervisorPageInfo> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, SupervisorPageInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.is_set_supervisor_summaries()) {
+ optionals.set(0);
+ }
+ if (struct.is_set_worker_summaries()) {
+ optionals.set(1);
+ }
+ oprot.writeBitSet(optionals, 2);
+ if (struct.is_set_supervisor_summaries()) {
+ {
+ oprot.writeI32(struct.supervisor_summaries.size());
+ for (SupervisorSummary _iter410 : struct.supervisor_summaries)
+ {
+ _iter410.write(oprot);
+ }
+ }
+ }
+ if (struct.is_set_worker_summaries()) {
+ {
+ oprot.writeI32(struct.worker_summaries.size());
+ for (WorkerSummary _iter411 : struct.worker_summaries)
+ {
+ _iter411.write(oprot);
+ }
+ }
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, SupervisorPageInfo struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(2);
+ if (incoming.get(0)) {
+ {
+ org.apache.thrift.protocol.TList _list412 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.supervisor_summaries = new ArrayList<SupervisorSummary>(_list412.size);
+ SupervisorSummary _elem413;
+ for (int _i414 = 0; _i414 < _list412.size; ++_i414)
+ {
+ _elem413 = new SupervisorSummary();
+ _elem413.read(iprot);
+ struct.supervisor_summaries.add(_elem413);
+ }
+ }
+ struct.set_supervisor_summaries_isSet(true);
+ }
+ if (incoming.get(1)) {
+ {
+ org.apache.thrift.protocol.TList _list415 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.worker_summaries = new ArrayList<WorkerSummary>(_list415.size);
+ WorkerSummary _elem416;
+ for (int _i417 = 0; _i417 < _list415.size; ++_i417)
+ {
+ _elem416 = new WorkerSummary();
+ _elem416.read(iprot);
+ struct.worker_summaries.add(_elem416);
+ }
+ }
+ struct.set_worker_summaries_isSet(true);
+ }
+ }
+ }
+
+}
+
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java b/storm-core/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
index 3ec261f..63225dc 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
@@ -364,13 +364,13 @@ public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHist
case 1: // TOPO_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list714 = iprot.readListBegin();
- struct.topo_ids = new ArrayList<String>(_list714.size);
- String _elem715;
- for (int _i716 = 0; _i716 < _list714.size; ++_i716)
+ org.apache.thrift.protocol.TList _list748 = iprot.readListBegin();
+ struct.topo_ids = new ArrayList<String>(_list748.size);
+ String _elem749;
+ for (int _i750 = 0; _i750 < _list748.size; ++_i750)
{
- _elem715 = iprot.readString();
- struct.topo_ids.add(_elem715);
+ _elem749 = iprot.readString();
+ struct.topo_ids.add(_elem749);
}
iprot.readListEnd();
}
@@ -396,9 +396,9 @@ public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHist
oprot.writeFieldBegin(TOPO_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.topo_ids.size()));
- for (String _iter717 : struct.topo_ids)
+ for (String _iter751 : struct.topo_ids)
{
- oprot.writeString(_iter717);
+ oprot.writeString(_iter751);
}
oprot.writeListEnd();
}
@@ -429,9 +429,9 @@ public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHist
if (struct.is_set_topo_ids()) {
{
oprot.writeI32(struct.topo_ids.size());
- for (String _iter718 : struct.topo_ids)
+ for (String _iter752 : struct.topo_ids)
{
- oprot.writeString(_iter718);
+ oprot.writeString(_iter752);
}
}
}
@@ -443,13 +443,13 @@ public class TopologyHistoryInfo implements org.apache.thrift.TBase<TopologyHist
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.STRING, iprot.readI32());
- struct.topo_ids = new ArrayList<String>(_list719.size);
- String _elem720;
- for (int _i721 = 0; _i721 < _list719.size; ++_i721)
+ org.apache.thrift.protocol.TList _list753 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.topo_ids = new ArrayList<String>(_list753.size);
+ String _elem754;
+ for (int _i755 = 0; _i755 < _list753.size; ++_i755)
{
- _elem720 = iprot.readString();
- struct.topo_ids.add(_elem720);
+ _elem754 = iprot.readString();
+ struct.topo_ids.add(_elem754);
}
}
struct.set_topo_ids_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/0e0bcf27/storm-core/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/TopologyPageInfo.java b/storm-core/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
index 1d9214b..e573ba3 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
@@ -70,6 +70,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
private static final org.apache.thrift.protocol.TField OWNER_FIELD_DESC = new org.apache.thrift.protocol.TField("owner", org.apache.thrift.protocol.TType.STRING, (short)13);
private static final org.apache.thrift.protocol.TField DEBUG_OPTIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("debug_options", org.apache.thrift.protocol.TType.STRUCT, (short)14);
private static final org.apache.thrift.protocol.TField REPLICATION_COUNT_FIELD_DESC = new org.apache.thrift.protocol.TField("replication_count", org.apache.thrift.protocol.TType.I32, (short)15);
+ private static final org.apache.thrift.protocol.TField WORKERS_FIELD_DESC = new org.apache.thrift.protocol.TField("workers", org.apache.thrift.protocol.TType.LIST, (short)16);
private static final org.apache.thrift.protocol.TField REQUESTED_MEMONHEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("requested_memonheap", org.apache.thrift.protocol.TType.DOUBLE, (short)521);
private static final org.apache.thrift.protocol.TField REQUESTED_MEMOFFHEAP_FIELD_DESC = new org.apache.thrift.protocol.TField("requested_memoffheap", org.apache.thrift.protocol.TType.DOUBLE, (short)522);
private static final org.apache.thrift.protocol.TField REQUESTED_CPU_FIELD_DESC = new org.apache.thrift.protocol.TField("requested_cpu", org.apache.thrift.protocol.TType.DOUBLE, (short)523);
@@ -98,6 +99,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
private String owner; // optional
private DebugOptions debug_options; // optional
private int replication_count; // optional
+ private List<WorkerSummary> workers; // optional
private double requested_memonheap; // optional
private double requested_memoffheap; // optional
private double requested_cpu; // optional
@@ -122,6 +124,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
OWNER((short)13, "owner"),
DEBUG_OPTIONS((short)14, "debug_options"),
REPLICATION_COUNT((short)15, "replication_count"),
+ WORKERS((short)16, "workers"),
REQUESTED_MEMONHEAP((short)521, "requested_memonheap"),
REQUESTED_MEMOFFHEAP((short)522, "requested_memoffheap"),
REQUESTED_CPU((short)523, "requested_cpu"),
@@ -172,6 +175,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return DEBUG_OPTIONS;
case 15: // REPLICATION_COUNT
return REPLICATION_COUNT;
+ case 16: // WORKERS
+ return WORKERS;
case 521: // REQUESTED_MEMONHEAP
return REQUESTED_MEMONHEAP;
case 522: // REQUESTED_MEMOFFHEAP
@@ -236,7 +241,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
private static final int __ASSIGNED_MEMOFFHEAP_ISSET_ID = 9;
private static final int __ASSIGNED_CPU_ISSET_ID = 10;
private short __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.NAME,_Fields.UPTIME_SECS,_Fields.STATUS,_Fields.NUM_TASKS,_Fields.NUM_WORKERS,_Fields.NUM_EXECUTORS,_Fields.TOPOLOGY_CONF,_Fields.ID_TO_SPOUT_AGG_STATS,_Fields.ID_TO_BOLT_AGG_STATS,_Fields.SCHED_STATUS,_Fields.TOPOLOGY_STATS,_Fields.OWNER,_Fields.DEBUG_OPTIONS,_Fields.REPLICATION_COUNT,_Fields.REQUESTED_MEMONHEAP,_Fields.REQUESTED_MEMOFFHEAP,_Fields.REQUESTED_CPU,_Fields.ASSIGNED_MEMONHEAP,_Fields.ASSIGNED_MEMOFFHEAP,_Fields.ASSIGNED_CPU};
+ private static final _Fields optionals[] = {_Fields.NAME,_Fields.UPTIME_SECS,_Fields.STATUS,_Fields.NUM_TASKS,_Fields.NUM_WORKERS,_Fields.NUM_EXECUTORS,_Fields.TOPOLOGY_CONF,_Fields.ID_TO_SPOUT_AGG_STATS,_Fields.ID_TO_BOLT_AGG_STATS,_Fields.SCHED_STATUS,_Fields.TOPOLOGY_STATS,_Fields.OWNER,_Fields.DEBUG_OPTIONS,_Fields.REPLICATION_COUNT,_Fields.WORKERS,_Fields.REQUESTED_MEMONHEAP,_Fields.REQUESTED_MEMOFFHEAP,_Fields.REQUESTED_CPU,_Fields.ASSIGNED_MEMONHEAP,_Fields.ASSIGNED_MEMOFFHEAP,_Fields.ASSIGNED_CPU};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -274,6 +279,9 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DebugOptions.class)));
tmpMap.put(_Fields.REPLICATION_COUNT, new org.apache.thrift.meta_data.FieldMetaData("replication_count", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+ tmpMap.put(_Fields.WORKERS, new org.apache.thrift.meta_data.FieldMetaData("workers", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, WorkerSummary.class))));
tmpMap.put(_Fields.REQUESTED_MEMONHEAP, new org.apache.thrift.meta_data.FieldMetaData("requested_memonheap", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE)));
tmpMap.put(_Fields.REQUESTED_MEMOFFHEAP, new org.apache.thrift.meta_data.FieldMetaData("requested_memoffheap", org.apache.thrift.TFieldRequirementType.OPTIONAL,
@@ -364,6 +372,13 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
this.debug_options = new DebugOptions(other.debug_options);
}
this.replication_count = other.replication_count;
+ if (other.is_set_workers()) {
+ List<WorkerSummary> __this__workers = new ArrayList<WorkerSummary>(other.workers.size());
+ for (WorkerSummary other_element : other.workers) {
+ __this__workers.add(new WorkerSummary(other_element));
+ }
+ this.workers = __this__workers;
+ }
this.requested_memonheap = other.requested_memonheap;
this.requested_memoffheap = other.requested_memoffheap;
this.requested_cpu = other.requested_cpu;
@@ -398,6 +413,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
this.debug_options = null;
set_replication_count_isSet(false);
this.replication_count = 0;
+ this.workers = null;
set_requested_memonheap_isSet(false);
this.requested_memonheap = 0.0;
set_requested_memoffheap_isSet(false);
@@ -774,6 +790,44 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
__isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __REPLICATION_COUNT_ISSET_ID, value);
}
+ public int get_workers_size() {
+ return (this.workers == null) ? 0 : this.workers.size();
+ }
+
+ public java.util.Iterator<WorkerSummary> get_workers_iterator() {
+ return (this.workers == null) ? null : this.workers.iterator();
+ }
+
+ public void add_to_workers(WorkerSummary elem) {
+ if (this.workers == null) {
+ this.workers = new ArrayList<WorkerSummary>();
+ }
+ this.workers.add(elem);
+ }
+
+ public List<WorkerSummary> get_workers() {
+ return this.workers;
+ }
+
+ public void set_workers(List<WorkerSummary> workers) {
+ this.workers = workers;
+ }
+
+ public void unset_workers() {
+ this.workers = null;
+ }
+
+ /** Returns true if field workers is set (has been assigned a value) and false otherwise */
+ public boolean is_set_workers() {
+ return this.workers != null;
+ }
+
+ public void set_workers_isSet(boolean value) {
+ if (!value) {
+ this.workers = null;
+ }
+ }
+
public double get_requested_memonheap() {
return this.requested_memonheap;
}
@@ -1028,6 +1082,14 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
}
break;
+ case WORKERS:
+ if (value == null) {
+ unset_workers();
+ } else {
+ set_workers((List<WorkerSummary>)value);
+ }
+ break;
+
case REQUESTED_MEMONHEAP:
if (value == null) {
unset_requested_memonheap();
@@ -1126,6 +1188,9 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
case REPLICATION_COUNT:
return get_replication_count();
+ case WORKERS:
+ return get_workers();
+
case REQUESTED_MEMONHEAP:
return get_requested_memonheap();
@@ -1185,6 +1250,8 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return is_set_debug_options();
case REPLICATION_COUNT:
return is_set_replication_count();
+ case WORKERS:
+ return is_set_workers();
case REQUESTED_MEMONHEAP:
return is_set_requested_memonheap();
case REQUESTED_MEMOFFHEAP:
@@ -1349,6 +1416,15 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return false;
}
+ boolean this_present_workers = true && this.is_set_workers();
+ boolean that_present_workers = true && that.is_set_workers();
+ if (this_present_workers || that_present_workers) {
+ if (!(this_present_workers && that_present_workers))
+ return false;
+ if (!this.workers.equals(that.workers))
+ return false;
+ }
+
boolean this_present_requested_memonheap = true && this.is_set_requested_memonheap();
boolean that_present_requested_memonheap = true && that.is_set_requested_memonheap();
if (this_present_requested_memonheap || that_present_requested_memonheap) {
@@ -1485,6 +1561,11 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
if (present_replication_count)
list.add(replication_count);
+ boolean present_workers = true && (is_set_workers());
+ list.add(present_workers);
+ if (present_workers)
+ list.add(workers);
+
boolean present_requested_memonheap = true && (is_set_requested_memonheap());
list.add(present_requested_memonheap);
if (present_requested_memonheap)
@@ -1676,6 +1757,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(is_set_workers()).compareTo(other.is_set_workers());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (is_set_workers()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.workers, other.workers);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
lastComparison = Boolean.valueOf(is_set_requested_memonheap()).compareTo(other.is_set_requested_memonheap());
if (lastComparison != 0) {
return lastComparison;
@@ -1883,6 +1974,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
sb.append(this.replication_count);
first = false;
}
+ if (is_set_workers()) {
+ if (!first) sb.append(", ");
+ sb.append("workers:");
+ if (this.workers == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.workers);
+ }
+ first = false;
+ }
if (is_set_requested_memonheap()) {
if (!first) sb.append(", ");
sb.append("requested_memonheap:");
@@ -2041,16 +2142,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
case 9: // ID_TO_SPOUT_AGG_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map402 = iprot.readMapBegin();
- struct.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map402.size);
- String _key403;
- ComponentAggregateStats _val404;
- for (int _i405 = 0; _i405 < _map402.size; ++_i405)
+ org.apache.thrift.protocol.TMap _map428 = iprot.readMapBegin();
+ struct.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map428.size);
+ String _key429;
+ ComponentAggregateStats _val430;
+ for (int _i431 = 0; _i431 < _map428.size; ++_i431)
{
- _key403 = iprot.readString();
- _val404 = new ComponentAggregateStats();
- _val404.read(iprot);
- struct.id_to_spout_agg_stats.put(_key403, _val404);
+ _key429 = iprot.readString();
+ _val430 = new ComponentAggregateStats();
+ _val430.read(iprot);
+ struct.id_to_spout_agg_stats.put(_key429, _val430);
}
iprot.readMapEnd();
}
@@ -2062,16 +2163,16 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
case 10: // ID_TO_BOLT_AGG_STATS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map406 = iprot.readMapBegin();
- struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map406.size);
- String _key407;
- ComponentAggregateStats _val408;
- for (int _i409 = 0; _i409 < _map406.size; ++_i409)
+ org.apache.thrift.protocol.TMap _map432 = iprot.readMapBegin();
+ struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map432.size);
+ String _key433;
+ ComponentAggregateStats _val434;
+ for (int _i435 = 0; _i435 < _map432.size; ++_i435)
{
- _key407 = iprot.readString();
- _val408 = new ComponentAggregateStats();
- _val408.read(iprot);
- struct.id_to_bolt_agg_stats.put(_key407, _val408);
+ _key433 = iprot.readString();
+ _val434 = new ComponentAggregateStats();
+ _val434.read(iprot);
+ struct.id_to_bolt_agg_stats.put(_key433, _val434);
}
iprot.readMapEnd();
}
@@ -2122,6 +2223,25 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 16: // WORKERS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list436 = iprot.readListBegin();
+ struct.workers = new ArrayList<WorkerSummary>(_list436.size);
+ WorkerSummary _elem437;
+ for (int _i438 = 0; _i438 < _list436.size; ++_i438)
+ {
+ _elem437 = new WorkerSummary();
+ _elem437.read(iprot);
+ struct.workers.add(_elem437);
+ }
+ iprot.readListEnd();
+ }
+ struct.set_workers_isSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
case 521: // REQUESTED_MEMONHEAP
if (schemeField.type == org.apache.thrift.protocol.TType.DOUBLE) {
struct.requested_memonheap = iprot.readDouble();
@@ -2234,10 +2354,10 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
oprot.writeFieldBegin(ID_TO_SPOUT_AGG_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.id_to_spout_agg_stats.size()));
- for (Map.Entry<String, ComponentAggregateStats> _iter410 : struct.id_to_spout_agg_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter439 : struct.id_to_spout_agg_stats.entrySet())
{
- oprot.writeString(_iter410.getKey());
- _iter410.getValue().write(oprot);
+ oprot.writeString(_iter439.getKey());
+ _iter439.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -2249,10 +2369,10 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
oprot.writeFieldBegin(ID_TO_BOLT_AGG_STATS_FIELD_DESC);
{
oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.id_to_bolt_agg_stats.size()));
- for (Map.Entry<String, ComponentAggregateStats> _iter411 : struct.id_to_bolt_agg_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter440 : struct.id_to_bolt_agg_stats.entrySet())
{
- oprot.writeString(_iter411.getKey());
- _iter411.getValue().write(oprot);
+ oprot.writeString(_iter440.getKey());
+ _iter440.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -2292,6 +2412,20 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
oprot.writeI32(struct.replication_count);
oprot.writeFieldEnd();
}
+ if (struct.workers != null) {
+ if (struct.is_set_workers()) {
+ oprot.writeFieldBegin(WORKERS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.workers.size()));
+ for (WorkerSummary _iter441 : struct.workers)
+ {
+ _iter441.write(oprot);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
if (struct.is_set_requested_memonheap()) {
oprot.writeFieldBegin(REQUESTED_MEMONHEAP_FIELD_DESC);
oprot.writeDouble(struct.requested_memonheap);
@@ -2383,25 +2517,28 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
if (struct.is_set_replication_count()) {
optionals.set(13);
}
- if (struct.is_set_requested_memonheap()) {
+ if (struct.is_set_workers()) {
optionals.set(14);
}
- if (struct.is_set_requested_memoffheap()) {
+ if (struct.is_set_requested_memonheap()) {
optionals.set(15);
}
- if (struct.is_set_requested_cpu()) {
+ if (struct.is_set_requested_memoffheap()) {
optionals.set(16);
}
- if (struct.is_set_assigned_memonheap()) {
+ if (struct.is_set_requested_cpu()) {
optionals.set(17);
}
- if (struct.is_set_assigned_memoffheap()) {
+ if (struct.is_set_assigned_memonheap()) {
optionals.set(18);
}
- if (struct.is_set_assigned_cpu()) {
+ if (struct.is_set_assigned_memoffheap()) {
optionals.set(19);
}
- oprot.writeBitSet(optionals, 20);
+ if (struct.is_set_assigned_cpu()) {
+ optionals.set(20);
+ }
+ oprot.writeBitSet(optionals, 21);
if (struct.is_set_name()) {
oprot.writeString(struct.name);
}
@@ -2426,20 +2563,20 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
if (struct.is_set_id_to_spout_agg_stats()) {
{
oprot.writeI32(struct.id_to_spout_agg_stats.size());
- for (Map.Entry<String, ComponentAggregateStats> _iter412 : struct.id_to_spout_agg_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter442 : struct.id_to_spout_agg_stats.entrySet())
{
- oprot.writeString(_iter412.getKey());
- _iter412.getValue().write(oprot);
+ oprot.writeString(_iter442.getKey());
+ _iter442.getValue().write(oprot);
}
}
}
if (struct.is_set_id_to_bolt_agg_stats()) {
{
oprot.writeI32(struct.id_to_bolt_agg_stats.size());
- for (Map.Entry<String, ComponentAggregateStats> _iter413 : struct.id_to_bolt_agg_stats.entrySet())
+ for (Map.Entry<String, ComponentAggregateStats> _iter443 : struct.id_to_bolt_agg_stats.entrySet())
{
- oprot.writeString(_iter413.getKey());
- _iter413.getValue().write(oprot);
+ oprot.writeString(_iter443.getKey());
+ _iter443.getValue().write(oprot);
}
}
}
@@ -2458,6 +2595,15 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
if (struct.is_set_replication_count()) {
oprot.writeI32(struct.replication_count);
}
+ if (struct.is_set_workers()) {
+ {
+ oprot.writeI32(struct.workers.size());
+ for (WorkerSummary _iter444 : struct.workers)
+ {
+ _iter444.write(oprot);
+ }
+ }
+ }
if (struct.is_set_requested_memonheap()) {
oprot.writeDouble(struct.requested_memonheap);
}
@@ -2483,7 +2629,7 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
TTupleProtocol iprot = (TTupleProtocol) prot;
struct.id = iprot.readString();
struct.set_id_isSet(true);
- BitSet incoming = iprot.readBitSet(20);
+ BitSet incoming = iprot.readBitSet(21);
if (incoming.get(0)) {
struct.name = iprot.readString();
struct.set_name_isSet(true);
@@ -2514,32 +2660,32 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
}
if (incoming.get(7)) {
{
- org.apache.thrift.protocol.TMap _map414 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.id_to_spout_agg_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 _map445 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.id_to_spout_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map445.size);
+ String _key446;
+ ComponentAggregateStats _val447;
+ for (int _i448 = 0; _i448 < _map445.size; ++_i448)
{
- _key415 = iprot.readString();
- _val416 = new ComponentAggregateStats();
- _val416.read(iprot);
- struct.id_to_spout_agg_stats.put(_key415, _val416);
+ _key446 = iprot.readString();
+ _val447 = new ComponentAggregateStats();
+ _val447.read(iprot);
+ struct.id_to_spout_agg_stats.put(_key446, _val447);
}
}
struct.set_id_to_spout_agg_stats_isSet(true);
}
if (incoming.get(8)) {
{
- org.apache.thrift.protocol.TMap _map418 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map418.size);
- String _key419;
- ComponentAggregateStats _val420;
- for (int _i421 = 0; _i421 < _map418.size; ++_i421)
+ org.apache.thrift.protocol.TMap _map449 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.id_to_bolt_agg_stats = new HashMap<String,ComponentAggregateStats>(2*_map449.size);
+ String _key450;
+ ComponentAggregateStats _val451;
+ for (int _i452 = 0; _i452 < _map449.size; ++_i452)
{
- _key419 = iprot.readString();
- _val420 = new ComponentAggregateStats();
- _val420.read(iprot);
- struct.id_to_bolt_agg_stats.put(_key419, _val420);
+ _key450 = iprot.readString();
+ _val451 = new ComponentAggregateStats();
+ _val451.read(iprot);
+ struct.id_to_bolt_agg_stats.put(_key450, _val451);
}
}
struct.set_id_to_bolt_agg_stats_isSet(true);
@@ -2567,26 +2713,40 @@ public class TopologyPageInfo implements org.apache.thrift.TBase<TopologyPageInf
struct.set_replication_count_isSet(true);
}
if (incoming.get(14)) {
+ {
+ org.apache.thrift.protocol.TList _list453 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.workers = new ArrayList<WorkerSummary>(_list453.size);
+ WorkerSummary _elem454;
+ for (int _i455 = 0; _i455 < _list453.size; ++_i455)
+ {
+ _elem454 = new WorkerSummary();
+ _elem454.read(iprot);
+ struct.workers.add(_elem454);
+ }
+ }
+ struct.set_workers_isSet(true);
+ }
+ if (incoming.get(15)) {
struct.requested_memonheap = iprot.readDouble();
struct.set_requested_memonheap_isSet(true);
}
- if (incoming.get(15)) {
+ if (incoming.get(16)) {
struct.requested_memoffheap = iprot.readDouble();
struct.set_requested_memoffheap_isSet(true);
}
- if (incoming.get(16)) {
+ if (incoming.get(17)) {
struct.requested_cpu = iprot.readDouble();
struct.set_requested_cpu_isSet(true);
}
- if (incoming.get(17)) {
+ if (incoming.get(18)) {
struct.assigned_memonheap = iprot.readDouble();
struct.set_assigned_memonheap_isSet(true);
}
- if (incoming.get(18)) {
+ if (incoming.get(19)) {
struct.assigned_memoffheap = iprot.readDouble();
struct.set_assigned_memoffheap_isSet(true);
}
- if (incoming.get(19)) {
+ if (incoming.get(20)) {
struct.assigned_cpu = iprot.readDouble();
struct.set_assigned_cpu_isSet(true);
}