http://git-wip-us.apache.org/repos/asf/zeppelin/blob/0d746fa2/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java ---------------------------------------------------------------------- diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java index d1c9d08..3dd8875 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java @@ -1,46 +1,52 @@ /** - * 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 + * 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 * - * <p>http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * <p>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 + * 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.2) * - * <p>DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * - * @generated + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated */ package org.apache.zeppelin.interpreter.thrift; -import java.nio.ByteBuffer; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.BitSet; -import java.util.Collections; -import java.util.EnumMap; -import java.util.EnumSet; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import javax.annotation.Generated; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.protocol.TTupleProtocol; 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; @@ -50,40 +56,21 @@ public class RemoteInterpreterService { public interface Iface { - public void createInterpreter( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName) - throws org.apache.thrift.TException; + public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException; public void open(String sessionId, String className) throws org.apache.thrift.TException; public void close(String sessionId, String className) throws org.apache.thrift.TException; - public RemoteInterpreterResult interpret( - String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException; + public RemoteInterpreterResult interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException; - public void cancel( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException; + public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException; - public int getProgress( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException; + public int getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException; - public String getFormType(String sessionId, String className) - throws org.apache.thrift.TException; + public String getFormType(String sessionId, String className) throws org.apache.thrift.TException; - public List<InterpreterCompletion> completion( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException; + public List<InterpreterCompletion> completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException; public void shutdown() throws org.apache.thrift.TException; @@ -91,216 +78,102 @@ public class RemoteInterpreterService { public List<String> resourcePoolGetAll() throws org.apache.thrift.TException; - public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException; + public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException; - public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException; + public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException; - public ByteBuffer resourceInvokeMethod( - String sessionId, String paragraphId, String resourceName, String invokeMessage) - throws org.apache.thrift.TException; + public ByteBuffer resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException; - public void angularObjectUpdate( - String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException; + public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException; - public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException; + public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException; - public void angularObjectRemove(String name, String sessionId, String paragraphId) - throws org.apache.thrift.TException; + public void angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException; public void angularRegistryPush(String registry) throws org.apache.thrift.TException; - public RemoteApplicationResult loadApplication( - String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) - throws org.apache.thrift.TException; + public RemoteApplicationResult loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException; - public RemoteApplicationResult unloadApplication(String applicationInstanceId) - throws org.apache.thrift.TException; + public RemoteApplicationResult unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException; + + public RemoteApplicationResult runApplication(String applicationInstanceId) throws org.apache.thrift.TException; - public RemoteApplicationResult runApplication(String applicationInstanceId) - throws org.apache.thrift.TException; } public interface AsyncIface { - public void createInterpreter( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void open( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void close( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void interpret( - String sessionId, - String className, - String st, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void cancel( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void getProgress( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void getFormType( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void completion( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void getStatus( - String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void resourceGet( - String sessionId, - String paragraphId, - String resourceName, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void resourceRemove( - String sessionId, - String paragraphId, - String resourceName, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void resourceInvokeMethod( - String sessionId, - String paragraphId, - String resourceName, - String invokeMessage, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void angularObjectUpdate( - String name, - String sessionId, - String paragraphId, - String object, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void angularObjectAdd( - String name, - String sessionId, - String paragraphId, - String object, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void angularObjectRemove( - String name, - String sessionId, - String paragraphId, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void angularRegistryPush( - String registry, org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void loadApplication( - String applicationInstanceId, - String packageInfo, - String sessionId, - String paragraphId, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void unloadApplication( - String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; - - public void runApplication( - String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException; + public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void open(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void close(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getFormType(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getStatus(String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourceGet(String sessionId, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourceRemove(String sessionId, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void angularObjectAdd(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void angularObjectRemove(String name, String sessionId, String paragraphId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void angularRegistryPush(String registry, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void unloadApplication(String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void runApplication(String applicationInstanceId, 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) { + 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) { + 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) { + public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { super(iprot, oprot); } - public void createInterpreter( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName) - throws org.apache.thrift.TException { + public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException + { send_createInterpreter(intpGroupId, sessionId, className, properties, userName); recv_createInterpreter(); } - public void send_createInterpreter( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName) - throws org.apache.thrift.TException { + public void send_createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException + { createInterpreter_args args = new createInterpreter_args(); args.setIntpGroupId(intpGroupId); args.setSessionId(sessionId); @@ -310,58 +183,63 @@ public class RemoteInterpreterService { sendBase("createInterpreter", args); } - public void recv_createInterpreter() throws org.apache.thrift.TException { + public void recv_createInterpreter() throws org.apache.thrift.TException + { createInterpreter_result result = new createInterpreter_result(); receiveBase(result, "createInterpreter"); return; } - public void open(String sessionId, String className) throws org.apache.thrift.TException { + public void open(String sessionId, String className) throws org.apache.thrift.TException + { send_open(sessionId, className); recv_open(); } - public void send_open(String sessionId, String className) throws org.apache.thrift.TException { + public void send_open(String sessionId, String className) throws org.apache.thrift.TException + { open_args args = new open_args(); args.setSessionId(sessionId); args.setClassName(className); sendBase("open", args); } - public void recv_open() throws org.apache.thrift.TException { + public void recv_open() throws org.apache.thrift.TException + { open_result result = new open_result(); receiveBase(result, "open"); return; } - public void close(String sessionId, String className) throws org.apache.thrift.TException { + public void close(String sessionId, String className) throws org.apache.thrift.TException + { send_close(sessionId, className); recv_close(); } - public void send_close(String sessionId, String className) throws org.apache.thrift.TException { + public void send_close(String sessionId, String className) throws org.apache.thrift.TException + { close_args args = new close_args(); args.setSessionId(sessionId); args.setClassName(className); sendBase("close", args); } - public void recv_close() throws org.apache.thrift.TException { + public void recv_close() throws org.apache.thrift.TException + { close_result result = new close_result(); receiveBase(result, "close"); return; } - public RemoteInterpreterResult interpret( - String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public RemoteInterpreterResult interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { send_interpret(sessionId, className, st, interpreterContext); return recv_interpret(); } - public void send_interpret( - String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public void send_interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { interpret_args args = new interpret_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -370,27 +248,24 @@ public class RemoteInterpreterService { sendBase("interpret", args); } - public RemoteInterpreterResult recv_interpret() throws org.apache.thrift.TException { + public RemoteInterpreterResult recv_interpret() throws org.apache.thrift.TException + { interpret_result result = new interpret_result(); receiveBase(result, "interpret"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "interpret failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "interpret failed: unknown result"); } - public void cancel( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { send_cancel(sessionId, className, interpreterContext); recv_cancel(); } - public void send_cancel( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public void send_cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { cancel_args args = new cancel_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -398,22 +273,21 @@ public class RemoteInterpreterService { sendBase("cancel", args); } - public void recv_cancel() throws org.apache.thrift.TException { + public void recv_cancel() throws org.apache.thrift.TException + { cancel_result result = new cancel_result(); receiveBase(result, "cancel"); return; } - public int getProgress( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public int getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { send_getProgress(sessionId, className, interpreterContext); return recv_getProgress(); } - public void send_getProgress( - String sessionId, String className, RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public void send_getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { getProgress_args args = new getProgress_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -421,60 +295,48 @@ public class RemoteInterpreterService { sendBase("getProgress", args); } - public int recv_getProgress() throws org.apache.thrift.TException { + public int recv_getProgress() throws org.apache.thrift.TException + { getProgress_result result = new getProgress_result(); receiveBase(result, "getProgress"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "getProgress failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getProgress failed: unknown result"); } - public String getFormType(String sessionId, String className) - throws org.apache.thrift.TException { + public String getFormType(String sessionId, String className) throws org.apache.thrift.TException + { send_getFormType(sessionId, className); return recv_getFormType(); } - public void send_getFormType(String sessionId, String className) - throws org.apache.thrift.TException { + public void send_getFormType(String sessionId, String className) throws org.apache.thrift.TException + { getFormType_args args = new getFormType_args(); args.setSessionId(sessionId); args.setClassName(className); sendBase("getFormType", args); } - public String recv_getFormType() throws org.apache.thrift.TException { + public String recv_getFormType() throws org.apache.thrift.TException + { getFormType_result result = new getFormType_result(); receiveBase(result, "getFormType"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "getFormType failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getFormType failed: unknown result"); } - public List<InterpreterCompletion> completion( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public List<InterpreterCompletion> completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { send_completion(sessionId, className, buf, cursor, interpreterContext); return recv_completion(); } - public void send_completion( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext) - throws org.apache.thrift.TException { + public void send_completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException + { completion_args args = new completion_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -484,85 +346,89 @@ public class RemoteInterpreterService { sendBase("completion", args); } - public List<InterpreterCompletion> recv_completion() throws org.apache.thrift.TException { + public List<InterpreterCompletion> recv_completion() throws org.apache.thrift.TException + { completion_result result = new completion_result(); receiveBase(result, "completion"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "completion failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "completion failed: unknown result"); } - public void shutdown() throws org.apache.thrift.TException { + public void shutdown() throws org.apache.thrift.TException + { send_shutdown(); recv_shutdown(); } - public void send_shutdown() throws org.apache.thrift.TException { + public void send_shutdown() throws org.apache.thrift.TException + { shutdown_args args = new shutdown_args(); sendBase("shutdown", args); } - public void recv_shutdown() throws org.apache.thrift.TException { + public void recv_shutdown() throws org.apache.thrift.TException + { shutdown_result result = new shutdown_result(); receiveBase(result, "shutdown"); return; } - public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException { + public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException + { send_getStatus(sessionId, jobId); return recv_getStatus(); } - public void send_getStatus(String sessionId, String jobId) throws org.apache.thrift.TException { + public void send_getStatus(String sessionId, String jobId) throws org.apache.thrift.TException + { getStatus_args args = new getStatus_args(); args.setSessionId(sessionId); args.setJobId(jobId); sendBase("getStatus", args); } - public String recv_getStatus() throws org.apache.thrift.TException { + public String recv_getStatus() throws org.apache.thrift.TException + { getStatus_result result = new getStatus_result(); receiveBase(result, "getStatus"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "getStatus failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getStatus failed: unknown result"); } - public List<String> resourcePoolGetAll() throws org.apache.thrift.TException { + public List<String> resourcePoolGetAll() throws org.apache.thrift.TException + { send_resourcePoolGetAll(); return recv_resourcePoolGetAll(); } - public void send_resourcePoolGetAll() throws org.apache.thrift.TException { + public void send_resourcePoolGetAll() throws org.apache.thrift.TException + { resourcePoolGetAll_args args = new resourcePoolGetAll_args(); sendBase("resourcePoolGetAll", args); } - public List<String> recv_resourcePoolGetAll() throws org.apache.thrift.TException { + public List<String> recv_resourcePoolGetAll() throws org.apache.thrift.TException + { resourcePoolGetAll_result result = new resourcePoolGetAll_result(); receiveBase(result, "resourcePoolGetAll"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "resourcePoolGetAll failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourcePoolGetAll failed: unknown result"); } - public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException { + public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException + { send_resourceGet(sessionId, paragraphId, resourceName); return recv_resourceGet(); } - public void send_resourceGet(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException { + public void send_resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException + { resourceGet_args args = new resourceGet_args(); args.setSessionId(sessionId); args.setParagraphId(paragraphId); @@ -570,25 +436,24 @@ public class RemoteInterpreterService { sendBase("resourceGet", args); } - public ByteBuffer recv_resourceGet() throws org.apache.thrift.TException { + public ByteBuffer recv_resourceGet() throws org.apache.thrift.TException + { resourceGet_result result = new resourceGet_result(); receiveBase(result, "resourceGet"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "resourceGet failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceGet failed: unknown result"); } - public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException { + public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException + { send_resourceRemove(sessionId, paragraphId, resourceName); return recv_resourceRemove(); } - public void send_resourceRemove(String sessionId, String paragraphId, String resourceName) - throws org.apache.thrift.TException { + public void send_resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException + { resourceRemove_args args = new resourceRemove_args(); args.setSessionId(sessionId); args.setParagraphId(paragraphId); @@ -596,27 +461,24 @@ public class RemoteInterpreterService { sendBase("resourceRemove", args); } - public boolean recv_resourceRemove() throws org.apache.thrift.TException { + public boolean recv_resourceRemove() throws org.apache.thrift.TException + { resourceRemove_result result = new resourceRemove_result(); receiveBase(result, "resourceRemove"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "resourceRemove failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceRemove failed: unknown result"); } - public ByteBuffer resourceInvokeMethod( - String sessionId, String paragraphId, String resourceName, String invokeMessage) - throws org.apache.thrift.TException { + public ByteBuffer resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException + { send_resourceInvokeMethod(sessionId, paragraphId, resourceName, invokeMessage); return recv_resourceInvokeMethod(); } - public void send_resourceInvokeMethod( - String sessionId, String paragraphId, String resourceName, String invokeMessage) - throws org.apache.thrift.TException { + public void send_resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException + { resourceInvokeMethod_args args = new resourceInvokeMethod_args(); args.setSessionId(sessionId); args.setParagraphId(paragraphId); @@ -625,27 +487,24 @@ public class RemoteInterpreterService { sendBase("resourceInvokeMethod", args); } - public ByteBuffer recv_resourceInvokeMethod() throws org.apache.thrift.TException { + public ByteBuffer recv_resourceInvokeMethod() throws org.apache.thrift.TException + { resourceInvokeMethod_result result = new resourceInvokeMethod_result(); receiveBase(result, "resourceInvokeMethod"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "resourceInvokeMethod failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceInvokeMethod failed: unknown result"); } - public void angularObjectUpdate( - String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException { + public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException + { send_angularObjectUpdate(name, sessionId, paragraphId, object); recv_angularObjectUpdate(); } - public void send_angularObjectUpdate( - String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException { + public void send_angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException + { angularObjectUpdate_args args = new angularObjectUpdate_args(); args.setName(name); args.setSessionId(sessionId); @@ -654,21 +513,21 @@ public class RemoteInterpreterService { sendBase("angularObjectUpdate", args); } - public void recv_angularObjectUpdate() throws org.apache.thrift.TException { + public void recv_angularObjectUpdate() throws org.apache.thrift.TException + { angularObjectUpdate_result result = new angularObjectUpdate_result(); receiveBase(result, "angularObjectUpdate"); return; } - public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException { + public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException + { send_angularObjectAdd(name, sessionId, paragraphId, object); recv_angularObjectAdd(); } - public void send_angularObjectAdd( - String name, String sessionId, String paragraphId, String object) - throws org.apache.thrift.TException { + public void send_angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException + { angularObjectAdd_args args = new angularObjectAdd_args(); args.setName(name); args.setSessionId(sessionId); @@ -677,20 +536,21 @@ public class RemoteInterpreterService { sendBase("angularObjectAdd", args); } - public void recv_angularObjectAdd() throws org.apache.thrift.TException { + public void recv_angularObjectAdd() throws org.apache.thrift.TException + { angularObjectAdd_result result = new angularObjectAdd_result(); receiveBase(result, "angularObjectAdd"); return; } - public void angularObjectRemove(String name, String sessionId, String paragraphId) - throws org.apache.thrift.TException { + public void angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException + { send_angularObjectRemove(name, sessionId, paragraphId); recv_angularObjectRemove(); } - public void send_angularObjectRemove(String name, String sessionId, String paragraphId) - throws org.apache.thrift.TException { + public void send_angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException + { angularObjectRemove_args args = new angularObjectRemove_args(); args.setName(name); args.setSessionId(sessionId); @@ -698,39 +558,41 @@ public class RemoteInterpreterService { sendBase("angularObjectRemove", args); } - public void recv_angularObjectRemove() throws org.apache.thrift.TException { + public void recv_angularObjectRemove() throws org.apache.thrift.TException + { angularObjectRemove_result result = new angularObjectRemove_result(); receiveBase(result, "angularObjectRemove"); return; } - public void angularRegistryPush(String registry) throws org.apache.thrift.TException { + public void angularRegistryPush(String registry) throws org.apache.thrift.TException + { send_angularRegistryPush(registry); recv_angularRegistryPush(); } - public void send_angularRegistryPush(String registry) throws org.apache.thrift.TException { + public void send_angularRegistryPush(String registry) throws org.apache.thrift.TException + { angularRegistryPush_args args = new angularRegistryPush_args(); args.setRegistry(registry); sendBase("angularRegistryPush", args); } - public void recv_angularRegistryPush() throws org.apache.thrift.TException { + public void recv_angularRegistryPush() throws org.apache.thrift.TException + { angularRegistryPush_result result = new angularRegistryPush_result(); receiveBase(result, "angularRegistryPush"); return; } - public RemoteApplicationResult loadApplication( - String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) - throws org.apache.thrift.TException { + public RemoteApplicationResult loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException + { send_loadApplication(applicationInstanceId, packageInfo, sessionId, paragraphId); return recv_loadApplication(); } - public void send_loadApplication( - String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) - throws org.apache.thrift.TException { + public void send_loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException + { loadApplication_args args = new loadApplication_args(); args.setApplicationInstanceId(applicationInstanceId); args.setPackageInfo(packageInfo); @@ -739,113 +601,83 @@ public class RemoteInterpreterService { sendBase("loadApplication", args); } - public RemoteApplicationResult recv_loadApplication() throws org.apache.thrift.TException { + public RemoteApplicationResult recv_loadApplication() throws org.apache.thrift.TException + { loadApplication_result result = new loadApplication_result(); receiveBase(result, "loadApplication"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "loadApplication failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "loadApplication failed: unknown result"); } - public RemoteApplicationResult unloadApplication(String applicationInstanceId) - throws org.apache.thrift.TException { + public RemoteApplicationResult unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException + { send_unloadApplication(applicationInstanceId); return recv_unloadApplication(); } - public void send_unloadApplication(String applicationInstanceId) - throws org.apache.thrift.TException { + public void send_unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException + { unloadApplication_args args = new unloadApplication_args(); args.setApplicationInstanceId(applicationInstanceId); sendBase("unloadApplication", args); } - public RemoteApplicationResult recv_unloadApplication() throws org.apache.thrift.TException { + public RemoteApplicationResult recv_unloadApplication() throws org.apache.thrift.TException + { unloadApplication_result result = new unloadApplication_result(); receiveBase(result, "unloadApplication"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "unloadApplication failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "unloadApplication failed: unknown result"); } - public RemoteApplicationResult runApplication(String applicationInstanceId) - throws org.apache.thrift.TException { + public RemoteApplicationResult runApplication(String applicationInstanceId) throws org.apache.thrift.TException + { send_runApplication(applicationInstanceId); return recv_runApplication(); } - public void send_runApplication(String applicationInstanceId) - throws org.apache.thrift.TException { + public void send_runApplication(String applicationInstanceId) throws org.apache.thrift.TException + { runApplication_args args = new runApplication_args(); args.setApplicationInstanceId(applicationInstanceId); sendBase("runApplication", args); } - public RemoteApplicationResult recv_runApplication() throws org.apache.thrift.TException { + public RemoteApplicationResult recv_runApplication() throws org.apache.thrift.TException + { runApplication_result result = new runApplication_result(); receiveBase(result, "runApplication"); if (result.isSetSuccess()) { return result.success; } - throw new org.apache.thrift.TApplicationException( - org.apache.thrift.TApplicationException.MISSING_RESULT, - "runApplication failed: unknown result"); + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "runApplication 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> { + } + 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) { + 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) { + 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) { + 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 createInterpreter( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - createInterpreter_call method_call = - new createInterpreter_call( - intpGroupId, - sessionId, - className, - properties, - userName, - resultHandler, - this, - ___protocolFactory, - ___transport); + createInterpreter_call method_call = new createInterpreter_call(intpGroupId, sessionId, className, properties, userName, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -854,20 +686,9 @@ public class RemoteInterpreterService { private String intpGroupId; private String sessionId; private String className; - private Map<String, String> properties; + private Map<String,String> properties; private String userName; - - public createInterpreter_call( - String intpGroupId, - String sessionId, - String className, - Map<String, String> properties, - String userName, - 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 { + public createInterpreter_call(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, 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.intpGroupId = intpGroupId; this.sessionId = sessionId; @@ -876,11 +697,8 @@ public class RemoteInterpreterService { this.userName = userName; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "createInterpreter", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createInterpreter", org.apache.thrift.protocol.TMessageType.CALL, 0)); createInterpreter_args args = new createInterpreter_args(); args.setIntpGroupId(intpGroupId); args.setSessionId(sessionId); @@ -895,23 +713,15 @@ public class RemoteInterpreterService { 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); + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); (new Client(prot)).recv_createInterpreter(); } } - public void open( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void open(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - open_call method_call = - new open_call( - sessionId, className, resultHandler, this, ___protocolFactory, ___transport); + open_call method_call = new open_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -919,25 +729,14 @@ public class RemoteInterpreterService { public static class open_call extends org.apache.thrift.async.TAsyncMethodCall { private String sessionId; private String className; - - public open_call( - String sessionId, - String className, - 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 { + public open_call(String sessionId, String className, 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.sessionId = sessionId; this.className = className; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "open", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("open", org.apache.thrift.protocol.TMessageType.CALL, 0)); open_args args = new open_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -949,23 +748,15 @@ public class RemoteInterpreterService { 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); + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); (new Client(prot)).recv_open(); } } - public void close( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void close(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - close_call method_call = - new close_call( - sessionId, className, resultHandler, this, ___protocolFactory, ___transport); + close_call method_call = new close_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -973,25 +764,14 @@ public class RemoteInterpreterService { public static class close_call extends org.apache.thrift.async.TAsyncMethodCall { private String sessionId; private String className; - - public close_call( - String sessionId, - String className, - 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 { + public close_call(String sessionId, String className, 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.sessionId = sessionId; this.className = className; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "close", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("close", org.apache.thrift.protocol.TMessageType.CALL, 0)); close_args args = new close_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1003,32 +783,15 @@ public class RemoteInterpreterService { 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); + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); (new Client(prot)).recv_close(); } } - public void interpret( - String sessionId, - String className, - String st, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - interpret_call method_call = - new interpret_call( - sessionId, - className, - st, - interpreterContext, - resultHandler, - this, - ___protocolFactory, - ___transport); + interpret_call method_call = new interpret_call(sessionId, className, st, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1038,17 +801,7 @@ public class RemoteInterpreterService { private String className; private String st; private RemoteInterpreterContext interpreterContext; - - public interpret_call( - String sessionId, - String className, - String st, - RemoteInterpreterContext interpreterContext, - 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 { + public interpret_call(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, 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.sessionId = sessionId; this.className = className; @@ -1056,11 +809,8 @@ public class RemoteInterpreterService { this.interpreterContext = interpreterContext; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "interpret", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("interpret", org.apache.thrift.protocol.TMessageType.CALL, 0)); interpret_args args = new interpret_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1074,30 +824,15 @@ public class RemoteInterpreterService { 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); + 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_interpret(); } } - public void cancel( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - cancel_call method_call = - new cancel_call( - sessionId, - className, - interpreterContext, - resultHandler, - this, - ___protocolFactory, - ___transport); + cancel_call method_call = new cancel_call(sessionId, className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1106,27 +841,15 @@ public class RemoteInterpreterService { private String sessionId; private String className; private RemoteInterpreterContext interpreterContext; - - public cancel_call( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - 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 { + public cancel_call(String sessionId, String className, RemoteInterpreterContext interpreterContext, 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.sessionId = sessionId; this.className = className; this.interpreterContext = interpreterContext; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "cancel", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancel", org.apache.thrift.protocol.TMessageType.CALL, 0)); cancel_args args = new cancel_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1139,30 +862,15 @@ public class RemoteInterpreterService { 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); + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); (new Client(prot)).recv_cancel(); } } - public void getProgress( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getProgress_call method_call = - new getProgress_call( - sessionId, - className, - interpreterContext, - resultHandler, - this, - ___protocolFactory, - ___transport); + getProgress_call method_call = new getProgress_call(sessionId, className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1171,27 +879,15 @@ public class RemoteInterpreterService { private String sessionId; private String className; private RemoteInterpreterContext interpreterContext; - - public getProgress_call( - String sessionId, - String className, - RemoteInterpreterContext interpreterContext, - 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 { + public getProgress_call(String sessionId, String className, RemoteInterpreterContext interpreterContext, 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.sessionId = sessionId; this.className = className; this.interpreterContext = interpreterContext; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "getProgress", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getProgress", org.apache.thrift.protocol.TMessageType.CALL, 0)); getProgress_args args = new getProgress_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1204,23 +900,15 @@ public class RemoteInterpreterService { 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); + 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_getProgress(); } } - public void getFormType( - String sessionId, - String className, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void getFormType(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getFormType_call method_call = - new getFormType_call( - sessionId, className, resultHandler, this, ___protocolFactory, ___transport); + getFormType_call method_call = new getFormType_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1228,25 +916,14 @@ public class RemoteInterpreterService { public static class getFormType_call extends org.apache.thrift.async.TAsyncMethodCall { private String sessionId; private String className; - - public getFormType_call( - String sessionId, - String className, - 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 { + public getFormType_call(String sessionId, String className, 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.sessionId = sessionId; this.className = className; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "getFormType", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getFormType", org.apache.thrift.protocol.TMessageType.CALL, 0)); getFormType_args args = new getFormType_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1258,34 +935,15 @@ public class RemoteInterpreterService { 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); + 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_getFormType(); } } - public void completion( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - completion_call method_call = - new completion_call( - sessionId, - className, - buf, - cursor, - interpreterContext, - resultHandler, - this, - ___protocolFactory, - ___transport); + completion_call method_call = new completion_call(sessionId, className, buf, cursor, interpreterContext, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1296,18 +954,7 @@ public class RemoteInterpreterService { private String buf; private int cursor; private RemoteInterpreterContext interpreterContext; - - public completion_call( - String sessionId, - String className, - String buf, - int cursor, - RemoteInterpreterContext interpreterContext, - 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 { + public completion_call(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, 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.sessionId = sessionId; this.className = className; @@ -1316,11 +963,8 @@ public class RemoteInterpreterService { this.interpreterContext = interpreterContext; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "completion", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("completion", org.apache.thrift.protocol.TMessageType.CALL, 0)); completion_args args = new completion_args(); args.setSessionId(sessionId); args.setClassName(className); @@ -1335,38 +979,26 @@ public class RemoteInterpreterService { 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); + 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_completion(); } } - public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - shutdown_call method_call = - new shutdown_call(resultHandler, this, ___protocolFactory, ___transport); + shutdown_call method_call = new shutdown_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class shutdown_call extends org.apache.thrift.async.TAsyncMethodCall { - public shutdown_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 { + public shutdown_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( - "shutdown", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdown", org.apache.thrift.protocol.TMessageType.CALL, 0)); shutdown_args args = new shutdown_args(); args.write(prot); prot.writeMessageEnd(); @@ -1376,21 +1008,15 @@ public class RemoteInterpreterService { 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); + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); (new Client(prot)).recv_shutdown(); } } - public void getStatus( - String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void getStatus(String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - getStatus_call method_call = - new getStatus_call( - sessionId, jobId, resultHandler, this, ___protocolFactory, ___transport); + getStatus_call method_call = new getStatus_call(sessionId, jobId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1398,25 +1024,14 @@ public class RemoteInterpreterService { public static class getStatus_call extends org.apache.thrift.async.TAsyncMethodCall { private String sessionId; private String jobId; - - public getStatus_call( - String sessionId, - String jobId, - 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 { + public getStatus_call(String sessionId, String jobId, 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.sessionId = sessionId; this.jobId = jobId; } - public void write_args(org.apache.thrift.protocol.TProtocol prot) - throws org.apache.thrift.TException { - prot.writeMessageBegin( - new org.apache.thrift.protocol.TMessage( - "getStatus", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getStatus", org.apache.thrift.protocol.TMessageType.CALL, 0)); getStatus_args args = new getStatus_args(); args.setSessionId(sessionId); args.setJobId(jobId); @@ -1428,38 +1043,26 @@ public class RemoteInterpreterService { 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); + 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_getStatus(); } } - public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - resourcePoolGetAll_call method_call = - new resourcePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport); + resourcePoolGetAll_call method_call = new resourcePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class resourcePoolGetAll_call extends org.apache.thrift.async.TAsyncMethodCall { - public resourcePoolGetAll_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 { + public resourcePoolGetAll_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( - "resourcePoolGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0)); + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourcePoolGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0)); resourcePoolGetAll_args args = new resourcePoolGetAll_args(); args.write(prot); prot.writeMessageEnd(); @@ -1469,30 +1072,15 @@ public class RemoteInterpreterService { 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); + 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_resourcePoolGetAll(); } } - public void resourceGet( - String sessionId, - String paragraphId, - String resourceName, - org.apache.thrift.async.AsyncMethodCallback resultHandler) - throws org.apache.thrift.TException { + public void resourceGet(String sessionId, String paragraphId, String resourceName, org.apache.thrift.asy
<TRUNCATED>
