You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by jo...@apache.org on 2018/08/26 04:44:04 UTC
[21/49] zeppelin git commit: [ZEPPELIN-3740] Adopt
`google-java-format` and `fmt-maven-plugin`
http://git-wip-us.apache.org/repos/asf/zeppelin/blob/55f6c91c/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 3dd8875..d1c9d08 100644
--- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java
+++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java
@@ -1,52 +1,46 @@
/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>http://www.apache.org/licenses/LICENSE-2.0
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
+ * <p>Unless required by applicable law or agreed to in writing, software distributed under the
+ * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ * express or implied. See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* Autogenerated by Thrift Compiler (0.9.2)
*
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
+ * <p>DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *
+ * @generated
*/
package org.apache.zeppelin.interpreter.thrift;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.BitSet;
+import java.util.Collections;
+import java.util.EnumMap;
+import java.util.EnumSet;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.annotation.Generated;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
-
import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.async.AsyncMethodCallback;
import org.apache.thrift.server.AbstractNonblockingServer.*;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -56,21 +50,40 @@ public class RemoteInterpreterService {
public interface Iface {
- public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException;
+ public void createInterpreter(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName)
+ throws org.apache.thrift.TException;
public void open(String sessionId, String className) throws org.apache.thrift.TException;
public void close(String sessionId, String className) throws org.apache.thrift.TException;
- public RemoteInterpreterResult interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException;
+ public RemoteInterpreterResult interpret(
+ String sessionId, String className, String st, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException;
- public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException;
+ public void cancel(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException;
- public int getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException;
+ public int getProgress(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException;
- public String getFormType(String sessionId, String className) throws org.apache.thrift.TException;
+ public String getFormType(String sessionId, String className)
+ throws org.apache.thrift.TException;
- public List<InterpreterCompletion> completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException;
+ public List<InterpreterCompletion> completion(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException;
public void shutdown() throws org.apache.thrift.TException;
@@ -78,102 +91,216 @@ public class RemoteInterpreterService {
public List<String> resourcePoolGetAll() throws org.apache.thrift.TException;
- public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException;
+ public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException;
- public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException;
+ public boolean resourceRemove(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException;
- public ByteBuffer resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException;
+ public ByteBuffer resourceInvokeMethod(
+ String sessionId, String paragraphId, String resourceName, String invokeMessage)
+ throws org.apache.thrift.TException;
- public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException;
+ public void angularObjectUpdate(
+ String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException;
- public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException;
+ public void angularObjectAdd(String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException;
- public void angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException;
+ public void angularObjectRemove(String name, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException;
public void angularRegistryPush(String registry) throws org.apache.thrift.TException;
- public RemoteApplicationResult loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException;
+ public RemoteApplicationResult loadApplication(
+ String applicationInstanceId, String packageInfo, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException;
- public RemoteApplicationResult unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException;
-
- public RemoteApplicationResult runApplication(String applicationInstanceId) throws org.apache.thrift.TException;
+ public RemoteApplicationResult unloadApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException;
+ public RemoteApplicationResult runApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException;
}
public interface AsyncIface {
- public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void open(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void close(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void getFormType(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void getStatus(String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void resourceGet(String sessionId, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void resourceRemove(String sessionId, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void angularObjectAdd(String name, String sessionId, String paragraphId, String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void angularObjectRemove(String name, String sessionId, String paragraphId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void angularRegistryPush(String registry, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void unloadApplication(String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void runApplication(String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
+ public void createInterpreter(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void open(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void close(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void interpret(
+ String sessionId,
+ String className,
+ String st,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void cancel(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void getProgress(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void getFormType(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void completion(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void getStatus(
+ String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void resourceGet(
+ String sessionId,
+ String paragraphId,
+ String resourceName,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void resourceRemove(
+ String sessionId,
+ String paragraphId,
+ String resourceName,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void resourceInvokeMethod(
+ String sessionId,
+ String paragraphId,
+ String resourceName,
+ String invokeMessage,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void angularObjectUpdate(
+ String name,
+ String sessionId,
+ String paragraphId,
+ String object,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void angularObjectAdd(
+ String name,
+ String sessionId,
+ String paragraphId,
+ String object,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void angularObjectRemove(
+ String name,
+ String sessionId,
+ String paragraphId,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void angularRegistryPush(
+ String registry, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void loadApplication(
+ String applicationInstanceId,
+ String packageInfo,
+ String sessionId,
+ String paragraphId,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void unloadApplication(
+ String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void runApplication(
+ String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface {
public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
public Factory() {}
+
public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
- public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+
+ public Client getClient(
+ org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
- public Client(org.apache.thrift.protocol.TProtocol prot)
- {
+ public Client(org.apache.thrift.protocol.TProtocol prot) {
super(prot, prot);
}
- public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ public Client(
+ org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
- public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException
- {
+ public void createInterpreter(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName)
+ throws org.apache.thrift.TException {
send_createInterpreter(intpGroupId, sessionId, className, properties, userName);
recv_createInterpreter();
}
- public void send_createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName) throws org.apache.thrift.TException
- {
+ public void send_createInterpreter(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName)
+ throws org.apache.thrift.TException {
createInterpreter_args args = new createInterpreter_args();
args.setIntpGroupId(intpGroupId);
args.setSessionId(sessionId);
@@ -183,63 +310,58 @@ public class RemoteInterpreterService {
sendBase("createInterpreter", args);
}
- public void recv_createInterpreter() throws org.apache.thrift.TException
- {
+ public void recv_createInterpreter() throws org.apache.thrift.TException {
createInterpreter_result result = new createInterpreter_result();
receiveBase(result, "createInterpreter");
return;
}
- public void open(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public void open(String sessionId, String className) throws org.apache.thrift.TException {
send_open(sessionId, className);
recv_open();
}
- public void send_open(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public void send_open(String sessionId, String className) throws org.apache.thrift.TException {
open_args args = new open_args();
args.setSessionId(sessionId);
args.setClassName(className);
sendBase("open", args);
}
- public void recv_open() throws org.apache.thrift.TException
- {
+ public void recv_open() throws org.apache.thrift.TException {
open_result result = new open_result();
receiveBase(result, "open");
return;
}
- public void close(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public void close(String sessionId, String className) throws org.apache.thrift.TException {
send_close(sessionId, className);
recv_close();
}
- public void send_close(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public void send_close(String sessionId, String className) throws org.apache.thrift.TException {
close_args args = new close_args();
args.setSessionId(sessionId);
args.setClassName(className);
sendBase("close", args);
}
- public void recv_close() throws org.apache.thrift.TException
- {
+ public void recv_close() throws org.apache.thrift.TException {
close_result result = new close_result();
receiveBase(result, "close");
return;
}
- public RemoteInterpreterResult interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public RemoteInterpreterResult interpret(
+ String sessionId, String className, String st, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
send_interpret(sessionId, className, st, interpreterContext);
return recv_interpret();
}
- public void send_interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public void send_interpret(
+ String sessionId, String className, String st, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
interpret_args args = new interpret_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -248,24 +370,27 @@ public class RemoteInterpreterService {
sendBase("interpret", args);
}
- public RemoteInterpreterResult recv_interpret() throws org.apache.thrift.TException
- {
+ public RemoteInterpreterResult recv_interpret() throws org.apache.thrift.TException {
interpret_result result = new interpret_result();
receiveBase(result, "interpret");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "interpret failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "interpret failed: unknown result");
}
- public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public void cancel(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
send_cancel(sessionId, className, interpreterContext);
recv_cancel();
}
- public void send_cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public void send_cancel(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
cancel_args args = new cancel_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -273,21 +398,22 @@ public class RemoteInterpreterService {
sendBase("cancel", args);
}
- public void recv_cancel() throws org.apache.thrift.TException
- {
+ public void recv_cancel() throws org.apache.thrift.TException {
cancel_result result = new cancel_result();
receiveBase(result, "cancel");
return;
}
- public int getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public int getProgress(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
send_getProgress(sessionId, className, interpreterContext);
return recv_getProgress();
}
- public void send_getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public void send_getProgress(
+ String sessionId, String className, RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
getProgress_args args = new getProgress_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -295,48 +421,60 @@ public class RemoteInterpreterService {
sendBase("getProgress", args);
}
- public int recv_getProgress() throws org.apache.thrift.TException
- {
+ public int recv_getProgress() throws org.apache.thrift.TException {
getProgress_result result = new getProgress_result();
receiveBase(result, "getProgress");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getProgress failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "getProgress failed: unknown result");
}
- public String getFormType(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public String getFormType(String sessionId, String className)
+ throws org.apache.thrift.TException {
send_getFormType(sessionId, className);
return recv_getFormType();
}
- public void send_getFormType(String sessionId, String className) throws org.apache.thrift.TException
- {
+ public void send_getFormType(String sessionId, String className)
+ throws org.apache.thrift.TException {
getFormType_args args = new getFormType_args();
args.setSessionId(sessionId);
args.setClassName(className);
sendBase("getFormType", args);
}
- public String recv_getFormType() throws org.apache.thrift.TException
- {
+ public String recv_getFormType() throws org.apache.thrift.TException {
getFormType_result result = new getFormType_result();
receiveBase(result, "getFormType");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getFormType failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "getFormType failed: unknown result");
}
- public List<InterpreterCompletion> completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public List<InterpreterCompletion> completion(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
send_completion(sessionId, className, buf, cursor, interpreterContext);
return recv_completion();
}
- public void send_completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext) throws org.apache.thrift.TException
- {
+ public void send_completion(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext)
+ throws org.apache.thrift.TException {
completion_args args = new completion_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -346,89 +484,85 @@ public class RemoteInterpreterService {
sendBase("completion", args);
}
- public List<InterpreterCompletion> recv_completion() throws org.apache.thrift.TException
- {
+ public List<InterpreterCompletion> recv_completion() throws org.apache.thrift.TException {
completion_result result = new completion_result();
receiveBase(result, "completion");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "completion failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "completion failed: unknown result");
}
- public void shutdown() throws org.apache.thrift.TException
- {
+ public void shutdown() throws org.apache.thrift.TException {
send_shutdown();
recv_shutdown();
}
- public void send_shutdown() throws org.apache.thrift.TException
- {
+ public void send_shutdown() throws org.apache.thrift.TException {
shutdown_args args = new shutdown_args();
sendBase("shutdown", args);
}
- public void recv_shutdown() throws org.apache.thrift.TException
- {
+ public void recv_shutdown() throws org.apache.thrift.TException {
shutdown_result result = new shutdown_result();
receiveBase(result, "shutdown");
return;
}
- public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException
- {
+ public String getStatus(String sessionId, String jobId) throws org.apache.thrift.TException {
send_getStatus(sessionId, jobId);
return recv_getStatus();
}
- public void send_getStatus(String sessionId, String jobId) throws org.apache.thrift.TException
- {
+ public void send_getStatus(String sessionId, String jobId) throws org.apache.thrift.TException {
getStatus_args args = new getStatus_args();
args.setSessionId(sessionId);
args.setJobId(jobId);
sendBase("getStatus", args);
}
- public String recv_getStatus() throws org.apache.thrift.TException
- {
+ public String recv_getStatus() throws org.apache.thrift.TException {
getStatus_result result = new getStatus_result();
receiveBase(result, "getStatus");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getStatus failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "getStatus failed: unknown result");
}
- public List<String> resourcePoolGetAll() throws org.apache.thrift.TException
- {
+ public List<String> resourcePoolGetAll() throws org.apache.thrift.TException {
send_resourcePoolGetAll();
return recv_resourcePoolGetAll();
}
- public void send_resourcePoolGetAll() throws org.apache.thrift.TException
- {
+ public void send_resourcePoolGetAll() throws org.apache.thrift.TException {
resourcePoolGetAll_args args = new resourcePoolGetAll_args();
sendBase("resourcePoolGetAll", args);
}
- public List<String> recv_resourcePoolGetAll() throws org.apache.thrift.TException
- {
+ public List<String> recv_resourcePoolGetAll() throws org.apache.thrift.TException {
resourcePoolGetAll_result result = new resourcePoolGetAll_result();
receiveBase(result, "resourcePoolGetAll");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourcePoolGetAll failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "resourcePoolGetAll failed: unknown result");
}
- public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException
- {
+ public ByteBuffer resourceGet(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException {
send_resourceGet(sessionId, paragraphId, resourceName);
return recv_resourceGet();
}
- public void send_resourceGet(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException
- {
+ public void send_resourceGet(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException {
resourceGet_args args = new resourceGet_args();
args.setSessionId(sessionId);
args.setParagraphId(paragraphId);
@@ -436,24 +570,25 @@ public class RemoteInterpreterService {
sendBase("resourceGet", args);
}
- public ByteBuffer recv_resourceGet() throws org.apache.thrift.TException
- {
+ public ByteBuffer recv_resourceGet() throws org.apache.thrift.TException {
resourceGet_result result = new resourceGet_result();
receiveBase(result, "resourceGet");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceGet failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "resourceGet failed: unknown result");
}
- public boolean resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException
- {
+ public boolean resourceRemove(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException {
send_resourceRemove(sessionId, paragraphId, resourceName);
return recv_resourceRemove();
}
- public void send_resourceRemove(String sessionId, String paragraphId, String resourceName) throws org.apache.thrift.TException
- {
+ public void send_resourceRemove(String sessionId, String paragraphId, String resourceName)
+ throws org.apache.thrift.TException {
resourceRemove_args args = new resourceRemove_args();
args.setSessionId(sessionId);
args.setParagraphId(paragraphId);
@@ -461,24 +596,27 @@ public class RemoteInterpreterService {
sendBase("resourceRemove", args);
}
- public boolean recv_resourceRemove() throws org.apache.thrift.TException
- {
+ public boolean recv_resourceRemove() throws org.apache.thrift.TException {
resourceRemove_result result = new resourceRemove_result();
receiveBase(result, "resourceRemove");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceRemove failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "resourceRemove failed: unknown result");
}
- public ByteBuffer resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException
- {
+ public ByteBuffer resourceInvokeMethod(
+ String sessionId, String paragraphId, String resourceName, String invokeMessage)
+ throws org.apache.thrift.TException {
send_resourceInvokeMethod(sessionId, paragraphId, resourceName, invokeMessage);
return recv_resourceInvokeMethod();
}
- public void send_resourceInvokeMethod(String sessionId, String paragraphId, String resourceName, String invokeMessage) throws org.apache.thrift.TException
- {
+ public void send_resourceInvokeMethod(
+ String sessionId, String paragraphId, String resourceName, String invokeMessage)
+ throws org.apache.thrift.TException {
resourceInvokeMethod_args args = new resourceInvokeMethod_args();
args.setSessionId(sessionId);
args.setParagraphId(paragraphId);
@@ -487,24 +625,27 @@ public class RemoteInterpreterService {
sendBase("resourceInvokeMethod", args);
}
- public ByteBuffer recv_resourceInvokeMethod() throws org.apache.thrift.TException
- {
+ public ByteBuffer recv_resourceInvokeMethod() throws org.apache.thrift.TException {
resourceInvokeMethod_result result = new resourceInvokeMethod_result();
receiveBase(result, "resourceInvokeMethod");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resourceInvokeMethod failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "resourceInvokeMethod failed: unknown result");
}
- public void angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException
- {
+ public void angularObjectUpdate(
+ String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException {
send_angularObjectUpdate(name, sessionId, paragraphId, object);
recv_angularObjectUpdate();
}
- public void send_angularObjectUpdate(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException
- {
+ public void send_angularObjectUpdate(
+ String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException {
angularObjectUpdate_args args = new angularObjectUpdate_args();
args.setName(name);
args.setSessionId(sessionId);
@@ -513,21 +654,21 @@ public class RemoteInterpreterService {
sendBase("angularObjectUpdate", args);
}
- public void recv_angularObjectUpdate() throws org.apache.thrift.TException
- {
+ public void recv_angularObjectUpdate() throws org.apache.thrift.TException {
angularObjectUpdate_result result = new angularObjectUpdate_result();
receiveBase(result, "angularObjectUpdate");
return;
}
- public void angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException
- {
+ public void angularObjectAdd(String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException {
send_angularObjectAdd(name, sessionId, paragraphId, object);
recv_angularObjectAdd();
}
- public void send_angularObjectAdd(String name, String sessionId, String paragraphId, String object) throws org.apache.thrift.TException
- {
+ public void send_angularObjectAdd(
+ String name, String sessionId, String paragraphId, String object)
+ throws org.apache.thrift.TException {
angularObjectAdd_args args = new angularObjectAdd_args();
args.setName(name);
args.setSessionId(sessionId);
@@ -536,21 +677,20 @@ public class RemoteInterpreterService {
sendBase("angularObjectAdd", args);
}
- public void recv_angularObjectAdd() throws org.apache.thrift.TException
- {
+ public void recv_angularObjectAdd() throws org.apache.thrift.TException {
angularObjectAdd_result result = new angularObjectAdd_result();
receiveBase(result, "angularObjectAdd");
return;
}
- public void angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException
- {
+ public void angularObjectRemove(String name, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException {
send_angularObjectRemove(name, sessionId, paragraphId);
recv_angularObjectRemove();
}
- public void send_angularObjectRemove(String name, String sessionId, String paragraphId) throws org.apache.thrift.TException
- {
+ public void send_angularObjectRemove(String name, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException {
angularObjectRemove_args args = new angularObjectRemove_args();
args.setName(name);
args.setSessionId(sessionId);
@@ -558,41 +698,39 @@ public class RemoteInterpreterService {
sendBase("angularObjectRemove", args);
}
- public void recv_angularObjectRemove() throws org.apache.thrift.TException
- {
+ public void recv_angularObjectRemove() throws org.apache.thrift.TException {
angularObjectRemove_result result = new angularObjectRemove_result();
receiveBase(result, "angularObjectRemove");
return;
}
- public void angularRegistryPush(String registry) throws org.apache.thrift.TException
- {
+ public void angularRegistryPush(String registry) throws org.apache.thrift.TException {
send_angularRegistryPush(registry);
recv_angularRegistryPush();
}
- public void send_angularRegistryPush(String registry) throws org.apache.thrift.TException
- {
+ public void send_angularRegistryPush(String registry) throws org.apache.thrift.TException {
angularRegistryPush_args args = new angularRegistryPush_args();
args.setRegistry(registry);
sendBase("angularRegistryPush", args);
}
- public void recv_angularRegistryPush() throws org.apache.thrift.TException
- {
+ public void recv_angularRegistryPush() throws org.apache.thrift.TException {
angularRegistryPush_result result = new angularRegistryPush_result();
receiveBase(result, "angularRegistryPush");
return;
}
- public RemoteApplicationResult loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult loadApplication(
+ String applicationInstanceId, String packageInfo, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException {
send_loadApplication(applicationInstanceId, packageInfo, sessionId, paragraphId);
return recv_loadApplication();
}
- public void send_loadApplication(String applicationInstanceId, String packageInfo, String sessionId, String paragraphId) throws org.apache.thrift.TException
- {
+ public void send_loadApplication(
+ String applicationInstanceId, String packageInfo, String sessionId, String paragraphId)
+ throws org.apache.thrift.TException {
loadApplication_args args = new loadApplication_args();
args.setApplicationInstanceId(applicationInstanceId);
args.setPackageInfo(packageInfo);
@@ -601,83 +739,113 @@ public class RemoteInterpreterService {
sendBase("loadApplication", args);
}
- public RemoteApplicationResult recv_loadApplication() throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult recv_loadApplication() throws org.apache.thrift.TException {
loadApplication_result result = new loadApplication_result();
receiveBase(result, "loadApplication");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "loadApplication failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "loadApplication failed: unknown result");
}
- public RemoteApplicationResult unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult unloadApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException {
send_unloadApplication(applicationInstanceId);
return recv_unloadApplication();
}
- public void send_unloadApplication(String applicationInstanceId) throws org.apache.thrift.TException
- {
+ public void send_unloadApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException {
unloadApplication_args args = new unloadApplication_args();
args.setApplicationInstanceId(applicationInstanceId);
sendBase("unloadApplication", args);
}
- public RemoteApplicationResult recv_unloadApplication() throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult recv_unloadApplication() throws org.apache.thrift.TException {
unloadApplication_result result = new unloadApplication_result();
receiveBase(result, "unloadApplication");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "unloadApplication failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "unloadApplication failed: unknown result");
}
- public RemoteApplicationResult runApplication(String applicationInstanceId) throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult runApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException {
send_runApplication(applicationInstanceId);
return recv_runApplication();
}
- public void send_runApplication(String applicationInstanceId) throws org.apache.thrift.TException
- {
+ public void send_runApplication(String applicationInstanceId)
+ throws org.apache.thrift.TException {
runApplication_args args = new runApplication_args();
args.setApplicationInstanceId(applicationInstanceId);
sendBase("runApplication", args);
}
- public RemoteApplicationResult recv_runApplication() throws org.apache.thrift.TException
- {
+ public RemoteApplicationResult recv_runApplication() throws org.apache.thrift.TException {
runApplication_result result = new runApplication_result();
receiveBase(result, "runApplication");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "runApplication failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "runApplication failed: unknown result");
}
-
}
- public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
- public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
+
+ public static class AsyncClient extends org.apache.thrift.async.TAsyncClient
+ implements AsyncIface {
+ public static class Factory
+ implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
private org.apache.thrift.async.TAsyncClientManager clientManager;
private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
- public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+
+ public Factory(
+ org.apache.thrift.async.TAsyncClientManager clientManager,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
this.clientManager = clientManager;
this.protocolFactory = protocolFactory;
}
- public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+
+ public AsyncClient getAsyncClient(
+ org.apache.thrift.transport.TNonblockingTransport transport) {
return new AsyncClient(protocolFactory, clientManager, transport);
}
}
- public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
+ public AsyncClient(
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.async.TAsyncClientManager clientManager,
+ org.apache.thrift.transport.TNonblockingTransport transport) {
super(protocolFactory, clientManager, transport);
}
- public void createInterpreter(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void createInterpreter(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- createInterpreter_call method_call = new createInterpreter_call(intpGroupId, sessionId, className, properties, userName, resultHandler, this, ___protocolFactory, ___transport);
+ createInterpreter_call method_call =
+ new createInterpreter_call(
+ intpGroupId,
+ sessionId,
+ className,
+ properties,
+ userName,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -686,9 +854,20 @@ public class RemoteInterpreterService {
private String intpGroupId;
private String sessionId;
private String className;
- private Map<String,String> properties;
+ private Map<String, String> properties;
private String userName;
- public createInterpreter_call(String intpGroupId, String sessionId, String className, Map<String,String> properties, String userName, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public createInterpreter_call(
+ String intpGroupId,
+ String sessionId,
+ String className,
+ Map<String, String> properties,
+ String userName,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.intpGroupId = intpGroupId;
this.sessionId = sessionId;
@@ -697,8 +876,11 @@ public class RemoteInterpreterService {
this.userName = userName;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createInterpreter", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "createInterpreter", org.apache.thrift.protocol.TMessageType.CALL, 0));
createInterpreter_args args = new createInterpreter_args();
args.setIntpGroupId(intpGroupId);
args.setSessionId(sessionId);
@@ -713,15 +895,23 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
(new Client(prot)).recv_createInterpreter();
}
}
- public void open(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void open(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- open_call method_call = new open_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
+ open_call method_call =
+ new open_call(
+ sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -729,14 +919,25 @@ public class RemoteInterpreterService {
public static class open_call extends org.apache.thrift.async.TAsyncMethodCall {
private String sessionId;
private String className;
- public open_call(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public open_call(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("open", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "open", org.apache.thrift.protocol.TMessageType.CALL, 0));
open_args args = new open_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -748,15 +949,23 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
(new Client(prot)).recv_open();
}
}
- public void close(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void close(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- close_call method_call = new close_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
+ close_call method_call =
+ new close_call(
+ sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -764,14 +973,25 @@ public class RemoteInterpreterService {
public static class close_call extends org.apache.thrift.async.TAsyncMethodCall {
private String sessionId;
private String className;
- public close_call(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public close_call(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("close", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "close", org.apache.thrift.protocol.TMessageType.CALL, 0));
close_args args = new close_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -783,15 +1003,32 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
(new Client(prot)).recv_close();
}
}
- public void interpret(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void interpret(
+ String sessionId,
+ String className,
+ String st,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- interpret_call method_call = new interpret_call(sessionId, className, st, interpreterContext, resultHandler, this, ___protocolFactory, ___transport);
+ interpret_call method_call =
+ new interpret_call(
+ sessionId,
+ className,
+ st,
+ interpreterContext,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -801,7 +1038,17 @@ public class RemoteInterpreterService {
private String className;
private String st;
private RemoteInterpreterContext interpreterContext;
- public interpret_call(String sessionId, String className, String st, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public interpret_call(
+ String sessionId,
+ String className,
+ String st,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
@@ -809,8 +1056,11 @@ public class RemoteInterpreterService {
this.interpreterContext = interpreterContext;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("interpret", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "interpret", org.apache.thrift.protocol.TMessageType.CALL, 0));
interpret_args args = new interpret_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -824,15 +1074,30 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_interpret();
}
}
- public void cancel(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void cancel(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- cancel_call method_call = new cancel_call(sessionId, className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport);
+ cancel_call method_call =
+ new cancel_call(
+ sessionId,
+ className,
+ interpreterContext,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -841,15 +1106,27 @@ public class RemoteInterpreterService {
private String sessionId;
private String className;
private RemoteInterpreterContext interpreterContext;
- public cancel_call(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public cancel_call(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
this.interpreterContext = interpreterContext;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancel", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "cancel", org.apache.thrift.protocol.TMessageType.CALL, 0));
cancel_args args = new cancel_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -862,15 +1139,30 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
(new Client(prot)).recv_cancel();
}
}
- public void getProgress(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void getProgress(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- getProgress_call method_call = new getProgress_call(sessionId, className, interpreterContext, resultHandler, this, ___protocolFactory, ___transport);
+ getProgress_call method_call =
+ new getProgress_call(
+ sessionId,
+ className,
+ interpreterContext,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -879,15 +1171,27 @@ public class RemoteInterpreterService {
private String sessionId;
private String className;
private RemoteInterpreterContext interpreterContext;
- public getProgress_call(String sessionId, String className, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public getProgress_call(
+ String sessionId,
+ String className,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
this.interpreterContext = interpreterContext;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getProgress", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "getProgress", org.apache.thrift.protocol.TMessageType.CALL, 0));
getProgress_args args = new getProgress_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -900,15 +1204,23 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_getProgress();
}
}
- public void getFormType(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void getFormType(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- getFormType_call method_call = new getFormType_call(sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
+ getFormType_call method_call =
+ new getFormType_call(
+ sessionId, className, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -916,14 +1228,25 @@ public class RemoteInterpreterService {
public static class getFormType_call extends org.apache.thrift.async.TAsyncMethodCall {
private String sessionId;
private String className;
- public getFormType_call(String sessionId, String className, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public getFormType_call(
+ String sessionId,
+ String className,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getFormType", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "getFormType", org.apache.thrift.protocol.TMessageType.CALL, 0));
getFormType_args args = new getFormType_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -935,15 +1258,34 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_getFormType();
}
}
- public void completion(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void completion(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- completion_call method_call = new completion_call(sessionId, className, buf, cursor, interpreterContext, resultHandler, this, ___protocolFactory, ___transport);
+ completion_call method_call =
+ new completion_call(
+ sessionId,
+ className,
+ buf,
+ cursor,
+ interpreterContext,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -954,7 +1296,18 @@ public class RemoteInterpreterService {
private String buf;
private int cursor;
private RemoteInterpreterContext interpreterContext;
- public completion_call(String sessionId, String className, String buf, int cursor, RemoteInterpreterContext interpreterContext, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public completion_call(
+ String sessionId,
+ String className,
+ String buf,
+ int cursor,
+ RemoteInterpreterContext interpreterContext,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.className = className;
@@ -963,8 +1316,11 @@ public class RemoteInterpreterService {
this.interpreterContext = interpreterContext;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("completion", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "completion", org.apache.thrift.protocol.TMessageType.CALL, 0));
completion_args args = new completion_args();
args.setSessionId(sessionId);
args.setClassName(className);
@@ -979,26 +1335,38 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_completion();
}
}
- public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void shutdown(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- shutdown_call method_call = new shutdown_call(resultHandler, this, ___protocolFactory, ___transport);
+ shutdown_call method_call =
+ new shutdown_call(resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class shutdown_call extends org.apache.thrift.async.TAsyncMethodCall {
- public shutdown_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public shutdown_call(
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shutdown", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "shutdown", org.apache.thrift.protocol.TMessageType.CALL, 0));
shutdown_args args = new shutdown_args();
args.write(prot);
prot.writeMessageEnd();
@@ -1008,15 +1376,21 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
(new Client(prot)).recv_shutdown();
}
}
- public void getStatus(String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void getStatus(
+ String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- getStatus_call method_call = new getStatus_call(sessionId, jobId, resultHandler, this, ___protocolFactory, ___transport);
+ getStatus_call method_call =
+ new getStatus_call(
+ sessionId, jobId, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -1024,14 +1398,25 @@ public class RemoteInterpreterService {
public static class getStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
private String sessionId;
private String jobId;
- public getStatus_call(String sessionId, String jobId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+
+ public getStatus_call(
+ String sessionId,
+ String jobId,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.sessionId = sessionId;
this.jobId = jobId;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "getStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
getStatus_args args = new getStatus_args();
args.setSessionId(sessionId);
args.setJobId(jobId);
@@ -1043,26 +1428,38 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_getStatus();
}
}
- public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void resourcePoolGetAll(org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- resourcePoolGetAll_call method_call = new resourcePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport);
+ resourcePoolGetAll_call method_call =
+ new resourcePoolGetAll_call(resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class resourcePoolGetAll_call extends org.apache.thrift.async.TAsyncMethodCall {
- public resourcePoolGetAll_call(org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public resourcePoolGetAll_call(
+ org.apache.thrift.async.AsyncMethodCallback resultHandler,
+ org.apache.thrift.async.TAsyncClient client,
+ org.apache.thrift.protocol.TProtocolFactory protocolFactory,
+ org.apache.thrift.transport.TNonblockingTransport transport)
+ throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resourcePoolGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void write_args(org.apache.thrift.protocol.TProtocol prot)
+ throws org.apache.thrift.TException {
+ prot.writeMessageBegin(
+ new org.apache.thrift.protocol.TMessage(
+ "resourcePoolGetAll", org.apache.thrift.protocol.TMessageType.CALL, 0));
resourcePoolGetAll_args args = new resourcePoolGetAll_args();
args.write(prot);
prot.writeMessageEnd();
@@ -1072,15 +1469,30 @@ public class RemoteInterpreterService {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
+ new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot =
+ client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_resourcePoolGetAll();
}
}
- public void resourceGet(String sessionId, String paragraphId, String resourceName, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void resourceGet(
+ String sessionId,
+ String paragraphId,
+ String resourceName,
+ org.apache.thrift.async.AsyncMeth
<TRUNCATED>