This is an automated email from the ASF dual-hosted git repository.
ethanli pushed a commit to branch 2.1.x-branch
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/2.1.x-branch by this push:
new 9a774f9 STORM-3511 Upgrade Thrift to 0.13.0
new d97cad3 Merge pull request #3179 from
marjoral/STORM-3511-Thrift-Upgrade-2.1.X
9a774f9 is described below
commit 9a774f9ea60930ea44a8295d0d60616b6602fe00
Author: MARJORAM Luke <[email protected]>
AuthorDate: Mon Dec 9 14:27:50 2019 +0000
STORM-3511 Upgrade Thrift to 0.13.0
---
DEPENDENCY-LICENSES | 2 +-
LICENSE-binary | 2 +-
pom.xml | 2 +-
.../src/jvm/org/apache/storm/generated/AccessControl.java | 4 ++--
.../src/jvm/org/apache/storm/generated/AccessControlType.java | 4 ++--
.../src/jvm/org/apache/storm/generated/AlreadyAliveException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Assignment.java | 4 ++--
.../jvm/org/apache/storm/generated/AuthorizationException.java | 4 ++--
.../src/jvm/org/apache/storm/generated/BeginDownloadResult.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Bolt.java | 4 ++--
.../src/jvm/org/apache/storm/generated/BoltAggregateStats.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/BoltStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ClusterSummary.java | 4 ++--
.../jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java | 4 ++--
.../src/jvm/org/apache/storm/generated/CommonAggregateStats.java | 4 ++--
.../jvm/org/apache/storm/generated/ComponentAggregateStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ComponentCommon.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ComponentObject.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ComponentPageInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ComponentType.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Credentials.java | 4 ++--
.../src/jvm/org/apache/storm/generated/DRPCExceptionType.java | 4 ++--
.../jvm/org/apache/storm/generated/DRPCExecutionException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java | 4 ++--
.../src/jvm/org/apache/storm/generated/DistributedRPC.java | 4 ++--
.../jvm/org/apache/storm/generated/DistributedRPCInvocations.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java | 4 ++--
.../jvm/org/apache/storm/generated/ExecutorAggregateStats.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ExecutorStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ExecutorSummary.java | 4 ++--
.../src/jvm/org/apache/storm/generated/GetInfoOptions.java | 4 ++--
.../src/jvm/org/apache/storm/generated/GlobalStreamId.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Grouping.java | 4 ++--
.../jvm/org/apache/storm/generated/HBAuthorizationException.java | 4 ++--
.../src/jvm/org/apache/storm/generated/HBExecutionException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/HBMessage.java | 4 ++--
.../src/jvm/org/apache/storm/generated/HBMessageData.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/HBNodes.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/HBPulse.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/HBRecords.java | 4 ++--
.../src/jvm/org/apache/storm/generated/HBServerMessageType.java | 4 ++--
.../src/jvm/org/apache/storm/generated/IllegalStateException.java | 4 ++--
.../jvm/org/apache/storm/generated/InvalidTopologyException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/JavaObject.java | 4 ++--
.../src/jvm/org/apache/storm/generated/JavaObjectArg.java | 4 ++--
.../jvm/org/apache/storm/generated/KeyAlreadyExistsException.java | 4 ++--
.../src/jvm/org/apache/storm/generated/KeyNotFoundException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/KillOptions.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LSApprovedWorkers.java | 4 ++--
.../jvm/org/apache/storm/generated/LSSupervisorAssignments.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LSSupervisorId.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LSTopoHistory.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LSTopoHistoryList.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ListBlobsResult.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LocalAssignment.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LocalStateData.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/LogConfig.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java | 4 ++--
.../src/jvm/org/apache/storm/generated/LogLevelAction.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java | 4 ++--
.../src/jvm/org/apache/storm/generated/NimbusSummary.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/NotAliveException.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/NullStruct.java | 4 ++--
.../src/jvm/org/apache/storm/generated/NumErrorsChoice.java | 4 ++--
.../src/jvm/org/apache/storm/generated/OwnerResourceSummary.java | 4 ++--
.../src/jvm/org/apache/storm/generated/PrivateWorkerKey.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ProfileAction.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ProfileRequest.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ReadableBlobMeta.java | 4 ++--
.../src/jvm/org/apache/storm/generated/RebalanceOptions.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SettableBlobMeta.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java | 4 ++--
.../src/jvm/org/apache/storm/generated/ShellComponent.java | 4 ++--
.../jvm/org/apache/storm/generated/SpecificAggregateStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SpoutAggregateStats.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/StateSpoutSpec.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/StormBase.java | 4 ++--
.../src/jvm/org/apache/storm/generated/StormTopology.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SubmitOptions.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SupervisorAssignments.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SupervisorInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SupervisorPageInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/SupervisorSummary.java | 4 ++--
.../jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java | 4 ++--
.../org/apache/storm/generated/SupervisorWorkerHeartbeats.java | 4 ++--
.../jvm/org/apache/storm/generated/ThriftSerializedObject.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyActionOptions.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyInitialStatus.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyPageInfo.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyStats.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologyStatus.java | 4 ++--
.../src/jvm/org/apache/storm/generated/TopologySummary.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerMetricList.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerMetricPoint.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerMetrics.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerResources.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerSummary.java | 4 ++--
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java | 4 ++--
.../src/jvm/org/apache/storm/generated/WorkerTokenInfo.java | 4 ++--
.../jvm/org/apache/storm/generated/WorkerTokenServiceType.java | 4 ++--
.../jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java | 4 ++--
.../org/apache/storm/security/auth/sasl/SaslTransportPlugin.java | 6 +++---
storm-client/src/py/storm/DistributedRPC-remote | 2 +-
storm-client/src/py/storm/DistributedRPC.py | 8 +++++++-
storm-client/src/py/storm/DistributedRPCInvocations-remote | 2 +-
storm-client/src/py/storm/DistributedRPCInvocations.py | 8 +++++++-
storm-client/src/py/storm/Nimbus-remote | 2 +-
storm-client/src/py/storm/Nimbus.py | 8 +++++++-
storm-client/src/py/storm/Supervisor-remote | 2 +-
storm-client/src/py/storm/Supervisor.py | 8 +++++++-
storm-client/src/py/storm/constants.py | 2 +-
storm-client/src/py/storm/ttypes.py | 2 +-
123 files changed, 258 insertions(+), 234 deletions(-)
diff --git a/DEPENDENCY-LICENSES b/DEPENDENCY-LICENSES
index 3761367..44d3551 100644
--- a/DEPENDENCY-LICENSES
+++ b/DEPENDENCY-LICENSES
@@ -124,7 +124,7 @@ List of third-party dependencies grouped by their license
type.
* Apache Parquet Hadoop Bundle
(org.apache.parquet:parquet-hadoop-bundle:1.8.1 - https://parquet.apache.org)
* Apache Solr Solrj (org.apache.solr:solr-solrj:5.5.5 -
http://lucene.apache.org/solr-parent/solr-solrj)
* Apache Thrift (org.apache.thrift:libfb303:0.9.3 -
http://thrift.apache.org)
- * Apache Thrift (org.apache.thrift:libthrift:0.12.0 -
http://thrift.apache.org)
+ * Apache Thrift (org.apache.thrift:libthrift:0.13.0 -
http://thrift.apache.org)
* Apache Thrift (org.apache.thrift:libthrift:0.9.3 -
http://thrift.apache.org)
* Apache Twill API (org.apache.twill:twill-api:0.6.0-incubating -
http://twill.incubator.apache.org/twill-api)
* Apache Twill common library
(org.apache.twill:twill-common:0.6.0-incubating -
http://twill.incubator.apache.org/twill-common)
diff --git a/LICENSE-binary b/LICENSE-binary
index 8704f1e..d6a6ff0 100644
--- a/LICENSE-binary
+++ b/LICENSE-binary
@@ -751,7 +751,7 @@ The license texts of these dependencies can be found in the
licenses directory.
* Apache Log4j Web (org.apache.logging.log4j:log4j-web:2.11.2 -
https://logging.apache.org/log4j/2.x/log4j-web/)
* Apache Parquet Hadoop Bundle
(org.apache.parquet:parquet-hadoop-bundle:1.8.1 - https://parquet.apache.org)
* Apache Thrift (org.apache.thrift:libfb303:0.9.3 -
http://thrift.apache.org)
- * Apache Thrift (org.apache.thrift:libthrift:0.12.0 -
http://thrift.apache.org)
+ * Apache Thrift (org.apache.thrift:libthrift:0.13.0 -
http://thrift.apache.org)
* Plexus Interpolation API
(org.codehaus.plexus:plexus-interpolation:1.25 -
http://codehaus-plexus.github.io/plexus-interpolation/)
* Apache Twill API (org.apache.twill:twill-api:0.6.0-incubating -
http://twill.incubator.apache.org/twill-api)
* Apache Twill common library
(org.apache.twill:twill-common:0.6.0-incubating -
http://twill.incubator.apache.org/twill-common)
diff --git a/pom.xml b/pom.xml
index 6ed98ab..42915f4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -297,7 +297,7 @@
<kryo.version>3.0.3</kryo.version>
<servlet.version>3.1.0</servlet.version>
<joda-time.version>2.3</joda-time.version>
- <thrift.version>0.12.0</thrift.version>
+ <thrift.version>0.13.0</thrift.version>
<junit.jupiter.version>5.5.1</junit.jupiter.version>
<surefire.version>2.22.1</surefire.version>
<awaitility.version>3.1.0</awaitility.version>
diff --git a/storm-client/src/jvm/org/apache/storm/generated/AccessControl.java
b/storm-client/src/jvm/org/apache/storm/generated/AccessControl.java
index 58b166b..1077051 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/AccessControl.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/AccessControl.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class AccessControl implements
org.apache.storm.thrift.TBase<AccessControl, AccessControl._Fields>,
java.io.Serializable, Cloneable, Comparable<AccessControl> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("AccessControl");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/AccessControlType.java
b/storm-client/src/jvm/org/apache/storm/generated/AccessControlType.java
index 9a32f8b..3d2415d 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/AccessControlType.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/AccessControlType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum AccessControlType implements org.apache.storm.thrift.TEnum {
OTHER(1),
USER(2);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java
b/storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java
index 02f3174..9d57361 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class AlreadyAliveException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<AlreadyAliveException,
AlreadyAliveException._Fields>, java.io.Serializable, Cloneable,
Comparable<AlreadyAliveException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("AlreadyAliveException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Assignment.java
b/storm-client/src/jvm/org/apache/storm/generated/Assignment.java
index bc11340..daf149a 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Assignment.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Assignment.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Assignment implements org.apache.storm.thrift.TBase<Assignment,
Assignment._Fields>, java.io.Serializable, Cloneable, Comparable<Assignment> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("Assignment");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java
b/storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java
index 56e03c3..29efde3 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class AuthorizationException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<AuthorizationException,
AuthorizationException._Fields>, java.io.Serializable, Cloneable,
Comparable<AuthorizationException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("AuthorizationException");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java
b/storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java
index 2dbb1fb..540246a 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class BeginDownloadResult implements
org.apache.storm.thrift.TBase<BeginDownloadResult,
BeginDownloadResult._Fields>, java.io.Serializable, Cloneable,
Comparable<BeginDownloadResult> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("BeginDownloadResult");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Bolt.java
b/storm-client/src/jvm/org/apache/storm/generated/Bolt.java
index 1eb5943..23cdf63 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Bolt.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Bolt.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Bolt implements org.apache.storm.thrift.TBase<Bolt,
Bolt._Fields>, java.io.Serializable, Cloneable, Comparable<Bolt> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("Bolt");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java
index de829cb..56f601e 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class BoltAggregateStats implements
org.apache.storm.thrift.TBase<BoltAggregateStats, BoltAggregateStats._Fields>,
java.io.Serializable, Cloneable, Comparable<BoltAggregateStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("BoltAggregateStats");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
index a66b1a9..2094fef 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/BoltStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class BoltStats implements org.apache.storm.thrift.TBase<BoltStats,
BoltStats._Fields>, java.io.Serializable, Cloneable, Comparable<BoltStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("BoltStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
index 01497a9..5a39b2c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ClusterSummary implements
org.apache.storm.thrift.TBase<ClusterSummary, ClusterSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<ClusterSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ClusterSummary");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java
b/storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java
index 43aa8fe..3dd828e 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ClusterWorkerHeartbeat implements
org.apache.storm.thrift.TBase<ClusterWorkerHeartbeat,
ClusterWorkerHeartbeat._Fields>, java.io.Serializable, Cloneable,
Comparable<ClusterWorkerHeartbeat> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ClusterWorkerHeartbeat");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java
index ae23480..e85cff6 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class CommonAggregateStats implements
org.apache.storm.thrift.TBase<CommonAggregateStats,
CommonAggregateStats._Fields>, java.io.Serializable, Cloneable,
Comparable<CommonAggregateStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("CommonAggregateStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java
index eed66e6..fda3205 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ComponentAggregateStats implements
org.apache.storm.thrift.TBase<ComponentAggregateStats,
ComponentAggregateStats._Fields>, java.io.Serializable, Cloneable,
Comparable<ComponentAggregateStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ComponentAggregateStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java
b/storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java
index cffaea4..5ba5556 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ComponentCommon implements
org.apache.storm.thrift.TBase<ComponentCommon, ComponentCommon._Fields>,
java.io.Serializable, Cloneable, Comparable<ComponentCommon> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ComponentCommon");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java
b/storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java
index e6562c0..599df7b 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ComponentObject extends
org.apache.storm.thrift.TUnion<ComponentObject, ComponentObject._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ComponentObject");
private static final org.apache.storm.thrift.protocol.TField
SERIALIZED_JAVA_FIELD_DESC = new
org.apache.storm.thrift.protocol.TField("serialized_java",
org.apache.storm.thrift.protocol.TType.STRING, (short)1);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java
index bb96e9a..6a87706 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ComponentPageInfo implements
org.apache.storm.thrift.TBase<ComponentPageInfo, ComponentPageInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<ComponentPageInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ComponentPageInfo");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ComponentType.java
b/storm-client/src/jvm/org/apache/storm/generated/ComponentType.java
index 67ed928..d9b6f39 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ComponentType.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ComponentType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum ComponentType implements org.apache.storm.thrift.TEnum {
BOLT(1),
SPOUT(2);
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Credentials.java
b/storm-client/src/jvm/org/apache/storm/generated/Credentials.java
index 437a030..707c000 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Credentials.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Credentials.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Credentials implements org.apache.storm.thrift.TBase<Credentials,
Credentials._Fields>, java.io.Serializable, Cloneable, Comparable<Credentials> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("Credentials");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/DRPCExceptionType.java
b/storm-client/src/jvm/org/apache/storm/generated/DRPCExceptionType.java
index 78ade53..8cf25c3 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/DRPCExceptionType.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/DRPCExceptionType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum DRPCExceptionType implements org.apache.storm.thrift.TEnum {
INTERNAL_ERROR(0),
SERVER_SHUTDOWN(1),
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java
b/storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java
index 4fdd1d5..1422358 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class DRPCExecutionException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<DRPCExecutionException,
DRPCExecutionException._Fields>, java.io.Serializable, Cloneable,
Comparable<DRPCExecutionException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("DRPCExecutionException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java
b/storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java
index 39f42da..d46aac9 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class DRPCRequest implements org.apache.storm.thrift.TBase<DRPCRequest,
DRPCRequest._Fields>, java.io.Serializable, Cloneable, Comparable<DRPCRequest> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("DRPCRequest");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java
index 20554c3..c593358 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class DebugOptions implements
org.apache.storm.thrift.TBase<DebugOptions, DebugOptions._Fields>,
java.io.Serializable, Cloneable, Comparable<DebugOptions> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("DebugOptions");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java
b/storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java
index 3841bc6..064c625 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class DistributedRPC {
public interface Iface {
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java
b/storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java
index 867d403..b9ef78f 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class DistributedRPCInvocations {
public interface Iface {
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java
index a607082..9715dbc 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ErrorInfo implements org.apache.storm.thrift.TBase<ErrorInfo,
ErrorInfo._Fields>, java.io.Serializable, Cloneable, Comparable<ErrorInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ErrorInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java
index 99c7e51..f6257e8 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ExecutorAggregateStats implements
org.apache.storm.thrift.TBase<ExecutorAggregateStats,
ExecutorAggregateStats._Fields>, java.io.Serializable, Cloneable,
Comparable<ExecutorAggregateStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ExecutorAggregateStats");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java
index de0f007..55b09f8 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ExecutorInfo implements
org.apache.storm.thrift.TBase<ExecutorInfo, ExecutorInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<ExecutorInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ExecutorInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java
index b6301d6..29778e9 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ExecutorSpecificStats extends
org.apache.storm.thrift.TUnion<ExecutorSpecificStats,
ExecutorSpecificStats._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ExecutorSpecificStats");
private static final org.apache.storm.thrift.protocol.TField BOLT_FIELD_DESC
= new org.apache.storm.thrift.protocol.TField("bolt",
org.apache.storm.thrift.protocol.TType.STRUCT, (short)1);
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java
index b66fd67..9bbe938 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ExecutorStats implements
org.apache.storm.thrift.TBase<ExecutorStats, ExecutorStats._Fields>,
java.io.Serializable, Cloneable, Comparable<ExecutorStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ExecutorStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java
index 1e59c59..77267dd 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ExecutorSummary implements
org.apache.storm.thrift.TBase<ExecutorSummary, ExecutorSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<ExecutorSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ExecutorSummary");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java
index 1bffafb..d6c3dc7 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class GetInfoOptions implements
org.apache.storm.thrift.TBase<GetInfoOptions, GetInfoOptions._Fields>,
java.io.Serializable, Cloneable, Comparable<GetInfoOptions> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("GetInfoOptions");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java
b/storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java
index d442ee5..e4a7062 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class GlobalStreamId implements
org.apache.storm.thrift.TBase<GlobalStreamId, GlobalStreamId._Fields>,
java.io.Serializable, Cloneable, Comparable<GlobalStreamId> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("GlobalStreamId");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Grouping.java
b/storm-client/src/jvm/org/apache/storm/generated/Grouping.java
index dae7db2..01c3544 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Grouping.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Grouping.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Grouping extends org.apache.storm.thrift.TUnion<Grouping,
Grouping._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("Grouping");
private static final org.apache.storm.thrift.protocol.TField
FIELDS_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("fields",
org.apache.storm.thrift.protocol.TType.LIST, (short)1);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java
b/storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java
index 4cc0482..5156996 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBAuthorizationException extends
org.apache.storm.thrift.TException implements
org.apache.storm.thrift.TBase<HBAuthorizationException,
HBAuthorizationException._Fields>, java.io.Serializable, Cloneable,
Comparable<HBAuthorizationException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBAuthorizationException");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java
b/storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java
index 0cebbaa..8c80374 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBExecutionException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<HBExecutionException,
HBExecutionException._Fields>, java.io.Serializable, Cloneable,
Comparable<HBExecutionException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBExecutionException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/HBMessage.java
b/storm-client/src/jvm/org/apache/storm/generated/HBMessage.java
index 2766ee0..0c5e1da 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBMessage.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBMessage.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBMessage implements org.apache.storm.thrift.TBase<HBMessage,
HBMessage._Fields>, java.io.Serializable, Cloneable, Comparable<HBMessage> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBMessage");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java
b/storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java
index 7415754..8af6927 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBMessageData extends
org.apache.storm.thrift.TUnion<HBMessageData, HBMessageData._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBMessageData");
private static final org.apache.storm.thrift.protocol.TField PATH_FIELD_DESC
= new org.apache.storm.thrift.protocol.TField("path",
org.apache.storm.thrift.protocol.TType.STRING, (short)1);
diff --git a/storm-client/src/jvm/org/apache/storm/generated/HBNodes.java
b/storm-client/src/jvm/org/apache/storm/generated/HBNodes.java
index 174dc26..ee60334 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBNodes.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBNodes.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBNodes implements org.apache.storm.thrift.TBase<HBNodes,
HBNodes._Fields>, java.io.Serializable, Cloneable, Comparable<HBNodes> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBNodes");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/HBPulse.java
b/storm-client/src/jvm/org/apache/storm/generated/HBPulse.java
index 84458bf..a2d3c12 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBPulse.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBPulse.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBPulse implements org.apache.storm.thrift.TBase<HBPulse,
HBPulse._Fields>, java.io.Serializable, Cloneable, Comparable<HBPulse> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBPulse");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/HBRecords.java
b/storm-client/src/jvm/org/apache/storm/generated/HBRecords.java
index 26e2648..3d4bc08 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBRecords.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBRecords.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class HBRecords implements org.apache.storm.thrift.TBase<HBRecords,
HBRecords._Fields>, java.io.Serializable, Cloneable, Comparable<HBRecords> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("HBRecords");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/HBServerMessageType.java
b/storm-client/src/jvm/org/apache/storm/generated/HBServerMessageType.java
index 7973290..9262719 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/HBServerMessageType.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/HBServerMessageType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum HBServerMessageType implements org.apache.storm.thrift.TEnum {
CREATE_PATH(0),
CREATE_PATH_RESPONSE(1),
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java
b/storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java
index c3f05e1..94d8f22 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class IllegalStateException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<IllegalStateException,
IllegalStateException._Fields>, java.io.Serializable, Cloneable,
Comparable<IllegalStateException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("IllegalStateException");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java
b/storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java
index d15cbd5..4320fd5 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class InvalidTopologyException extends
org.apache.storm.thrift.TException implements
org.apache.storm.thrift.TBase<InvalidTopologyException,
InvalidTopologyException._Fields>, java.io.Serializable, Cloneable,
Comparable<InvalidTopologyException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("InvalidTopologyException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/JavaObject.java
b/storm-client/src/jvm/org/apache/storm/generated/JavaObject.java
index ff84aa3..420e3e8 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/JavaObject.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/JavaObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class JavaObject implements org.apache.storm.thrift.TBase<JavaObject,
JavaObject._Fields>, java.io.Serializable, Cloneable, Comparable<JavaObject> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("JavaObject");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java
b/storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java
index 89ad6c6..1bed24c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class JavaObjectArg extends
org.apache.storm.thrift.TUnion<JavaObjectArg, JavaObjectArg._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("JavaObjectArg");
private static final org.apache.storm.thrift.protocol.TField
INT_ARG_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("int_arg",
org.apache.storm.thrift.protocol.TType.I32, (short)1);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/KeyAlreadyExistsException.java
b/storm-client/src/jvm/org/apache/storm/generated/KeyAlreadyExistsException.java
index 79bc94a..2baf8e3 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/KeyAlreadyExistsException.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/KeyAlreadyExistsException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class KeyAlreadyExistsException extends
org.apache.storm.thrift.TException implements
org.apache.storm.thrift.TBase<KeyAlreadyExistsException,
KeyAlreadyExistsException._Fields>, java.io.Serializable, Cloneable,
Comparable<KeyAlreadyExistsException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("KeyAlreadyExistsException");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java
b/storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java
index 55039ee..a2d9d81 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class KeyNotFoundException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<KeyNotFoundException,
KeyNotFoundException._Fields>, java.io.Serializable, Cloneable,
Comparable<KeyNotFoundException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("KeyNotFoundException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/KillOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/KillOptions.java
index 1ab7693..c4b9580 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/KillOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/KillOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class KillOptions implements org.apache.storm.thrift.TBase<KillOptions,
KillOptions._Fields>, java.io.Serializable, Cloneable, Comparable<KillOptions> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("KillOptions");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
b/storm-client/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
index 4370d1a..049aea2 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSApprovedWorkers implements
org.apache.storm.thrift.TBase<LSApprovedWorkers, LSApprovedWorkers._Fields>,
java.io.Serializable, Cloneable, Comparable<LSApprovedWorkers> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSApprovedWorkers");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
b/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
index 129259a..97e55d5 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSSupervisorAssignments implements
org.apache.storm.thrift.TBase<LSSupervisorAssignments,
LSSupervisorAssignments._Fields>, java.io.Serializable, Cloneable,
Comparable<LSSupervisorAssignments> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSSupervisorAssignments");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java
b/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java
index 416dcb6..c6af8d3 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSSupervisorId implements
org.apache.storm.thrift.TBase<LSSupervisorId, LSSupervisorId._Fields>,
java.io.Serializable, Cloneable, Comparable<LSSupervisorId> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSSupervisorId");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java
b/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java
index ef7e0ab..420d41d 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSTopoHistory implements
org.apache.storm.thrift.TBase<LSTopoHistory, LSTopoHistory._Fields>,
java.io.Serializable, Cloneable, Comparable<LSTopoHistory> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSTopoHistory");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
b/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
index 17afd66..062d6be 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSTopoHistoryList implements
org.apache.storm.thrift.TBase<LSTopoHistoryList, LSTopoHistoryList._Fields>,
java.io.Serializable, Cloneable, Comparable<LSTopoHistoryList> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSTopoHistoryList");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
b/storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
index 4a01e3e..fd9ac14 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LSWorkerHeartbeat implements
org.apache.storm.thrift.TBase<LSWorkerHeartbeat, LSWorkerHeartbeat._Fields>,
java.io.Serializable, Cloneable, Comparable<LSWorkerHeartbeat> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LSWorkerHeartbeat");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java
b/storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java
index 86b93e5..dfbae2d 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ListBlobsResult implements
org.apache.storm.thrift.TBase<ListBlobsResult, ListBlobsResult._Fields>,
java.io.Serializable, Cloneable, Comparable<ListBlobsResult> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ListBlobsResult");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java
b/storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java
index 22095f9..f674091 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LocalAssignment implements
org.apache.storm.thrift.TBase<LocalAssignment, LocalAssignment._Fields>,
java.io.Serializable, Cloneable, Comparable<LocalAssignment> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LocalAssignment");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java
b/storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java
index 23b532a..063e6ec 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LocalStateData implements
org.apache.storm.thrift.TBase<LocalStateData, LocalStateData._Fields>,
java.io.Serializable, Cloneable, Comparable<LocalStateData> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LocalStateData");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/LogConfig.java
b/storm-client/src/jvm/org/apache/storm/generated/LogConfig.java
index 1b6e3b2..1e33de2 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LogConfig.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LogConfig.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LogConfig implements org.apache.storm.thrift.TBase<LogConfig,
LogConfig._Fields>, java.io.Serializable, Cloneable, Comparable<LogConfig> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LogConfig");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/LogLevel.java
b/storm-client/src/jvm/org/apache/storm/generated/LogLevel.java
index 7879c73..7b98d74 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LogLevel.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LogLevel.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class LogLevel implements org.apache.storm.thrift.TBase<LogLevel,
LogLevel._Fields>, java.io.Serializable, Cloneable, Comparable<LogLevel> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("LogLevel");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/LogLevelAction.java
b/storm-client/src/jvm/org/apache/storm/generated/LogLevelAction.java
index 887d6ae..2ec322c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/LogLevelAction.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/LogLevelAction.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum LogLevelAction implements org.apache.storm.thrift.TEnum {
UNCHANGED(1),
UPDATE(2),
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
index d6093a0..9e19688 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Nimbus {
public interface Iface {
diff --git a/storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java
index 1adbb60..9985fbb 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class NimbusSummary implements
org.apache.storm.thrift.TBase<NimbusSummary, NimbusSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<NimbusSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("NimbusSummary");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java
index 863c162..2aab594 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class NodeInfo implements org.apache.storm.thrift.TBase<NodeInfo,
NodeInfo._Fields>, java.io.Serializable, Cloneable, Comparable<NodeInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("NodeInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/NotAliveException.java
b/storm-client/src/jvm/org/apache/storm/generated/NotAliveException.java
index 72fbf71..5a29703 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/NotAliveException.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/NotAliveException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class NotAliveException extends org.apache.storm.thrift.TException
implements org.apache.storm.thrift.TBase<NotAliveException,
NotAliveException._Fields>, java.io.Serializable, Cloneable,
Comparable<NotAliveException> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("NotAliveException");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/NullStruct.java
b/storm-client/src/jvm/org/apache/storm/generated/NullStruct.java
index e1b4d5d..cea8e31 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/NullStruct.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/NullStruct.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class NullStruct implements org.apache.storm.thrift.TBase<NullStruct,
NullStruct._Fields>, java.io.Serializable, Cloneable, Comparable<NullStruct> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("NullStruct");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/NumErrorsChoice.java
b/storm-client/src/jvm/org/apache/storm/generated/NumErrorsChoice.java
index ace4920..7140e32 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/NumErrorsChoice.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/NumErrorsChoice.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum NumErrorsChoice implements org.apache.storm.thrift.TEnum {
ALL(0),
NONE(1),
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java
index 63c1c15..474a7bc 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class OwnerResourceSummary implements
org.apache.storm.thrift.TBase<OwnerResourceSummary,
OwnerResourceSummary._Fields>, java.io.Serializable, Cloneable,
Comparable<OwnerResourceSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("OwnerResourceSummary");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java
b/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java
index 3895c7c..4a96981 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class PrivateWorkerKey implements
org.apache.storm.thrift.TBase<PrivateWorkerKey, PrivateWorkerKey._Fields>,
java.io.Serializable, Cloneable, Comparable<PrivateWorkerKey> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("PrivateWorkerKey");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java
b/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java
index 7253cdb..40f9892 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum ProfileAction implements org.apache.storm.thrift.TEnum {
JPROFILE_STOP(0),
JPROFILE_START(1),
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java
b/storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java
index ac0ec79..dfc0c7f 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ProfileRequest implements
org.apache.storm.thrift.TBase<ProfileRequest, ProfileRequest._Fields>,
java.io.Serializable, Cloneable, Comparable<ProfileRequest> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ProfileRequest");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java
b/storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java
index dfd3d33..14d5844 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ReadableBlobMeta implements
org.apache.storm.thrift.TBase<ReadableBlobMeta, ReadableBlobMeta._Fields>,
java.io.Serializable, Cloneable, Comparable<ReadableBlobMeta> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ReadableBlobMeta");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java
index 6cb752d..7078eb8 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class RebalanceOptions implements
org.apache.storm.thrift.TBase<RebalanceOptions, RebalanceOptions._Fields>,
java.io.Serializable, Cloneable, Comparable<RebalanceOptions> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("RebalanceOptions");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
b/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
index c33548e..6e5d68c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SettableBlobMeta implements
org.apache.storm.thrift.TBase<SettableBlobMeta, SettableBlobMeta._Fields>,
java.io.Serializable, Cloneable, Comparable<SettableBlobMeta> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SettableBlobMeta");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
b/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
index 632f1ca..1cd1d32 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SharedMemory implements
org.apache.storm.thrift.TBase<SharedMemory, SharedMemory._Fields>,
java.io.Serializable, Cloneable, Comparable<SharedMemory> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SharedMemory");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
b/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
index c58828d..a5b7c8a 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ShellComponent implements
org.apache.storm.thrift.TBase<ShellComponent, ShellComponent._Fields>,
java.io.Serializable, Cloneable, Comparable<ShellComponent> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ShellComponent");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
index a58a286..4f2cb5e 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SpecificAggregateStats extends
org.apache.storm.thrift.TUnion<SpecificAggregateStats,
SpecificAggregateStats._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SpecificAggregateStats");
private static final org.apache.storm.thrift.protocol.TField BOLT_FIELD_DESC
= new org.apache.storm.thrift.protocol.TField("bolt",
org.apache.storm.thrift.protocol.TType.STRUCT, (short)1);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
b/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
index a8fd8cc..c93f5f4 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SpoutAggregateStats implements
org.apache.storm.thrift.TBase<SpoutAggregateStats,
SpoutAggregateStats._Fields>, java.io.Serializable, Cloneable,
Comparable<SpoutAggregateStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SpoutAggregateStats");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java
b/storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java
index b80a07d..1cf7965 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SpoutSpec implements org.apache.storm.thrift.TBase<SpoutSpec,
SpoutSpec._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutSpec> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SpoutSpec");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java
b/storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java
index 14e3844..f943868 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SpoutStats implements org.apache.storm.thrift.TBase<SpoutStats,
SpoutStats._Fields>, java.io.Serializable, Cloneable, Comparable<SpoutStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SpoutStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java
b/storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java
index c387bd5..d14aff7 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class StateSpoutSpec implements
org.apache.storm.thrift.TBase<StateSpoutSpec, StateSpoutSpec._Fields>,
java.io.Serializable, Cloneable, Comparable<StateSpoutSpec> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("StateSpoutSpec");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
b/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
index 7a68c20..3ff0b3a 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StormBase.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class StormBase implements org.apache.storm.thrift.TBase<StormBase,
StormBase._Fields>, java.io.Serializable, Cloneable, Comparable<StormBase> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("StormBase");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
b/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
index dc1fd18..1bd0c25 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StormTopology.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class StormTopology implements
org.apache.storm.thrift.TBase<StormTopology, StormTopology._Fields>,
java.io.Serializable, Cloneable, Comparable<StormTopology> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("StormTopology");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
index e16f83a..4a102f8 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class StreamInfo implements org.apache.storm.thrift.TBase<StreamInfo,
StreamInfo._Fields>, java.io.Serializable, Cloneable, Comparable<StreamInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("StreamInfo");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java
index 6c6a21c..206d59b 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SubmitOptions implements
org.apache.storm.thrift.TBase<SubmitOptions, SubmitOptions._Fields>,
java.io.Serializable, Cloneable, Comparable<SubmitOptions> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SubmitOptions");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Supervisor.java
b/storm-client/src/jvm/org/apache/storm/generated/Supervisor.java
index c38d57c..96e3e13 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Supervisor.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Supervisor.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class Supervisor {
public interface Iface {
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java
index 7d61955..490c80c 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorAssignments implements
org.apache.storm.thrift.TBase<SupervisorAssignments,
SupervisorAssignments._Fields>, java.io.Serializable, Cloneable,
Comparable<SupervisorAssignments> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorAssignments");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java
index 0270e5b..366ca3d 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorInfo implements
org.apache.storm.thrift.TBase<SupervisorInfo, SupervisorInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<SupervisorInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
index a77f242..d3cf4b3 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorPageInfo implements
org.apache.storm.thrift.TBase<SupervisorPageInfo, SupervisorPageInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<SupervisorPageInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorPageInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java
index 8cb28ec..ccbeaf7 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorSummary implements
org.apache.storm.thrift.TBase<SupervisorSummary, SupervisorSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<SupervisorSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorSummary");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java
index 497a447..751cd8e 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorWorkerHeartbeat implements
org.apache.storm.thrift.TBase<SupervisorWorkerHeartbeat,
SupervisorWorkerHeartbeat._Fields>, java.io.Serializable, Cloneable,
Comparable<SupervisorWorkerHeartbeat> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorWorkerHeartbeat");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java
index 20edbfb..28299b8 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class SupervisorWorkerHeartbeats implements
org.apache.storm.thrift.TBase<SupervisorWorkerHeartbeats,
SupervisorWorkerHeartbeats._Fields>, java.io.Serializable, Cloneable,
Comparable<SupervisorWorkerHeartbeats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("SupervisorWorkerHeartbeats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java
b/storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java
index 8a77daa..7ec1f7b 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class ThriftSerializedObject implements
org.apache.storm.thrift.TBase<ThriftSerializedObject,
ThriftSerializedObject._Fields>, java.io.Serializable, Cloneable,
Comparable<ThriftSerializedObject> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("ThriftSerializedObject");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java
index f0ce214..c1500bd 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologyActionOptions extends
org.apache.storm.thrift.TUnion<TopologyActionOptions,
TopologyActionOptions._Fields> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologyActionOptions");
private static final org.apache.storm.thrift.protocol.TField
KILL_OPTIONS_FIELD_DESC = new
org.apache.storm.thrift.protocol.TField("kill_options",
org.apache.storm.thrift.protocol.TType.STRUCT, (short)1);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
index f88a7fc..dbc4fa5 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyHistoryInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologyHistoryInfo implements
org.apache.storm.thrift.TBase<TopologyHistoryInfo,
TopologyHistoryInfo._Fields>, java.io.Serializable, Cloneable,
Comparable<TopologyHistoryInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologyHistoryInfo");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java
index 0596f79..7cda752 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologyInfo implements
org.apache.storm.thrift.TBase<TopologyInfo, TopologyInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<TopologyInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologyInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java
index e55e7fa..114d0f4 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum TopologyInitialStatus implements org.apache.storm.thrift.TEnum {
ACTIVE(1),
INACTIVE(2);
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
index 90d950a..5c37201 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologyPageInfo implements
org.apache.storm.thrift.TBase<TopologyPageInfo, TopologyPageInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<TopologyPageInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologyPageInfo");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
index de7306e..21189f9 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologyStats implements
org.apache.storm.thrift.TBase<TopologyStats, TopologyStats._Fields>,
java.io.Serializable, Cloneable, Comparable<TopologyStats> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologyStats");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
index b138865..4563334 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologyStatus.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum TopologyStatus implements org.apache.storm.thrift.TEnum {
ACTIVE(1),
INACTIVE(2),
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java
b/storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java
index 656c8e1..cb8b331 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class TopologySummary implements
org.apache.storm.thrift.TBase<TopologySummary, TopologySummary._Fields>,
java.io.Serializable, Cloneable, Comparable<TopologySummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("TopologySummary");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java
index 6ca8470..cec7efb 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerMetricList implements
org.apache.storm.thrift.TBase<WorkerMetricList, WorkerMetricList._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerMetricList> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerMetricList");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java
index ca3b14e..879f686 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerMetricPoint implements
org.apache.storm.thrift.TBase<WorkerMetricPoint, WorkerMetricPoint._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerMetricPoint> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerMetricPoint");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java
index 935cb66..dcdbdb5 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerMetrics implements
org.apache.storm.thrift.TBase<WorkerMetrics, WorkerMetrics._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerMetrics> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerMetrics");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java
index 8f08b33..178e722 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerResources implements
org.apache.storm.thrift.TBase<WorkerResources, WorkerResources._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerResources> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerResources");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java
index dbecba0..d296360 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerSummary implements
org.apache.storm.thrift.TBase<WorkerSummary, WorkerSummary._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerSummary> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerSummary");
diff --git a/storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java
index efeb1d4..8bdbdca 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerToken implements org.apache.storm.thrift.TBase<WorkerToken,
WorkerToken._Fields>, java.io.Serializable, Cloneable, Comparable<WorkerToken> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerToken");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java
index 4736b65..b58b240 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public class WorkerTokenInfo implements
org.apache.storm.thrift.TBase<WorkerTokenInfo, WorkerTokenInfo._Fields>,
java.io.Serializable, Cloneable, Comparable<WorkerTokenInfo> {
private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC =
new org.apache.storm.thrift.protocol.TStruct("WorkerTokenInfo");
diff --git
a/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenServiceType.java
b/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenServiceType.java
index 5d834d0..420e571 100644
---
a/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenServiceType.java
+++
b/storm-client/src/jvm/org/apache/storm/generated/WorkerTokenServiceType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.12.0)
+ * Autogenerated by Thrift Compiler (0.13.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -24,7 +24,7 @@
package org.apache.storm.generated;
[email protected](value = "Autogenerated by Thrift Compiler
(0.12.0)")
[email protected](value = "Autogenerated by Thrift Compiler
(0.13.0)")
public enum WorkerTokenServiceType implements org.apache.storm.thrift.TEnum {
NIMBUS(0),
DRPC(1),
diff --git
a/storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java
b/storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java
index 21a6ce1..0276525 100644
---
a/storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java
+++
b/storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java
@@ -130,7 +130,7 @@ public class SimpleTransportPlugin implements
ITransportPlugin {
}
@Override
- public boolean process(final TProtocol inProt, final TProtocol
outProt) throws TException {
+ public void process(final TProtocol inProt, final TProtocol outProt)
throws TException {
//populating request context
ReqContext reqContext = ReqContext.context();
@@ -171,7 +171,7 @@ public class SimpleTransportPlugin implements
ITransportPlugin {
reqContext.setSubject(s);
//invoke service handler
- return wrapped.process(inProt, outProt);
+ wrapped.process(inProt, outProt);
}
}
}
diff --git
a/storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java
b/storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java
index b204c1a..343c247 100644
---
a/storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java
+++
b/storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java
@@ -126,7 +126,7 @@ public abstract class SaslTransportPlugin implements
ITransportPlugin, Closeable
}
@Override
- public boolean process(final TProtocol inProt, final TProtocol
outProt) throws TException {
+ public void process(final TProtocol inProt, final TProtocol outProt)
throws TException {
//populating request context
ReqContext reqContext = ReqContext.context();
@@ -135,7 +135,7 @@ public abstract class SaslTransportPlugin implements
ITransportPlugin, Closeable
TSaslServerTransport saslTrans = (TSaslServerTransport) trans;
if (trans instanceof NoOpTTrasport) {
- return false;
+ return;
}
//remote address
@@ -151,7 +151,7 @@ public abstract class SaslTransportPlugin implements
ITransportPlugin, Closeable
reqContext.setSubject(remoteUser);
//invoke service handler
- return wrapped.process(inProt, outProt);
+ wrapped.process(inProt, outProt);
}
}
diff --git a/storm-client/src/py/storm/DistributedRPC-remote
b/storm-client/src/py/storm/DistributedRPC-remote
index c0ebdb6..8a04566 100644
--- a/storm-client/src/py/storm/DistributedRPC-remote
+++ b/storm-client/src/py/storm/DistributedRPC-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
diff --git a/storm-client/src/py/storm/DistributedRPC.py
b/storm-client/src/py/storm/DistributedRPC.py
index 4d91b1d..24be6a1 100644
--- a/storm-client/src/py/storm/DistributedRPC.py
+++ b/storm-client/src/py/storm/DistributedRPC.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -98,9 +98,15 @@ class Processor(Iface, TProcessor):
self._handler = handler
self._processMap = {}
self._processMap["execute"] = Processor.process_execute
+ self._on_message_begin = None
+
+ def on_message_begin(self, func):
+ self._on_message_begin = func
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
+ if self._on_message_begin:
+ self._on_message_begin(name, type, seqid)
if name not in self._processMap:
iprot.skip(TType.STRUCT)
iprot.readMessageEnd()
diff --git a/storm-client/src/py/storm/DistributedRPCInvocations-remote
b/storm-client/src/py/storm/DistributedRPCInvocations-remote
index 6535546..2213e35 100644
--- a/storm-client/src/py/storm/DistributedRPCInvocations-remote
+++ b/storm-client/src/py/storm/DistributedRPCInvocations-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
diff --git a/storm-client/src/py/storm/DistributedRPCInvocations.py
b/storm-client/src/py/storm/DistributedRPCInvocations.py
index d58e70c..bf71173 100644
--- a/storm-client/src/py/storm/DistributedRPCInvocations.py
+++ b/storm-client/src/py/storm/DistributedRPCInvocations.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -222,9 +222,15 @@ class Processor(Iface, TProcessor):
self._processMap["fetchRequest"] = Processor.process_fetchRequest
self._processMap["failRequest"] = Processor.process_failRequest
self._processMap["failRequestV2"] = Processor.process_failRequestV2
+ self._on_message_begin = None
+
+ def on_message_begin(self, func):
+ self._on_message_begin = func
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
+ if self._on_message_begin:
+ self._on_message_begin(name, type, seqid)
if name not in self._processMap:
iprot.skip(TType.STRUCT)
iprot.readMessageEnd()
diff --git a/storm-client/src/py/storm/Nimbus-remote
b/storm-client/src/py/storm/Nimbus-remote
index f1e56d5..6b104dc 100644
--- a/storm-client/src/py/storm/Nimbus-remote
+++ b/storm-client/src/py/storm/Nimbus-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
diff --git a/storm-client/src/py/storm/Nimbus.py
b/storm-client/src/py/storm/Nimbus.py
index ea55747..973018d 100644
--- a/storm-client/src/py/storm/Nimbus.py
+++ b/storm-client/src/py/storm/Nimbus.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -2286,9 +2286,15 @@ class Processor(Iface, TProcessor):
self._processMap["sendSupervisorWorkerHeartbeat"] =
Processor.process_sendSupervisorWorkerHeartbeat
self._processMap["processWorkerMetrics"] =
Processor.process_processWorkerMetrics
self._processMap["isRemoteBlobExists"] =
Processor.process_isRemoteBlobExists
+ self._on_message_begin = None
+
+ def on_message_begin(self, func):
+ self._on_message_begin = func
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
+ if self._on_message_begin:
+ self._on_message_begin(name, type, seqid)
if name not in self._processMap:
iprot.skip(TType.STRUCT)
iprot.readMessageEnd()
diff --git a/storm-client/src/py/storm/Supervisor-remote
b/storm-client/src/py/storm/Supervisor-remote
index 4f0bc2f..b08c4fd 100644
--- a/storm-client/src/py/storm/Supervisor-remote
+++ b/storm-client/src/py/storm/Supervisor-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
diff --git a/storm-client/src/py/storm/Supervisor.py
b/storm-client/src/py/storm/Supervisor.py
index 5ade6cc..72d4529 100644
--- a/storm-client/src/py/storm/Supervisor.py
+++ b/storm-client/src/py/storm/Supervisor.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -189,9 +189,15 @@ class Processor(Iface, TProcessor):
self._processMap["sendSupervisorAssignments"] =
Processor.process_sendSupervisorAssignments
self._processMap["getLocalAssignmentForStorm"] =
Processor.process_getLocalAssignmentForStorm
self._processMap["sendSupervisorWorkerHeartbeat"] =
Processor.process_sendSupervisorWorkerHeartbeat
+ self._on_message_begin = None
+
+ def on_message_begin(self, func):
+ self._on_message_begin = func
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
+ if self._on_message_begin:
+ self._on_message_begin(name, type, seqid)
if name not in self._processMap:
iprot.skip(TType.STRUCT)
iprot.readMessageEnd()
diff --git a/storm-client/src/py/storm/constants.py
b/storm-client/src/py/storm/constants.py
index 8d8ee2c..2bfb61e 100644
--- a/storm-client/src/py/storm/constants.py
+++ b/storm-client/src/py/storm/constants.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
diff --git a/storm-client/src/py/storm/ttypes.py
b/storm-client/src/py/storm/ttypes.py
index 4fae416..bf19374 100644
--- a/storm-client/src/py/storm/ttypes.py
+++ b/storm-client/src/py/storm/ttypes.py
@@ -17,7 +17,7 @@
# limitations under the License.
#
-# Autogenerated by Thrift Compiler (0.12.0)
+# Autogenerated by Thrift Compiler (0.13.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#