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/06/07 15:55:04 UTC
[28/50] [abbrv] storm git commit: STORM-2882: thrift
http://git-wip-us.apache.org/repos/asf/storm/blob/91251c54/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 3955ddc..9fcc8ee 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -29,23 +29,23 @@ public class Nimbus {
public interface Iface {
- 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 submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.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 submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException;
- public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
- public void killTopologyWithOpts(java.lang.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.storm.thrift.TException;
- public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
- public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
- public void rebalance(java.lang.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.storm.thrift.TException;
- public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException;
+ public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.storm.thrift.TException;
- public LogConfig getLogConfig(java.lang.String name) throws org.apache.thrift.TException;
+ public LogConfig getLogConfig(java.lang.String name) throws org.apache.storm.thrift.TException;
/**
* Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional
@@ -59,255 +59,255 @@ public class Nimbus {
* @param enable
* @param samplingPercentage
*/
- public void debug(java.lang.String name, java.lang.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.storm.thrift.TException;
- public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException;
+ public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.storm.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 java.util.List<ProfileRequest> getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action) throws org.apache.storm.thrift.TException;
- public void uploadNewCredentials(java.lang.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.storm.thrift.TException;
- public java.lang.String beginCreateBlob(java.lang.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.storm.thrift.TException;
- public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException;
- public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
+ public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException;
- public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
+ public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException;
- public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
+ public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException;
- public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException;
- public void setBlobMeta(java.lang.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.storm.thrift.TException;
- public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException;
- public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException;
+ public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException;
- public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException;
- public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.thrift.TException;
+ public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.storm.thrift.TException;
- public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException;
+ public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException;
- public int updateBlobReplication(java.lang.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.storm.thrift.TException;
- public void createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException;
+ public void createStateInZookeeper(java.lang.String key) throws org.apache.storm.thrift.TException;
- public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException;
- public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException;
+ public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException;
- public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.thrift.TException;
+ public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.storm.thrift.TException;
- public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException;
- public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.thrift.TException;
+ public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException;
- public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException;
- public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException;
+ public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException;
- public NimbusSummary getLeader() throws AuthorizationException, org.apache.thrift.TException;
+ public NimbusSummary getLeader() throws AuthorizationException, org.apache.storm.thrift.TException;
- public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.thrift.TException;
+ public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.storm.thrift.TException;
- public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
- public TopologyInfo getTopologyInfoWithOpts(java.lang.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.storm.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 TopologyPageInfo getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.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 SupervisorPageInfo getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.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 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.storm.thrift.TException;
- public java.lang.String getTopologyConf(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public java.lang.String getTopologyConf(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
/**
* Returns the compiled topology that contains ackers and metrics consumsers. Compare {@link #getUserTopology(String id)}.
*
* @param id
*/
- public StormTopology getTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public StormTopology getTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
/**
* Returns the user specified topology as submitted originally. Compare {@link #getTopology(String id)}.
*
* @param id
*/
- public StormTopology getUserTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException;
+ public StormTopology getUserTopology(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException;
- public TopologyHistoryInfo getTopologyHistory(java.lang.String user) throws AuthorizationException, org.apache.thrift.TException;
+ public TopologyHistoryInfo getTopologyHistory(java.lang.String user) throws AuthorizationException, org.apache.storm.thrift.TException;
- public java.util.List<OwnerResourceSummary> getOwnerResourceSummaries(java.lang.String owner) throws AuthorizationException, org.apache.thrift.TException;
+ public java.util.List<OwnerResourceSummary> getOwnerResourceSummaries(java.lang.String owner) throws AuthorizationException, org.apache.storm.thrift.TException;
/**
* Get assigned assignments for a specific supervisor
*
* @param node
*/
- public SupervisorAssignments getSupervisorAssignments(java.lang.String node) throws AuthorizationException, org.apache.thrift.TException;
+ public SupervisorAssignments getSupervisorAssignments(java.lang.String node) throws AuthorizationException, org.apache.storm.thrift.TException;
/**
* Send supervisor worker heartbeats for a specific supervisor
*
* @param heartbeats
*/
- public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.storm.thrift.TException;
/**
* Send supervisor local worker heartbeat when a supervisor is unreachable
*
* @param heatbeat
*/
- public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException;
- public void processWorkerMetrics(WorkerMetrics metrics) throws org.apache.thrift.TException;
+ public void processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException;
/**
* Decide if the blob is removed from cluster.
*
* @param blobKey
*/
- public boolean isRemoteBlobExists(java.lang.String blobKey) throws AuthorizationException, org.apache.thrift.TException;
+ public boolean isRemoteBlobExists(java.lang.String blobKey) throws AuthorizationException, org.apache.storm.thrift.TException;
}
public interface AsyncIface {
- 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 submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void killTopology(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void killTopology(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 killTopologyWithOpts(java.lang.String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void activate(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void activate(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void deactivate(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void deactivate(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 rebalance(java.lang.String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 setLogConfig(java.lang.String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void getLogConfig(java.lang.String name, org.apache.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.thrift.TException;
+ public void getLogConfig(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.storm.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 debug(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 getComponentPendingProfileActions(java.lang.String id, java.lang.String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<ProfileRequest>> resultHandler) throws org.apache.storm.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 uploadNewCredentials(java.lang.String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 beginCreateBlob(java.lang.String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.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 beginUpdateBlob(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.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 uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void finishBlobUpload(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void finishBlobUpload(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void cancelBlobUpload(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void cancelBlobUpload(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void getBlobMeta(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.thrift.TException;
+ public void getBlobMeta(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.storm.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 setBlobMeta(java.lang.String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void beginBlobDownload(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.thrift.TException;
+ public void beginBlobDownload(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.storm.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 downloadBlobChunk(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException;
- public void deleteBlob(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void deleteBlob(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void listBlobs(java.lang.String session, org.apache.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.thrift.TException;
+ public void listBlobs(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.storm.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 getBlobReplication(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Integer> resultHandler) throws org.apache.storm.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 updateBlobReplication(java.lang.String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Integer> resultHandler) throws org.apache.storm.thrift.TException;
- public void createStateInZookeeper(java.lang.String key, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void createStateInZookeeper(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
+ public void beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.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 uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void finishFileUpload(java.lang.String location, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void finishFileUpload(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.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 beginFileDownload(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.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 downloadChunk(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException;
- public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.thrift.TException;
+ public void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
- public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.thrift.TException;
+ public void getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException;
- public void getLeader(org.apache.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.thrift.TException;
+ public void getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.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 isTopologyNameAllowed(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException;
- public void getTopologyInfo(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyInfo(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.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 getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.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 getTopologyPageInfo(java.lang.String id, java.lang.String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.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 getSupervisorPageInfo(java.lang.String id, java.lang.String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.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 getComponentPageInfo(java.lang.String topology_id, java.lang.String component_id, java.lang.String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.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 getTopologyConf(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
- public void getTopology(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.thrift.TException;
+ public void getTopology(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException;
- public void getUserTopology(java.lang.String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.thrift.TException;
+ public void getUserTopology(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException;
- public void getTopologyHistory(java.lang.String user, org.apache.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.thrift.TException;
+ public void getTopologyHistory(java.lang.String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.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 getOwnerResourceSummaries(java.lang.String owner, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException;
- public void getSupervisorAssignments(java.lang.String node, org.apache.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.thrift.TException;
+ public void getSupervisorAssignments(java.lang.String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException;
- public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void processWorkerMetrics(WorkerMetrics metrics, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException;
+ public void processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
- public void isRemoteBlobExists(java.lang.String blobKey, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException;
+ public void isRemoteBlobExists(java.lang.String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException;
}
- public static class Client extends org.apache.thrift.TServiceClient implements Iface {
- public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
+ public static class Client extends org.apache.storm.thrift.TServiceClient implements Iface {
+ public static class Factory implements org.apache.storm.thrift.TServiceClientFactory<Client> {
public Factory() {}
- public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
+ public Client getClient(org.apache.storm.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
- public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ public Client getClient(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
- public Client(org.apache.thrift.protocol.TProtocol prot)
+ public Client(org.apache.storm.thrift.protocol.TProtocol prot)
{
super(prot, prot);
}
- public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ public Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
- 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 submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
send_submitTopology(name, uploadedJarLocation, jsonConf, topology);
recv_submitTopology();
}
- public void send_submitTopology(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.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.storm.thrift.TException
{
submitTopology_args args = new submitTopology_args();
args.set_name(name);
@@ -317,7 +317,7 @@ public class Nimbus {
sendBase("submitTopology", args);
}
- public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
submitTopology_result result = new submitTopology_result();
receiveBase(result, "submitTopology");
@@ -333,13 +333,13 @@ public class Nimbus {
return;
}
- 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 submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
send_submitTopologyWithOpts(name, uploadedJarLocation, jsonConf, topology, options);
recv_submitTopologyWithOpts();
}
- 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
+ public void send_submitTopologyWithOpts(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.storm.thrift.TException
{
submitTopologyWithOpts_args args = new submitTopologyWithOpts_args();
args.set_name(name);
@@ -350,7 +350,7 @@ public class Nimbus {
sendBase("submitTopologyWithOpts", args);
}
- public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
submitTopologyWithOpts_result result = new submitTopologyWithOpts_result();
receiveBase(result, "submitTopologyWithOpts");
@@ -366,20 +366,20 @@ public class Nimbus {
return;
}
- public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void killTopology(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
send_killTopology(name);
recv_killTopology();
}
- public void send_killTopology(java.lang.String name) throws org.apache.thrift.TException
+ public void send_killTopology(java.lang.String name) throws org.apache.storm.thrift.TException
{
killTopology_args args = new killTopology_args();
args.set_name(name);
sendBase("killTopology", args);
}
- public void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
killTopology_result result = new killTopology_result();
receiveBase(result, "killTopology");
@@ -392,13 +392,13 @@ public class Nimbus {
return;
}
- public void killTopologyWithOpts(java.lang.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.storm.thrift.TException
{
send_killTopologyWithOpts(name, options);
recv_killTopologyWithOpts();
}
- public void send_killTopologyWithOpts(java.lang.String name, KillOptions options) throws org.apache.thrift.TException
+ public void send_killTopologyWithOpts(java.lang.String name, KillOptions options) throws org.apache.storm.thrift.TException
{
killTopologyWithOpts_args args = new killTopologyWithOpts_args();
args.set_name(name);
@@ -406,7 +406,7 @@ public class Nimbus {
sendBase("killTopologyWithOpts", args);
}
- public void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
killTopologyWithOpts_result result = new killTopologyWithOpts_result();
receiveBase(result, "killTopologyWithOpts");
@@ -419,20 +419,20 @@ public class Nimbus {
return;
}
- public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void activate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
send_activate(name);
recv_activate();
}
- public void send_activate(java.lang.String name) throws org.apache.thrift.TException
+ public void send_activate(java.lang.String name) throws org.apache.storm.thrift.TException
{
activate_args args = new activate_args();
args.set_name(name);
sendBase("activate", args);
}
- public void recv_activate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void recv_activate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
activate_result result = new activate_result();
receiveBase(result, "activate");
@@ -445,20 +445,20 @@ public class Nimbus {
return;
}
- public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void deactivate(java.lang.String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
send_deactivate(name);
recv_deactivate();
}
- public void send_deactivate(java.lang.String name) throws org.apache.thrift.TException
+ public void send_deactivate(java.lang.String name) throws org.apache.storm.thrift.TException
{
deactivate_args args = new deactivate_args();
args.set_name(name);
sendBase("deactivate", args);
}
- public void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
deactivate_result result = new deactivate_result();
receiveBase(result, "deactivate");
@@ -471,13 +471,13 @@ public class Nimbus {
return;
}
- public void rebalance(java.lang.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.storm.thrift.TException
{
send_rebalance(name, options);
recv_rebalance();
}
- public void send_rebalance(java.lang.String name, RebalanceOptions options) throws org.apache.thrift.TException
+ public void send_rebalance(java.lang.String name, RebalanceOptions options) throws org.apache.storm.thrift.TException
{
rebalance_args args = new rebalance_args();
args.set_name(name);
@@ -485,7 +485,7 @@ public class Nimbus {
sendBase("rebalance", args);
}
- public void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
rebalance_result result = new rebalance_result();
receiveBase(result, "rebalance");
@@ -501,13 +501,13 @@ public class Nimbus {
return;
}
- public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException
+ public void setLogConfig(java.lang.String name, LogConfig config) throws org.apache.storm.thrift.TException
{
send_setLogConfig(name, config);
recv_setLogConfig();
}
- public void send_setLogConfig(java.lang.String name, LogConfig config) throws org.apache.thrift.TException
+ public void send_setLogConfig(java.lang.String name, LogConfig config) throws org.apache.storm.thrift.TException
{
setLogConfig_args args = new setLogConfig_args();
args.set_name(name);
@@ -515,43 +515,43 @@ public class Nimbus {
sendBase("setLogConfig", args);
}
- public void recv_setLogConfig() throws org.apache.thrift.TException
+ public void recv_setLogConfig() throws org.apache.storm.thrift.TException
{
setLogConfig_result result = new setLogConfig_result();
receiveBase(result, "setLogConfig");
return;
}
- public LogConfig getLogConfig(java.lang.String name) throws org.apache.thrift.TException
+ public LogConfig getLogConfig(java.lang.String name) throws org.apache.storm.thrift.TException
{
send_getLogConfig(name);
return recv_getLogConfig();
}
- public void send_getLogConfig(java.lang.String name) throws org.apache.thrift.TException
+ public void send_getLogConfig(java.lang.String name) throws org.apache.storm.thrift.TException
{
getLogConfig_args args = new getLogConfig_args();
args.set_name(name);
sendBase("getLogConfig", args);
}
- public LogConfig recv_getLogConfig() throws org.apache.thrift.TException
+ public LogConfig recv_getLogConfig() throws org.apache.storm.thrift.TException
{
getLogConfig_result result = new getLogConfig_result();
receiveBase(result, "getLogConfig");
if (result.is_set_success()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLogConfig failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getLogConfig failed: unknown result");
}
- public void debug(java.lang.String name, java.lang.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.storm.thrift.TException
{
send_debug(name, component, enable, samplingPercentage);
recv_debug();
}
- public void send_debug(java.lang.String name, java.lang.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.storm.thrift.TException
{
debug_args args = new debug_args();
args.set_name(name);
@@ -561,7 +561,7 @@ public class Nimbus {
sendBase("debug", args);
}
- public void recv_debug() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public void recv_debug() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
debug_result result = new debug_result();
receiveBase(result, "debug");
@@ -574,13 +574,13 @@ public class Nimbus {
return;
}
- public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
+ public void setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException
{
send_setWorkerProfiler(id, profileRequest);
recv_setWorkerProfiler();
}
- public void send_setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.thrift.TException
+ public void send_setWorkerProfiler(java.lang.String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException
{
setWorkerProfiler_args args = new setWorkerProfiler_args();
args.set_id(id);
@@ -588,20 +588,20 @@ public class Nimbus {
sendBase("setWorkerProfiler", args);
}
- public void recv_setWorkerProfiler() throws org.apache.thrift.TException
+ public void recv_setWorkerProfiler() throws org.apache.storm.thrift.TException
{
setWorkerProfiler_result result = new setWorkerProfiler_result();
receiveBase(result, "setWorkerProfiler");
return;
}
- public java.util.List<ProfileRequest> getComponentPendingProfileActions(java.lang.String id, java.lang.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.storm.thrift.TException
{
send_getComponentPendingProfileActions(id, component_id, action);
return recv_getComponentPendingProfileActions();
}
- public void send_getComponentPendingProfileActions(java.lang.String id, java.lang.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.storm.thrift.TException
{
getComponentPendingProfileActions_args args = new getComponentPendingProfileActions_args();
args.set_id(id);
@@ -610,23 +610,23 @@ public class Nimbus {
sendBase("getComponentPendingProfileActions", args);
}
- public java.util.List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.thrift.TException
+ public java.util.List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.storm.thrift.TException
{
getComponentPendingProfileActions_result result = new getComponentPendingProfileActions_result();
receiveBase(result, "getComponentPendingProfileActions");
if (result.is_set_success()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getComponentPendingProfileActions failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getComponentPendingProfileActions failed: unknown result");
}
- public void uploadNewCredentials(java.lang.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.storm.thrift.TException
{
send_uploadNewCredentials(name, creds);
recv_uploadNewCredentials();
}
- public void send_uploadNewCredentials(java.lang.String name, Credentials creds) throws org.apache.thrift.TException
+ public void send_uploadNewCredentials(java.lang.String name, Credentials creds) throws org.apache.storm.thrift.TException
{
uploadNewCredentials_args args = new uploadNewCredentials_args();
args.set_name(name);
@@ -634,7 +634,7 @@ public class Nimbus {
sendBase("uploadNewCredentials", args);
}
- public void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException
+ public void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
{
uploadNewCredentials_result result = new uploadNewCredentials_result();
receiveBase(result, "uploadNewCredentials");
@@ -650,13 +650,13 @@ public class Nimbus {
return;
}
- public java.lang.String beginCreateBlob(java.lang.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.storm.thrift.TException
{
send_beginCreateBlob(key, meta);
return recv_beginCreateBlob();
}
- public void send_beginCreateBlob(java.lang.String key, SettableBlobMeta meta) throws org.apache.thrift.TException
+ public void send_beginCreateBlob(java.lang.String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException
{
beginCreateBlob_args args = new beginCreateBlob_args();
args.set_key(key);
@@ -664,7 +664,7 @@ public class Nimbus {
sendBase("beginCreateBlob", args);
}
- public java.lang.String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException
+ public java.lang.String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException
{
beginCreateBlob_result result = new beginCreateBlob_result();
receiveBase(result, "beginCreateBlob");
@@ -677,23 +677,23 @@ public class Nimbus {
if (result.kae != null) {
throw result.kae;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginCreateBlob failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginCreateBlob failed: unknown result");
}
- public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public java.lang.String beginUpdateBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
send_beginUpdateBlob(key);
return recv_beginUpdateBlob();
}
- public void send_beginUpdateBlob(java.lang.String key) throws org.apache.thrift.TException
+ public void send_beginUpdateBlob(java.lang.String key) throws org.apache.storm.thrift.TException
{
beginUpdateBlob_args args = new beginUpdateBlob_args();
args.set_key(key);
sendBase("beginUpdateBlob", args);
}
- public java.lang.String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public java.lang.String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
beginUpdateBlob_result result = new beginUpdateBlob_result();
receiveBase(result, "beginUpdateBlob");
@@ -706,16 +706,16 @@ public class Nimbus {
if (result.knf != null) {
throw result.knf;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginUpdateBlob failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginUpdateBlob failed: unknown result");
}
- public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
+ public void uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_uploadBlobChunk(session, chunk);
recv_uploadBlobChunk();
}
- public void send_uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws org.apache.thrift.TException
+ public void send_uploadBlobChunk(java.lang.String session, java.nio.ByteBuffer chunk) throws org.apache.storm.thrift.TException
{
uploadBlobChunk_args args = new uploadBlobChunk_args();
args.set_session(session);
@@ -723,7 +723,7 @@ public class Nimbus {
sendBase("uploadBlobChunk", args);
}
- public void recv_uploadBlobChunk() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_uploadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException
{
uploadBlobChunk_result result = new uploadBlobChunk_result();
receiveBase(result, "uploadBlobChunk");
@@ -733,20 +733,20 @@ public class Nimbus {
return;
}
- public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
+ public void finishBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_finishBlobUpload(session);
recv_finishBlobUpload();
}
- public void send_finishBlobUpload(java.lang.String session) throws org.apache.thrift.TException
+ public void send_finishBlobUpload(java.lang.String session) throws org.apache.storm.thrift.TException
{
finishBlobUpload_args args = new finishBlobUpload_args();
args.set_session(session);
sendBase("finishBlobUpload", args);
}
- public void recv_finishBlobUpload() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_finishBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException
{
finishBlobUpload_result result = new finishBlobUpload_result();
receiveBase(result, "finishBlobUpload");
@@ -756,20 +756,20 @@ public class Nimbus {
return;
}
- public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
+ public void cancelBlobUpload(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_cancelBlobUpload(session);
recv_cancelBlobUpload();
}
- public void send_cancelBlobUpload(java.lang.String session) throws org.apache.thrift.TException
+ public void send_cancelBlobUpload(java.lang.String session) throws org.apache.storm.thrift.TException
{
cancelBlobUpload_args args = new cancelBlobUpload_args();
args.set_session(session);
sendBase("cancelBlobUpload", args);
}
- public void recv_cancelBlobUpload() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_cancelBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException
{
cancelBlobUpload_result result = new cancelBlobUpload_result();
receiveBase(result, "cancelBlobUpload");
@@ -779,20 +779,20 @@ public class Nimbus {
return;
}
- public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public ReadableBlobMeta getBlobMeta(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
send_getBlobMeta(key);
return recv_getBlobMeta();
}
- public void send_getBlobMeta(java.lang.String key) throws org.apache.thrift.TException
+ public void send_getBlobMeta(java.lang.String key) throws org.apache.storm.thrift.TException
{
getBlobMeta_args args = new getBlobMeta_args();
args.set_key(key);
sendBase("getBlobMeta", args);
}
- public ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
getBlobMeta_result result = new getBlobMeta_result();
receiveBase(result, "getBlobMeta");
@@ -805,16 +805,16 @@ public class Nimbus {
if (result.knf != null) {
throw result.knf;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getBlobMeta failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getBlobMeta failed: unknown result");
}
- public void setBlobMeta(java.lang.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.storm.thrift.TException
{
send_setBlobMeta(key, meta);
recv_setBlobMeta();
}
- public void send_setBlobMeta(java.lang.String key, SettableBlobMeta meta) throws org.apache.thrift.TException
+ public void send_setBlobMeta(java.lang.String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException
{
setBlobMeta_args args = new setBlobMeta_args();
args.set_key(key);
@@ -822,7 +822,7 @@ public class Nimbus {
sendBase("setBlobMeta", args);
}
- public void recv_setBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public void recv_setBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
setBlobMeta_result result = new setBlobMeta_result();
receiveBase(result, "setBlobMeta");
@@ -835,20 +835,20 @@ public class Nimbus {
return;
}
- public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public BeginDownloadResult beginBlobDownload(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
send_beginBlobDownload(key);
return recv_beginBlobDownload();
}
- public void send_beginBlobDownload(java.lang.String key) throws org.apache.thrift.TException
+ public void send_beginBlobDownload(java.lang.String key) throws org.apache.storm.thrift.TException
{
beginBlobDownload_args args = new beginBlobDownload_args();
args.set_key(key);
sendBase("beginBlobDownload", args);
}
- public BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
beginBlobDownload_result result = new beginBlobDownload_result();
receiveBase(result, "beginBlobDownload");
@@ -861,23 +861,23 @@ public class Nimbus {
if (result.knf != null) {
throw result.knf;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginBlobDownload failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginBlobDownload failed: unknown result");
}
- public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer downloadBlobChunk(java.lang.String session) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_downloadBlobChunk(session);
return recv_downloadBlobChunk();
}
- public void send_downloadBlobChunk(java.lang.String session) throws org.apache.thrift.TException
+ public void send_downloadBlobChunk(java.lang.String session) throws org.apache.storm.thrift.TException
{
downloadBlobChunk_args args = new downloadBlobChunk_args();
args.set_session(session);
sendBase("downloadBlobChunk", args);
}
- public java.nio.ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException
{
downloadBlobChunk_result result = new downloadBlobChunk_result();
receiveBase(result, "downloadBlobChunk");
@@ -887,23 +887,23 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadBlobChunk failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "downloadBlobChunk failed: unknown result");
}
- public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public void deleteBlob(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
send_deleteBlob(key);
recv_deleteBlob();
}
- public void send_deleteBlob(java.lang.String key) throws org.apache.thrift.TException
+ public void send_deleteBlob(java.lang.String key) throws org.apache.storm.thrift.TException
{
deleteBlob_args args = new deleteBlob_args();
args.set_key(key);
sendBase("deleteBlob", args);
}
- public void recv_deleteBlob() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public void recv_deleteBlob() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
deleteBlob_result result = new deleteBlob_result();
receiveBase(result, "deleteBlob");
@@ -916,43 +916,43 @@ public class Nimbus {
return;
}
- public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.thrift.TException
+ public ListBlobsResult listBlobs(java.lang.String session) throws org.apache.storm.thrift.TException
{
send_listBlobs(session);
return recv_listBlobs();
}
- public void send_listBlobs(java.lang.String session) throws org.apache.thrift.TException
+ public void send_listBlobs(java.lang.String session) throws org.apache.storm.thrift.TException
{
listBlobs_args args = new listBlobs_args();
args.set_session(session);
sendBase("listBlobs", args);
}
- public ListBlobsResult recv_listBlobs() throws org.apache.thrift.TException
+ public ListBlobsResult recv_listBlobs() throws org.apache.storm.thrift.TException
{
listBlobs_result result = new listBlobs_result();
receiveBase(result, "listBlobs");
if (result.is_set_success()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listBlobs failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "listBlobs failed: unknown result");
}
- public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public int getBlobReplication(java.lang.String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
send_getBlobReplication(key);
return recv_getBlobReplication();
}
- public void send_getBlobReplication(java.lang.String key) throws org.apache.thrift.TException
+ public void send_getBlobReplication(java.lang.String key) throws org.apache.storm.thrift.TException
{
getBlobReplication_args args = new getBlobReplication_args();
args.set_key(key);
sendBase("getBlobReplication", args);
}
- public int recv_getBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public int recv_getBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
getBlobReplication_result result = new getBlobReplication_result();
receiveBase(result, "getBlobReplication");
@@ -965,16 +965,16 @@ public class Nimbus {
if (result.knf != null) {
throw result.knf;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getBlobReplication failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getBlobReplication failed: unknown result");
}
- public int updateBlobReplication(java.lang.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.storm.thrift.TException
{
send_updateBlobReplication(key, replication);
return recv_updateBlobReplication();
}
- public void send_updateBlobReplication(java.lang.String key, int replication) throws org.apache.thrift.TException
+ public void send_updateBlobReplication(java.lang.String key, int replication) throws org.apache.storm.thrift.TException
{
updateBlobReplication_args args = new updateBlobReplication_args();
args.set_key(key);
@@ -982,7 +982,7 @@ public class Nimbus {
sendBase("updateBlobReplication", args);
}
- public int recv_updateBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException
+ public int recv_updateBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
{
updateBlobReplication_result result = new updateBlobReplication_result();
receiveBase(result, "updateBlobReplication");
@@ -995,42 +995,42 @@ public class Nimbus {
if (result.knf != null) {
throw result.knf;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateBlobReplication failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "updateBlobReplication failed: unknown result");
}
- public void createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException
+ public void createStateInZookeeper(java.lang.String key) throws org.apache.storm.thrift.TException
{
send_createStateInZookeeper(key);
recv_createStateInZookeeper();
}
- public void send_createStateInZookeeper(java.lang.String key) throws org.apache.thrift.TException
+ public void send_createStateInZookeeper(java.lang.String key) throws org.apache.storm.thrift.TException
{
createStateInZookeeper_args args = new createStateInZookeeper_args();
args.set_key(key);
sendBase("createStateInZookeeper", args);
}
- public void recv_createStateInZookeeper() throws org.apache.thrift.TException
+ public void recv_createStateInZookeeper() throws org.apache.storm.thrift.TException
{
createStateInZookeeper_result result = new createStateInZookeeper_result();
receiveBase(result, "createStateInZookeeper");
return;
}
- public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
{
send_beginFileUpload();
return recv_beginFileUpload();
}
- public void send_beginFileUpload() throws org.apache.thrift.TException
+ public void send_beginFileUpload() throws org.apache.storm.thrift.TException
{
beginFileUpload_args args = new beginFileUpload_args();
sendBase("beginFileUpload", args);
}
- public java.lang.String recv_beginFileUpload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
{
beginFileUpload_result result = new beginFileUpload_result();
receiveBase(result, "beginFileUpload");
@@ -1040,16 +1040,16 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginFileUpload failed: unknown result");
}
- public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException
+ public void uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_uploadChunk(location, chunk);
recv_uploadChunk();
}
- public void send_uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws org.apache.thrift.TException
+ public void send_uploadChunk(java.lang.String location, java.nio.ByteBuffer chunk) throws org.apache.storm.thrift.TException
{
uploadChunk_args args = new uploadChunk_args();
args.set_location(location);
@@ -1057,7 +1057,7 @@ public class Nimbus {
sendBase("uploadChunk", args);
}
- public void recv_uploadChunk() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_uploadChunk() throws AuthorizationException, org.apache.storm.thrift.TException
{
uploadChunk_result result = new uploadChunk_result();
receiveBase(result, "uploadChunk");
@@ -1067,20 +1067,20 @@ public class Nimbus {
return;
}
- public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.thrift.TException
+ public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_finishFileUpload(location);
recv_finishFileUpload();
}
- public void send_finishFileUpload(java.lang.String location) throws org.apache.thrift.TException
+ public void send_finishFileUpload(java.lang.String location) throws org.apache.storm.thrift.TException
{
finishFileUpload_args args = new finishFileUpload_args();
args.set_location(location);
sendBase("finishFileUpload", args);
}
- public void recv_finishFileUpload() throws AuthorizationException, org.apache.thrift.TException
+ public void recv_finishFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
{
finishFileUpload_result result = new finishFileUpload_result();
receiveBase(result, "finishFileUpload");
@@ -1090,20 +1090,20 @@ public class Nimbus {
return;
}
- public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_beginFileDownload(file);
return recv_beginFileDownload();
}
- public void send_beginFileDownload(java.lang.String file) throws org.apache.thrift.TException
+ public void send_beginFileDownload(java.lang.String file) throws org.apache.storm.thrift.TException
{
beginFileDownload_args args = new beginFileDownload_args();
args.set_file(file);
sendBase("beginFileDownload", args);
}
- public java.lang.String recv_beginFileDownload() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_beginFileDownload() throws AuthorizationException, org.apache.storm.thrift.TException
{
beginFileDownload_result result = new beginFileDownload_result();
receiveBase(result, "beginFileDownload");
@@ -1113,23 +1113,23 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
}
- public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_downloadChunk(id);
return recv_downloadChunk();
}
- public void send_downloadChunk(java.lang.String id) throws org.apache.thrift.TException
+ public void send_downloadChunk(java.lang.String id) throws org.apache.storm.thrift.TException
{
downloadChunk_args args = new downloadChunk_args();
args.set_id(id);
sendBase("downloadChunk", args);
}
- public java.nio.ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.thrift.TException
+ public java.nio.ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.storm.thrift.TException
{
downloadChunk_result result = new downloadChunk_result();
receiveBase(result, "downloadChunk");
@@ -1139,22 +1139,22 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "downloadChunk failed: unknown result");
}
- public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
{
send_getNimbusConf();
return recv_getNimbusConf();
}
- public void send_getNimbusConf() throws org.apache.thrift.TException
+ public void send_getNimbusConf() throws org.apache.storm.thrift.TException
{
getNimbusConf_args args = new getNimbusConf_args();
sendBase("getNimbusConf", args);
}
- public java.lang.String recv_getNimbusConf() throws AuthorizationException, org.apache.thrift.TException
+ public java.lang.String recv_getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
{
getNimbusConf_result result = new getNimbusConf_result();
receiveBase(result, "getNimbusConf");
@@ -1164,22 +1164,22 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result");
}
- public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException
+ public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException
{
send_getClusterInfo();
return recv_getClusterInfo();
}
- public void send_getClusterInfo() throws org.apache.thrift.TException
+ public void send_getClusterInfo() throws org.apache.storm.thrift.TException
{
getClusterInfo_args args = new getClusterInfo_args();
sendBase("getClusterInfo", args);
}
- public ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.thrift.TException
+ public ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException
{
getClusterInfo_result result = new getClusterInfo_result();
receiveBase(result, "getClusterInfo");
@@ -1189,22 +1189,22 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result");
}
- public NimbusSummary getLeader() throws AuthorizationException, org.apache.thrift.TException
+ public NimbusSummary getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
{
send_getLeader();
return recv_getLeader();
}
- public void send_getLeader() throws org.apache.thrift.TException
+ public void send_getLeader() throws org.apache.storm.thrift.TException
{
getLeader_args args = new getLeader_args();
sendBase("getLeader", args);
}
- public NimbusSummary recv_getLeader() throws AuthorizationException, org.apache.thrift.TException
+ public NimbusSummary recv_getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
{
getLeader_result result = new getLeader_result();
receiveBase(result, "getLeader");
@@ -1214,23 +1214,23 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getLeader failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getLeader failed: unknown result");
}
- public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.thrift.TException
+ public boolean isTopologyNameAllowed(java.lang.String name) throws AuthorizationException, org.apache.storm.thrift.TException
{
send_isTopologyNameAllowed(name);
return recv_isTopologyNameAllowed();
}
- public void send_isTopologyNameAllowed(java.lang.String name) throws org.apache.thrift.TException
+ public void send_isTopologyNameAllowed(java.lang.String name) throws org.apache.storm.thrift.TException
{
isTopologyNameAllowed_args args = new isTopologyNameAllowed_args();
args.set_name(name);
sendBase("isTopologyNameAllowed", args);
}
- public boolean recv_isTopologyNameAllowed() throws AuthorizationException, org.apache.thrift.TException
+ public boolean recv_isTopologyNameAllowed() throws AuthorizationException, org.apache.storm.thrift.TException
{
isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
receiveBase(result, "isTopologyNameAllowed");
@@ -1240,23 +1240,23 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isTopologyNameAllowed failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "isTopologyNameAllowed failed: unknown result");
}
- public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public TopologyInfo getTopologyInfo(java.lang.String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
send_getTopologyInfo(id);
return recv_getTopologyInfo();
}
- public void send_getTopologyInfo(java.lang.String id) throws org.apache.thrift.TException
+ public void send_getTopologyInfo(java.lang.String id) throws org.apache.storm.thrift.TException
{
getTopologyInfo_args args = new getTopologyInfo_args();
args.set_id(id);
sendBase("getTopologyInfo", args);
}
- public TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException
+ public TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
{
getTopologyInfo_result result = new getTopologyInfo_result();
receiveBase(result, "getTopologyInfo");
@@ -1269,16 +1269,16 @@ public class Nimbus {
if (result.aze != null) {
throw result.aze;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
+ throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "getTopologyInfo failed: unknown result");
}
- public TopologyInfo getTopologyInfoWithOpts(java.lang.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.storm.thrift.TException
{
send_getTopologyInfoWithOpts(id, options);
return recv_getTopologyInfoWithOpts();
}
- public void send_getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options) throws org.apache.thrift.TException
+ public void send_getTopologyInfoWithOpts(java.lang.String id, GetInfoOptions options) throws org.apache.storm.thrift.TException
{
getTopologyInfoWithOpts_args args = new getTopologyInfoWithOpts_args();
args.set_id(id);
@@ -1286,7 +1286,7 @@ public class Nimbus {
sendBase("getTopologyInfoWithOpts", args);
}
- public TopologyInfo recv_get
<TRUNCATED>