airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scnakand...@apache.org
Subject [26/51] [partial] airavata-php-gateway git commit: removing files from wrong merge
Date Tue, 13 Dec 2016 22:14:50 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/ReadOnlyScheduler.java
----------------------------------------------------------------------
diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java
deleted file mode 100644
index fff3116..0000000
--- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/ReadOnlyScheduler.java
+++ /dev/null
@@ -1,11291 +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 ReadOnlyScheduler {
-
-  public interface Iface {
-
-    /**
-     * Returns a summary of the jobs grouped by role.
-     */
-    public Response getRoleSummary() throws org.apache.thrift.TException;
-
-    /**
-     * Returns a summary of jobs, optionally only those owned by a specific role.
-     * 
-     * @param role
-     */
-    public Response getJobSummary(String role) throws org.apache.thrift.TException;
-
-    /**
-     * Fetches the status of tasks.
-     * 
-     * @param query
-     */
-    public Response getTasksStatus(TaskQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Same as getTaskStatus but without the TaskConfig.ExecutorConfig data set.
-     * This is an interim solution until we have a better way to query TaskConfigs (AURORA-541).
-     * 
-     * @param query
-     */
-    public Response getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Returns user-friendly reasons (if available) for tasks retained in PENDING state.
-     * 
-     * @param query
-     */
-    public Response getPendingReason(TaskQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Fetches the configuration summary of active tasks for the specified job.
-     * 
-     * @param job
-     */
-    public Response getConfigSummary(JobKey job) throws org.apache.thrift.TException;
-
-    /**
-     * Fetches the status of jobs.
-     * ownerRole is optional, in which case all jobs are returned.
-     * 
-     * @param ownerRole
-     */
-    public Response getJobs(String ownerRole) throws org.apache.thrift.TException;
-
-    /**
-     * Fetches the quota allocated for a user.
-     * 
-     * @param ownerRole
-     */
-    public Response getQuota(String ownerRole) throws org.apache.thrift.TException;
-
-    /**
-     * Populates fields in a job configuration as though it were about to be run.
-     * This can be used to diff a configuration running tasks.
-     * 
-     * @param description
-     */
-    public Response populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException;
-
-    /**
-     * Gets job update summaries.
-     * 
-     * @param jobUpdateQuery
-     */
-    public Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException;
-
-    /**
-     * Gets job update details.
-     * 
-     * @param key
-     * @param query
-     */
-    public Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException;
-
-    /**
-     * Gets the diff between client (desired) and server (current) job states.
-     * 
-     * @param request
-     */
-    public Response getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException;
-
-    /**
-     * Gets tier configurations.
-     */
-    public Response getTierConfigs() throws org.apache.thrift.TException;
-
-  }
-
-  public interface AsyncIface {
-
-    public void getRoleSummary(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getJobSummary(String role, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getTasksStatus(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getTasksWithoutConfigs(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getPendingReason(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getConfigSummary(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getJobs(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getQuota(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void populateJobConfig(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getJobUpdateDiff(JobUpdateRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
-    public void getTierConfigs(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 Response getRoleSummary() throws org.apache.thrift.TException
-    {
-      send_getRoleSummary();
-      return recv_getRoleSummary();
-    }
-
-    public void send_getRoleSummary() throws org.apache.thrift.TException
-    {
-      getRoleSummary_args args = new getRoleSummary_args();
-      sendBase("getRoleSummary", args);
-    }
-
-    public Response recv_getRoleSummary() throws org.apache.thrift.TException
-    {
-      getRoleSummary_result result = new getRoleSummary_result();
-      receiveBase(result, "getRoleSummary");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRoleSummary failed: unknown result");
-    }
-
-    public Response getJobSummary(String role) throws org.apache.thrift.TException
-    {
-      send_getJobSummary(role);
-      return recv_getJobSummary();
-    }
-
-    public void send_getJobSummary(String role) throws org.apache.thrift.TException
-    {
-      getJobSummary_args args = new getJobSummary_args();
-      args.setRole(role);
-      sendBase("getJobSummary", args);
-    }
-
-    public Response recv_getJobSummary() throws org.apache.thrift.TException
-    {
-      getJobSummary_result result = new getJobSummary_result();
-      receiveBase(result, "getJobSummary");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobSummary failed: unknown result");
-    }
-
-    public Response getTasksStatus(TaskQuery query) throws org.apache.thrift.TException
-    {
-      send_getTasksStatus(query);
-      return recv_getTasksStatus();
-    }
-
-    public void send_getTasksStatus(TaskQuery query) throws org.apache.thrift.TException
-    {
-      getTasksStatus_args args = new getTasksStatus_args();
-      args.setQuery(query);
-      sendBase("getTasksStatus", args);
-    }
-
-    public Response recv_getTasksStatus() throws org.apache.thrift.TException
-    {
-      getTasksStatus_result result = new getTasksStatus_result();
-      receiveBase(result, "getTasksStatus");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTasksStatus failed: unknown result");
-    }
-
-    public Response getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException
-    {
-      send_getTasksWithoutConfigs(query);
-      return recv_getTasksWithoutConfigs();
-    }
-
-    public void send_getTasksWithoutConfigs(TaskQuery query) throws org.apache.thrift.TException
-    {
-      getTasksWithoutConfigs_args args = new getTasksWithoutConfigs_args();
-      args.setQuery(query);
-      sendBase("getTasksWithoutConfigs", args);
-    }
-
-    public Response recv_getTasksWithoutConfigs() throws org.apache.thrift.TException
-    {
-      getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_result();
-      receiveBase(result, "getTasksWithoutConfigs");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTasksWithoutConfigs failed: unknown result");
-    }
-
-    public Response getPendingReason(TaskQuery query) throws org.apache.thrift.TException
-    {
-      send_getPendingReason(query);
-      return recv_getPendingReason();
-    }
-
-    public void send_getPendingReason(TaskQuery query) throws org.apache.thrift.TException
-    {
-      getPendingReason_args args = new getPendingReason_args();
-      args.setQuery(query);
-      sendBase("getPendingReason", args);
-    }
-
-    public Response recv_getPendingReason() throws org.apache.thrift.TException
-    {
-      getPendingReason_result result = new getPendingReason_result();
-      receiveBase(result, "getPendingReason");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPendingReason failed: unknown result");
-    }
-
-    public Response getConfigSummary(JobKey job) throws org.apache.thrift.TException
-    {
-      send_getConfigSummary(job);
-      return recv_getConfigSummary();
-    }
-
-    public void send_getConfigSummary(JobKey job) throws org.apache.thrift.TException
-    {
-      getConfigSummary_args args = new getConfigSummary_args();
-      args.setJob(job);
-      sendBase("getConfigSummary", args);
-    }
-
-    public Response recv_getConfigSummary() throws org.apache.thrift.TException
-    {
-      getConfigSummary_result result = new getConfigSummary_result();
-      receiveBase(result, "getConfigSummary");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getConfigSummary failed: unknown result");
-    }
-
-    public Response getJobs(String ownerRole) throws org.apache.thrift.TException
-    {
-      send_getJobs(ownerRole);
-      return recv_getJobs();
-    }
-
-    public void send_getJobs(String ownerRole) throws org.apache.thrift.TException
-    {
-      getJobs_args args = new getJobs_args();
-      args.setOwnerRole(ownerRole);
-      sendBase("getJobs", args);
-    }
-
-    public Response recv_getJobs() throws org.apache.thrift.TException
-    {
-      getJobs_result result = new getJobs_result();
-      receiveBase(result, "getJobs");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobs failed: unknown result");
-    }
-
-    public Response getQuota(String ownerRole) throws org.apache.thrift.TException
-    {
-      send_getQuota(ownerRole);
-      return recv_getQuota();
-    }
-
-    public void send_getQuota(String ownerRole) throws org.apache.thrift.TException
-    {
-      getQuota_args args = new getQuota_args();
-      args.setOwnerRole(ownerRole);
-      sendBase("getQuota", args);
-    }
-
-    public Response recv_getQuota() throws org.apache.thrift.TException
-    {
-      getQuota_result result = new getQuota_result();
-      receiveBase(result, "getQuota");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getQuota failed: unknown result");
-    }
-
-    public Response populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException
-    {
-      send_populateJobConfig(description);
-      return recv_populateJobConfig();
-    }
-
-    public void send_populateJobConfig(JobConfiguration description) throws org.apache.thrift.TException
-    {
-      populateJobConfig_args args = new populateJobConfig_args();
-      args.setDescription(description);
-      sendBase("populateJobConfig", args);
-    }
-
-    public Response recv_populateJobConfig() throws org.apache.thrift.TException
-    {
-      populateJobConfig_result result = new populateJobConfig_result();
-      receiveBase(result, "populateJobConfig");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "populateJobConfig failed: unknown result");
-    }
-
-    public Response getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException
-    {
-      send_getJobUpdateSummaries(jobUpdateQuery);
-      return recv_getJobUpdateSummaries();
-    }
-
-    public void send_getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery) throws org.apache.thrift.TException
-    {
-      getJobUpdateSummaries_args args = new getJobUpdateSummaries_args();
-      args.setJobUpdateQuery(jobUpdateQuery);
-      sendBase("getJobUpdateSummaries", args);
-    }
-
-    public Response recv_getJobUpdateSummaries() throws org.apache.thrift.TException
-    {
-      getJobUpdateSummaries_result result = new getJobUpdateSummaries_result();
-      receiveBase(result, "getJobUpdateSummaries");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateSummaries failed: unknown result");
-    }
-
-    public Response getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException
-    {
-      send_getJobUpdateDetails(key, query);
-      return recv_getJobUpdateDetails();
-    }
-
-    public void send_getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query) throws org.apache.thrift.TException
-    {
-      getJobUpdateDetails_args args = new getJobUpdateDetails_args();
-      args.setKey(key);
-      args.setQuery(query);
-      sendBase("getJobUpdateDetails", args);
-    }
-
-    public Response recv_getJobUpdateDetails() throws org.apache.thrift.TException
-    {
-      getJobUpdateDetails_result result = new getJobUpdateDetails_result();
-      receiveBase(result, "getJobUpdateDetails");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateDetails failed: unknown result");
-    }
-
-    public Response getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException
-    {
-      send_getJobUpdateDiff(request);
-      return recv_getJobUpdateDiff();
-    }
-
-    public void send_getJobUpdateDiff(JobUpdateRequest request) throws org.apache.thrift.TException
-    {
-      getJobUpdateDiff_args args = new getJobUpdateDiff_args();
-      args.setRequest(request);
-      sendBase("getJobUpdateDiff", args);
-    }
-
-    public Response recv_getJobUpdateDiff() throws org.apache.thrift.TException
-    {
-      getJobUpdateDiff_result result = new getJobUpdateDiff_result();
-      receiveBase(result, "getJobUpdateDiff");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getJobUpdateDiff failed: unknown result");
-    }
-
-    public Response getTierConfigs() throws org.apache.thrift.TException
-    {
-      send_getTierConfigs();
-      return recv_getTierConfigs();
-    }
-
-    public void send_getTierConfigs() throws org.apache.thrift.TException
-    {
-      getTierConfigs_args args = new getTierConfigs_args();
-      sendBase("getTierConfigs", args);
-    }
-
-    public Response recv_getTierConfigs() throws org.apache.thrift.TException
-    {
-      getTierConfigs_result result = new getTierConfigs_result();
-      receiveBase(result, "getTierConfigs");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTierConfigs 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 getRoleSummary(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getRoleSummary_call method_call = new getRoleSummary_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getRoleSummary_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public getRoleSummary_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("getRoleSummary", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getRoleSummary_args args = new getRoleSummary_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_getRoleSummary();
-      }
-    }
-
-    public void getJobSummary(String role, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getJobSummary_call method_call = new getJobSummary_call(role, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getJobSummary_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String role;
-      public getJobSummary_call(String role, 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.role = role;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobSummary", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getJobSummary_args args = new getJobSummary_args();
-        args.setRole(role);
-        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_getJobSummary();
-      }
-    }
-
-    public void getTasksStatus(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getTasksStatus_call method_call = new getTasksStatus_call(query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getTasksStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TaskQuery query;
-      public getTasksStatus_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("getTasksStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getTasksStatus_args args = new getTasksStatus_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_getTasksStatus();
-      }
-    }
-
-    public void getTasksWithoutConfigs(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getTasksWithoutConfigs_call method_call = new getTasksWithoutConfigs_call(query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getTasksWithoutConfigs_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TaskQuery query;
-      public getTasksWithoutConfigs_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("getTasksWithoutConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getTasksWithoutConfigs_args args = new getTasksWithoutConfigs_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_getTasksWithoutConfigs();
-      }
-    }
-
-    public void getPendingReason(TaskQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getPendingReason_call method_call = new getPendingReason_call(query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getPendingReason_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TaskQuery query;
-      public getPendingReason_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("getPendingReason", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getPendingReason_args args = new getPendingReason_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_getPendingReason();
-      }
-    }
-
-    public void getConfigSummary(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getConfigSummary_call method_call = new getConfigSummary_call(job, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getConfigSummary_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private JobKey job;
-      public getConfigSummary_call(JobKey job, 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.job = job;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getConfigSummary", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getConfigSummary_args args = new getConfigSummary_args();
-        args.setJob(job);
-        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_getConfigSummary();
-      }
-    }
-
-    public void getJobs(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getJobs_call method_call = new getJobs_call(ownerRole, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getJobs_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String ownerRole;
-      public getJobs_call(String ownerRole, 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;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobs", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getJobs_args args = new getJobs_args();
-        args.setOwnerRole(ownerRole);
-        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_getJobs();
-      }
-    }
-
-    public void getQuota(String ownerRole, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getQuota_call method_call = new getQuota_call(ownerRole, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getQuota_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String ownerRole;
-      public getQuota_call(String ownerRole, 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;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getQuota", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getQuota_args args = new getQuota_args();
-        args.setOwnerRole(ownerRole);
-        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_getQuota();
-      }
-    }
-
-    public void populateJobConfig(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      populateJobConfig_call method_call = new populateJobConfig_call(description, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class populateJobConfig_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private JobConfiguration description;
-      public populateJobConfig_call(JobConfiguration description, 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.description = description;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("populateJobConfig", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        populateJobConfig_args args = new populateJobConfig_args();
-        args.setDescription(description);
-        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_populateJobConfig();
-      }
-    }
-
-    public void getJobUpdateSummaries(JobUpdateQuery jobUpdateQuery, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getJobUpdateSummaries_call method_call = new getJobUpdateSummaries_call(jobUpdateQuery, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getJobUpdateSummaries_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private JobUpdateQuery jobUpdateQuery;
-      public getJobUpdateSummaries_call(JobUpdateQuery jobUpdateQuery, 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.jobUpdateQuery = jobUpdateQuery;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getJobUpdateSummaries", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getJobUpdateSummaries_args args = new getJobUpdateSummaries_args();
-        args.setJobUpdateQuery(jobUpdateQuery);
-        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_getJobUpdateSummaries();
-      }
-    }
-
-    public void getJobUpdateDetails(JobUpdateKey key, JobUpdateQuery query, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getJobUpdateDetails_call method_call = new getJobUpdateDetails_call(key, query, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getJobUpdateDetails_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private JobUpdateKey key;
-      private JobUpdateQuery query;
-      public getJobUpdateDetails_call(JobUpdateKey key, JobUpdateQuery 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.key = key;
-        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("getJobUpdateDetails", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getJobUpdateDetails_args args = new getJobUpdateDetails_args();
-        args.setKey(key);
-        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_getJobUpdateDetails();
-      }
-    }
-
-    public void getJobUpdateDiff(JobUpdateRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getJobUpdateDiff_call method_call = new getJobUpdateDiff_call(request, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getJobUpdateDiff_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private JobUpdateRequest request;
-      public getJobUpdateDiff_call(JobUpdateRequest 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("getJobUpdateDiff", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getJobUpdateDiff_args args = new getJobUpdateDiff_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_getJobUpdateDiff();
-      }
-    }
-
-    public void getTierConfigs(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getTierConfigs_call method_call = new getTierConfigs_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getTierConfigs_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public getTierConfigs_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("getTierConfigs", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getTierConfigs_args args = new getTierConfigs_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_getTierConfigs();
-      }
-    }
-
-  }
-
-  public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<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("getRoleSummary", new getRoleSummary());
-      processMap.put("getJobSummary", new getJobSummary());
-      processMap.put("getTasksStatus", new getTasksStatus());
-      processMap.put("getTasksWithoutConfigs", new getTasksWithoutConfigs());
-      processMap.put("getPendingReason", new getPendingReason());
-      processMap.put("getConfigSummary", new getConfigSummary());
-      processMap.put("getJobs", new getJobs());
-      processMap.put("getQuota", new getQuota());
-      processMap.put("populateJobConfig", new populateJobConfig());
-      processMap.put("getJobUpdateSummaries", new getJobUpdateSummaries());
-      processMap.put("getJobUpdateDetails", new getJobUpdateDetails());
-      processMap.put("getJobUpdateDiff", new getJobUpdateDiff());
-      processMap.put("getTierConfigs", new getTierConfigs());
-      return processMap;
-    }
-
-    public static class getRoleSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRoleSummary_args> {
-      public getRoleSummary() {
-        super("getRoleSummary");
-      }
-
-      public getRoleSummary_args getEmptyArgsInstance() {
-        return new getRoleSummary_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getRoleSummary_result getResult(I iface, getRoleSummary_args args) throws org.apache.thrift.TException {
-        getRoleSummary_result result = new getRoleSummary_result();
-        result.success = iface.getRoleSummary();
-        return result;
-      }
-    }
-
-    public static class getJobSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobSummary_args> {
-      public getJobSummary() {
-        super("getJobSummary");
-      }
-
-      public getJobSummary_args getEmptyArgsInstance() {
-        return new getJobSummary_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getJobSummary_result getResult(I iface, getJobSummary_args args) throws org.apache.thrift.TException {
-        getJobSummary_result result = new getJobSummary_result();
-        result.success = iface.getJobSummary(args.role);
-        return result;
-      }
-    }
-
-    public static class getTasksStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTasksStatus_args> {
-      public getTasksStatus() {
-        super("getTasksStatus");
-      }
-
-      public getTasksStatus_args getEmptyArgsInstance() {
-        return new getTasksStatus_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getTasksStatus_result getResult(I iface, getTasksStatus_args args) throws org.apache.thrift.TException {
-        getTasksStatus_result result = new getTasksStatus_result();
-        result.success = iface.getTasksStatus(args.query);
-        return result;
-      }
-    }
-
-    public static class getTasksWithoutConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTasksWithoutConfigs_args> {
-      public getTasksWithoutConfigs() {
-        super("getTasksWithoutConfigs");
-      }
-
-      public getTasksWithoutConfigs_args getEmptyArgsInstance() {
-        return new getTasksWithoutConfigs_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getTasksWithoutConfigs_result getResult(I iface, getTasksWithoutConfigs_args args) throws org.apache.thrift.TException {
-        getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_result();
-        result.success = iface.getTasksWithoutConfigs(args.query);
-        return result;
-      }
-    }
-
-    public static class getPendingReason<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getPendingReason_args> {
-      public getPendingReason() {
-        super("getPendingReason");
-      }
-
-      public getPendingReason_args getEmptyArgsInstance() {
-        return new getPendingReason_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getPendingReason_result getResult(I iface, getPendingReason_args args) throws org.apache.thrift.TException {
-        getPendingReason_result result = new getPendingReason_result();
-        result.success = iface.getPendingReason(args.query);
-        return result;
-      }
-    }
-
-    public static class getConfigSummary<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getConfigSummary_args> {
-      public getConfigSummary() {
-        super("getConfigSummary");
-      }
-
-      public getConfigSummary_args getEmptyArgsInstance() {
-        return new getConfigSummary_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getConfigSummary_result getResult(I iface, getConfigSummary_args args) throws org.apache.thrift.TException {
-        getConfigSummary_result result = new getConfigSummary_result();
-        result.success = iface.getConfigSummary(args.job);
-        return result;
-      }
-    }
-
-    public static class getJobs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobs_args> {
-      public getJobs() {
-        super("getJobs");
-      }
-
-      public getJobs_args getEmptyArgsInstance() {
-        return new getJobs_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getJobs_result getResult(I iface, getJobs_args args) throws org.apache.thrift.TException {
-        getJobs_result result = new getJobs_result();
-        result.success = iface.getJobs(args.ownerRole);
-        return result;
-      }
-    }
-
-    public static class getQuota<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getQuota_args> {
-      public getQuota() {
-        super("getQuota");
-      }
-
-      public getQuota_args getEmptyArgsInstance() {
-        return new getQuota_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getQuota_result getResult(I iface, getQuota_args args) throws org.apache.thrift.TException {
-        getQuota_result result = new getQuota_result();
-        result.success = iface.getQuota(args.ownerRole);
-        return result;
-      }
-    }
-
-    public static class populateJobConfig<I extends Iface> extends org.apache.thrift.ProcessFunction<I, populateJobConfig_args> {
-      public populateJobConfig() {
-        super("populateJobConfig");
-      }
-
-      public populateJobConfig_args getEmptyArgsInstance() {
-        return new populateJobConfig_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public populateJobConfig_result getResult(I iface, populateJobConfig_args args) throws org.apache.thrift.TException {
-        populateJobConfig_result result = new populateJobConfig_result();
-        result.success = iface.populateJobConfig(args.description);
-        return result;
-      }
-    }
-
-    public static class getJobUpdateSummaries<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateSummaries_args> {
-      public getJobUpdateSummaries() {
-        super("getJobUpdateSummaries");
-      }
-
-      public getJobUpdateSummaries_args getEmptyArgsInstance() {
-        return new getJobUpdateSummaries_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getJobUpdateSummaries_result getResult(I iface, getJobUpdateSummaries_args args) throws org.apache.thrift.TException {
-        getJobUpdateSummaries_result result = new getJobUpdateSummaries_result();
-        result.success = iface.getJobUpdateSummaries(args.jobUpdateQuery);
-        return result;
-      }
-    }
-
-    public static class getJobUpdateDetails<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateDetails_args> {
-      public getJobUpdateDetails() {
-        super("getJobUpdateDetails");
-      }
-
-      public getJobUpdateDetails_args getEmptyArgsInstance() {
-        return new getJobUpdateDetails_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getJobUpdateDetails_result getResult(I iface, getJobUpdateDetails_args args) throws org.apache.thrift.TException {
-        getJobUpdateDetails_result result = new getJobUpdateDetails_result();
-        result.success = iface.getJobUpdateDetails(args.key, args.query);
-        return result;
-      }
-    }
-
-    public static class getJobUpdateDiff<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getJobUpdateDiff_args> {
-      public getJobUpdateDiff() {
-        super("getJobUpdateDiff");
-      }
-
-      public getJobUpdateDiff_args getEmptyArgsInstance() {
-        return new getJobUpdateDiff_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getJobUpdateDiff_result getResult(I iface, getJobUpdateDiff_args args) throws org.apache.thrift.TException {
-        getJobUpdateDiff_result result = new getJobUpdateDiff_result();
-        result.success = iface.getJobUpdateDiff(args.request);
-        return result;
-      }
-    }
-
-    public static class getTierConfigs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTierConfigs_args> {
-      public getTierConfigs() {
-        super("getTierConfigs");
-      }
-
-      public getTierConfigs_args getEmptyArgsInstance() {
-        return new getTierConfigs_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public getTierConfigs_result getResult(I iface, getTierConfigs_args args) throws org.apache.thrift.TException {
-        getTierConfigs_result result = new getTierConfigs_result();
-        result.success = iface.getTierConfigs();
-        return result;
-      }
-    }
-
-  }
-
-  public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<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("getRoleSummary", new getRoleSummary());
-      processMap.put("getJobSummary", new getJobSummary());
-      processMap.put("getTasksStatus", new getTasksStatus());
-      processMap.put("getTasksWithoutConfigs", new getTasksWithoutConfigs());
-      processMap.put("getPendingReason", new getPendingReason());
-      processMap.put("getConfigSummary", new getConfigSummary());
-      processMap.put("getJobs", new getJobs());
-      processMap.put("getQuota", new getQuota());
-      processMap.put("populateJobConfig", new populateJobConfig());
-      processMap.put("getJobUpdateSummaries", new getJobUpdateSummaries());
-      processMap.put("getJobUpdateDetails", new getJobUpdateDetails());
-      processMap.put("getJobUpdateDiff", new getJobUpdateDiff());
-      processMap.put("getTierConfigs", new getTierConfigs());
-      return processMap;
-    }
-
-    public static class getRoleSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getRoleSummary_args, Response> {
-      public getRoleSummary() {
-        super("getRoleSummary");
-      }
-
-      public getRoleSummary_args getEmptyArgsInstance() {
-        return new getRoleSummary_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) {
-            getRoleSummary_result result = new getRoleSummary_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;
-            getRoleSummary_result result = new getRoleSummary_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, getRoleSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getRoleSummary(resultHandler);
-      }
-    }
-
-    public static class getJobSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobSummary_args, Response> {
-      public getJobSummary() {
-        super("getJobSummary");
-      }
-
-      public getJobSummary_args getEmptyArgsInstance() {
-        return new getJobSummary_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) {
-            getJobSummary_result result = new getJobSummary_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;
-            getJobSummary_result result = new getJobSummary_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, getJobSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getJobSummary(args.role,resultHandler);
-      }
-    }
-
-    public static class getTasksStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTasksStatus_args, Response> {
-      public getTasksStatus() {
-        super("getTasksStatus");
-      }
-
-      public getTasksStatus_args getEmptyArgsInstance() {
-        return new getTasksStatus_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) {
-            getTasksStatus_result result = new getTasksStatus_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;
-            getTasksStatus_result result = new getTasksStatus_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, getTasksStatus_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getTasksStatus(args.query,resultHandler);
-      }
-    }
-
-    public static class getTasksWithoutConfigs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTasksWithoutConfigs_args, Response> {
-      public getTasksWithoutConfigs() {
-        super("getTasksWithoutConfigs");
-      }
-
-      public getTasksWithoutConfigs_args getEmptyArgsInstance() {
-        return new getTasksWithoutConfigs_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) {
-            getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_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;
-            getTasksWithoutConfigs_result result = new getTasksWithoutConfigs_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, getTasksWithoutConfigs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getTasksWithoutConfigs(args.query,resultHandler);
-      }
-    }
-
-    public static class getPendingReason<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPendingReason_args, Response> {
-      public getPendingReason() {
-        super("getPendingReason");
-      }
-
-      public getPendingReason_args getEmptyArgsInstance() {
-        return new getPendingReason_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) {
-            getPendingReason_result result = new getPendingReason_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;
-            getPendingReason_result result = new getPendingReason_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, getPendingReason_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getPendingReason(args.query,resultHandler);
-      }
-    }
-
-    public static class getConfigSummary<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getConfigSummary_args, Response> {
-      public getConfigSummary() {
-        super("getConfigSummary");
-      }
-
-      public getConfigSummary_args getEmptyArgsInstance() {
-        return new getConfigSummary_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) {
-            getConfigSummary_result result = new getConfigSummary_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;
-            getConfigSummary_result result = new getConfigSummary_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, getConfigSummary_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getConfigSummary(args.job,resultHandler);
-      }
-    }
-
-    public static class getJobs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobs_args, Response> {
-      public getJobs() {
-        super("getJobs");
-      }
-
-      public getJobs_args getEmptyArgsInstance() {
-        return new getJobs_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) {
-            getJobs_result result = new getJobs_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;
-            getJobs_result result = new getJobs_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, getJobs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getJobs(args.ownerRole,resultHandler);
-      }
-    }
-
-    public static class getQuota<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getQuota_args, Response> {
-      public getQuota() {
-        super("getQuota");
-      }
-
-      public getQuota_args getEmptyArgsInstance() {
-        return new getQuota_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) {
-            getQuota_result result = new getQuota_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;
-            getQuota_result result = new getQuota_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, getQuota_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getQuota(args.ownerRole,resultHandler);
-      }
-    }
-
-    public static class populateJobConfig<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, populateJobConfig_args, Response> {
-      public populateJobConfig() {
-        super("populateJobConfig");
-      }
-
-      public populateJobConfig_args getEmptyArgsInstance() {
-        return new populateJobConfig_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) {
-            populateJobConfig_result result = new populateJobConfig_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;
-            populateJobConfig_result result = new populateJobConfig_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, populateJobConfig_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.populateJobConfig(args.description,resultHandler);
-      }
-    }
-
-    public static class getJobUpdateSummaries<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateSummaries_args, Response> {
-      public getJobUpdateSummaries() {
-        super("getJobUpdateSummaries");
-      }
-
-      public getJobUpdateSummaries_args getEmptyArgsInstance() {
-        return new getJobUpdateSummaries_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) {
-            getJobUpdateSummaries_result result = new getJobUpdateSummaries_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;
-            getJobUpdateSummaries_result result = new getJobUpdateSummaries_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, getJobUpdateSummaries_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getJobUpdateSummaries(args.jobUpdateQuery,resultHandler);
-      }
-    }
-
-    public static class getJobUpdateDetails<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateDetails_args, Response> {
-      public getJobUpdateDetails() {
-        super("getJobUpdateDetails");
-      }
-
-      public getJobUpdateDetails_args getEmptyArgsInstance() {
-        return new getJobUpdateDetails_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) {
-            getJobUpdateDetails_result result = new getJobUpdateDetails_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;
-            getJobUpdateDetails_result result = new getJobUpdateDetails_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, getJobUpdateDetails_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getJobUpdateDetails(args.key, args.query,resultHandler);
-      }
-    }
-
-    public static class getJobUpdateDiff<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getJobUpdateDiff_args, Response> {
-      public getJobUpdateDiff() {
-        super("getJobUpdateDiff");
-      }
-
-      public getJobUpdateDiff_args getEmptyArgsInstance() {
-        return new getJobUpdateDiff_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) {
-            getJobUpdateDiff_result result = new getJobUpdateDiff_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;
-            getJobUpdateDiff_result result = new getJobUpdateDiff_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, getJobUpdateDiff_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getJobUpdateDiff(args.request,resultHandler);
-      }
-    }
-
-    public static class getTierConfigs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getTierConfigs_args, Response> {
-      public getTierConfigs() {
-        super("getTierConfigs");
-      }
-
-      public getTierConfigs_args getEmptyArgsInstance() {
-        return new getTierConfigs_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) {
-            getTierConfigs_result result = new getTierConfigs_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;
-            getTierConfigs_result result = new getTierConfigs_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, getTierConfigs_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException {
-        iface.getTierConfigs(resultHandler);
-      }
-    }
-
-  }
-
-  public static class getRoleSummary_args implements org.apache.thrift.TBase<getRoleSummary_args, getRoleSummary_args._Fields>, java.io.Serializable, Cloneable, Comparable<getRoleSummary_args>   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getRoleSummary_args");
-
-
-    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
-    static {
-      schemes.put(StandardScheme.class, new getRoleSummary_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new getRoleSummary_argsTupleSchemeFactory());
-    }
-
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-;
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-    public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getRoleSummary_args.class, metaDataMap);
-    }
-
-    public getR

<TRUNCATED>

Mime
View raw message