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>
