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