airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scnakand...@apache.org
Subject [44/51] [partial] airavata-php-gateway git commit: removing files from wrong merge
Date Tue, 13 Dec 2016 22:15:08 GMT
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java
deleted file mode 100644
index f3a62e3..0000000
--- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraAdmin.java
+++ /dev/null
@@ -1,14400 +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.airavata.cloud.aurora.client.sdk;
-
-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)", date = "2016-10-21")
-public class AuroraAdmin {
-
-  public interface Iface extends AuroraSchedulerManager.Iface {
-
-    /**
-     * Assign quota to a user.  This will overwrite any pre-existing quota for the user.
-     * 
-     * @param ownerRole
-     * @param quota
-     */
-    public Response setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException;
-
-    /**
-     * Forces a task into a specific state.  This does not guarantee the task will enter the given
-     * state, as the task must still transition within the bounds of the state machine.  However,
-     * it attempts to enter that state via the state machine.
-     * 
-     * @param taskId
-     * @param status
-     */
-    public Response forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException;
-
-    /**
-     * Immediately writes a storage snapshot to disk.
-     */
-    public Response performBackup() throws org.apache.thrift.TException;
-
-    /**
-     * Lists backups that are available for recovery.
-     */
-    public Response listBackups() throws org.apache.thrift.TException;
-
-    /**
-     * Loads a backup to an in-memory storage.  This must precede all other recovery operations.
-     * 
-     * @param backupId
-     */
-    public Response stageRecovery(String backupId) throws org.apache.thrift.TException;
-
-    /**
-     * Queries for tasks in a staged recovery.
-     * 
-     * @param query
-     */
-    public Response queryRecovery(TaskQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Deletes tasks from a staged recovery.
-     * 
-     * @param query
-     */
-    public Response deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Commits a staged recovery, completely replacing the previous storage state.
-     */
-    public Response commitRecovery() throws org.apache.thrift.TException;
-
-    /**
-     * Unloads (aborts) a staged recovery.
-     */
-    public Response unloadRecovery() throws org.apache.thrift.TException;
-
-    /**
-     * Put the given hosts into maintenance mode.
-     * 
-     * @param hosts
-     */
-    public Response startMaintenance(Hosts hosts) throws org.apache.thrift.TException;
-
-    /**
-     * Ask scheduler to begin moving tasks scheduled on given hosts.
-     * 
-     * @param hosts
-     */
-    public Response drainHosts(Hosts hosts) throws org.apache.thrift.TException;
-
-    /**
-     * Retrieve the current maintenance states for a group of hosts.
-     * 
-     * @param hosts
-     */
-    public Response maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException;
-
-    /**
-     * Set the given hosts back into serving mode.
-     * 
-     * @param hosts
-     */
-    public Response endMaintenance(Hosts hosts) throws org.apache.thrift.TException;
-
-    /**
-     * Start a storage snapshot and block until it completes.
-     */
-    public Response snapshot() throws org.apache.thrift.TException;
-
-    /**
-     * Forcibly rewrites the stored definition of user configurations.  This is intended to be used
-     * in a controlled setting, primarily to migrate pieces of configurations that are opaque to the
-     * scheduler (e.g. executorConfig).
-     * The scheduler may do some validation of the rewritten configurations, but it is important
-     * that the caller take care to provide valid input and alter only necessary fields.
-     * 
-     * @param request
-     */
-    public Response rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException;
-
-    /**
-     * Tell scheduler to trigger an explicit task reconciliation with the given settings.
-     * 
-     * @param settings
-     */
-    public Response triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException;
-
-    /**
-     * Tell scheduler to trigger an implicit task reconciliation.
-     */
-    public Response triggerImplicitTaskReconciliation() throws org.apache.thrift.TException;
-
-  }
-
-  public interface AsyncIface extends AuroraSchedulerManager .AsyncIface {
-
-    public void setQuota(String ownerRole, ResourceAggregate quota, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void forceTaskState(String taskId, ScheduleStatus status, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void performBackup(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void listBackups(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void stageRecovery(String backupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void queryRecovery(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void deleteRecoveryTasks(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void commitRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void unloadRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void startMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void drainHosts(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void maintenanceStatus(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void endMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void snapshot(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void rewriteConfigs(RewriteConfigsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void triggerImplicitTaskReconciliation(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-  }
-
-  public static class Client extends AuroraSchedulerManager.Client 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 Response setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException
-    {
-      send_setQuota(ownerRole, quota);
-      return recv_setQuota();
-    }
-
-    public void send_setQuota(String ownerRole, ResourceAggregate quota) throws org.apache.thrift.TException
-    {
-      setQuota_args args = new setQuota_args();
-      args.setOwnerRole(ownerRole);
-      args.setQuota(quota);
-      sendBase("setQuota", args);
-    }
-
-    public Response recv_setQuota() throws org.apache.thrift.TException
-    {
-      setQuota_result result = new setQuota_result();
-      receiveBase(result, "setQuota");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "setQuota failed: unknown result");
-    }
-
-    public Response forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException
-    {
-      send_forceTaskState(taskId, status);
-      return recv_forceTaskState();
-    }
-
-    public void send_forceTaskState(String taskId, ScheduleStatus status) throws org.apache.thrift.TException
-    {
-      forceTaskState_args args = new forceTaskState_args();
-      args.setTaskId(taskId);
-      args.setStatus(status);
-      sendBase("forceTaskState", args);
-    }
-
-    public Response recv_forceTaskState() throws org.apache.thrift.TException
-    {
-      forceTaskState_result result = new forceTaskState_result();
-      receiveBase(result, "forceTaskState");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "forceTaskState failed: unknown result");
-    }
-
-    public Response performBackup() throws org.apache.thrift.TException
-    {
-      send_performBackup();
-      return recv_performBackup();
-    }
-
-    public void send_performBackup() throws org.apache.thrift.TException
-    {
-      performBackup_args args = new performBackup_args();
-      sendBase("performBackup", args);
-    }
-
-    public Response recv_performBackup() throws org.apache.thrift.TException
-    {
-      performBackup_result result = new performBackup_result();
-      receiveBase(result, "performBackup");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "performBackup failed: unknown result");
-    }
-
-    public Response listBackups() throws org.apache.thrift.TException
-    {
-      send_listBackups();
-      return recv_listBackups();
-    }
-
-    public void send_listBackups() throws org.apache.thrift.TException
-    {
-      listBackups_args args = new listBackups_args();
-      sendBase("listBackups", args);
-    }
-
-    public Response recv_listBackups() throws org.apache.thrift.TException
-    {
-      listBackups_result result = new listBackups_result();
-      receiveBase(result, "listBackups");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listBackups failed: unknown result");
-    }
-
-    public Response stageRecovery(String backupId) throws org.apache.thrift.TException
-    {
-      send_stageRecovery(backupId);
-      return recv_stageRecovery();
-    }
-
-    public void send_stageRecovery(String backupId) throws org.apache.thrift.TException
-    {
-      stageRecovery_args args = new stageRecovery_args();
-      args.setBackupId(backupId);
-      sendBase("stageRecovery", args);
-    }
-
-    public Response recv_stageRecovery() throws org.apache.thrift.TException
-    {
-      stageRecovery_result result = new stageRecovery_result();
-      receiveBase(result, "stageRecovery");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "stageRecovery failed: unknown result");
-    }
-
-    public Response queryRecovery(TaskQuery query) throws org.apache.thrift.TException
-    {
-      send_queryRecovery(query);
-      return recv_queryRecovery();
-    }
-
-    public void send_queryRecovery(TaskQuery query) throws org.apache.thrift.TException
-    {
-      queryRecovery_args args = new queryRecovery_args();
-      args.setQuery(query);
-      sendBase("queryRecovery", args);
-    }
-
-    public Response recv_queryRecovery() throws org.apache.thrift.TException
-    {
-      queryRecovery_result result = new queryRecovery_result();
-      receiveBase(result, "queryRecovery");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryRecovery failed: unknown result");
-    }
-
-    public Response deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException
-    {
-      send_deleteRecoveryTasks(query);
-      return recv_deleteRecoveryTasks();
-    }
-
-    public void send_deleteRecoveryTasks(TaskQuery query) throws org.apache.thrift.TException
-    {
-      deleteRecoveryTasks_args args = new deleteRecoveryTasks_args();
-      args.setQuery(query);
-      sendBase("deleteRecoveryTasks", args);
-    }
-
-    public Response recv_deleteRecoveryTasks() throws org.apache.thrift.TException
-    {
-      deleteRecoveryTasks_result result = new deleteRecoveryTasks_result();
-      receiveBase(result, "deleteRecoveryTasks");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteRecoveryTasks failed: unknown result");
-    }
-
-    public Response commitRecovery() throws org.apache.thrift.TException
-    {
-      send_commitRecovery();
-      return recv_commitRecovery();
-    }
-
-    public void send_commitRecovery() throws org.apache.thrift.TException
-    {
-      commitRecovery_args args = new commitRecovery_args();
-      sendBase("commitRecovery", args);
-    }
-
-    public Response recv_commitRecovery() throws org.apache.thrift.TException
-    {
-      commitRecovery_result result = new commitRecovery_result();
-      receiveBase(result, "commitRecovery");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "commitRecovery failed: unknown result");
-    }
-
-    public Response unloadRecovery() throws org.apache.thrift.TException
-    {
-      send_unloadRecovery();
-      return recv_unloadRecovery();
-    }
-
-    public void send_unloadRecovery() throws org.apache.thrift.TException
-    {
-      unloadRecovery_args args = new unloadRecovery_args();
-      sendBase("unloadRecovery", args);
-    }
-
-    public Response recv_unloadRecovery() throws org.apache.thrift.TException
-    {
-      unloadRecovery_result result = new unloadRecovery_result();
-      receiveBase(result, "unloadRecovery");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "unloadRecovery failed: unknown result");
-    }
-
-    public Response startMaintenance(Hosts hosts) throws org.apache.thrift.TException
-    {
-      send_startMaintenance(hosts);
-      return recv_startMaintenance();
-    }
-
-    public void send_startMaintenance(Hosts hosts) throws org.apache.thrift.TException
-    {
-      startMaintenance_args args = new startMaintenance_args();
-      args.setHosts(hosts);
-      sendBase("startMaintenance", args);
-    }
-
-    public Response recv_startMaintenance() throws org.apache.thrift.TException
-    {
-      startMaintenance_result result = new startMaintenance_result();
-      receiveBase(result, "startMaintenance");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startMaintenance failed: unknown result");
-    }
-
-    public Response drainHosts(Hosts hosts) throws org.apache.thrift.TException
-    {
-      send_drainHosts(hosts);
-      return recv_drainHosts();
-    }
-
-    public void send_drainHosts(Hosts hosts) throws org.apache.thrift.TException
-    {
-      drainHosts_args args = new drainHosts_args();
-      args.setHosts(hosts);
-      sendBase("drainHosts", args);
-    }
-
-    public Response recv_drainHosts() throws org.apache.thrift.TException
-    {
-      drainHosts_result result = new drainHosts_result();
-      receiveBase(result, "drainHosts");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drainHosts failed: unknown result");
-    }
-
-    public Response maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException
-    {
-      send_maintenanceStatus(hosts);
-      return recv_maintenanceStatus();
-    }
-
-    public void send_maintenanceStatus(Hosts hosts) throws org.apache.thrift.TException
-    {
-      maintenanceStatus_args args = new maintenanceStatus_args();
-      args.setHosts(hosts);
-      sendBase("maintenanceStatus", args);
-    }
-
-    public Response recv_maintenanceStatus() throws org.apache.thrift.TException
-    {
-      maintenanceStatus_result result = new maintenanceStatus_result();
-      receiveBase(result, "maintenanceStatus");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "maintenanceStatus failed: unknown result");
-    }
-
-    public Response endMaintenance(Hosts hosts) throws org.apache.thrift.TException
-    {
-      send_endMaintenance(hosts);
-      return recv_endMaintenance();
-    }
-
-    public void send_endMaintenance(Hosts hosts) throws org.apache.thrift.TException
-    {
-      endMaintenance_args args = new endMaintenance_args();
-      args.setHosts(hosts);
-      sendBase("endMaintenance", args);
-    }
-
-    public Response recv_endMaintenance() throws org.apache.thrift.TException
-    {
-      endMaintenance_result result = new endMaintenance_result();
-      receiveBase(result, "endMaintenance");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "endMaintenance failed: unknown result");
-    }
-
-    public Response snapshot() throws org.apache.thrift.TException
-    {
-      send_snapshot();
-      return recv_snapshot();
-    }
-
-    public void send_snapshot() throws org.apache.thrift.TException
-    {
-      snapshot_args args = new snapshot_args();
-      sendBase("snapshot", args);
-    }
-
-    public Response recv_snapshot() throws org.apache.thrift.TException
-    {
-      snapshot_result result = new snapshot_result();
-      receiveBase(result, "snapshot");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "snapshot failed: unknown result");
-    }
-
-    public Response rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException
-    {
-      send_rewriteConfigs(request);
-      return recv_rewriteConfigs();
-    }
-
-    public void send_rewriteConfigs(RewriteConfigsRequest request) throws org.apache.thrift.TException
-    {
-      rewriteConfigs_args args = new rewriteConfigs_args();
-      args.setRequest(request);
-      sendBase("rewriteConfigs", args);
-    }
-
-    public Response recv_rewriteConfigs() throws org.apache.thrift.TException
-    {
-      rewriteConfigs_result result = new rewriteConfigs_result();
-      receiveBase(result, "rewriteConfigs");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "rewriteConfigs failed: unknown result");
-    }
-
-    public Response triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException
-    {
-      send_triggerExplicitTaskReconciliation(settings);
-      return recv_triggerExplicitTaskReconciliation();
-    }
-
-    public void send_triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings) throws org.apache.thrift.TException
-    {
-      triggerExplicitTaskReconciliation_args args = new triggerExplicitTaskReconciliation_args();
-      args.setSettings(settings);
-      sendBase("triggerExplicitTaskReconciliation", args);
-    }
-
-    public Response recv_triggerExplicitTaskReconciliation() throws org.apache.thrift.TException
-    {
-      triggerExplicitTaskReconciliation_result result = new triggerExplicitTaskReconciliation_result();
-      receiveBase(result, "triggerExplicitTaskReconciliation");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "triggerExplicitTaskReconciliation failed: unknown result");
-    }
-
-    public Response triggerImplicitTaskReconciliation() throws org.apache.thrift.TException
-    {
-      send_triggerImplicitTaskReconciliation();
-      return recv_triggerImplicitTaskReconciliation();
-    }
-
-    public void send_triggerImplicitTaskReconciliation() throws org.apache.thrift.TException
-    {
-      triggerImplicitTaskReconciliation_args args = new triggerImplicitTaskReconciliation_args();
-      sendBase("triggerImplicitTaskReconciliation", args);
-    }
-
-    public Response recv_triggerImplicitTaskReconciliation() throws org.apache.thrift.TException
-    {
-      triggerImplicitTaskReconciliation_result result = new triggerImplicitTaskReconciliation_result();
-      receiveBase(result, "triggerImplicitTaskReconciliation");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "triggerImplicitTaskReconciliation failed: unknown result");
-    }
-
-  }
-  public static class AsyncClient extends AuroraSchedulerManager.AsyncClient 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 setQuota(String ownerRole, ResourceAggregate quota, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      setQuota_call method_call = new setQuota_call(ownerRole, quota, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class setQuota_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String ownerRole;
-      private ResourceAggregate quota;
-      public setQuota_call(String ownerRole, ResourceAggregate quota, 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.ownerRole = ownerRole;
-        this.quota = quota;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("setQuota", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        setQuota_args args = new setQuota_args();
-        args.setOwnerRole(ownerRole);
-        args.setQuota(quota);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_setQuota();
-      }
-    }
-
-    public void forceTaskState(String taskId, ScheduleStatus status, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      forceTaskState_call method_call = new forceTaskState_call(taskId, status, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class forceTaskState_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String taskId;
-      private ScheduleStatus status;
-      public forceTaskState_call(String taskId, ScheduleStatus status, 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.taskId = taskId;
-        this.status = status;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("forceTaskState", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        forceTaskState_args args = new forceTaskState_args();
-        args.setTaskId(taskId);
-        args.setStatus(status);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_forceTaskState();
-      }
-    }
-
-    public void performBackup(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      performBackup_call method_call = new performBackup_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class performBackup_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public performBackup_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("performBackup", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        performBackup_args args = new performBackup_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_performBackup();
-      }
-    }
-
-    public void listBackups(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      listBackups_call method_call = new listBackups_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class listBackups_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public listBackups_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("listBackups", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        listBackups_args args = new listBackups_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_listBackups();
-      }
-    }
-
-    public void stageRecovery(String backupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      stageRecovery_call method_call = new stageRecovery_call(backupId, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class stageRecovery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String backupId;
-      public stageRecovery_call(String backupId, 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.backupId = backupId;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("stageRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        stageRecovery_args args = new stageRecovery_args();
-        args.setBackupId(backupId);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_stageRecovery();
-      }
-    }
-
-    public void queryRecovery(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      queryRecovery_call method_call = new queryRecovery_call(query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class queryRecovery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TaskQuery query;
-      public queryRecovery_call(TaskQuery query, 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.query = query;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        queryRecovery_args args = new queryRecovery_args();
-        args.setQuery(query);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_queryRecovery();
-      }
-    }
-
-    public void deleteRecoveryTasks(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      deleteRecoveryTasks_call method_call = new deleteRecoveryTasks_call(query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class deleteRecoveryTasks_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TaskQuery query;
-      public deleteRecoveryTasks_call(TaskQuery query, 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.query = query;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteRecoveryTasks", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        deleteRecoveryTasks_args args = new deleteRecoveryTasks_args();
-        args.setQuery(query);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_deleteRecoveryTasks();
-      }
-    }
-
-    public void commitRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      commitRecovery_call method_call = new commitRecovery_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class commitRecovery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public commitRecovery_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("commitRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        commitRecovery_args args = new commitRecovery_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_commitRecovery();
-      }
-    }
-
-    public void unloadRecovery(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      unloadRecovery_call method_call = new unloadRecovery_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class unloadRecovery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public unloadRecovery_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("unloadRecovery", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        unloadRecovery_args args = new unloadRecovery_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_unloadRecovery();
-      }
-    }
-
-    public void startMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      startMaintenance_call method_call = new startMaintenance_call(hosts, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class startMaintenance_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Hosts hosts;
-      public startMaintenance_call(Hosts hosts, 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.hosts = hosts;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startMaintenance", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        startMaintenance_args args = new startMaintenance_args();
-        args.setHosts(hosts);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_startMaintenance();
-      }
-    }
-
-    public void drainHosts(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      drainHosts_call method_call = new drainHosts_call(hosts, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class drainHosts_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Hosts hosts;
-      public drainHosts_call(Hosts hosts, 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.hosts = hosts;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("drainHosts", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        drainHosts_args args = new drainHosts_args();
-        args.setHosts(hosts);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_drainHosts();
-      }
-    }
-
-    public void maintenanceStatus(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      maintenanceStatus_call method_call = new maintenanceStatus_call(hosts, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class maintenanceStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Hosts hosts;
-      public maintenanceStatus_call(Hosts hosts, 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.hosts = hosts;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("maintenanceStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        maintenanceStatus_args args = new maintenanceStatus_args();
-        args.setHosts(hosts);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_maintenanceStatus();
-      }
-    }
-
-    public void endMaintenance(Hosts hosts, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      endMaintenance_call method_call = new endMaintenance_call(hosts, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class endMaintenance_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Hosts hosts;
-      public endMaintenance_call(Hosts hosts, 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.hosts = hosts;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("endMaintenance", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        endMaintenance_args args = new endMaintenance_args();
-        args.setHosts(hosts);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_endMaintenance();
-      }
-    }
-
-    public void snapshot(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      snapshot_call method_call = new snapshot_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class snapshot_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public snapshot_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("snapshot", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        snapshot_args args = new snapshot_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_snapshot();
-      }
-    }
-
-    public void rewriteConfigs(RewriteConfigsRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      rewriteConfigs_call method_call = new rewriteConfigs_call(request, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class rewriteConfigs_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private RewriteConfigsRequest request;
-      public rewriteConfigs_call(RewriteConfigsRequest request, 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.request = request;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rewriteConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        rewriteConfigs_args args = new rewriteConfigs_args();
-        args.setRequest(request);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_rewriteConfigs();
-      }
-    }
-
-    public void triggerExplicitTaskReconciliation(ExplicitReconciliationSettings settings, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      triggerExplicitTaskReconciliation_call method_call = new triggerExplicitTaskReconciliation_call(settings, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class triggerExplicitTaskReconciliation_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ExplicitReconciliationSettings settings;
-      public triggerExplicitTaskReconciliation_call(ExplicitReconciliationSettings settings, 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.settings = settings;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("triggerExplicitTaskReconciliation", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        triggerExplicitTaskReconciliation_args args = new triggerExplicitTaskReconciliation_args();
-        args.setSettings(settings);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_triggerExplicitTaskReconciliation();
-      }
-    }
-
-    public void triggerImplicitTaskReconciliation(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      triggerImplicitTaskReconciliation_call method_call = new triggerImplicitTaskReconciliation_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class triggerImplicitTaskReconciliation_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public triggerImplicitTaskReconciliation_call(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);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("triggerImplicitTaskReconciliation", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        triggerImplicitTaskReconciliation_args args = new triggerImplicitTaskReconciliation_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Response 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_triggerImplicitTaskReconciliation();
-      }
-    }
-
-  }
-
-  public static class Processor<I extends Iface> extends AuroraSchedulerManager.Processor<I> implements org.apache.thrift.TProcessor {
-    private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
-    public Processor(I iface) {
-      super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
-    }
-
-    protected Processor(I iface, Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
-      super(iface, getProcessMap(processMap));
-    }
-
-    private static <I extends Iface> Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> getProcessMap(Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
-      processMap.put("setQuota", new setQuota());
-      processMap.put("forceTaskState", new forceTaskState());
-      processMap.put("performBackup", new performBackup());
-      processMap.put("listBackups", new listBackups());
-      processMap.put("stageRecovery", new stageRecovery());
-      processMap.put("queryRecovery", new queryRecovery());
-      processMap.put("deleteRecoveryTasks", new deleteRecoveryTasks());
-      processMap.put("commitRecovery", new commitRecovery());
-      processMap.put("unloadRecovery", new unloadRecovery());
-      processMap.put("startMaintenance", new startMaintenance());
-      processMap.put("drainHosts", new drainHosts());
-      processMap.put("maintenanceStatus", new maintenanceStatus());
-      processMap.put("endMaintenance", new endMaintenance());
-      processMap.put("snapshot", new snapshot());
-      processMap.put("rewriteConfigs", new rewriteConfigs());
-      processMap.put("triggerExplicitTaskReconciliation", new triggerExplicitTaskReconciliation());
-      processMap.put("triggerImplicitTaskReconciliation", new triggerImplicitTaskReconciliation());
-      return processMap;
-    }
-
-    public static class setQuota<I extends Iface> extends org.apache.thrift.ProcessFunction<I, setQuota_args> {
-      public setQuota() {
-        super("setQuota");
-      }
-
-      public setQuota_args getEmptyArgsInstance() {
-        return new setQuota_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public setQuota_result getResult(I iface, setQuota_args args) throws org.apache.thrift.TException {
-        setQuota_result result = new setQuota_result();
-        result.success = iface.setQuota(args.ownerRole, args.quota);
-        return result;
-      }
-    }
-
-    public static class forceTaskState<I extends Iface> extends org.apache.thrift.ProcessFunction<I, forceTaskState_args> {
-      public forceTaskState() {
-        super("forceTaskState");
-      }
-
-      public forceTaskState_args getEmptyArgsInstance() {
-        return new forceTaskState_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public forceTaskState_result getResult(I iface, forceTaskState_args args) throws org.apache.thrift.TException {
-        forceTaskState_result result = new forceTaskState_result();
-        result.success = iface.forceTaskState(args.taskId, args.status);
-        return result;
-      }
-    }
-
-    public static class performBackup<I extends Iface> extends org.apache.thrift.ProcessFunction<I, performBackup_args> {
-      public performBackup() {
-        super("performBackup");
-      }
-
-      public performBackup_args getEmptyArgsInstance() {
-        return new performBackup_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public performBackup_result getResult(I iface, performBackup_args args) throws org.apache.thrift.TException {
-        performBackup_result result = new performBackup_result();
-        result.success = iface.performBackup();
-        return result;
-      }
-    }
-
-    public static class listBackups<I extends Iface> extends org.apache.thrift.ProcessFunction<I, listBackups_args> {
-      public listBackups() {
-        super("listBackups");
-      }
-
-      public listBackups_args getEmptyArgsInstance() {
-        return new listBackups_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public listBackups_result getResult(I iface, listBackups_args args) throws org.apache.thrift.TException {
-        listBackups_result result = new listBackups_result();
-        result.success = iface.listBackups();
-        return result;
-      }
-    }
-
-    public static class stageRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, stageRecovery_args> {
-      public stageRecovery() {
-        super("stageRecovery");
-      }
-
-      public stageRecovery_args getEmptyArgsInstance() {
-        return new stageRecovery_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public stageRecovery_result getResult(I iface, stageRecovery_args args) throws org.apache.thrift.TException {
-        stageRecovery_result result = new stageRecovery_result();
-        result.success = iface.stageRecovery(args.backupId);
-        return result;
-      }
-    }
-
-    public static class queryRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryRecovery_args> {
-      public queryRecovery() {
-        super("queryRecovery");
-      }
-
-      public queryRecovery_args getEmptyArgsInstance() {
-        return new queryRecovery_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public queryRecovery_result getResult(I iface, queryRecovery_args args) throws org.apache.thrift.TException {
-        queryRecovery_result result = new queryRecovery_result();
-        result.success = iface.queryRecovery(args.query);
-        return result;
-      }
-    }
-
-    public static class deleteRecoveryTasks<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteRecoveryTasks_args> {
-      public deleteRecoveryTasks() {
-        super("deleteRecoveryTasks");
-      }
-
-      public deleteRecoveryTasks_args getEmptyArgsInstance() {
-        return new deleteRecoveryTasks_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public deleteRecoveryTasks_result getResult(I iface, deleteRecoveryTasks_args args) throws org.apache.thrift.TException {
-        deleteRecoveryTasks_result result = new deleteRecoveryTasks_result();
-        result.success = iface.deleteRecoveryTasks(args.query);
-        return result;
-      }
-    }
-
-    public static class commitRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, commitRecovery_args> {
-      public commitRecovery() {
-        super("commitRecovery");
-      }
-
-      public commitRecovery_args getEmptyArgsInstance() {
-        return new commitRecovery_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public commitRecovery_result getResult(I iface, commitRecovery_args args) throws org.apache.thrift.TException {
-        commitRecovery_result result = new commitRecovery_result();
-        result.success = iface.commitRecovery();
-        return result;
-      }
-    }
-
-    public static class unloadRecovery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, unloadRecovery_args> {
-      public unloadRecovery() {
-        super("unloadRecovery");
-      }
-
-      public unloadRecovery_args getEmptyArgsInstance() {
-        return new unloadRecovery_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public unloadRecovery_result getResult(I iface, unloadRecovery_args args) throws org.apache.thrift.TException {
-        unloadRecovery_result result = new unloadRecovery_result();
-        result.success = iface.unloadRecovery();
-        return result;
-      }
-    }
-
-    public static class startMaintenance<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startMaintenance_args> {
-      public startMaintenance() {
-        super("startMaintenance");
-      }
-
-      public startMaintenance_args getEmptyArgsInstance() {
-        return new startMaintenance_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public startMaintenance_result getResult(I iface, startMaintenance_args args) throws org.apache.thrift.TException {
-        startMaintenance_result result = new startMaintenance_result();
-        result.success = iface.startMaintenance(args.hosts);
-        return result;
-      }
-    }
-
-    public static class drainHosts<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drainHosts_args> {
-      public drainHosts() {
-        super("drainHosts");
-      }
-
-      public drainHosts_args getEmptyArgsInstance() {
-        return new drainHosts_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public drainHosts_result getResult(I iface, drainHosts_args args) throws org.apache.thrift.TException {
-        drainHosts_result result = new drainHosts_result();
-        result.success = iface.drainHosts(args.hosts);
-        return result;
-      }
-    }
-
-    public static class maintenanceStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, maintenanceStatus_args> {
-      public maintenanceStatus() {
-        super("maintenanceStatus");
-      }
-
-      public maintenanceStatus_args getEmptyArgsInstance() {
-        return new maintenanceStatus_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public maintenanceStatus_result getResult(I iface, maintenanceStatus_args args) throws org.apache.thrift.TException {
-        maintenanceStatus_result result = new maintenanceStatus_result();
-        result.success = iface.maintenanceStatus(args.hosts);
-        return result;
-      }
-    }
-
-    public static class endMaintenance<I extends Iface> extends org.apache.thrift.ProcessFunction<I, endMaintenance_args> {
-      public endMaintenance() {
-        super("endMaintenance");
-      }
-
-      public endMaintenance_args getEmptyArgsInstance() {
-        return new endMaintenance_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public endMaintenance_result getResult(I iface, endMaintenance_args args) throws org.apache.thrift.TException {
-        endMaintenance_result result = new endMaintenance_result();
-        result.success = iface.endMaintenance(args.hosts);
-        return result;
-      }
-    }
-
-    public static class snapshot<I extends Iface> extends org.apache.thrift.ProcessFunction<I, snapshot_args> {
-      public snapshot() {
-        super("snapshot");
-      }
-
-      public snapshot_args getEmptyArgsInstance() {
-        return new snapshot_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public snapshot_result getResult(I iface, snapshot_args args) throws org.apache.thrift.TException {
-        snapshot_result result = new snapshot_result();
-        result.success = iface.snapshot();
-        return result;
-      }
-    }
-
-    public static class rewriteConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, rewriteConfigs_args> {
-      public rewriteConfigs() {
-        super("rewriteConfigs");
-      }
-
-      public rewriteConfigs_args getEmptyArgsInstance() {
-        return new rewriteConfigs_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public rewriteConfigs_result getResult(I iface, rewriteConfigs_args args) throws org.apache.thrift.TException {
-        rewriteConfigs_result result = new rewriteConfigs_result();
-        result.success = iface.rewriteConfigs(args.request);
-        return result;
-      }
-    }
-
-    public static class triggerExplicitTaskReconciliation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, triggerExplicitTaskReconciliation_args> {
-      public triggerExplicitTaskReconciliation() {
-        super("triggerExplicitTaskReconciliation");
-      }
-
-      public triggerExplicitTaskReconciliation_args getEmptyArgsInstance() {
-        return new triggerExplicitTaskReconciliation_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public triggerExplicitTaskReconciliation_result getResult(I iface, triggerExplicitTaskReconciliation_args args) throws org.apache.thrift.TException {
-        triggerExplicitTaskReconciliation_result result = new triggerExplicitTaskReconciliation_result();
-        result.success = iface.triggerExplicitTaskReconciliation(args.settings);
-        return result;
-      }
-    }
-
-    public static class triggerImplicitTaskReconciliation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, triggerImplicitTaskReconciliation_args> {
-      public triggerImplicitTaskReconciliation() {
-        super("triggerImplicitTaskReconciliation");
-      }
-
-      public triggerImplicitTaskReconciliation_args getEmptyArgsInstance() {
-        return new triggerImplicitTaskReconciliation_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public triggerImplicitTaskReconciliation_result getResult(I iface, triggerImplicitTaskReconciliation_args args) throws org.apache.thrift.TException {
-        triggerImplicitTaskReconciliation_result result = new triggerImplicitTaskReconciliation_result();
-        result.success = iface.triggerImplicitTaskReconciliation();
-        return result;
-      }
-    }
-
-  }
-
-  public static class AsyncProcessor<I extends AsyncIface> extends AuroraSchedulerManager.AsyncProcessor<I> {
-    private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName());
-    public AsyncProcessor(I iface) {
-      super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>()));
-    }
-
-    protected AsyncProcessor(I iface, Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase, ?>> processMap) {
-      super(iface, getProcessMap(processMap));
-    }
-
-    private static <I extends AsyncIface> Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase,?>> getProcessMap(Map<String,  org.apache.thrift.AsyncProcessFunction<I, ? extends  org.apache.thrift.TBase, ?>> processMap) {
-      processMap.put("setQuota", new setQuota());
-      processMap.put("forceTaskState", new forceTaskState());
-      processMap.put("performBackup", new performBackup());
-      processMap.put("listBackups", new listBackups());
-      processMap.put("stageRecovery", new stageRecovery());
-      processMap.put("queryRecovery", new queryRecovery());
-      processMap.put("deleteRecoveryTasks", new deleteRecoveryTasks());
-      processMap.put("commitRecovery", new commitRecovery());
-      processMap.put("unloadRecovery", new unloadRecovery());
-      processMap.put("startMaintenance", new startMaintenance());
-      processMap.put("drainHosts", new drainHosts());
-      processMap.put("maintenanceStatus", new maintenanceStatus());
-      processMap.put("endMaintenance", new endMaintenance());
-      processMap.put("snapshot", new snapshot());
-      processMap.put("rewriteConfigs", new rewriteConfigs());
-      processMap.put("triggerExplicitTaskReconciliation", new triggerExplicitTaskReconciliation());
-      processMap.put("triggerImplicitTaskReconciliation", new triggerImplicitTaskReconciliation());
-      return processMap;
-    }
-
-    public static class setQuota<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, setQuota_args, Response> {
-      public setQuota() {
-        super("setQuota");
-      }
-
-      public setQuota_args getEmptyArgsInstance() {
-        return new setQuota_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            setQuota_result result = new setQuota_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            setQuota_result result = new setQuota_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, setQuota_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.setQuota(args.ownerRole, args.quota,resultHandler);
-      }
-    }
-
-    public static class forceTaskState<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, forceTaskState_args, Response> {
-      public forceTaskState() {
-        super("forceTaskState");
-      }
-
-      public forceTaskState_args getEmptyArgsInstance() {
-        return new forceTaskState_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            forceTaskState_result result = new forceTaskState_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            forceTaskState_result result = new forceTaskState_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, forceTaskState_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.forceTaskState(args.taskId, args.status,resultHandler);
-      }
-    }
-
-    public static class performBackup<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, performBackup_args, Response> {
-      public performBackup() {
-        super("performBackup");
-      }
-
-      public performBackup_args getEmptyArgsInstance() {
-        return new performBackup_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            performBackup_result result = new performBackup_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            performBackup_result result = new performBackup_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, performBackup_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.performBackup(resultHandler);
-      }
-    }
-
-    public static class listBackups<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, listBackups_args, Response> {
-      public listBackups() {
-        super("listBackups");
-      }
-
-      public listBackups_args getEmptyArgsInstance() {
-        return new listBackups_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            listBackups_result result = new listBackups_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            listBackups_result result = new listBackups_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, listBackups_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.listBackups(resultHandler);
-      }
-    }
-
-    public static class stageRecovery<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, stageRecovery_args, Response> {
-      public stageRecovery() {
-        super("stageRecovery");
-      }
-
-      public stageRecovery_args getEmptyArgsInstance() {
-        return new stageRecovery_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            stageRecovery_result result = new stageRecovery_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            stageRecovery_result result = new stageRecovery_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, stageRecovery_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.stageRecovery(args.backupId,resultHandler);
-      }
-    }
-
-    public static class queryRecovery<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, queryRecovery_args, Response> {
-      public queryRecovery() {
-        super("queryRecovery");
-      }
-
-      public queryRecovery_args getEmptyArgsInstance() {
-        return new queryRecovery_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            queryRecovery_result result = new queryRecovery_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            queryRecovery_result result = new queryRecovery_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, queryRecovery_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.queryRecovery(args.query,resultHandler);
-      }
-    }
-
-    public static class deleteRecoveryTasks<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteRecoveryTasks_args, Response> {
-      public deleteRecoveryTasks() {
-        super("deleteRecoveryTasks");
-      }
-
-      public deleteRecoveryTasks_args getEmptyArgsInstance() {
-        return new deleteRecoveryTasks_args();
-      }
-
-      public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.thrift.AsyncProcessFunction fcall = this;
-        return new AsyncMethodCallback<Response>() { 
-          public void onComplete(Response o) {
-            deleteRecoveryTasks_result result = new deleteRecoveryTasks_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
-              return;
-            } catch (Exception e) {
-              LOGGER.error("Exception writing to internal frame buffer", e);
-            }
-            fb.close();
-          }
-          public void onError(Exception e) {
-            byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
-            org.apache.thrift.TBase msg;
-            deleteRecoveryTasks_result result = new deleteRecoveryTasks_result();
-            {
-              msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-              return;
-            } catch (Exception ex) {
-              LOGGER.error("Exception writing to internal frame buffer", ex);
-            }
-            fb.close();
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, deleteRecoveryTasks_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        if

<TRUNCATED>

Mime
View raw message