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"}) [email protected](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>
