http://git-wip-us.apache.org/repos/asf/storm/blob/a6171bd6/storm-core/src/jvm/backtype/storm/generated/Nimbus.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java b/storm-core/src/jvm/backtype/storm/generated/Nimbus.java deleted file mode 100644 index ba9e66a..0000000 --- a/storm-core/src/jvm/backtype/storm/generated/Nimbus.java +++ /dev/null @@ -1,45416 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * 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)") -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 submitTopologyWithOpts(String name, String uploadedJarLocation, 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 killTopologyWithOpts(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 deactivate(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 setLogConfig(String name, LogConfig config) throws org.apache.thrift.TException; - - public LogConfig getLogConfig(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 - * and if null or empty, the debug flag will apply to the entire topology. - * - * The 'samplingPercentage' will limit loggging to a percentage of generated tuples. - * - * - * @param name - * @param component - * @param enable - * @param samplingPercentage - */ - public void debug(String name, 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 List<ProfileRequest> getComponentPendingProfileActions(String id, 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 String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException; - - public String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException; - - public void finishBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException; - - public void cancelBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException; - - public ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.thrift.TException; - - public void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public ListBlobsResult listBlobs(String session) throws org.apache.thrift.TException; - - public int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException; - - public void createStateInZookeeper(String key) throws org.apache.thrift.TException; - - public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException; - - public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.thrift.TException; - - public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException; - - public String beginFileDownload(String file) throws AuthorizationException, org.apache.thrift.TException; - - public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.thrift.TException; - - public String getNimbusConf() throws AuthorizationException, org.apache.thrift.TException; - - public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException; - - public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.thrift.TException; - - public TopologyInfo getTopologyInfoWithOpts(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 SupervisorPageInfo getSupervisorPageInfo(String id, 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 String getTopologyConf(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; - - /** - * 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 TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.thrift.TException; - - } - - 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 submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback 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 activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback 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 setLogConfig(String name, LogConfig config, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getLogConfig(String name, org.apache.thrift.async.AsyncMethodCallback 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 setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.thrift.async.AsyncMethodCallback 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 uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback 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 beginUpdateBlob(String key, org.apache.thrift.async.AsyncMethodCallback 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 finishBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void cancelBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getBlobMeta(String key, org.apache.thrift.async.AsyncMethodCallback 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 beginBlobDownload(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void downloadBlobChunk(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deleteBlob(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void listBlobs(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getBlobReplication(String key, org.apache.thrift.async.AsyncMethodCallback 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 createStateInZookeeper(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback 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 finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback 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 getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback 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 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 getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getTopologyHistory(String user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - } - - public static class Client extends org.apache.thrift.TServiceClient implements Iface { - public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { - public Factory() {} - public Client getClient(org.apache.thrift.protocol.TProtocol prot) { - return new Client(prot); - } - public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - return new Client(iprot, oprot); - } - } - - public Client(org.apache.thrift.protocol.TProtocol prot) - { - super(prot, prot); - } - - public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - super(iprot, oprot); - } - - public void submitTopology(String name, String uploadedJarLocation, 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 - { - submitTopology_args args = new submitTopology_args(); - args.set_name(name); - args.set_uploadedJarLocation(uploadedJarLocation); - args.set_jsonConf(jsonConf); - args.set_topology(topology); - sendBase("submitTopology", args); - } - - public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException - { - submitTopology_result result = new submitTopology_result(); - receiveBase(result, "submitTopology"); - if (result.e != null) { - throw result.e; - } - if (result.ite != null) { - throw result.ite; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void submitTopologyWithOpts(String name, String uploadedJarLocation, 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 - { - submitTopologyWithOpts_args args = new submitTopologyWithOpts_args(); - args.set_name(name); - args.set_uploadedJarLocation(uploadedJarLocation); - args.set_jsonConf(jsonConf); - args.set_topology(topology); - args.set_options(options); - sendBase("submitTopologyWithOpts", args); - } - - public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException - { - submitTopologyWithOpts_result result = new submitTopologyWithOpts_result(); - receiveBase(result, "submitTopologyWithOpts"); - if (result.e != null) { - throw result.e; - } - if (result.ite != null) { - throw result.ite; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void killTopology(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 - { - killTopology_args args = new killTopology_args(); - args.set_name(name); - sendBase("killTopology", args); - } - - public void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - killTopology_result result = new killTopology_result(); - receiveBase(result, "killTopology"); - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void killTopologyWithOpts(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 - { - killTopologyWithOpts_args args = new killTopologyWithOpts_args(); - args.set_name(name); - args.set_options(options); - sendBase("killTopologyWithOpts", args); - } - - public void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - killTopologyWithOpts_result result = new killTopologyWithOpts_result(); - receiveBase(result, "killTopologyWithOpts"); - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void activate(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 - { - activate_args args = new activate_args(); - args.set_name(name); - sendBase("activate", args); - } - - public void recv_activate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - activate_result result = new activate_result(); - receiveBase(result, "activate"); - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void deactivate(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 - { - deactivate_args args = new deactivate_args(); - args.set_name(name); - sendBase("deactivate", args); - } - - public void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - deactivate_result result = new deactivate_result(); - receiveBase(result, "deactivate"); - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void rebalance(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 - { - rebalance_args args = new rebalance_args(); - args.set_name(name); - args.set_options(options); - sendBase("rebalance", args); - } - - public void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException - { - rebalance_result result = new rebalance_result(); - receiveBase(result, "rebalance"); - if (result.e != null) { - throw result.e; - } - if (result.ite != null) { - throw result.ite; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void setLogConfig(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 - { - setLogConfig_args args = new setLogConfig_args(); - args.set_name(name); - args.set_config(config); - sendBase("setLogConfig", args); - } - - public void recv_setLogConfig() throws org.apache.thrift.TException - { - setLogConfig_result result = new setLogConfig_result(); - receiveBase(result, "setLogConfig"); - return; - } - - public LogConfig getLogConfig(String name) throws org.apache.thrift.TException - { - send_getLogConfig(name); - return recv_getLogConfig(); - } - - public void send_getLogConfig(String name) throws org.apache.thrift.TException - { - getLogConfig_args args = new getLogConfig_args(); - args.set_name(name); - sendBase("getLogConfig", args); - } - - public LogConfig recv_getLogConfig() throws org.apache.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"); - } - - public void debug(String name, 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 - { - debug_args args = new debug_args(); - args.set_name(name); - args.set_component(component); - args.set_enable(enable); - args.set_samplingPercentage(samplingPercentage); - sendBase("debug", args); - } - - public void recv_debug() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - debug_result result = new debug_result(); - receiveBase(result, "debug"); - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void setWorkerProfiler(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 - { - setWorkerProfiler_args args = new setWorkerProfiler_args(); - args.set_id(id); - args.set_profileRequest(profileRequest); - sendBase("setWorkerProfiler", args); - } - - public void recv_setWorkerProfiler() throws org.apache.thrift.TException - { - setWorkerProfiler_result result = new setWorkerProfiler_result(); - receiveBase(result, "setWorkerProfiler"); - return; - } - - public List<ProfileRequest> getComponentPendingProfileActions(String id, 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 - { - getComponentPendingProfileActions_args args = new getComponentPendingProfileActions_args(); - args.set_id(id); - args.set_component_id(component_id); - args.set_action(action); - sendBase("getComponentPendingProfileActions", args); - } - - public List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.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"); - } - - public void uploadNewCredentials(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 - { - uploadNewCredentials_args args = new uploadNewCredentials_args(); - args.set_name(name); - args.set_creds(creds); - sendBase("uploadNewCredentials", args); - } - - public void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException - { - uploadNewCredentials_result result = new uploadNewCredentials_result(); - receiveBase(result, "uploadNewCredentials"); - if (result.e != null) { - throw result.e; - } - if (result.ite != null) { - throw result.ite; - } - if (result.aze != null) { - throw result.aze; - } - return; - } - - public String beginCreateBlob(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 - { - beginCreateBlob_args args = new beginCreateBlob_args(); - args.set_key(key); - args.set_meta(meta); - sendBase("beginCreateBlob", args); - } - - public String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.thrift.TException - { - beginCreateBlob_result result = new beginCreateBlob_result(); - receiveBase(result, "beginCreateBlob"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.kae != null) { - throw result.kae; - } - 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 - { - send_beginUpdateBlob(key); - return recv_beginUpdateBlob(); - } - - public void send_beginUpdateBlob(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 - { - beginUpdateBlob_result result = new beginUpdateBlob_result(); - receiveBase(result, "beginUpdateBlob"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - 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 - { - send_uploadBlobChunk(session, chunk); - recv_uploadBlobChunk(); - } - - public void send_uploadBlobChunk(String session, ByteBuffer chunk) throws org.apache.thrift.TException - { - uploadBlobChunk_args args = new uploadBlobChunk_args(); - args.set_session(session); - args.set_chunk(chunk); - sendBase("uploadBlobChunk", args); - } - - public void recv_uploadBlobChunk() throws AuthorizationException, org.apache.thrift.TException - { - uploadBlobChunk_result result = new uploadBlobChunk_result(); - receiveBase(result, "uploadBlobChunk"); - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void finishBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException - { - send_finishBlobUpload(session); - recv_finishBlobUpload(); - } - - public void send_finishBlobUpload(String session) throws org.apache.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 - { - finishBlobUpload_result result = new finishBlobUpload_result(); - receiveBase(result, "finishBlobUpload"); - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void cancelBlobUpload(String session) throws AuthorizationException, org.apache.thrift.TException - { - send_cancelBlobUpload(session); - recv_cancelBlobUpload(); - } - - public void send_cancelBlobUpload(String session) throws org.apache.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 - { - cancelBlobUpload_result result = new cancelBlobUpload_result(); - receiveBase(result, "cancelBlobUpload"); - if (result.aze != null) { - throw result.aze; - } - return; - } - - public ReadableBlobMeta getBlobMeta(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 - { - getBlobMeta_args args = new getBlobMeta_args(); - args.set_key(key); - sendBase("getBlobMeta", args); - } - - public ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException - { - getBlobMeta_result result = new getBlobMeta_result(); - receiveBase(result, "getBlobMeta"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - 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 - { - send_setBlobMeta(key, meta); - recv_setBlobMeta(); - } - - public void send_setBlobMeta(String key, SettableBlobMeta meta) throws org.apache.thrift.TException - { - setBlobMeta_args args = new setBlobMeta_args(); - args.set_key(key); - args.set_meta(meta); - sendBase("setBlobMeta", args); - } - - public void recv_setBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException - { - setBlobMeta_result result = new setBlobMeta_result(); - receiveBase(result, "setBlobMeta"); - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - return; - } - - public BeginDownloadResult beginBlobDownload(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 - { - beginBlobDownload_args args = new beginBlobDownload_args(); - args.set_key(key); - sendBase("beginBlobDownload", args); - } - - public BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException - { - beginBlobDownload_result result = new beginBlobDownload_result(); - receiveBase(result, "beginBlobDownload"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - 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 - { - send_downloadBlobChunk(session); - return recv_downloadBlobChunk(); - } - - public void send_downloadBlobChunk(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 - { - downloadBlobChunk_result result = new downloadBlobChunk_result(); - receiveBase(result, "downloadBlobChunk"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_deleteBlob(key); - recv_deleteBlob(); - } - - public void send_deleteBlob(String key) throws org.apache.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 - { - deleteBlob_result result = new deleteBlob_result(); - receiveBase(result, "deleteBlob"); - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - return; - } - - public ListBlobsResult listBlobs(String session) throws org.apache.thrift.TException - { - send_listBlobs(session); - return recv_listBlobs(); - } - - public void send_listBlobs(String session) throws org.apache.thrift.TException - { - listBlobs_args args = new listBlobs_args(); - args.set_session(session); - sendBase("listBlobs", args); - } - - public ListBlobsResult recv_listBlobs() throws org.apache.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"); - } - - public int getBlobReplication(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 - { - getBlobReplication_args args = new getBlobReplication_args(); - args.set_key(key); - sendBase("getBlobReplication", args); - } - - public int recv_getBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException - { - getBlobReplication_result result = new getBlobReplication_result(); - receiveBase(result, "getBlobReplication"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - 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 - { - send_updateBlobReplication(key, replication); - return recv_updateBlobReplication(); - } - - public void send_updateBlobReplication(String key, int replication) throws org.apache.thrift.TException - { - updateBlobReplication_args args = new updateBlobReplication_args(); - args.set_key(key); - args.set_replication(replication); - sendBase("updateBlobReplication", args); - } - - public int recv_updateBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.thrift.TException - { - updateBlobReplication_result result = new updateBlobReplication_result(); - receiveBase(result, "updateBlobReplication"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - if (result.knf != null) { - throw result.knf; - } - 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 - { - send_createStateInZookeeper(key); - recv_createStateInZookeeper(); - } - - public void send_createStateInZookeeper(String key) throws org.apache.thrift.TException - { - createStateInZookeeper_args args = new createStateInZookeeper_args(); - args.set_key(key); - sendBase("createStateInZookeeper", args); - } - - public void recv_createStateInZookeeper() throws org.apache.thrift.TException - { - createStateInZookeeper_result result = new createStateInZookeeper_result(); - receiveBase(result, "createStateInZookeeper"); - return; - } - - public String beginFileUpload() throws AuthorizationException, org.apache.thrift.TException - { - send_beginFileUpload(); - return recv_beginFileUpload(); - } - - public void send_beginFileUpload() throws org.apache.thrift.TException - { - beginFileUpload_args args = new beginFileUpload_args(); - sendBase("beginFileUpload", args); - } - - public String recv_beginFileUpload() throws AuthorizationException, org.apache.thrift.TException - { - beginFileUpload_result result = new beginFileUpload_result(); - receiveBase(result, "beginFileUpload"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_uploadChunk(location, chunk); - recv_uploadChunk(); - } - - public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException - { - uploadChunk_args args = new uploadChunk_args(); - args.set_location(location); - args.set_chunk(chunk); - sendBase("uploadChunk", args); - } - - public void recv_uploadChunk() throws AuthorizationException, org.apache.thrift.TException - { - uploadChunk_result result = new uploadChunk_result(); - receiveBase(result, "uploadChunk"); - if (result.aze != null) { - throw result.aze; - } - return; - } - - public void finishFileUpload(String location) throws AuthorizationException, org.apache.thrift.TException - { - send_finishFileUpload(location); - recv_finishFileUpload(); - } - - public void send_finishFileUpload(String location) throws org.apache.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 - { - finishFileUpload_result result = new finishFileUpload_result(); - receiveBase(result, "finishFileUpload"); - if (result.aze != null) { - throw result.aze; - } - return; - } - - public String beginFileDownload(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 - { - beginFileDownload_args args = new beginFileDownload_args(); - args.set_file(file); - sendBase("beginFileDownload", args); - } - - public String recv_beginFileDownload() throws AuthorizationException, org.apache.thrift.TException - { - beginFileDownload_result result = new beginFileDownload_result(); - receiveBase(result, "beginFileDownload"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_downloadChunk(id); - return recv_downloadChunk(); - } - - public void send_downloadChunk(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 - { - downloadChunk_result result = new downloadChunk_result(); - receiveBase(result, "downloadChunk"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getNimbusConf(); - return recv_getNimbusConf(); - } - - public void send_getNimbusConf() throws org.apache.thrift.TException - { - getNimbusConf_args args = new getNimbusConf_args(); - sendBase("getNimbusConf", args); - } - - public String recv_getNimbusConf() throws AuthorizationException, org.apache.thrift.TException - { - getNimbusConf_result result = new getNimbusConf_result(); - receiveBase(result, "getNimbusConf"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getNimbusConf failed: unknown result"); - } - - public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.thrift.TException - { - send_getClusterInfo(); - return recv_getClusterInfo(); - } - - public void send_getClusterInfo() throws org.apache.thrift.TException - { - getClusterInfo_args args = new getClusterInfo_args(); - sendBase("getClusterInfo", args); - } - - public ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.thrift.TException - { - getClusterInfo_result result = new getClusterInfo_result(); - receiveBase(result, "getClusterInfo"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getClusterInfo failed: unknown result"); - } - - public TopologyInfo getTopologyInfo(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 - { - getTopologyInfo_args args = new getTopologyInfo_args(); - args.set_id(id); - sendBase("getTopologyInfo", args); - } - - public TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getTopologyInfo_result result = new getTopologyInfo_result(); - receiveBase(result, "getTopologyInfo"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getTopologyInfoWithOpts(id, options); - return recv_getTopologyInfoWithOpts(); - } - - public void send_getTopologyInfoWithOpts(String id, GetInfoOptions options) throws org.apache.thrift.TException - { - getTopologyInfoWithOpts_args args = new getTopologyInfoWithOpts_args(); - args.set_id(id); - args.set_options(options); - sendBase("getTopologyInfoWithOpts", args); - } - - public TopologyInfo recv_getTopologyInfoWithOpts() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result(); - receiveBase(result, "getTopologyInfoWithOpts"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - 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 - { - getTopologyPageInfo_args args = new getTopologyPageInfo_args(); - args.set_id(id); - args.set_window(window); - args.set_is_include_sys(is_include_sys); - sendBase("getTopologyPageInfo", args); - } - - public TopologyPageInfo recv_getTopologyPageInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getTopologyPageInfo_result result = new getTopologyPageInfo_result(); - receiveBase(result, "getTopologyPageInfo"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - 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 - { - getSupervisorPageInfo_args args = new getSupervisorPageInfo_args(); - args.set_id(id); - args.set_host(host); - args.set_is_include_sys(is_include_sys); - sendBase("getSupervisorPageInfo", args); - } - - public SupervisorPageInfo recv_getSupervisorPageInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getSupervisorPageInfo_result result = new getSupervisorPageInfo_result(); - receiveBase(result, "getSupervisorPageInfo"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - 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 - { - getComponentPageInfo_args args = new getComponentPageInfo_args(); - args.set_topology_id(topology_id); - args.set_component_id(component_id); - args.set_window(window); - args.set_is_include_sys(is_include_sys); - sendBase("getComponentPageInfo", args); - } - - public ComponentPageInfo recv_getComponentPageInfo() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getComponentPageInfo_result result = new getComponentPageInfo_result(); - receiveBase(result, "getComponentPageInfo"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getTopologyConf(id); - return recv_getTopologyConf(); - } - - public void send_getTopologyConf(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 - { - getTopologyConf_result result = new getTopologyConf_result(); - receiveBase(result, "getTopologyConf"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getTopology(id); - return recv_getTopology(); - } - - public void send_getTopology(String id) throws org.apache.thrift.TException - { - getTopology_args args = new getTopology_args(); - args.set_id(id); - sendBase("getTopology", args); - } - - public StormTopology recv_getTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getTopology_result result = new getTopology_result(); - receiveBase(result, "getTopology"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getUserTopology(id); - return recv_getUserTopology(); - } - - public void send_getUserTopology(String id) throws org.apache.thrift.TException - { - getUserTopology_args args = new getUserTopology_args(); - args.set_id(id); - sendBase("getUserTopology", args); - } - - public StormTopology recv_getUserTopology() throws NotAliveException, AuthorizationException, org.apache.thrift.TException - { - getUserTopology_result result = new getUserTopology_result(); - receiveBase(result, "getUserTopology"); - if (result.is_set_success()) { - return result.success; - } - if (result.e != null) { - throw result.e; - } - if (result.aze != null) { - throw result.aze; - } - 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 - { - send_getTopologyHistory(user); - return recv_getTopologyHistory(); - } - - public void send_getTopologyHistory(String user) throws org.apache.thrift.TException - { - getTopologyHistory_args args = new getTopologyHistory_args(); - args.set_user(user); - sendBase("getTopologyHistory", args); - } - - public TopologyHistoryInfo recv_getTopologyHistory() throws AuthorizationException, org.apache.thrift.TException - { - getTopologyHistory_result result = new getTopologyHistory_result(); - receiveBase(result, "getTopologyHistory"); - if (result.is_set_success()) { - return result.success; - } - if (result.aze != null) { - throw result.aze; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTopologyHistory failed: unknown result"); - } - - } - public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { - public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { - private org.apache.thrift.async.TAsyncClientManager clientManager; - private org.apache.thrift.protocol.TProtocolFactory protocolFactory; - public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { - this.clientManager = clientManager; - this.protocolFactory = protocolFactory; - } - public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { - return new AsyncClient(protocolFactory, clientManager, transport); - } - } - - public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { - 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 { - 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; - 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.uploadedJarLocation = uploadedJarLocation; - this.jsonConf = jsonConf; - this.topology = topology; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("submitTopology", org.apache.thrift.protocol.TMessageType.CALL, 0)); - submitTopology_args args = new submitTopology_args(); - args.set_name(name); - args.set_uploadedJarLocation(uploadedJarLocation); - args.set_jsonConf(jsonConf); - args.set_topology(topology); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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(); - } - } - - public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback 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; - 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.uploadedJarLocation = uploadedJarLocation; - this.jsonConf = jsonConf; - this.topology = topology; - this.options = options; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("submitTopologyWithOpts", org.apache.thrift.protocol.TMessageType.CALL, 0)); - submitTopologyWithOpts_args args = new submitTopologyWithOpts_args(); - args.set_name(name); - args.set_uploadedJarLocation(uploadedJarLocation); - args.set_jsonConf(jsonConf); - args.set_topology(topology); - args.set_options(options); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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(); - } - } - - public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("killTopology", org.apache.thrift.protocol.TMessageType.CALL, 0)); - killTopology_args args = new killTopology_args(); - args.set_name(name); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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(); - } - } - - public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback 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; - 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.options = options; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("killTopologyWithOpts", org.apache.thrift.protocol.TMessageType.CALL, 0)); - killTopologyWithOpts_args args = new killTopologyWithOpts_args(); - args.set_name(name); - args.set_options(options); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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(); - } - } - - public void activate(String name, org.apache.thrift.async.AsyncMethodCallback 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("activate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - activate_args args = new activate_args(); - args.set_name(name); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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_activate(); - } - } - - public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - deactivate_call method_call = new deactivate_call(name, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class deactivate_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - public deactivate_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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deactivate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - deactivate_args args = new deactivate_args(); - args.set_name(name); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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_deactivate(); - } - } - - public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - rebalance_call method_call = new rebalance_call(name, options, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class rebalance_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - private RebalanceOptions options; - public rebalance_call(String name, RebalanceOptions 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.options = options; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rebalance", org.apache.thrift.protocol.TMessageType.CALL, 0)); - rebalance_args args = new rebalance_args(); - args.set_name(name); - args.set_options(options); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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_rebalance(); - } - } - - public void setLogConfig(String name, LogConfig config, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - setLogConfig_call method_call = new setLogConfig_call(name, config, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class setLogConfig_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - private LogConfig config; - public setLogConfig_call(String name, LogConfig config, 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.config = config; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setLogConfig", org.apache.thrift.protocol.TMessageType.CALL, 0)); - setLogConfig_args args = new setLogConfig_args(); - args.set_name(name); - args.set_config(config); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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_setLogConfig(); - } - } - - public void getLogConfig(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getLogConfig_call method_call = new getLogConfig_call(name, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getLogConfig_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - public getLogConfig_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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getLogConfig", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getLogConfig_args args = new getLogConfig_args(); - args.set_name(name); - args.write(prot); - prot.writeMessageEnd(); - } - - public LogConfig getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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); - return (new Client(prot)).recv_getLogConfig(); - } - } - - public void debug(String name, String component, boolean enable, double samplingPercentage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - debug_call method_call = new debug_call(name, component, enable, samplingPercentage, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class debug_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - private String component; - private boolean enable; - private double samplingPercentage; - public debug_call(String name, String component, boolean enable, double samplingPercentage, 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.component = component; - this.enable = enable; - this.samplingPercentage = samplingPercentage; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("debug", org.apache.thrift.protocol.TMessageType.CALL, 0)); - debug_args args = new debug_args(); - args.set_name(name); - args.set_component(component); - args.set_enable(enable); - args.set_samplingPercentage(samplingPercentage); - args.write(prot); - prot.writeMessageEnd(); - } - - 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!"); - } - 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_debug(); - } - } - - public void setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - setWorkerProfiler_call method_call = new setWorkerProfiler_call(id, profileRequest, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class setWorkerProfiler_call extends org.apache.thrift.async.TAsyncMethodCall { - private String id; - private ProfileRequest profileRequest; - public setWorkerProfiler_call(String id, ProfileRequest profileRequest, 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.id = id; - this.profileRequest = profileRequest; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setWorkerProfiler", org.apache.thrift.protocol.TMessageType.CALL, 0)); - setWorkerProfiler_args args = new setWorkerProfiler_args(); - args.set_id(id); - args.set_profileRequest(profileRequest); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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_setWorkerProfiler(); - } - } - - public void getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getComponentPendingProfileActions_call method_call = new getComponentPendingProfileActions_call(id, component_id, action, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getComponentPendingProfileActions_call extends org.apache.thrift.async.TAsyncMethodCall { - private String id; - private String component_id; - private ProfileAction action; - public getComponentPendingProfileActions_call(String id, String component_id, ProfileAction action, 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.id = id; - this.component_id = component_id; - this.action = action; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getComponentPendingProfileActions", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getComponentPendingProfileActions_args args = new getComponentPendingProfileActions_args(); - args.set_id(id); - args.set_component_id(component_id); - args.set_action(action); - args.write(prot); - prot.writeMessageEnd(); - } - - public List<ProfileRequest> getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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); - return (new Client(prot)).recv_getComponentPendingProfileActions(); - } - } - - public void uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - uploadNewCredentials_call method_call = new uploadNewCredentials_call(name, creds, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class uploadNewCredentials_call extends org.apache.thrift.async.TAsyncMethodCall { - private String name; - private Credentials creds; - public uploadNewCredentials_call(String name, Credentials creds, 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 { - super(client, protocolFactory, transport, resultHandler, false); - this.name = name; - this.creds = creds; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("uploadNewCredentials", org.apache.thrift.protocol.TMessageType.CALL, 0)); - uploadNewCredentials_args args = new uploadNewCredentials_args(); - args.set_name(name); - args.set_creds(creds); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new 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_uploadNewCredentials(); -
<TRUNCATED>
