You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/09/27 21:58:43 UTC
[4/8] storm git commit: STORM-2124: show requested cpu/memory for
each component on topology and component pages
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 8b9bf08..c5c7407 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 _list780 = iprot.readListBegin();
- struct.pulseIds = new ArrayList<String>(_list780.size);
- String _elem781;
- for (int _i782 = 0; _i782 < _list780.size; ++_i782)
+ org.apache.thrift.protocol.TList _list800 = iprot.readListBegin();
+ struct.pulseIds = new ArrayList<String>(_list800.size);
+ String _elem801;
+ for (int _i802 = 0; _i802 < _list800.size; ++_i802)
{
- _elem781 = iprot.readString();
- struct.pulseIds.add(_elem781);
+ _elem801 = iprot.readString();
+ struct.pulseIds.add(_elem801);
}
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 _iter783 : struct.pulseIds)
+ for (String _iter803 : struct.pulseIds)
{
- oprot.writeString(_iter783);
+ oprot.writeString(_iter803);
}
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 _iter784 : struct.pulseIds)
+ for (String _iter804 : struct.pulseIds)
{
- oprot.writeString(_iter784);
+ oprot.writeString(_iter804);
}
}
}
@@ -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 _list785 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.pulseIds = new ArrayList<String>(_list785.size);
- String _elem786;
- for (int _i787 = 0; _i787 < _list785.size; ++_i787)
+ org.apache.thrift.protocol.TList _list805 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.pulseIds = new ArrayList<String>(_list805.size);
+ String _elem806;
+ for (int _i807 = 0; _i807 < _list805.size; ++_i807)
{
- _elem786 = iprot.readString();
- struct.pulseIds.add(_elem786);
+ _elem806 = iprot.readString();
+ struct.pulseIds.add(_elem806);
}
}
struct.set_pulseIds_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 de7cfbf..6a6d4f2 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 _list772 = iprot.readListBegin();
- struct.pulses = new ArrayList<HBPulse>(_list772.size);
- HBPulse _elem773;
- for (int _i774 = 0; _i774 < _list772.size; ++_i774)
+ org.apache.thrift.protocol.TList _list792 = iprot.readListBegin();
+ struct.pulses = new ArrayList<HBPulse>(_list792.size);
+ HBPulse _elem793;
+ for (int _i794 = 0; _i794 < _list792.size; ++_i794)
{
- _elem773 = new HBPulse();
- _elem773.read(iprot);
- struct.pulses.add(_elem773);
+ _elem793 = new HBPulse();
+ _elem793.read(iprot);
+ struct.pulses.add(_elem793);
}
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 _iter775 : struct.pulses)
+ for (HBPulse _iter795 : struct.pulses)
{
- _iter775.write(oprot);
+ _iter795.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 _iter776 : struct.pulses)
+ for (HBPulse _iter796 : struct.pulses)
{
- _iter776.write(oprot);
+ _iter796.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 _list777 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.pulses = new ArrayList<HBPulse>(_list777.size);
- HBPulse _elem778;
- for (int _i779 = 0; _i779 < _list777.size; ++_i779)
+ org.apache.thrift.protocol.TList _list797 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.pulses = new ArrayList<HBPulse>(_list797.size);
+ HBPulse _elem798;
+ for (int _i799 = 0; _i799 < _list797.size; ++_i799)
{
- _elem778 = new HBPulse();
- _elem778.read(iprot);
- struct.pulses.add(_elem778);
+ _elem798 = new HBPulse();
+ _elem798.read(iprot);
+ struct.pulses.add(_elem798);
}
}
struct.set_pulses_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 ef7a589..b4795a5 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 _map702 = iprot.readMapBegin();
- struct.approved_workers = new HashMap<String,Integer>(2*_map702.size);
- String _key703;
- int _val704;
- for (int _i705 = 0; _i705 < _map702.size; ++_i705)
+ org.apache.thrift.protocol.TMap _map722 = iprot.readMapBegin();
+ struct.approved_workers = new HashMap<String,Integer>(2*_map722.size);
+ String _key723;
+ int _val724;
+ for (int _i725 = 0; _i725 < _map722.size; ++_i725)
{
- _key703 = iprot.readString();
- _val704 = iprot.readI32();
- struct.approved_workers.put(_key703, _val704);
+ _key723 = iprot.readString();
+ _val724 = iprot.readI32();
+ struct.approved_workers.put(_key723, _val724);
}
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> _iter706 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter726 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter706.getKey());
- oprot.writeI32(_iter706.getValue());
+ oprot.writeString(_iter726.getKey());
+ oprot.writeI32(_iter726.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> _iter707 : struct.approved_workers.entrySet())
+ for (Map.Entry<String, Integer> _iter727 : struct.approved_workers.entrySet())
{
- oprot.writeString(_iter707.getKey());
- oprot.writeI32(_iter707.getValue());
+ oprot.writeString(_iter727.getKey());
+ oprot.writeI32(_iter727.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 _map708 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.approved_workers = new HashMap<String,Integer>(2*_map708.size);
- String _key709;
- int _val710;
- for (int _i711 = 0; _i711 < _map708.size; ++_i711)
+ org.apache.thrift.protocol.TMap _map728 = 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*_map728.size);
+ String _key729;
+ int _val730;
+ for (int _i731 = 0; _i731 < _map728.size; ++_i731)
{
- _key709 = iprot.readString();
- _val710 = iprot.readI32();
- struct.approved_workers.put(_key709, _val710);
+ _key729 = iprot.readString();
+ _val730 = iprot.readI32();
+ struct.approved_workers.put(_key729, _val730);
}
}
struct.set_approved_workers_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 a86b7f3..b3194ad 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 _map712 = iprot.readMapBegin();
- struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map712.size);
- int _key713;
- LocalAssignment _val714;
- for (int _i715 = 0; _i715 < _map712.size; ++_i715)
+ org.apache.thrift.protocol.TMap _map732 = iprot.readMapBegin();
+ struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map732.size);
+ int _key733;
+ LocalAssignment _val734;
+ for (int _i735 = 0; _i735 < _map732.size; ++_i735)
{
- _key713 = iprot.readI32();
- _val714 = new LocalAssignment();
- _val714.read(iprot);
- struct.assignments.put(_key713, _val714);
+ _key733 = iprot.readI32();
+ _val734 = new LocalAssignment();
+ _val734.read(iprot);
+ struct.assignments.put(_key733, _val734);
}
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> _iter716 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter736 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter716.getKey());
- _iter716.getValue().write(oprot);
+ oprot.writeI32(_iter736.getKey());
+ _iter736.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> _iter717 : struct.assignments.entrySet())
+ for (Map.Entry<Integer, LocalAssignment> _iter737 : struct.assignments.entrySet())
{
- oprot.writeI32(_iter717.getKey());
- _iter717.getValue().write(oprot);
+ oprot.writeI32(_iter737.getKey());
+ _iter737.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 _map718 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I32, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.assignments = new HashMap<Integer,LocalAssignment>(2*_map718.size);
- int _key719;
- LocalAssignment _val720;
- for (int _i721 = 0; _i721 < _map718.size; ++_i721)
+ org.apache.thrift.protocol.TMap _map738 = 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*_map738.size);
+ int _key739;
+ LocalAssignment _val740;
+ for (int _i741 = 0; _i741 < _map738.size; ++_i741)
{
- _key719 = iprot.readI32();
- _val720 = new LocalAssignment();
- _val720.read(iprot);
- struct.assignments.put(_key719, _val720);
+ _key739 = iprot.readI32();
+ _val740 = new LocalAssignment();
+ _val740.read(iprot);
+ struct.assignments.put(_key739, _val740);
}
}
struct.set_assignments_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 f74d582..792c185 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 _list730 = iprot.readListBegin();
- struct.users = new ArrayList<String>(_list730.size);
- String _elem731;
- for (int _i732 = 0; _i732 < _list730.size; ++_i732)
+ org.apache.thrift.protocol.TList _list750 = iprot.readListBegin();
+ struct.users = new ArrayList<String>(_list750.size);
+ String _elem751;
+ for (int _i752 = 0; _i752 < _list750.size; ++_i752)
{
- _elem731 = iprot.readString();
- struct.users.add(_elem731);
+ _elem751 = iprot.readString();
+ struct.users.add(_elem751);
}
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 _list733 = iprot.readListBegin();
- struct.groups = new ArrayList<String>(_list733.size);
- String _elem734;
- for (int _i735 = 0; _i735 < _list733.size; ++_i735)
+ org.apache.thrift.protocol.TList _list753 = iprot.readListBegin();
+ struct.groups = new ArrayList<String>(_list753.size);
+ String _elem754;
+ for (int _i755 = 0; _i755 < _list753.size; ++_i755)
{
- _elem734 = iprot.readString();
- struct.groups.add(_elem734);
+ _elem754 = iprot.readString();
+ struct.groups.add(_elem754);
}
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 _iter736 : struct.users)
+ for (String _iter756 : struct.users)
{
- oprot.writeString(_iter736);
+ oprot.writeString(_iter756);
}
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 _iter737 : struct.groups)
+ for (String _iter757 : struct.groups)
{
- oprot.writeString(_iter737);
+ oprot.writeString(_iter757);
}
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 _iter738 : struct.users)
+ for (String _iter758 : struct.users)
{
- oprot.writeString(_iter738);
+ oprot.writeString(_iter758);
}
}
{
oprot.writeI32(struct.groups.size());
- for (String _iter739 : struct.groups)
+ for (String _iter759 : struct.groups)
{
- oprot.writeString(_iter739);
+ oprot.writeString(_iter759);
}
}
}
@@ -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 _list740 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.users = new ArrayList<String>(_list740.size);
- String _elem741;
- for (int _i742 = 0; _i742 < _list740.size; ++_i742)
+ org.apache.thrift.protocol.TList _list760 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.users = new ArrayList<String>(_list760.size);
+ String _elem761;
+ for (int _i762 = 0; _i762 < _list760.size; ++_i762)
{
- _elem741 = iprot.readString();
- struct.users.add(_elem741);
+ _elem761 = iprot.readString();
+ struct.users.add(_elem761);
}
}
struct.set_users_isSet(true);
{
- org.apache.thrift.protocol.TList _list743 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.groups = new ArrayList<String>(_list743.size);
- String _elem744;
- for (int _i745 = 0; _i745 < _list743.size; ++_i745)
+ org.apache.thrift.protocol.TList _list763 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.groups = new ArrayList<String>(_list763.size);
+ String _elem764;
+ for (int _i765 = 0; _i765 < _list763.size; ++_i765)
{
- _elem744 = iprot.readString();
- struct.groups.add(_elem744);
+ _elem764 = iprot.readString();
+ struct.groups.add(_elem764);
}
}
struct.set_groups_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 1f694eb..4b9b150 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 _list746 = iprot.readListBegin();
- struct.topo_history = new ArrayList<LSTopoHistory>(_list746.size);
- LSTopoHistory _elem747;
- for (int _i748 = 0; _i748 < _list746.size; ++_i748)
+ org.apache.thrift.protocol.TList _list766 = iprot.readListBegin();
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list766.size);
+ LSTopoHistory _elem767;
+ for (int _i768 = 0; _i768 < _list766.size; ++_i768)
{
- _elem747 = new LSTopoHistory();
- _elem747.read(iprot);
- struct.topo_history.add(_elem747);
+ _elem767 = new LSTopoHistory();
+ _elem767.read(iprot);
+ struct.topo_history.add(_elem767);
}
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 _iter749 : struct.topo_history)
+ for (LSTopoHistory _iter769 : struct.topo_history)
{
- _iter749.write(oprot);
+ _iter769.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 _iter750 : struct.topo_history)
+ for (LSTopoHistory _iter770 : struct.topo_history)
{
- _iter750.write(oprot);
+ _iter770.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 _list751 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.topo_history = new ArrayList<LSTopoHistory>(_list751.size);
- LSTopoHistory _elem752;
- for (int _i753 = 0; _i753 < _list751.size; ++_i753)
+ org.apache.thrift.protocol.TList _list771 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.topo_history = new ArrayList<LSTopoHistory>(_list771.size);
+ LSTopoHistory _elem772;
+ for (int _i773 = 0; _i773 < _list771.size; ++_i773)
{
- _elem752 = new LSTopoHistory();
- _elem752.read(iprot);
- struct.topo_history.add(_elem752);
+ _elem772 = new LSTopoHistory();
+ _elem772.read(iprot);
+ struct.topo_history.add(_elem772);
}
}
struct.set_topo_history_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 77d7aab..1c42bde 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 _list722 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list722.size);
- ExecutorInfo _elem723;
- for (int _i724 = 0; _i724 < _list722.size; ++_i724)
+ org.apache.thrift.protocol.TList _list742 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list742.size);
+ ExecutorInfo _elem743;
+ for (int _i744 = 0; _i744 < _list742.size; ++_i744)
{
- _elem723 = new ExecutorInfo();
- _elem723.read(iprot);
- struct.executors.add(_elem723);
+ _elem743 = new ExecutorInfo();
+ _elem743.read(iprot);
+ struct.executors.add(_elem743);
}
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 _iter725 : struct.executors)
+ for (ExecutorInfo _iter745 : struct.executors)
{
- _iter725.write(oprot);
+ _iter745.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 _iter726 : struct.executors)
+ for (ExecutorInfo _iter746 : struct.executors)
{
- _iter726.write(oprot);
+ _iter746.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 _list727 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list727.size);
- ExecutorInfo _elem728;
- for (int _i729 = 0; _i729 < _list727.size; ++_i729)
+ org.apache.thrift.protocol.TList _list747 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list747.size);
+ ExecutorInfo _elem748;
+ for (int _i749 = 0; _i749 < _list747.size; ++_i749)
{
- _elem728 = new ExecutorInfo();
- _elem728.read(iprot);
- struct.executors.add(_elem728);
+ _elem748 = new ExecutorInfo();
+ _elem748.read(iprot);
+ struct.executors.add(_elem748);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 244beda..87337e1 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 _list546 = iprot.readListBegin();
- struct.keys = new ArrayList<String>(_list546.size);
- String _elem547;
- for (int _i548 = 0; _i548 < _list546.size; ++_i548)
+ org.apache.thrift.protocol.TList _list566 = iprot.readListBegin();
+ struct.keys = new ArrayList<String>(_list566.size);
+ String _elem567;
+ for (int _i568 = 0; _i568 < _list566.size; ++_i568)
{
- _elem547 = iprot.readString();
- struct.keys.add(_elem547);
+ _elem567 = iprot.readString();
+ struct.keys.add(_elem567);
}
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 _iter549 : struct.keys)
+ for (String _iter569 : struct.keys)
{
- oprot.writeString(_iter549);
+ oprot.writeString(_iter569);
}
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 _iter550 : struct.keys)
+ for (String _iter570 : struct.keys)
{
- oprot.writeString(_iter550);
+ oprot.writeString(_iter570);
}
}
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 _list551 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.keys = new ArrayList<String>(_list551.size);
- String _elem552;
- for (int _i553 = 0; _i553 < _list551.size; ++_i553)
+ org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.keys = new ArrayList<String>(_list571.size);
+ String _elem572;
+ for (int _i573 = 0; _i573 < _list571.size; ++_i573)
{
- _elem552 = iprot.readString();
- struct.keys.add(_elem552);
+ _elem572 = iprot.readString();
+ struct.keys.add(_elem572);
}
}
struct.set_keys_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 471e67f..b48d342 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 _list694 = iprot.readListBegin();
- struct.executors = new ArrayList<ExecutorInfo>(_list694.size);
- ExecutorInfo _elem695;
- for (int _i696 = 0; _i696 < _list694.size; ++_i696)
+ org.apache.thrift.protocol.TList _list714 = iprot.readListBegin();
+ struct.executors = new ArrayList<ExecutorInfo>(_list714.size);
+ ExecutorInfo _elem715;
+ for (int _i716 = 0; _i716 < _list714.size; ++_i716)
{
- _elem695 = new ExecutorInfo();
- _elem695.read(iprot);
- struct.executors.add(_elem695);
+ _elem715 = new ExecutorInfo();
+ _elem715.read(iprot);
+ struct.executors.add(_elem715);
}
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 _iter697 : struct.executors)
+ for (ExecutorInfo _iter717 : struct.executors)
{
- _iter697.write(oprot);
+ _iter717.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 _iter698 : struct.executors)
+ for (ExecutorInfo _iter718 : struct.executors)
{
- _iter698.write(oprot);
+ _iter718.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 _list699 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.executors = new ArrayList<ExecutorInfo>(_list699.size);
- ExecutorInfo _elem700;
- for (int _i701 = 0; _i701 < _list699.size; ++_i701)
+ org.apache.thrift.protocol.TList _list719 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.executors = new ArrayList<ExecutorInfo>(_list719.size);
+ ExecutorInfo _elem720;
+ for (int _i721 = 0; _i721 < _list719.size; ++_i721)
{
- _elem700 = new ExecutorInfo();
- _elem700.read(iprot);
- struct.executors.add(_elem700);
+ _elem720 = new ExecutorInfo();
+ _elem720.read(iprot);
+ struct.executors.add(_elem720);
}
}
struct.set_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 0393fa9..4b8c430 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 _map684 = iprot.readMapBegin();
- struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map684.size);
- String _key685;
- ThriftSerializedObject _val686;
- for (int _i687 = 0; _i687 < _map684.size; ++_i687)
+ org.apache.thrift.protocol.TMap _map704 = iprot.readMapBegin();
+ struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map704.size);
+ String _key705;
+ ThriftSerializedObject _val706;
+ for (int _i707 = 0; _i707 < _map704.size; ++_i707)
{
- _key685 = iprot.readString();
- _val686 = new ThriftSerializedObject();
- _val686.read(iprot);
- struct.serialized_parts.put(_key685, _val686);
+ _key705 = iprot.readString();
+ _val706 = new ThriftSerializedObject();
+ _val706.read(iprot);
+ struct.serialized_parts.put(_key705, _val706);
}
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> _iter688 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter708 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter688.getKey());
- _iter688.getValue().write(oprot);
+ oprot.writeString(_iter708.getKey());
+ _iter708.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> _iter689 : struct.serialized_parts.entrySet())
+ for (Map.Entry<String, ThriftSerializedObject> _iter709 : struct.serialized_parts.entrySet())
{
- oprot.writeString(_iter689.getKey());
- _iter689.getValue().write(oprot);
+ oprot.writeString(_iter709.getKey());
+ _iter709.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 _map690 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map690.size);
- String _key691;
- ThriftSerializedObject _val692;
- for (int _i693 = 0; _i693 < _map690.size; ++_i693)
+ 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.serialized_parts = new HashMap<String,ThriftSerializedObject>(2*_map710.size);
+ String _key711;
+ ThriftSerializedObject _val712;
+ for (int _i713 = 0; _i713 < _map710.size; ++_i713)
{
- _key691 = iprot.readString();
- _val692 = new ThriftSerializedObject();
- _val692.read(iprot);
- struct.serialized_parts.put(_key691, _val692);
+ _key711 = iprot.readString();
+ _val712 = new ThriftSerializedObject();
+ _val712.read(iprot);
+ struct.serialized_parts.put(_key711, _val712);
}
}
struct.set_serialized_parts_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 19c4f5e..f6633a6 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 _map754 = iprot.readMapBegin();
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map754.size);
- String _key755;
- LogLevel _val756;
- for (int _i757 = 0; _i757 < _map754.size; ++_i757)
+ org.apache.thrift.protocol.TMap _map774 = iprot.readMapBegin();
+ struct.named_logger_level = new HashMap<String,LogLevel>(2*_map774.size);
+ String _key775;
+ LogLevel _val776;
+ for (int _i777 = 0; _i777 < _map774.size; ++_i777)
{
- _key755 = iprot.readString();
- _val756 = new LogLevel();
- _val756.read(iprot);
- struct.named_logger_level.put(_key755, _val756);
+ _key775 = iprot.readString();
+ _val776 = new LogLevel();
+ _val776.read(iprot);
+ struct.named_logger_level.put(_key775, _val776);
}
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> _iter758 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter778 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter758.getKey());
- _iter758.getValue().write(oprot);
+ oprot.writeString(_iter778.getKey());
+ _iter778.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> _iter759 : struct.named_logger_level.entrySet())
+ for (Map.Entry<String, LogLevel> _iter779 : struct.named_logger_level.entrySet())
{
- oprot.writeString(_iter759.getKey());
- _iter759.getValue().write(oprot);
+ oprot.writeString(_iter779.getKey());
+ _iter779.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 _map760 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.named_logger_level = new HashMap<String,LogLevel>(2*_map760.size);
- String _key761;
- LogLevel _val762;
- for (int _i763 = 0; _i763 < _map760.size; ++_i763)
+ org.apache.thrift.protocol.TMap _map780 = 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*_map780.size);
+ String _key781;
+ LogLevel _val782;
+ for (int _i783 = 0; _i783 < _map780.size; ++_i783)
{
- _key761 = iprot.readString();
- _val762 = new LogLevel();
- _val762.read(iprot);
- struct.named_logger_level.put(_key761, _val762);
+ _key781 = iprot.readString();
+ _val782 = new LogLevel();
+ _val782.read(iprot);
+ struct.named_logger_level.put(_key781, _val782);
}
}
struct.set_named_logger_level_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java b/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
index 8feac31..ba9e66a 100644
--- a/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-core/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -17854,14 +17854,14 @@ public class Nimbus {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list788 = iprot.readListBegin();
- struct.success = new ArrayList<ProfileRequest>(_list788.size);
- ProfileRequest _elem789;
- for (int _i790 = 0; _i790 < _list788.size; ++_i790)
+ org.apache.thrift.protocol.TList _list808 = iprot.readListBegin();
+ struct.success = new ArrayList<ProfileRequest>(_list808.size);
+ ProfileRequest _elem809;
+ for (int _i810 = 0; _i810 < _list808.size; ++_i810)
{
- _elem789 = new ProfileRequest();
- _elem789.read(iprot);
- struct.success.add(_elem789);
+ _elem809 = new ProfileRequest();
+ _elem809.read(iprot);
+ struct.success.add(_elem809);
}
iprot.readListEnd();
}
@@ -17887,9 +17887,9 @@ public class Nimbus {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (ProfileRequest _iter791 : struct.success)
+ for (ProfileRequest _iter811 : struct.success)
{
- _iter791.write(oprot);
+ _iter811.write(oprot);
}
oprot.writeListEnd();
}
@@ -17920,9 +17920,9 @@ public class Nimbus {
if (struct.is_set_success()) {
{
oprot.writeI32(struct.success.size());
- for (ProfileRequest _iter792 : struct.success)
+ for (ProfileRequest _iter812 : struct.success)
{
- _iter792.write(oprot);
+ _iter812.write(oprot);
}
}
}
@@ -17934,14 +17934,14 @@ public class Nimbus {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list793 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<ProfileRequest>(_list793.size);
- ProfileRequest _elem794;
- for (int _i795 = 0; _i795 < _list793.size; ++_i795)
+ org.apache.thrift.protocol.TList _list813 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<ProfileRequest>(_list813.size);
+ ProfileRequest _elem814;
+ for (int _i815 = 0; _i815 < _list813.size; ++_i815)
{
- _elem794 = new ProfileRequest();
- _elem794.read(iprot);
- struct.success.add(_elem794);
+ _elem814 = new ProfileRequest();
+ _elem814.read(iprot);
+ struct.success.add(_elem814);
}
}
struct.set_success_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 4bf0196..5776717 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 _set590 = iprot.readSetBegin();
- struct.port = new HashSet<Long>(2*_set590.size);
- long _elem591;
- for (int _i592 = 0; _i592 < _set590.size; ++_i592)
+ org.apache.thrift.protocol.TSet _set610 = iprot.readSetBegin();
+ struct.port = new HashSet<Long>(2*_set610.size);
+ long _elem611;
+ for (int _i612 = 0; _i612 < _set610.size; ++_i612)
{
- _elem591 = iprot.readI64();
- struct.port.add(_elem591);
+ _elem611 = iprot.readI64();
+ struct.port.add(_elem611);
}
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 _iter593 : struct.port)
+ for (long _iter613 : struct.port)
{
- oprot.writeI64(_iter593);
+ oprot.writeI64(_iter613);
}
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 _iter594 : struct.port)
+ for (long _iter614 : struct.port)
{
- oprot.writeI64(_iter594);
+ oprot.writeI64(_iter614);
}
}
}
@@ -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 _set595 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.port = new HashSet<Long>(2*_set595.size);
- long _elem596;
- for (int _i597 = 0; _i597 < _set595.size; ++_i597)
+ org.apache.thrift.protocol.TSet _set615 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.port = new HashSet<Long>(2*_set615.size);
+ long _elem616;
+ for (int _i617 = 0; _i617 < _set615.size; ++_i617)
{
- _elem596 = iprot.readI64();
- struct.port.add(_elem596);
+ _elem616 = iprot.readI64();
+ struct.port.add(_elem616);
}
}
struct.set_port_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 6835cb4..bbb8f91 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 _map518 = iprot.readMapBegin();
- struct.num_executors = new HashMap<String,Integer>(2*_map518.size);
- String _key519;
- int _val520;
- for (int _i521 = 0; _i521 < _map518.size; ++_i521)
+ org.apache.thrift.protocol.TMap _map538 = iprot.readMapBegin();
+ struct.num_executors = new HashMap<String,Integer>(2*_map538.size);
+ String _key539;
+ int _val540;
+ for (int _i541 = 0; _i541 < _map538.size; ++_i541)
{
- _key519 = iprot.readString();
- _val520 = iprot.readI32();
- struct.num_executors.put(_key519, _val520);
+ _key539 = iprot.readString();
+ _val540 = iprot.readI32();
+ struct.num_executors.put(_key539, _val540);
}
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> _iter522 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter542 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter522.getKey());
- oprot.writeI32(_iter522.getValue());
+ oprot.writeString(_iter542.getKey());
+ oprot.writeI32(_iter542.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> _iter523 : struct.num_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter543 : struct.num_executors.entrySet())
{
- oprot.writeString(_iter523.getKey());
- oprot.writeI32(_iter523.getValue());
+ oprot.writeString(_iter543.getKey());
+ oprot.writeI32(_iter543.getValue());
}
}
}
@@ -644,15 +644,15 @@ public class RebalanceOptions implements org.apache.thrift.TBase<RebalanceOption
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TMap _map524 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
- struct.num_executors = new HashMap<String,Integer>(2*_map524.size);
- String _key525;
- int _val526;
- for (int _i527 = 0; _i527 < _map524.size; ++_i527)
+ org.apache.thrift.protocol.TMap _map544 = 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*_map544.size);
+ String _key545;
+ int _val546;
+ for (int _i547 = 0; _i547 < _map544.size; ++_i547)
{
- _key525 = iprot.readString();
- _val526 = iprot.readI32();
- struct.num_executors.put(_key525, _val526);
+ _key545 = iprot.readString();
+ _val546 = iprot.readI32();
+ struct.num_executors.put(_key545, _val546);
}
}
struct.set_num_executors_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 5cfea0d..349e045 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 _list538 = iprot.readListBegin();
- struct.acl = new ArrayList<AccessControl>(_list538.size);
- AccessControl _elem539;
- for (int _i540 = 0; _i540 < _list538.size; ++_i540)
+ org.apache.thrift.protocol.TList _list558 = iprot.readListBegin();
+ struct.acl = new ArrayList<AccessControl>(_list558.size);
+ AccessControl _elem559;
+ for (int _i560 = 0; _i560 < _list558.size; ++_i560)
{
- _elem539 = new AccessControl();
- _elem539.read(iprot);
- struct.acl.add(_elem539);
+ _elem559 = new AccessControl();
+ _elem559.read(iprot);
+ struct.acl.add(_elem559);
}
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 _iter541 : struct.acl)
+ for (AccessControl _iter561 : struct.acl)
{
- _iter541.write(oprot);
+ _iter561.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 _iter542 : struct.acl)
+ for (AccessControl _iter562 : struct.acl)
{
- _iter542.write(oprot);
+ _iter562.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 _list543 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.acl = new ArrayList<AccessControl>(_list543.size);
- AccessControl _elem544;
- for (int _i545 = 0; _i545 < _list543.size; ++_i545)
+ org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.acl = new ArrayList<AccessControl>(_list563.size);
+ AccessControl _elem564;
+ for (int _i565 = 0; _i565 < _list563.size; ++_i565)
{
- _elem544 = new AccessControl();
- _elem544.read(iprot);
- struct.acl.add(_elem544);
+ _elem564 = new AccessControl();
+ _elem564.read(iprot);
+ struct.acl.add(_elem564);
}
}
struct.set_acl_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 92d7eb4..34b2358 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 _map654 = iprot.readMapBegin();
- struct.component_executors = new HashMap<String,Integer>(2*_map654.size);
- String _key655;
- int _val656;
- for (int _i657 = 0; _i657 < _map654.size; ++_i657)
+ org.apache.thrift.protocol.TMap _map674 = iprot.readMapBegin();
+ struct.component_executors = new HashMap<String,Integer>(2*_map674.size);
+ String _key675;
+ int _val676;
+ for (int _i677 = 0; _i677 < _map674.size; ++_i677)
{
- _key655 = iprot.readString();
- _val656 = iprot.readI32();
- struct.component_executors.put(_key655, _val656);
+ _key675 = iprot.readString();
+ _val676 = iprot.readI32();
+ struct.component_executors.put(_key675, _val676);
}
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 _map658 = iprot.readMapBegin();
- struct.component_debug = new HashMap<String,DebugOptions>(2*_map658.size);
- String _key659;
- DebugOptions _val660;
- for (int _i661 = 0; _i661 < _map658.size; ++_i661)
+ org.apache.thrift.protocol.TMap _map678 = iprot.readMapBegin();
+ struct.component_debug = new HashMap<String,DebugOptions>(2*_map678.size);
+ String _key679;
+ DebugOptions _val680;
+ for (int _i681 = 0; _i681 < _map678.size; ++_i681)
{
- _key659 = iprot.readString();
- _val660 = new DebugOptions();
- _val660.read(iprot);
- struct.component_debug.put(_key659, _val660);
+ _key679 = iprot.readString();
+ _val680 = new DebugOptions();
+ _val680.read(iprot);
+ struct.component_debug.put(_key679, _val680);
}
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> _iter662 : struct.component_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter682 : struct.component_executors.entrySet())
{
- oprot.writeString(_iter662.getKey());
- oprot.writeI32(_iter662.getValue());
+ oprot.writeString(_iter682.getKey());
+ oprot.writeI32(_iter682.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> _iter663 : struct.component_debug.entrySet())
+ for (Map.Entry<String, DebugOptions> _iter683 : struct.component_debug.entrySet())
{
- oprot.writeString(_iter663.getKey());
- _iter663.getValue().write(oprot);
+ oprot.writeString(_iter683.getKey());
+ _iter683.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> _iter664 : struct.component_executors.entrySet())
+ for (Map.Entry<String, Integer> _iter684 : struct.component_executors.entrySet())
{
- oprot.writeString(_iter664.getKey());
- oprot.writeI32(_iter664.getValue());
+ oprot.writeString(_iter684.getKey());
+ oprot.writeI32(_iter684.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> _iter665 : struct.component_debug.entrySet())
+ for (Map.Entry<String, DebugOptions> _iter685 : struct.component_debug.entrySet())
{
- oprot.writeString(_iter665.getKey());
- _iter665.getValue().write(oprot);
+ oprot.writeString(_iter685.getKey());
+ _iter685.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 _map666 = 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*_map666.size);
- String _key667;
- int _val668;
- for (int _i669 = 0; _i669 < _map666.size; ++_i669)
+ org.apache.thrift.protocol.TMap _map686 = 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*_map686.size);
+ String _key687;
+ int _val688;
+ for (int _i689 = 0; _i689 < _map686.size; ++_i689)
{
- _key667 = iprot.readString();
- _val668 = iprot.readI32();
- struct.component_executors.put(_key667, _val668);
+ _key687 = iprot.readString();
+ _val688 = iprot.readI32();
+ struct.component_executors.put(_key687, _val688);
}
}
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 _map670 = 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*_map670.size);
- String _key671;
- DebugOptions _val672;
- for (int _i673 = 0; _i673 < _map670.size; ++_i673)
+ org.apache.thrift.protocol.TMap _map690 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component_debug = new HashMap<String,DebugOptions>(2*_map690.size);
+ String _key691;
+ DebugOptions _val692;
+ for (int _i693 = 0; _i693 < _map690.size; ++_i693)
{
- _key671 = iprot.readString();
- _val672 = new DebugOptions();
- _val672.read(iprot);
- struct.component_debug.put(_key671, _val672);
+ _key691 = iprot.readString();
+ _val692 = new DebugOptions();
+ _val692.read(iprot);
+ struct.component_debug.put(_key691, _val692);
}
}
struct.set_component_debug_isSet(true);
http://git-wip-us.apache.org/repos/asf/storm/blob/d9d2e118/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 64b2d7d..44003c2 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 _list554 = iprot.readListBegin();
- struct.used_ports = new ArrayList<Long>(_list554.size);
- long _elem555;
- for (int _i556 = 0; _i556 < _list554.size; ++_i556)
+ org.apache.thrift.protocol.TList _list574 = iprot.readListBegin();
+ struct.used_ports = new ArrayList<Long>(_list574.size);
+ long _elem575;
+ for (int _i576 = 0; _i576 < _list574.size; ++_i576)
{
- _elem555 = iprot.readI64();
- struct.used_ports.add(_elem555);
+ _elem575 = iprot.readI64();
+ struct.used_ports.add(_elem575);
}
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 _list557 = iprot.readListBegin();
- struct.meta = new ArrayList<Long>(_list557.size);
- long _elem558;
- for (int _i559 = 0; _i559 < _list557.size; ++_i559)
+ org.apache.thrift.protocol.TList _list577 = iprot.readListBegin();
+ struct.meta = new ArrayList<Long>(_list577.size);
+ long _elem578;
+ for (int _i579 = 0; _i579 < _list577.size; ++_i579)
{
- _elem558 = iprot.readI64();
- struct.meta.add(_elem558);
+ _elem578 = iprot.readI64();
+ struct.meta.add(_elem578);
}
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 _map560 = iprot.readMapBegin();
- struct.scheduler_meta = new HashMap<String,String>(2*_map560.size);
- String _key561;
- String _val562;
- for (int _i563 = 0; _i563 < _map560.size; ++_i563)
+ org.apache.thrift.protocol.TMap _map580 = iprot.readMapBegin();
+ struct.scheduler_meta = new HashMap<String,String>(2*_map580.size);
+ String _key581;
+ String _val582;
+ for (int _i583 = 0; _i583 < _map580.size; ++_i583)
{
- _key561 = iprot.readString();
- _val562 = iprot.readString();
- struct.scheduler_meta.put(_key561, _val562);
+ _key581 = iprot.readString();
+ _val582 = iprot.readString();
+ struct.scheduler_meta.put(_key581, _val582);
}
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 _map564 = iprot.readMapBegin();
- struct.resources_map = new HashMap<String,Double>(2*_map564.size);
- String _key565;
- double _val566;
- for (int _i567 = 0; _i567 < _map564.size; ++_i567)
+ org.apache.thrift.protocol.TMap _map584 = iprot.readMapBegin();
+ struct.resources_map = new HashMap<String,Double>(2*_map584.size);
+ String _key585;
+ double _val586;
+ for (int _i587 = 0; _i587 < _map584.size; ++_i587)
{
- _key565 = iprot.readString();
- _val566 = iprot.readDouble();
- struct.resources_map.put(_key565, _val566);
+ _key585 = iprot.readString();
+ _val586 = iprot.readDouble();
+ struct.resources_map.put(_key585, _val586);
}
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 _iter568 : struct.used_ports)
+ for (long _iter588 : struct.used_ports)
{
- oprot.writeI64(_iter568);
+ oprot.writeI64(_iter588);
}
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 _iter569 : struct.meta)
+ for (long _iter589 : struct.meta)
{
- oprot.writeI64(_iter569);
+ oprot.writeI64(_iter589);
}
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> _iter570 : struct.scheduler_meta.entrySet())
+ for (Map.Entry<String, String> _iter590 : struct.scheduler_meta.entrySet())
{
- oprot.writeString(_iter570.getKey());
- oprot.writeString(_iter570.getValue());
+ oprot.writeString(_iter590.getKey());
+ oprot.writeString(_iter590.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> _iter571 : struct.resources_map.entrySet())
+ for (Map.Entry<String, Double> _iter591 : struct.resources_map.entrySet())
{
- oprot.writeString(_iter571.getKey());
- oprot.writeDouble(_iter571.getValue());
+ oprot.writeString(_iter591.getKey());
+ oprot.writeDouble(_iter591.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 _iter572 : struct.used_ports)
+ for (long _iter592 : struct.used_ports)
{
- oprot.writeI64(_iter572);
+ oprot.writeI64(_iter592);
}
}
}
if (struct.is_set_meta()) {
{
oprot.writeI32(struct.meta.size());
- for (long _iter573 : struct.meta)
+ for (long _iter593 : struct.meta)
{
- oprot.writeI64(_iter573);
+ oprot.writeI64(_iter593);
}
}
}
if (struct.is_set_scheduler_meta()) {
{
oprot.writeI32(struct.scheduler_meta.size());
- for (Map.Entry<String, String> _iter574 : struct.scheduler_meta.entrySet())
+ for (Map.Entry<String, String> _iter594 : struct.scheduler_meta.entrySet())
{
- oprot.writeString(_iter574.getKey());
- oprot.writeString(_iter574.getValue());
+ oprot.writeString(_iter594.getKey());
+ oprot.writeString(_iter594.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> _iter575 : struct.resources_map.entrySet())
+ for (Map.Entry<String, Double> _iter595 : struct.resources_map.entrySet())
{
- oprot.writeString(_iter575.getKey());
- oprot.writeDouble(_iter575.getValue());
+ oprot.writeString(_iter595.getKey());
+ oprot.writeDouble(_iter595.getValue());
}
}
}
@@ -1377,41 +1377,41 @@ public class SupervisorInfo implements org.apache.thrift.TBase<SupervisorInfo, S
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list576 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.used_ports = new ArrayList<Long>(_list576.size);
- long _elem577;
- for (int _i578 = 0; _i578 < _list576.size; ++_i578)
+ org.apache.thrift.protocol.TList _list596 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.used_ports = new ArrayList<Long>(_list596.size);
+ long _elem597;
+ for (int _i598 = 0; _i598 < _list596.size; ++_i598)
{
- _elem577 = iprot.readI64();
- struct.used_ports.add(_elem577);
+ _elem597 = iprot.readI64();
+ struct.used_ports.add(_elem597);
}
}
struct.set_used_ports_isSet(true);
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.meta = new ArrayList<Long>(_list579.size);
- long _elem580;
- for (int _i581 = 0; _i581 < _list579.size; ++_i581)
+ org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.meta = new ArrayList<Long>(_list599.size);
+ long _elem600;
+ for (int _i601 = 0; _i601 < _list599.size; ++_i601)
{
- _elem580 = iprot.readI64();
- struct.meta.add(_elem580);
+ _elem600 = iprot.readI64();
+ struct.meta.add(_elem600);
}
}
struct.set_meta_isSet(true);
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TMap _map582 = 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*_map582.size);
- String _key583;
- String _val584;
- for (int _i585 = 0; _i585 < _map582.size; ++_i585)
+ org.apache.thrift.protocol.TMap _map602 = 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*_map602.size);
+ String _key603;
+ String _val604;
+ for (int _i605 = 0; _i605 < _map602.size; ++_i605)
{
- _key583 = iprot.readString();
- _val584 = iprot.readString();
- struct.scheduler_meta.put(_key583, _val584);
+ _key603 = iprot.readString();
+ _val604 = iprot.readString();
+ struct.scheduler_meta.put(_key603, _val604);
}
}
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 _map586 = 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*_map586.size);
- String _key587;
- double _val588;
- for (int _i589 = 0; _i589 < _map586.size; ++_i589)
+ org.apache.thrift.protocol.TMap _map606 = 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*_map606.size);
+ String _key607;
+ double _val608;
+ for (int _i609 = 0; _i609 < _map606.size; ++_i609)
{
- _key587 = iprot.readString();
- _val588 = iprot.readDouble();
- struct.resources_map.put(_key587, _val588);
+ _key607 = iprot.readString();
+ _val608 = iprot.readDouble();
+ struct.resources_map.put(_key607, _val608);
}
}
struct.set_resources_map_isSet(true);