You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/05/23 20:03:54 UTC
[24/43] storm git commit: STORM-3061: thrift 0.11
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
----------------------------------------------------------------------
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 ddefe4c..ac105e1 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -16,63 +16,36 @@
* limitations under the License.
*/
/**
- * Autogenerated by Thrift Compiler (0.9.3)
+ * Autogenerated by Thrift Compiler (0.11.0)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.storm.generated;
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
-import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)")
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
+@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)")
public class Nimbus {
public interface Iface {
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
+ public void submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
+ public void submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void killTopologyWithOpts(java.lang.String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void activate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
+ public void rebalance(java.lang.String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public void setLogConfig(String name, LogConfig config) throws org.apache.thrift.TException;
+ public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException;
- public LogConfig getLogConfig(String name) throws org.apache.thrift.TException;
+ public LogConfig getLogConfig(java.lang.String name) throws org.apache.thrift.TException;
/**
* Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional
@@ -86,96 +59,96 @@ public class Nimbus {
* @param enable
* @param samplingPercentage
*/
- public void debug(String name, String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void debug(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.thrift.TException;
+ public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException;
- public List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.thrift.TException;
+ public java.util.List<ProfileRequest> getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action) throws org.apache.thrift.TException;
- public void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
+ public void uploadNewCredentials(java.lang.String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException;
- public String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException;
+ public java.lang.String beginCreateBlob(java.lang.String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException;
- public String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
+ public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
- public void finishBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException;
+ public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
- public void cancelBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException;
+ public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
- public ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public void setBlobMeta(java.lang.String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.thrift.TException;
+ public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
- public void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public ListBlobsResult listBlobs(String session) throws org.apache.thrift.TException;
+ public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.thrift.TException;
- public int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public int updateBlobReplication(java.lang.String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
- public void createStateInZookeeper(String key) throws org.apache.thrift.TException;
+ public void createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException;
- public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException;
- public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
+ public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
- public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException;
+ public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.thrift.TException;
- public String beginFileDownload(String file) throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.thrift.TException;
- public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.thrift.TException;
+ public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.thrift.TException;
- public String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException;
public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException;
public NimbusSummary getLeader() throws AuthorizationException, org.apache.thrift.TException;
- public boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.thrift.TException;
+ public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.thrift.TException;
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public TopologyInfo getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public TopologyPageInfo getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public SupervisorPageInfo getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public ComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public ComponentPageInfo getComponentPageInfo(java.lang.String topology_id, java.lang.String component_id, java.lang.String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String getTopologyConf(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
/**
* Returns the compiled topology that contains ackers and metrics consumsers. Compare {@link #getUserTopology(String id)}.
*
* @param id
*/
- public StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public StormTopology getTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
/**
* Returns the user specified topology as submitted originally. Compare {@link #getTopology(String id)}.
*
* @param id
*/
- public StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public StormTopology getUserTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
- public TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.thrift.TException;
+ public TopologyHistoryInfo getTopologyHistory(java.lang.String user) throws AuthorizationException, org.apache.thrift.TException;
- public List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.thrift.TException;
+ public java.util.List<OwnerResourceSummary> getOwnerResourceSummaries(java.lang.String owner) throws AuthorizationException, org.apache.thrift.TException;
/**
* Get assigned assignments for a specific supervisor
*
* @param node
*/
- public SupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.thrift.TException;
+ public SupervisorAssignments getSupervisorAssignments(java.lang.String node) throws AuthorizationException, org.apache.thrift.TException;
/**
* Send supervisor worker heartbeats for a specific supervisor
@@ -189,7 +162,7 @@ public class Nimbus {
*
* @param heatbeat
*/
- public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.thrift.TException;
public void processWorkerMetrics(WorkerMetrics metrics) throws org.apache.thrift.TException;
@@ -197,105 +170,105 @@ public class Nimbus {
public interface AsyncIface {
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void killTopology(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void killTopologyWithOpts(java.lang.String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void activate(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void deactivate(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void rebalance(java.lang.String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void setLogConfig(String name, LogConfig config, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void setLogConfig(java.lang.String name, LogConfig config, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void getLogConfig(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getLogConfig(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.thrift.TException;
- public void debug(String name, String component, boolean enable, double samplingPercentage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void debug(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action, org.apache.thrift.async.AsyncMethodCallback<java.util.List<ProfileRequest>> resultHandler) throws org.apache.thrift.TException;
- public void uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void uploadNewCredentials(java.lang.String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void beginCreateBlob(String key, SettableBlobMeta meta, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void beginCreateBlob(java.lang.String key, SettableBlobMeta meta, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void beginUpdateBlob(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void beginUpdateBlob(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void uploadBlobChunk(String session, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void finishBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void finishBlobUpload(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void cancelBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void cancelBlobUpload(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void getBlobMeta(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getBlobMeta(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.thrift.TException;
- public void setBlobMeta(String key, SettableBlobMeta meta, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void setBlobMeta(java.lang.String key, SettableBlobMeta meta, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void beginBlobDownload(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void beginBlobDownload(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.thrift.TException;
- public void downloadBlobChunk(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void downloadBlobChunk(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.thrift.TException;
- public void deleteBlob(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void deleteBlob(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void listBlobs(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void listBlobs(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.thrift.TException;
- public void getBlobReplication(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getBlobReplication(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> resultHandler) throws org.apache.thrift.TException;
- public void updateBlobReplication(String key, int replication, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void updateBlobReplication(java.lang.String key, int replication, org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> resultHandler) throws org.apache.thrift.TException;
- public void createStateInZookeeper(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void createStateInZookeeper(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void finishFileUpload(java.lang.String location, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void beginFileDownload(java.lang.String file, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void downloadChunk(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.thrift.TException;
- public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.thrift.TException;
- public void getLeader(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getLeader(org.apache.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.thrift.TException;
- public void isTopologyNameAllowed(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void isTopologyNameAllowed(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException;
- public void getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyInfo(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.thrift.TException;
- public void getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options, org.apache.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.thrift.TException;
- public void getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.thrift.TException;
- public void getSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.thrift.TException;
- public void getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getComponentPageInfo(java.lang.String topology_id, java.lang.String component_id, java.lang.String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.thrift.TException;
- public void getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyConf(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
- public void getTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopology(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.thrift.TException;
- public void getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getUserTopology(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.thrift.TException;
- public void getTopologyHistory(String user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyHistory(java.lang.String user, org.apache.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.thrift.TException;
- public void getOwnerResourceSummaries(String owner, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getOwnerResourceSummaries(java.lang.String owner, org.apache.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.thrift.TException;
- public void getSupervisorAssignments(String node, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void getSupervisorAssignments(java.lang.String node, org.apache.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.thrift.TException;
- public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
- public void processWorkerMetrics(WorkerMetrics metrics, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void processWorkerMetrics(WorkerMetrics metrics, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
}
@@ -319,13 +292,13 @@ public class Nimbus {
super(iprot, oprot);
}
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_submitTopology(name, uploadedJarLocation, jsonConf, topology);
recv_submitTopology();
}
- public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.thrift.TException
+ public void send_submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology) throws org.apache.thrift.TException
{
submitTopology_args args = new submitTopology_args();
args.set_name(name);
@@ -351,13 +324,13 @@ public class Nimbus {
return;
}
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_submitTopologyWithOpts(name, uploadedJarLocation, jsonConf, topology, options);
recv_submitTopologyWithOpts();
}
- public void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.thrift.TException
+ public void send_submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.thrift.TException
{
submitTopologyWithOpts_args args = new submitTopologyWithOpts_args();
args.set_name(name);
@@ -384,13 +357,13 @@ public class Nimbus {
return;
}
- public void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_killTopology(name);
recv_killTopology();
}
- public void send_killTopology(String name) throws org.apache.thrift.TException
+ public void send_killTopology(java.lang.String name) throws org.apache.thrift.TException
{
killTopology_args args = new killTopology_args();
args.set_name(name);
@@ -410,13 +383,13 @@ public class Nimbus {
return;
}
- public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void killTopologyWithOpts(java.lang.String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_killTopologyWithOpts(name, options);
recv_killTopologyWithOpts();
}
- public void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.thrift.TException
+ public void send_killTopologyWithOpts(java.lang.String name, KillOptions options) throws org.apache.thrift.TException
{
killTopologyWithOpts_args args = new killTopologyWithOpts_args();
args.set_name(name);
@@ -437,13 +410,13 @@ public class Nimbus {
return;
}
- public void activate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_activate(name);
recv_activate();
}
- public void send_activate(String name) throws org.apache.thrift.TException
+ public void send_activate(java.lang.String name) throws org.apache.thrift.TException
{
activate_args args = new activate_args();
args.set_name(name);
@@ -463,13 +436,13 @@ public class Nimbus {
return;
}
- public void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_deactivate(name);
recv_deactivate();
}
- public void send_deactivate(String name) throws org.apache.thrift.TException
+ public void send_deactivate(java.lang.String name) throws org.apache.thrift.TException
{
deactivate_args args = new deactivate_args();
args.set_name(name);
@@ -489,13 +462,13 @@ public class Nimbus {
return;
}
- public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void rebalance(java.lang.String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_rebalance(name, options);
recv_rebalance();
}
- public void send_rebalance(String name, RebalanceOptions options) throws org.apache.thrift.TException
+ public void send_rebalance(java.lang.String name, RebalanceOptions options) throws org.apache.thrift.TException
{
rebalance_args args = new rebalance_args();
args.set_name(name);
@@ -519,13 +492,13 @@ public class Nimbus {
return;
}
- public void setLogConfig(String name, LogConfig config) throws org.apache.thrift.TException
+ public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException
{
send_setLogConfig(name, config);
recv_setLogConfig();
}
- public void send_setLogConfig(String name, LogConfig config) throws org.apache.thrift.TException
+ public void send_setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException
{
setLogConfig_args args = new setLogConfig_args();
args.set_name(name);
@@ -540,13 +513,13 @@ public class Nimbus {
return;
}
- public LogConfig getLogConfig(String name) throws org.apache.thrift.TException
+ public LogConfig getLogConfig(java.lang.String name) throws org.apache.thrift.TException
{
send_getLogConfig(name);
return recv_getLogConfig();
}
- public void send_getLogConfig(String name) throws org.apache.thrift.TException
+ public void send_getLogConfig(java.lang.String name) throws org.apache.thrift.TException
{
getLogConfig_args args = new getLogConfig_args();
args.set_name(name);
@@ -563,13 +536,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLogConfig failed: unknown result");
}
- public void debug(String name, String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void debug(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_debug(name, component, enable, samplingPercentage);
recv_debug();
}
- public void send_debug(String name, String component, boolean enable, double samplingPercentage) throws org.apache.thrift.TException
+ public void send_debug(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage) throws org.apache.thrift.TException
{
debug_args args = new debug_args();
args.set_name(name);
@@ -592,13 +565,13 @@ public class Nimbus {
return;
}
- public void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
+ public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
{
send_setWorkerProfiler(id, profileRequest);
recv_setWorkerProfiler();
}
- public void send_setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
+ public void send_setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
{
setWorkerProfiler_args args = new setWorkerProfiler_args();
args.set_id(id);
@@ -613,13 +586,13 @@ public class Nimbus {
return;
}
- public List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.thrift.TException
+ public java.util.List<ProfileRequest> getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action) throws org.apache.thrift.TException
{
send_getComponentPendingProfileActions(id, component_id, action);
return recv_getComponentPendingProfileActions();
}
- public void send_getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.thrift.TException
+ public void send_getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action) throws org.apache.thrift.TException
{
getComponentPendingProfileActions_args args = new getComponentPendingProfileActions_args();
args.set_id(id);
@@ -628,7 +601,7 @@ public class Nimbus {
sendBase("getComponentPendingProfileActions", args);
}
- public List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.thrift.TException
+ public java.util.List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.thrift.TException
{
getComponentPendingProfileActions_result result = new getComponentPendingProfileActions_result();
receiveBase(result, "getComponentPendingProfileActions");
@@ -638,13 +611,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComponentPendingProfileActions failed: unknown result");
}
- public void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void uploadNewCredentials(java.lang.String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
{
send_uploadNewCredentials(name, creds);
recv_uploadNewCredentials();
}
- public void send_uploadNewCredentials(String name, Credentials creds) throws org.apache.thrift.TException
+ public void send_uploadNewCredentials(java.lang.String name, Credentials creds) throws org.apache.thrift.TException
{
uploadNewCredentials_args args = new uploadNewCredentials_args();
args.set_name(name);
@@ -668,13 +641,13 @@ public class Nimbus {
return;
}
- public String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException
+ public java.lang.String beginCreateBlob(java.lang.String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException
{
send_beginCreateBlob(key, meta);
return recv_beginCreateBlob();
}
- public void send_beginCreateBlob(String key, SettableBlobMeta meta) throws org.apache.thrift.TException
+ public void send_beginCreateBlob(java.lang.String key, SettableBlobMeta meta) throws org.apache.thrift.TException
{
beginCreateBlob_args args = new beginCreateBlob_args();
args.set_key(key);
@@ -682,7 +655,7 @@ public class Nimbus {
sendBase("beginCreateBlob", args);
}
- public String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException
+ public java.lang.String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException
{
beginCreateBlob_result result = new beginCreateBlob_result();
receiveBase(result, "beginCreateBlob");
@@ -698,20 +671,20 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginCreateBlob failed: unknown result");
}
- public String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_beginUpdateBlob(key);
return recv_beginUpdateBlob();
}
- public void send_beginUpdateBlob(String key) throws org.apache.thrift.TException
+ public void send_beginUpdateBlob(java.lang.String key) throws org.apache.thrift.TException
{
beginUpdateBlob_args args = new beginUpdateBlob_args();
args.set_key(key);
sendBase("beginUpdateBlob", args);
}
- public String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public java.lang.String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
beginUpdateBlob_result result = new beginUpdateBlob_result();
receiveBase(result, "beginUpdateBlob");
@@ -727,13 +700,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginUpdateBlob failed: unknown result");
}
- public void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
+ public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
{
send_uploadBlobChunk(session, chunk);
recv_uploadBlobChunk();
}
- public void send_uploadBlobChunk(String session, ByteBuffer chunk) throws org.apache.thrift.TException
+ public void send_uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws org.apache.thrift.TException
{
uploadBlobChunk_args args = new uploadBlobChunk_args();
args.set_session(session);
@@ -751,13 +724,13 @@ public class Nimbus {
return;
}
- public void finishBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException
+ public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
{
send_finishBlobUpload(session);
recv_finishBlobUpload();
}
- public void send_finishBlobUpload(String session) throws org.apache.thrift.TException
+ public void send_finishBlobUpload(java.lang.String session) throws org.apache.thrift.TException
{
finishBlobUpload_args args = new finishBlobUpload_args();
args.set_session(session);
@@ -774,13 +747,13 @@ public class Nimbus {
return;
}
- public void cancelBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException
+ public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
{
send_cancelBlobUpload(session);
recv_cancelBlobUpload();
}
- public void send_cancelBlobUpload(String session) throws org.apache.thrift.TException
+ public void send_cancelBlobUpload(java.lang.String session) throws org.apache.thrift.TException
{
cancelBlobUpload_args args = new cancelBlobUpload_args();
args.set_session(session);
@@ -797,13 +770,13 @@ public class Nimbus {
return;
}
- public ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_getBlobMeta(key);
return recv_getBlobMeta();
}
- public void send_getBlobMeta(String key) throws org.apache.thrift.TException
+ public void send_getBlobMeta(java.lang.String key) throws org.apache.thrift.TException
{
getBlobMeta_args args = new getBlobMeta_args();
args.set_key(key);
@@ -826,13 +799,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getBlobMeta failed: unknown result");
}
- public void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public void setBlobMeta(java.lang.String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_setBlobMeta(key, meta);
recv_setBlobMeta();
}
- public void send_setBlobMeta(String key, SettableBlobMeta meta) throws org.apache.thrift.TException
+ public void send_setBlobMeta(java.lang.String key, SettableBlobMeta meta) throws org.apache.thrift.TException
{
setBlobMeta_args args = new setBlobMeta_args();
args.set_key(key);
@@ -853,13 +826,13 @@ public class Nimbus {
return;
}
- public BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_beginBlobDownload(key);
return recv_beginBlobDownload();
}
- public void send_beginBlobDownload(String key) throws org.apache.thrift.TException
+ public void send_beginBlobDownload(java.lang.String key) throws org.apache.thrift.TException
{
beginBlobDownload_args args = new beginBlobDownload_args();
args.set_key(key);
@@ -882,20 +855,20 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginBlobDownload failed: unknown result");
}
- public ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
{
send_downloadBlobChunk(session);
return recv_downloadBlobChunk();
}
- public void send_downloadBlobChunk(String session) throws org.apache.thrift.TException
+ public void send_downloadBlobChunk(java.lang.String session) throws org.apache.thrift.TException
{
downloadBlobChunk_args args = new downloadBlobChunk_args();
args.set_session(session);
sendBase("downloadBlobChunk", args);
}
- public ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.thrift.TException
{
downloadBlobChunk_result result = new downloadBlobChunk_result();
receiveBase(result, "downloadBlobChunk");
@@ -908,13 +881,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadBlobChunk failed: unknown result");
}
- public void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_deleteBlob(key);
recv_deleteBlob();
}
- public void send_deleteBlob(String key) throws org.apache.thrift.TException
+ public void send_deleteBlob(java.lang.String key) throws org.apache.thrift.TException
{
deleteBlob_args args = new deleteBlob_args();
args.set_key(key);
@@ -934,13 +907,13 @@ public class Nimbus {
return;
}
- public ListBlobsResult listBlobs(String session) throws org.apache.thrift.TException
+ public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.thrift.TException
{
send_listBlobs(session);
return recv_listBlobs();
}
- public void send_listBlobs(String session) throws org.apache.thrift.TException
+ public void send_listBlobs(java.lang.String session) throws org.apache.thrift.TException
{
listBlobs_args args = new listBlobs_args();
args.set_session(session);
@@ -957,13 +930,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listBlobs failed: unknown result");
}
- public int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_getBlobReplication(key);
return recv_getBlobReplication();
}
- public void send_getBlobReplication(String key) throws org.apache.thrift.TException
+ public void send_getBlobReplication(java.lang.String key) throws org.apache.thrift.TException
{
getBlobReplication_args args = new getBlobReplication_args();
args.set_key(key);
@@ -986,13 +959,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getBlobReplication failed: unknown result");
}
- public int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public int updateBlobReplication(java.lang.String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
{
send_updateBlobReplication(key, replication);
return recv_updateBlobReplication();
}
- public void send_updateBlobReplication(String key, int replication) throws org.apache.thrift.TException
+ public void send_updateBlobReplication(java.lang.String key, int replication) throws org.apache.thrift.TException
{
updateBlobReplication_args args = new updateBlobReplication_args();
args.set_key(key);
@@ -1016,13 +989,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateBlobReplication failed: unknown result");
}
- public void createStateInZookeeper(String key) throws org.apache.thrift.TException
+ public void createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException
{
send_createStateInZookeeper(key);
recv_createStateInZookeeper();
}
- public void send_createStateInZookeeper(String key) throws org.apache.thrift.TException
+ public void send_createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException
{
createStateInZookeeper_args args = new createStateInZookeeper_args();
args.set_key(key);
@@ -1036,7 +1009,7 @@ public class Nimbus {
return;
}
- public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
{
send_beginFileUpload();
return recv_beginFileUpload();
@@ -1048,7 +1021,7 @@ public class Nimbus {
sendBase("beginFileUpload", args);
}
- public String recv_beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
{
beginFileUpload_result result = new beginFileUpload_result();
receiveBase(result, "beginFileUpload");
@@ -1061,13 +1034,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
}
- public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
+ public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
{
send_uploadChunk(location, chunk);
recv_uploadChunk();
}
- public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException
+ public void send_uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws org.apache.thrift.TException
{
uploadChunk_args args = new uploadChunk_args();
args.set_location(location);
@@ -1085,13 +1058,13 @@ public class Nimbus {
return;
}
- public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException
+ public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.thrift.TException
{
send_finishFileUpload(location);
recv_finishFileUpload();
}
- public void send_finishFileUpload(String location) throws org.apache.thrift.TException
+ public void send_finishFileUpload(java.lang.String location) throws org.apache.thrift.TException
{
finishFileUpload_args args = new finishFileUpload_args();
args.set_location(location);
@@ -1108,20 +1081,20 @@ public class Nimbus {
return;
}
- public String beginFileDownload(String file) throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.thrift.TException
{
send_beginFileDownload(file);
return recv_beginFileDownload();
}
- public void send_beginFileDownload(String file) throws org.apache.thrift.TException
+ public void send_beginFileDownload(java.lang.String file) throws org.apache.thrift.TException
{
beginFileDownload_args args = new beginFileDownload_args();
args.set_file(file);
sendBase("beginFileDownload", args);
}
- public String recv_beginFileDownload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_beginFileDownload() throws AuthorizationException, org.apache.thrift.TException
{
beginFileDownload_result result = new beginFileDownload_result();
receiveBase(result, "beginFileDownload");
@@ -1134,20 +1107,20 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
}
- public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.thrift.TException
{
send_downloadChunk(id);
return recv_downloadChunk();
}
- public void send_downloadChunk(String id) throws org.apache.thrift.TException
+ public void send_downloadChunk(java.lang.String id) throws org.apache.thrift.TException
{
downloadChunk_args args = new downloadChunk_args();
args.set_id(id);
sendBase("downloadChunk", args);
}
- public ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.thrift.TException
{
downloadChunk_result result = new downloadChunk_result();
receiveBase(result, "downloadChunk");
@@ -1160,7 +1133,7 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
}
- public String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
{
send_getNimbusConf();
return recv_getNimbusConf();
@@ -1172,7 +1145,7 @@ public class Nimbus {
sendBase("getNimbusConf", args);
}
- public String recv_getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
{
getNimbusConf_result result = new getNimbusConf_result();
receiveBase(result, "getNimbusConf");
@@ -1235,13 +1208,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLeader failed: unknown result");
}
- public boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.thrift.TException
+ public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.thrift.TException
{
send_isTopologyNameAllowed(name);
return recv_isTopologyNameAllowed();
}
- public void send_isTopologyNameAllowed(String name) throws org.apache.thrift.TException
+ public void send_isTopologyNameAllowed(java.lang.String name) throws org.apache.thrift.TException
{
isTopologyNameAllowed_args args = new isTopologyNameAllowed_args();
args.set_name(name);
@@ -1261,13 +1234,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTopologyNameAllowed failed: unknown result");
}
- public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyInfo(id);
return recv_getTopologyInfo();
}
- public void send_getTopologyInfo(String id) throws org.apache.thrift.TException
+ public void send_getTopologyInfo(java.lang.String id) throws org.apache.thrift.TException
{
getTopologyInfo_args args = new getTopologyInfo_args();
args.set_id(id);
@@ -1290,13 +1263,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
}
- public TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public TopologyInfo getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyInfoWithOpts(id, options);
return recv_getTopologyInfoWithOpts();
}
- public void send_getTopologyInfoWithOpts(String id, GetInfoOptions options) throws org.apache.thrift.TException
+ public void send_getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options) throws org.apache.thrift.TException
{
getTopologyInfoWithOpts_args args = new getTopologyInfoWithOpts_args();
args.set_id(id);
@@ -1320,13 +1293,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfoWithOpts failed: unknown result");
}
- public TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public TopologyPageInfo getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyPageInfo(id, window, is_include_sys);
return recv_getTopologyPageInfo();
}
- public void send_getTopologyPageInfo(String id, String window, boolean is_include_sys) throws org.apache.thrift.TException
+ public void send_getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys) throws org.apache.thrift.TException
{
getTopologyPageInfo_args args = new getTopologyPageInfo_args();
args.set_id(id);
@@ -1351,13 +1324,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyPageInfo failed: unknown result");
}
- public SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public SupervisorPageInfo getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getSupervisorPageInfo(id, host, is_include_sys);
return recv_getSupervisorPageInfo();
}
- public void send_getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws org.apache.thrift.TException
+ public void send_getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys) throws org.apache.thrift.TException
{
getSupervisorPageInfo_args args = new getSupervisorPageInfo_args();
args.set_id(id);
@@ -1382,13 +1355,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSupervisorPageInfo failed: unknown result");
}
- public ComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public ComponentPageInfo getComponentPageInfo(java.lang.String topology_id, java.lang.String component_id, java.lang.String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getComponentPageInfo(topology_id, component_id, window, is_include_sys);
return recv_getComponentPageInfo();
}
- public void send_getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws org.apache.thrift.TException
+ public void send_getComponentPageInfo(java.lang.String topology_id, java.lang.String component_id, java.lang.String window, boolean is_include_sys) throws org.apache.thrift.TException
{
getComponentPageInfo_args args = new getComponentPageInfo_args();
args.set_topology_id(topology_id);
@@ -1414,20 +1387,20 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComponentPageInfo failed: unknown result");
}
- public String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public java.lang.String getTopologyConf(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopologyConf(id);
return recv_getTopologyConf();
}
- public void send_getTopologyConf(String id) throws org.apache.thrift.TException
+ public void send_getTopologyConf(java.lang.String id) throws org.apache.thrift.TException
{
getTopologyConf_args args = new getTopologyConf_args();
args.set_id(id);
sendBase("getTopologyConf", args);
}
- public String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
getTopologyConf_result result = new getTopologyConf_result();
receiveBase(result, "getTopologyConf");
@@ -1443,13 +1416,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyConf failed: unknown result");
}
- public StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public StormTopology getTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getTopology(id);
return recv_getTopology();
}
- public void send_getTopology(String id) throws org.apache.thrift.TException
+ public void send_getTopology(java.lang.String id) throws org.apache.thrift.TException
{
getTopology_args args = new getTopology_args();
args.set_id(id);
@@ -1472,13 +1445,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopology failed: unknown result");
}
- public StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public StormTopology getUserTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
{
send_getUserTopology(id);
return recv_getUserTopology();
}
- public void send_getUserTopology(String id) throws org.apache.thrift.TException
+ public void send_getUserTopology(java.lang.String id) throws org.apache.thrift.TException
{
getUserTopology_args args = new getUserTopology_args();
args.set_id(id);
@@ -1501,13 +1474,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getUserTopology failed: unknown result");
}
- public TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.thrift.TException
+ public TopologyHistoryInfo getTopologyHistory(java.lang.String user) throws AuthorizationException, org.apache.thrift.TException
{
send_getTopologyHistory(user);
return recv_getTopologyHistory();
}
- public void send_getTopologyHistory(String user) throws org.apache.thrift.TException
+ public void send_getTopologyHistory(java.lang.String user) throws org.apache.thrift.TException
{
getTopologyHistory_args args = new getTopologyHistory_args();
args.set_user(user);
@@ -1527,20 +1500,20 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyHistory failed: unknown result");
}
- public List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.thrift.TException
+ public java.util.List<OwnerResourceSummary> getOwnerResourceSummaries(java.lang.String owner) throws AuthorizationException, org.apache.thrift.TException
{
send_getOwnerResourceSummaries(owner);
return recv_getOwnerResourceSummaries();
}
- public void send_getOwnerResourceSummaries(String owner) throws org.apache.thrift.TException
+ public void send_getOwnerResourceSummaries(java.lang.String owner) throws org.apache.thrift.TException
{
getOwnerResourceSummaries_args args = new getOwnerResourceSummaries_args();
args.set_owner(owner);
sendBase("getOwnerResourceSummaries", args);
}
- public List<OwnerResourceSummary> recv_getOwnerResourceSummaries() throws AuthorizationException, org.apache.thrift.TException
+ public java.util.List<OwnerResourceSummary> recv_getOwnerResourceSummaries() throws AuthorizationException, org.apache.thrift.TException
{
getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
receiveBase(result, "getOwnerResourceSummaries");
@@ -1553,13 +1526,13 @@ public class Nimbus {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getOwnerResourceSummaries failed: unknown result");
}
- public SupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.thrift.TException
+ public SupervisorAssignments getSupervisorAssignments(java.lang.String node) throws AuthorizationException, org.apache.thrift.TException
{
send_getSupervisorAssignments(node);
return recv_getSupervisorAssignments();
}
- public void send_getSupervisorAssignments(String node) throws org.apache.thrift.TException
+ public void send_getSupervisorAssignments(java.lang.String node) throws org.apache.thrift.TException
{
getSupervisorAssignments_args args = new getSupervisorAssignments_args();
args.set_node(node);
@@ -1602,7 +1575,7 @@ public class Nimbus {
return;
}
- public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, org.apache.thrift.TException
+ public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.thrift.TException
{
send_sendSupervisorWorkerHeartbeat(heatbeat);
recv_sendSupervisorWorkerHeartbeat();
@@ -1615,13 +1588,16 @@ public class Nimbus {
sendBase("sendSupervisorWorkerHeartbeat", args);
}
- public void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, NotAliveException, org.apache.thrift.TException
{
sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
receiveBase(result, "sendSupervisorWorkerHeartbeat");
if (result.aze != null) {
throw result.aze;
}
+ if (result.e != null) {
+ throw result.e;
+ }
return;
}
@@ -1663,19 +1639,19 @@ public class Nimbus {
super(protocolFactory, clientManager, transport);
}
- public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException {
checkReady();
submitTopology_call method_call = new submitTopology_call(name, uploadedJarLocation, jsonConf, topology, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class submitTopology_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String name;
- private String uploadedJarLocation;
- private String jsonConf;
+ public static class submitTopology_call extends org.apache.thrift.async.TAsyncMethodCall<Void> {
+ private java.lang.String name;
+ private java.lang.String uploadedJarLocation;
+ private java.lang.String jsonConf;
private StormTopology topology;
- public submitTopology_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public submitTopology_call(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.name = name;
this.uploadedJarLocation = uploadedJarLocation;
@@ -1694,30 +1670,30 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
+ public Void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_submitTopology();
+ return null;
}
}
- public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException {
checkReady();
submitTopologyWithOpts_call method_call = new submitTopologyWithOpts_call(name, uploadedJarLocation, jsonConf, topology, options, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class submitTopologyWithOpts_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String name;
- private String uploadedJarLocation;
- private String jsonConf;
+ public static class submitTopologyWithOpts_call extends org.apache.thrift.async.TAsyncMethodCall<Void> {
+ private java.lang.String name;
+ private java.lang.String uploadedJarLocation;
+ private java.lang.String jsonConf;
private StormTopology topology;
private SubmitOptions options;
- public submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public submitTopologyWithOpts_call(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.name = name;
this.uploadedJarLocation = uploadedJarLocation;
@@ -1738,26 +1714,26 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
+ public Void getResult() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_submitTopologyWithOpts();
+ return null;
}
}
- public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void killTopology(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException {
checkReady();
killTopology_call method_call = new killTopology_call(name, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class killTopology_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String name;
- public killTopology_call(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public static class killTopology_call extends org.apache.thrift.async.TAsyncMethodCall<Void> {
+ private java.lang.String name;
+ public killTopology_call(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.name = name;
}
@@ -1770,27 +1746,27 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
+ public Void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_killTopology();
+ return null;
}
}
- public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void killTopologyWithOpts(java.lang.String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException {
checkReady();
killTopologyWithOpts_call method_call = new killTopologyWithOpts_call(name, options, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class killTopologyWithOpts_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String name;
+ public static class killTopologyWithOpts_call extends org.apache.thrift.async.TAsyncMethodCall<Void> {
+ private java.lang.String name;
private KillOptions options;
- public killTopologyWithOpts_call(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public killTopologyWithOpts_call(java.lang.String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.name = name;
this.options = options;
@@ -1805,26 +1781,26 @@ public class Nimbus {
prot.writeMessageEnd();
}
- public void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
+ public Void getResult() throws NotAliveException, AuthorizationException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
+ throw new java.lang.IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_killTopologyWithOpts();
+ return null;
}
}
- public void activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void activate(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException {
checkReady();
activate_call method_call = new activate_call(name, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class activate_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String name;
- public activate_call(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public static class activate_call extends org.apache.thrift.async.TAsyncMethodCall<Void> {
+
<TRUNCATED>