You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by zj...@apache.org on 2018/06/15 01:09:59 UTC
[04/13] zeppelin git commit: ZEPPELIN-2035. BI directional RPC
framework between ZeppelinServer and InterpreterProcess on top of thrift
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>