http://git-wip-us.apache.org/repos/asf/zeppelin/blob/7af86168/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 37bf0c4..b34ba15 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 @@ -16,7 +16,7 @@ * limitations under the License. */ /** - * Autogenerated by Thrift Compiler (0.9.3) + * Autogenerated by Thrift Compiler (0.9.2) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated @@ -51,56 +51,48 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2018-05-22") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2018-5-29") public class RemoteInterpreterService { public interface Iface { - public void createInterpreter(String intpGroupId, String sessionKey, 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 sessionKey, String className) throws org.apache.thrift.TException; + public void open(String sessionId, String className) throws org.apache.thrift.TException; - public void close(String sessionKey, String className) throws org.apache.thrift.TException; + public void close(String sessionId, String className) throws org.apache.thrift.TException; - public RemoteInterpreterResult interpret(String sessionKey, 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 sessionKey, 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 sessionKey, 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 sessionKey, String className) throws org.apache.thrift.TException; + public String getFormType(String sessionId, String className) throws org.apache.thrift.TException; - public List<InterpreterCompletion> completion(String sessionKey, 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; - public String getStatus(String sessionKey, String jobId) throws org.apache.thrift.TException; - - public RemoteInterpreterEvent getEvent() throws org.apache.thrift.TException; - - public void resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException; - - public void resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException; - - public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException; + public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException; public List<String> resourcePoolGetAll() throws org.apache.thrift.TException; - public ByteBuffer resourceGet(String sessionKey, 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 sessionKey, 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 sessionKey, 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 sessionKey, 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 sessionKey, 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 sessionKey, 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 sessionKey, 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; @@ -112,51 +104,43 @@ public class RemoteInterpreterService { public interface AsyncIface { - public void createInterpreter(String intpGroupId, String sessionKey, 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; - public void open(String sessionKey, 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; - public void close(String sessionKey, 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 sessionKey, 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; - public void cancel(String sessionKey, 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; - public void getProgress(String sessionKey, 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 sessionKey, 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; - public void completion(String sessionKey, 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; public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void getStatus(String sessionKey, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void resourcePoolResponseGetAll(List<String> resources, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void resourceResponseGet(String resourceId, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object, 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 sessionKey, 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.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - public void resourceRemove(String sessionKey, 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 sessionKey, String paragraphId, String resourceName, String invokeMessage, 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 sessionKey, String paragraphId, String object, 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 sessionKey, 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 sessionKey, String paragraphId, 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 sessionKey, String paragraphId, 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; @@ -186,17 +170,17 @@ public class RemoteInterpreterService { super(iprot, oprot); } - public void createInterpreter(String intpGroupId, String sessionKey, 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, sessionKey, className, properties, userName); + send_createInterpreter(intpGroupId, sessionId, className, properties, userName); recv_createInterpreter(); } - public void send_createInterpreter(String intpGroupId, String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setProperties(properties); args.setUserName(userName); @@ -210,16 +194,16 @@ public class RemoteInterpreterService { return; } - public void open(String sessionKey, String className) throws org.apache.thrift.TException + public void open(String sessionId, String className) throws org.apache.thrift.TException { - send_open(sessionKey, className); + send_open(sessionId, className); recv_open(); } - public void send_open(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); sendBase("open", args); } @@ -231,16 +215,16 @@ public class RemoteInterpreterService { return; } - public void close(String sessionKey, String className) throws org.apache.thrift.TException + public void close(String sessionId, String className) throws org.apache.thrift.TException { - send_close(sessionKey, className); + send_close(sessionId, className); recv_close(); } - public void send_close(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); sendBase("close", args); } @@ -252,16 +236,16 @@ public class RemoteInterpreterService { return; } - public RemoteInterpreterResult interpret(String sessionKey, 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(sessionKey, className, st, interpreterContext); + send_interpret(sessionId, className, st, interpreterContext); return recv_interpret(); } - public void send_interpret(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setSt(st); args.setInterpreterContext(interpreterContext); @@ -278,16 +262,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "interpret failed: unknown result"); } - public void cancel(String sessionKey, 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(sessionKey, className, interpreterContext); + send_cancel(sessionId, className, interpreterContext); recv_cancel(); } - public void send_cancel(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setInterpreterContext(interpreterContext); sendBase("cancel", args); @@ -300,16 +284,16 @@ public class RemoteInterpreterService { return; } - public int getProgress(String sessionKey, 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(sessionKey, className, interpreterContext); + send_getProgress(sessionId, className, interpreterContext); return recv_getProgress(); } - public void send_getProgress(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setInterpreterContext(interpreterContext); sendBase("getProgress", args); @@ -325,16 +309,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getProgress failed: unknown result"); } - public String getFormType(String sessionKey, String className) throws org.apache.thrift.TException + public String getFormType(String sessionId, String className) throws org.apache.thrift.TException { - send_getFormType(sessionKey, className); + send_getFormType(sessionId, className); return recv_getFormType(); } - public void send_getFormType(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); sendBase("getFormType", args); } @@ -349,16 +333,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getFormType failed: unknown result"); } - public List<InterpreterCompletion> completion(String sessionKey, 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(sessionKey, className, buf, cursor, interpreterContext); + send_completion(sessionId, className, buf, cursor, interpreterContext); return recv_completion(); } - public void send_completion(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setBuf(buf); args.setCursor(cursor); @@ -395,16 +379,16 @@ public class RemoteInterpreterService { return; } - public String getStatus(String sessionKey, String jobId) throws org.apache.thrift.TException + public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException { - send_getStatus(sessionKey, jobId); + send_getStatus(sessionId, jobId); return recv_getStatus(); } - public void send_getStatus(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setJobId(jobId); sendBase("getStatus", args); } @@ -419,90 +403,6 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getStatus failed: unknown result"); } - public RemoteInterpreterEvent getEvent() throws org.apache.thrift.TException - { - send_getEvent(); - return recv_getEvent(); - } - - public void send_getEvent() throws org.apache.thrift.TException - { - getEvent_args args = new getEvent_args(); - sendBase("getEvent", args); - } - - public RemoteInterpreterEvent recv_getEvent() throws org.apache.thrift.TException - { - getEvent_result result = new getEvent_result(); - receiveBase(result, "getEvent"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getEvent failed: unknown result"); - } - - public void resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException - { - send_resourcePoolResponseGetAll(resources); - recv_resourcePoolResponseGetAll(); - } - - public void send_resourcePoolResponseGetAll(List<String> resources) throws org.apache.thrift.TException - { - resourcePoolResponseGetAll_args args = new resourcePoolResponseGetAll_args(); - args.setResources(resources); - sendBase("resourcePoolResponseGetAll", args); - } - - public void recv_resourcePoolResponseGetAll() throws org.apache.thrift.TException - { - resourcePoolResponseGetAll_result result = new resourcePoolResponseGetAll_result(); - receiveBase(result, "resourcePoolResponseGetAll"); - return; - } - - public void resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException - { - send_resourceResponseGet(resourceId, object); - recv_resourceResponseGet(); - } - - public void send_resourceResponseGet(String resourceId, ByteBuffer object) throws org.apache.thrift.TException - { - resourceResponseGet_args args = new resourceResponseGet_args(); - args.setResourceId(resourceId); - args.setObject(object); - sendBase("resourceResponseGet", args); - } - - public void recv_resourceResponseGet() throws org.apache.thrift.TException - { - resourceResponseGet_result result = new resourceResponseGet_result(); - receiveBase(result, "resourceResponseGet"); - return; - } - - public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException - { - send_resourceResponseInvokeMethod(invokeMessage, object); - recv_resourceResponseInvokeMethod(); - } - - public void send_resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object) throws org.apache.thrift.TException - { - resourceResponseInvokeMethod_args args = new resourceResponseInvokeMethod_args(); - args.setInvokeMessage(invokeMessage); - args.setObject(object); - sendBase("resourceResponseInvokeMethod", args); - } - - public void recv_resourceResponseInvokeMethod() throws org.apache.thrift.TException - { - resourceResponseInvokeMethod_result result = new resourceResponseInvokeMethod_result(); - receiveBase(result, "resourceResponseInvokeMethod"); - return; - } - public List<String> resourcePoolGetAll() throws org.apache.thrift.TException { send_resourcePoolGetAll(); @@ -525,16 +425,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourcePoolGetAll failed: unknown result"); } - public ByteBuffer resourceGet(String sessionKey, 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(sessionKey, paragraphId, resourceName); + send_resourceGet(sessionId, paragraphId, resourceName); return recv_resourceGet(); } - public void send_resourceGet(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); sendBase("resourceGet", args); @@ -550,16 +450,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceGet failed: unknown result"); } - public boolean resourceRemove(String sessionKey, 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(sessionKey, paragraphId, resourceName); + send_resourceRemove(sessionId, paragraphId, resourceName); return recv_resourceRemove(); } - public void send_resourceRemove(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); sendBase("resourceRemove", args); @@ -575,16 +475,16 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceRemove failed: unknown result"); } - public ByteBuffer resourceInvokeMethod(String sessionKey, 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(sessionKey, paragraphId, resourceName, invokeMessage); + send_resourceInvokeMethod(sessionId, paragraphId, resourceName, invokeMessage); return recv_resourceInvokeMethod(); } - public void send_resourceInvokeMethod(String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); args.setInvokeMessage(invokeMessage); @@ -601,17 +501,17 @@ public class RemoteInterpreterService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceInvokeMethod failed: unknown result"); } - public void angularObjectUpdate(String name, String sessionKey, 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, sessionKey, paragraphId, object); + send_angularObjectUpdate(name, sessionId, paragraphId, object); recv_angularObjectUpdate(); } - public void send_angularObjectUpdate(String name, String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setObject(object); sendBase("angularObjectUpdate", args); @@ -624,17 +524,17 @@ public class RemoteInterpreterService { return; } - public void angularObjectAdd(String name, String sessionKey, 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, sessionKey, paragraphId, object); + send_angularObjectAdd(name, sessionId, paragraphId, object); recv_angularObjectAdd(); } - public void send_angularObjectAdd(String name, String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setObject(object); sendBase("angularObjectAdd", args); @@ -647,17 +547,17 @@ public class RemoteInterpreterService { return; } - public void angularObjectRemove(String name, String sessionKey, String paragraphId) throws org.apache.thrift.TException + public void angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException { - send_angularObjectRemove(name, sessionKey, paragraphId); + send_angularObjectRemove(name, sessionId, paragraphId); recv_angularObjectRemove(); } - public void send_angularObjectRemove(String name, String sessionKey, 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); sendBase("angularObjectRemove", args); } @@ -689,18 +589,18 @@ public class RemoteInterpreterService { return; } - public RemoteApplicationResult loadApplication(String applicationInstanceId, String packageInfo, String sessionKey, 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, sessionKey, paragraphId); + send_loadApplication(applicationInstanceId, packageInfo, sessionId, paragraphId); return recv_loadApplication(); } - public void send_loadApplication(String applicationInstanceId, String packageInfo, String sessionKey, 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); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); sendBase("loadApplication", args); } @@ -799,23 +699,23 @@ public class RemoteInterpreterService { super(protocolFactory, clientManager, transport); } - public void createInterpreter(String intpGroupId, String sessionKey, 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, sessionKey, 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); } public static class createInterpreter_call extends org.apache.thrift.async.TAsyncMethodCall { private String intpGroupId; - private String sessionKey; + private String sessionId; private String className; private Map<String,String> properties; private String userName; - public createInterpreter_call(String intpGroupId, String sessionKey, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.className = className; this.properties = properties; this.userName = userName; @@ -825,7 +725,7 @@ public class RemoteInterpreterService { 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setProperties(properties); args.setUserName(userName); @@ -843,26 +743,26 @@ public class RemoteInterpreterService { } } - public void open(String sessionKey, 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(sessionKey, 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); } public static class open_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; - public open_call(String sessionKey, 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.sessionKey = sessionKey; + 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)); open_args args = new open_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.write(prot); prot.writeMessageEnd(); @@ -878,26 +778,26 @@ public class RemoteInterpreterService { } } - public void close(String sessionKey, 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(sessionKey, 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); } public static class close_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; - public close_call(String sessionKey, 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.sessionKey = sessionKey; + 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)); close_args args = new close_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.write(prot); prot.writeMessageEnd(); @@ -913,21 +813,21 @@ public class RemoteInterpreterService { } } - public void interpret(String sessionKey, 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(sessionKey, 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); } public static class interpret_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; private String st; private RemoteInterpreterContext interpreterContext; - public interpret_call(String sessionKey, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.className = className; this.st = st; this.interpreterContext = interpreterContext; @@ -936,7 +836,7 @@ public class RemoteInterpreterService { 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setSt(st); args.setInterpreterContext(interpreterContext); @@ -954,20 +854,20 @@ public class RemoteInterpreterService { } } - public void cancel(String sessionKey, 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(sessionKey, 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); } public static class cancel_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; private RemoteInterpreterContext interpreterContext; - public cancel_call(String sessionKey, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.className = className; this.interpreterContext = interpreterContext; } @@ -975,7 +875,7 @@ public class RemoteInterpreterService { 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setInterpreterContext(interpreterContext); args.write(prot); @@ -992,20 +892,20 @@ public class RemoteInterpreterService { } } - public void getProgress(String sessionKey, 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(sessionKey, 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); } public static class getProgress_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; private RemoteInterpreterContext interpreterContext; - public getProgress_call(String sessionKey, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.className = className; this.interpreterContext = interpreterContext; } @@ -1013,7 +913,7 @@ public class RemoteInterpreterService { 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setInterpreterContext(interpreterContext); args.write(prot); @@ -1030,26 +930,26 @@ public class RemoteInterpreterService { } } - public void getFormType(String sessionKey, 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(sessionKey, 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); } public static class getFormType_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; - public getFormType_call(String sessionKey, 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.sessionKey = sessionKey; + 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)); getFormType_args args = new getFormType_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.write(prot); prot.writeMessageEnd(); @@ -1065,22 +965,22 @@ public class RemoteInterpreterService { } } - public void completion(String sessionKey, 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(sessionKey, 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); } public static class completion_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String className; private String buf; private int cursor; private RemoteInterpreterContext interpreterContext; - public completion_call(String sessionKey, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.className = className; this.buf = buf; this.cursor = cursor; @@ -1090,7 +990,7 @@ public class RemoteInterpreterService { 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.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setClassName(className); args.setBuf(buf); args.setCursor(cursor); @@ -1138,26 +1038,26 @@ public class RemoteInterpreterService { } } - public void getStatus(String sessionKey, 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(sessionKey, 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); } public static class getStatus_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String jobId; - public getStatus_call(String sessionKey, 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.sessionKey = sessionKey; + 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)); getStatus_args args = new getStatus_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setJobId(jobId); args.write(prot); prot.writeMessageEnd(); @@ -1173,137 +1073,6 @@ public class RemoteInterpreterService { } } - public void getEvent(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getEvent_call method_call = new getEvent_call(resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getEvent_call extends org.apache.thrift.async.TAsyncMethodCall { - public getEvent_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("getEvent", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getEvent_args args = new getEvent_args(); - args.write(prot); - prot.writeMessageEnd(); - } - - public RemoteInterpreterEvent 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_getEvent(); - } - } - - public void resourcePoolResponseGetAll(List<String> resources, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - resourcePoolResponseGetAll_call method_call = new resourcePoolResponseGetAll_call(resources, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class resourcePoolResponseGetAll_call extends org.apache.thrift.async.TAsyncMethodCall { - private List<String> resources; - public resourcePoolResponseGetAll_call(List<String> resources, 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.resources = resources; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourcePoolResponseGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0)); - resourcePoolResponseGetAll_args args = new resourcePoolResponseGetAll_args(); - args.setResources(resources); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - (new Client(prot)).recv_resourcePoolResponseGetAll(); - } - } - - public void resourceResponseGet(String resourceId, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - resourceResponseGet_call method_call = new resourceResponseGet_call(resourceId, object, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class resourceResponseGet_call extends org.apache.thrift.async.TAsyncMethodCall { - private String resourceId; - private ByteBuffer object; - public resourceResponseGet_call(String resourceId, ByteBuffer object, 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.resourceId = resourceId; - this.object = object; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceResponseGet", org.apache.thrift.protocol.TMessageType.CALL, 0)); - resourceResponseGet_args args = new resourceResponseGet_args(); - args.setResourceId(resourceId); - args.setObject(object); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - (new Client(prot)).recv_resourceResponseGet(); - } - } - - public void resourceResponseInvokeMethod(String invokeMessage, ByteBuffer object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - resourceResponseInvokeMethod_call method_call = new resourceResponseInvokeMethod_call(invokeMessage, object, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class resourceResponseInvokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall { - private String invokeMessage; - private ByteBuffer object; - public resourceResponseInvokeMethod_call(String invokeMessage, ByteBuffer object, 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.invokeMessage = invokeMessage; - this.object = object; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceResponseInvokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0)); - resourceResponseInvokeMethod_args args = new resourceResponseInvokeMethod_args(); - args.setInvokeMessage(invokeMessage); - args.setObject(object); - args.write(prot); - prot.writeMessageEnd(); - } - - public void getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - (new Client(prot)).recv_resourceResponseInvokeMethod(); - } - } - 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); @@ -1333,20 +1102,20 @@ public class RemoteInterpreterService { } } - public void resourceGet(String sessionKey, 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.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); - resourceGet_call method_call = new resourceGet_call(sessionKey, paragraphId, resourceName, resultHandler, this, ___protocolFactory, ___transport); + resourceGet_call method_call = new resourceGet_call(sessionId, paragraphId, resourceName, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class resourceGet_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String paragraphId; private String resourceName; - public resourceGet_call(String sessionKey, String paragraphId, String resourceName, 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 resourceGet_call(String sessionId, String paragraphId, String resourceName, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; this.resourceName = resourceName; } @@ -1354,7 +1123,7 @@ public class RemoteInterpreterService { public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceGet", org.apache.thrift.protocol.TMessageType.CALL, 0)); resourceGet_args args = new resourceGet_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); args.write(prot); @@ -1371,20 +1140,20 @@ public class RemoteInterpreterService { } } - public void resourceRemove(String sessionKey, 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 { checkReady(); - resourceRemove_call method_call = new resourceRemove_call(sessionKey, paragraphId, resourceName, resultHandler, this, ___protocolFactory, ___transport); + resourceRemove_call method_call = new resourceRemove_call(sessionId, paragraphId, resourceName, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class resourceRemove_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String paragraphId; private String resourceName; - public resourceRemove_call(String sessionKey, String paragraphId, String resourceName, 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 resourceRemove_call(String sessionId, String paragraphId, String resourceName, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; this.resourceName = resourceName; } @@ -1392,7 +1161,7 @@ public class RemoteInterpreterService { public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceRemove", org.apache.thrift.protocol.TMessageType.CALL, 0)); resourceRemove_args args = new resourceRemove_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); args.write(prot); @@ -1409,21 +1178,21 @@ public class RemoteInterpreterService { } } - public void resourceInvokeMethod(String sessionKey, String paragraphId, String resourceName, String invokeMessage, 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 { checkReady(); - resourceInvokeMethod_call method_call = new resourceInvokeMethod_call(sessionKey, paragraphId, resourceName, invokeMessage, resultHandler, this, ___protocolFactory, ___transport); + resourceInvokeMethod_call method_call = new resourceInvokeMethod_call(sessionId, paragraphId, resourceName, invokeMessage, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class resourceInvokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall { - private String sessionKey; + private String sessionId; private String paragraphId; private String resourceName; private String invokeMessage; - public resourceInvokeMethod_call(String sessionKey, String paragraphId, String resourceName, String invokeMessage, 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 resourceInvokeMethod_call(String sessionId, String paragraphId, String resourceName, String invokeMessage, 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.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; this.resourceName = resourceName; this.invokeMessage = invokeMessage; @@ -1432,7 +1201,7 @@ public class RemoteInterpreterService { public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourceInvokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0)); resourceInvokeMethod_args args = new resourceInvokeMethod_args(); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setResourceName(resourceName); args.setInvokeMessage(invokeMessage); @@ -1450,22 +1219,22 @@ public class RemoteInterpreterService { } } - public void angularObjectUpdate(String name, String sessionKey, String paragraphId, String object, 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 { checkReady(); - angularObjectUpdate_call method_call = new angularObjectUpdate_call(name, sessionKey, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); + angularObjectUpdate_call method_call = new angularObjectUpdate_call(name, sessionId, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class angularObjectUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - private String sessionKey; + private String sessionId; private String paragraphId; private String object; - public angularObjectUpdate_call(String name, String sessionKey, String paragraphId, String object, 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 angularObjectUpdate_call(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; - this.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; this.object = object; } @@ -1474,7 +1243,7 @@ public class RemoteInterpreterService { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("angularObjectUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); angularObjectUpdate_args args = new angularObjectUpdate_args(); args.setName(name); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setObject(object); args.write(prot); @@ -1491,22 +1260,22 @@ public class RemoteInterpreterService { } } - public void angularObjectAdd(String name, String sessionKey, 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 { checkReady(); - angularObjectAdd_call method_call = new angularObjectAdd_call(name, sessionKey, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); + angularObjectAdd_call method_call = new angularObjectAdd_call(name, sessionId, paragraphId, object, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class angularObjectAdd_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - private String sessionKey; + private String sessionId; private String paragraphId; private String object; - public angularObjectAdd_call(String name, String sessionKey, String paragraphId, String object, 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 angularObjectAdd_call(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; - this.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; this.object = object; } @@ -1515,7 +1284,7 @@ public class RemoteInterpreterService { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("angularObjectAdd", org.apache.thrift.protocol.TMessageType.CALL, 0)); angularObjectAdd_args args = new angularObjectAdd_args(); args.setName(name); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.setObject(object); args.write(prot); @@ -1532,21 +1301,21 @@ public class RemoteInterpreterService { } } - public void angularObjectRemove(String name, String sessionKey, String paragraphId, 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 { checkReady(); - angularObjectRemove_call method_call = new angularObjectRemove_call(name, sessionKey, paragraphId, resultHandler, this, ___protocolFactory, ___transport); + angularObjectRemove_call method_call = new angularObjectRemove_call(name, sessionId, paragraphId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class angularObjectRemove_call extends org.apache.thrift.async.TAsyncMethodCall { private String name; - private String sessionKey; + private String sessionId; private String paragraphId; - public angularObjectRemove_call(String name, String sessionKey, String paragraphId, 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 angularObjectRemove_call(String name, String sessionId, String paragraphId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.name = name; - this.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; } @@ -1554,7 +1323,7 @@ public class RemoteInterpreterService { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("angularObjectRemove", org.apache.thrift.protocol.TMessageType.CALL, 0)); angularObjectRemove_args args = new angularObjectRemove_args(); args.setName(name); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.write(prot); prot.writeMessageEnd(); @@ -1602,9 +1371,9 @@ public class RemoteInterpreterService { } } - public void loadApplication(String applicationInstanceId, String packageInfo, String sessionKey, String paragraphId, 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 { checkReady(); - loadApplication_call method_call = new loadApplication_call(applicationInstanceId, packageInfo, sessionKey, paragraphId, resultHandler, this, ___protocolFactory, ___transport); + loadApplication_call method_call = new loadApplication_call(applicationInstanceId, packageInfo, sessionId, paragraphId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1612,13 +1381,13 @@ public class RemoteInterpreterService { public static class loadApplication_call extends org.apache.thrift.async.TAsyncMethodCall { private String applicationInstanceId; private String packageInfo; - private String sessionKey; + private String sessionId; private String paragraphId; - public loadApplication_call(String applicationInstanceId, String packageInfo, String sessionKey, String paragraphId, 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 loadApplication_call(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId, 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.applicationInstanceId = applicationInstanceId; this.packageInfo = packageInfo; - this.sessionKey = sessionKey; + this.sessionId = sessionId; this.paragraphId = paragraphId; } @@ -1627,7 +1396,7 @@ public class RemoteInterpreterService { loadApplication_args args = new loadApplication_args(); args.setApplicationInstanceId(applicationInstanceId); args.setPackageInfo(packageInfo); - args.setSessionKey(sessionKey); + args.setSessionId(sessionId); args.setParagraphId(paragraphId); args.write(prot); prot.writeMessageEnd(); @@ -1762,10 +1531,6 @@ public class RemoteInterpreterService { processMap.put("completion", new completion()); processMap.put("shutdown", new shutdown()); processMap.put("getStatus", new getStatus()); - processMap.put("getEvent", new getEvent()); - processMap.put("resourcePoolResponseGetAll", new resourcePoolResponseGetAll()); - processMap.put("resourceResponseGet", new resourceResponseGet()); - processMap.put("resourceResponseInvokeMethod", new resourceResponseInvokeMethod()); processMap.put("resourcePoolGetAll", new resourcePoolGetAll()); processMap.put("resourceGet", new resourceGet()); processMap.put("resourceRemove", new resourceRemove()); @@ -1796,7 +1561,7 @@ public class RemoteInterpreterService { public createInterpreter_result getResult(I iface, createInterpreter_args args) throws org.apache.thrift.TException { createInterpreter_result result = new createInterpreter_result(); - iface.createInterpreter(args.intpGroupId, args.sessionKey, args.className, args.properties, args.userName); + iface.createInterpreter(args.intpGroupId, args.sessionId, args.className, args.properties, args.userName); return result; } } @@ -1816,7 +1581,7 @@ public class RemoteInterpreterService { public open_result getResult(I iface, open_args args) throws org.apache.thrift.TException { open_result result = new open_result(); - iface.open(args.sessionKey, args.className); + iface.open(args.sessionId, args.className); return result; } } @@ -1836,7 +1601,7 @@ public class RemoteInterpreterService { public close_result getResult(I iface, close_args args) throws org.apache.thrift.TException { close_result result = new close_result(); - iface.close(args.sessionKey, args.className); + iface.close(args.sessionId, args.className); return result; } } @@ -1856,7 +1621,7 @@ public class RemoteInterpreterService { public interpret_result getResult(I iface, interpret_args args) throws org.apache.thrift.TException { interpret_result result = new interpret_result(); - result.success = iface.interpret(args.sessionKey, args.className, args.st, args.interpreterContext); + result.success = iface.interpret(args.sessionId, args.className, args.st, args.interpreterContext); return result; } } @@ -1876,7 +1641,7 @@ public class RemoteInterpreterService { public cancel_result getResult(I iface, cancel_args args) throws org.apache.thrift.TException { cancel_result result = new cancel_
<TRUNCATED>
