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:06 UTC
[23/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/RemoteInterpreterEventService.java
----------------------------------------------------------------------
diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java
index 1290b74..2dbfd01 100644
--- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java
+++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java
@@ -1,52 +1,45 @@
/**
- * 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.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,7 +49,8 @@ public class RemoteInterpreterEventService {
public interface Iface {
- public void registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException;
+ public void registerInterpreterProcess(RegisterInfo registerInfo)
+ throws org.apache.thrift.TException;
public void appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException;
@@ -72,286 +66,311 @@ public class RemoteInterpreterEventService {
public void runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException;
- public void addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException;
+ public void addAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException;
- public void updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException;
+ public void updateAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException;
- public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException;
+ public void removeAngularObject(
+ String intpGroupId, String noteId, String paragraphId, String name)
+ throws org.apache.thrift.TException;
- public void sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException;
+ public void sendParagraphInfo(String intpGroupId, String json)
+ throws org.apache.thrift.TException;
public List<String> getAllResources(String intpGroupId) throws org.apache.thrift.TException;
public ByteBuffer getResource(String resourceIdJson) throws org.apache.thrift.TException;
- public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException;
-
+ public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson)
+ throws org.apache.thrift.TException;
}
public interface AsyncIface {
- public void registerInterpreterProcess(RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void appendOutput(OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void updateOutput(OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void updateAllOutput(OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void appendAppOutput(AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void updateAppOutput(AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void updateAppStatus(AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void runParagraphs(RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void addAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void updateAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void sendParagraphInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void getAllResources(String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void getResource(String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
- public void invokeMethod(String intpGroupId, String invokeMethodJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
-
+ public void registerInterpreterProcess(
+ RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void appendOutput(
+ OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void updateOutput(
+ OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void updateAllOutput(
+ OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void appendAppOutput(
+ AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void updateAppOutput(
+ AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void updateAppStatus(
+ AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void runParagraphs(
+ RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void addAngularObject(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void updateAngularObject(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void removeAngularObject(
+ String intpGroupId,
+ String noteId,
+ String paragraphId,
+ String name,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void sendParagraphInfo(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void getAllResources(
+ String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void getResource(
+ String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException;
+
+ public void invokeMethod(
+ String intpGroupId,
+ String invokeMethodJson,
+ 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 registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException
- {
+ public void registerInterpreterProcess(RegisterInfo registerInfo)
+ throws org.apache.thrift.TException {
send_registerInterpreterProcess(registerInfo);
recv_registerInterpreterProcess();
}
- public void send_registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException
- {
+ public void send_registerInterpreterProcess(RegisterInfo registerInfo)
+ throws org.apache.thrift.TException {
registerInterpreterProcess_args args = new registerInterpreterProcess_args();
args.setRegisterInfo(registerInfo);
sendBase("registerInterpreterProcess", args);
}
- public void recv_registerInterpreterProcess() throws org.apache.thrift.TException
- {
+ public void recv_registerInterpreterProcess() throws org.apache.thrift.TException {
registerInterpreterProcess_result result = new registerInterpreterProcess_result();
receiveBase(result, "registerInterpreterProcess");
return;
}
- public void appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException
- {
+ public void appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException {
send_appendOutput(event);
recv_appendOutput();
}
- public void send_appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException
- {
+ public void send_appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException {
appendOutput_args args = new appendOutput_args();
args.setEvent(event);
sendBase("appendOutput", args);
}
- public void recv_appendOutput() throws org.apache.thrift.TException
- {
+ public void recv_appendOutput() throws org.apache.thrift.TException {
appendOutput_result result = new appendOutput_result();
receiveBase(result, "appendOutput");
return;
}
- public void updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException {
send_updateOutput(event);
recv_updateOutput();
}
- public void send_updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void send_updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException {
updateOutput_args args = new updateOutput_args();
args.setEvent(event);
sendBase("updateOutput", args);
}
- public void recv_updateOutput() throws org.apache.thrift.TException
- {
+ public void recv_updateOutput() throws org.apache.thrift.TException {
updateOutput_result result = new updateOutput_result();
receiveBase(result, "updateOutput");
return;
}
- public void updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException
- {
+ public void updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException {
send_updateAllOutput(event);
recv_updateAllOutput();
}
- public void send_updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException
- {
+ public void send_updateAllOutput(OutputUpdateAllEvent event)
+ throws org.apache.thrift.TException {
updateAllOutput_args args = new updateAllOutput_args();
args.setEvent(event);
sendBase("updateAllOutput", args);
}
- public void recv_updateAllOutput() throws org.apache.thrift.TException
- {
+ public void recv_updateAllOutput() throws org.apache.thrift.TException {
updateAllOutput_result result = new updateAllOutput_result();
receiveBase(result, "updateAllOutput");
return;
}
- public void appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException
- {
+ public void appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException {
send_appendAppOutput(event);
recv_appendAppOutput();
}
- public void send_appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException
- {
+ public void send_appendAppOutput(AppOutputAppendEvent event)
+ throws org.apache.thrift.TException {
appendAppOutput_args args = new appendAppOutput_args();
args.setEvent(event);
sendBase("appendAppOutput", args);
}
- public void recv_appendAppOutput() throws org.apache.thrift.TException
- {
+ public void recv_appendAppOutput() throws org.apache.thrift.TException {
appendAppOutput_result result = new appendAppOutput_result();
receiveBase(result, "appendAppOutput");
return;
}
- public void updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException {
send_updateAppOutput(event);
recv_updateAppOutput();
}
- public void send_updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void send_updateAppOutput(AppOutputUpdateEvent event)
+ throws org.apache.thrift.TException {
updateAppOutput_args args = new updateAppOutput_args();
args.setEvent(event);
sendBase("updateAppOutput", args);
}
- public void recv_updateAppOutput() throws org.apache.thrift.TException
- {
+ public void recv_updateAppOutput() throws org.apache.thrift.TException {
updateAppOutput_result result = new updateAppOutput_result();
receiveBase(result, "updateAppOutput");
return;
}
- public void updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException {
send_updateAppStatus(event);
recv_updateAppStatus();
}
- public void send_updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException
- {
+ public void send_updateAppStatus(AppStatusUpdateEvent event)
+ throws org.apache.thrift.TException {
updateAppStatus_args args = new updateAppStatus_args();
args.setEvent(event);
sendBase("updateAppStatus", args);
}
- public void recv_updateAppStatus() throws org.apache.thrift.TException
- {
+ public void recv_updateAppStatus() throws org.apache.thrift.TException {
updateAppStatus_result result = new updateAppStatus_result();
receiveBase(result, "updateAppStatus");
return;
}
- public void runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException
- {
+ public void runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException {
send_runParagraphs(event);
recv_runParagraphs();
}
- public void send_runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException
- {
+ public void send_runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException {
runParagraphs_args args = new runParagraphs_args();
args.setEvent(event);
sendBase("runParagraphs", args);
}
- public void recv_runParagraphs() throws org.apache.thrift.TException
- {
+ public void recv_runParagraphs() throws org.apache.thrift.TException {
runParagraphs_result result = new runParagraphs_result();
receiveBase(result, "runParagraphs");
return;
}
- public void addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void addAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
send_addAngularObject(intpGroupId, json);
recv_addAngularObject();
}
- public void send_addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void send_addAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
addAngularObject_args args = new addAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
sendBase("addAngularObject", args);
}
- public void recv_addAngularObject() throws org.apache.thrift.TException
- {
+ public void recv_addAngularObject() throws org.apache.thrift.TException {
addAngularObject_result result = new addAngularObject_result();
receiveBase(result, "addAngularObject");
return;
}
- public void updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void updateAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
send_updateAngularObject(intpGroupId, json);
recv_updateAngularObject();
}
- public void send_updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void send_updateAngularObject(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
updateAngularObject_args args = new updateAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
sendBase("updateAngularObject", args);
}
- public void recv_updateAngularObject() throws org.apache.thrift.TException
- {
+ public void recv_updateAngularObject() throws org.apache.thrift.TException {
updateAngularObject_result result = new updateAngularObject_result();
receiveBase(result, "updateAngularObject");
return;
}
- public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException
- {
+ public void removeAngularObject(
+ String intpGroupId, String noteId, String paragraphId, String name)
+ throws org.apache.thrift.TException {
send_removeAngularObject(intpGroupId, noteId, paragraphId, name);
recv_removeAngularObject();
}
- public void send_removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException
- {
+ public void send_removeAngularObject(
+ String intpGroupId, String noteId, String paragraphId, String name)
+ throws org.apache.thrift.TException {
removeAngularObject_args args = new removeAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setNoteId(noteId);
@@ -360,138 +379,160 @@ public class RemoteInterpreterEventService {
sendBase("removeAngularObject", args);
}
- public void recv_removeAngularObject() throws org.apache.thrift.TException
- {
+ public void recv_removeAngularObject() throws org.apache.thrift.TException {
removeAngularObject_result result = new removeAngularObject_result();
receiveBase(result, "removeAngularObject");
return;
}
- public void sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void sendParagraphInfo(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
send_sendParagraphInfo(intpGroupId, json);
recv_sendParagraphInfo();
}
- public void send_sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException
- {
+ public void send_sendParagraphInfo(String intpGroupId, String json)
+ throws org.apache.thrift.TException {
sendParagraphInfo_args args = new sendParagraphInfo_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
sendBase("sendParagraphInfo", args);
}
- public void recv_sendParagraphInfo() throws org.apache.thrift.TException
- {
+ public void recv_sendParagraphInfo() throws org.apache.thrift.TException {
sendParagraphInfo_result result = new sendParagraphInfo_result();
receiveBase(result, "sendParagraphInfo");
return;
}
- public List<String> getAllResources(String intpGroupId) throws org.apache.thrift.TException
- {
+ public List<String> getAllResources(String intpGroupId) throws org.apache.thrift.TException {
send_getAllResources(intpGroupId);
return recv_getAllResources();
}
- public void send_getAllResources(String intpGroupId) throws org.apache.thrift.TException
- {
+ public void send_getAllResources(String intpGroupId) throws org.apache.thrift.TException {
getAllResources_args args = new getAllResources_args();
args.setIntpGroupId(intpGroupId);
sendBase("getAllResources", args);
}
- public List<String> recv_getAllResources() throws org.apache.thrift.TException
- {
+ public List<String> recv_getAllResources() throws org.apache.thrift.TException {
getAllResources_result result = new getAllResources_result();
receiveBase(result, "getAllResources");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllResources failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "getAllResources failed: unknown result");
}
- public ByteBuffer getResource(String resourceIdJson) throws org.apache.thrift.TException
- {
+ public ByteBuffer getResource(String resourceIdJson) throws org.apache.thrift.TException {
send_getResource(resourceIdJson);
return recv_getResource();
}
- public void send_getResource(String resourceIdJson) throws org.apache.thrift.TException
- {
+ public void send_getResource(String resourceIdJson) throws org.apache.thrift.TException {
getResource_args args = new getResource_args();
args.setResourceIdJson(resourceIdJson);
sendBase("getResource", args);
}
- public ByteBuffer recv_getResource() throws org.apache.thrift.TException
- {
+ public ByteBuffer recv_getResource() throws org.apache.thrift.TException {
getResource_result result = new getResource_result();
receiveBase(result, "getResource");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getResource failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "getResource failed: unknown result");
}
- public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException
- {
+ public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson)
+ throws org.apache.thrift.TException {
send_invokeMethod(intpGroupId, invokeMethodJson);
return recv_invokeMethod();
}
- public void send_invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException
- {
+ public void send_invokeMethod(String intpGroupId, String invokeMethodJson)
+ throws org.apache.thrift.TException {
invokeMethod_args args = new invokeMethod_args();
args.setIntpGroupId(intpGroupId);
args.setInvokeMethodJson(invokeMethodJson);
sendBase("invokeMethod", args);
}
- public ByteBuffer recv_invokeMethod() throws org.apache.thrift.TException
- {
+ public ByteBuffer recv_invokeMethod() throws org.apache.thrift.TException {
invokeMethod_result result = new invokeMethod_result();
receiveBase(result, "invokeMethod");
if (result.isSetSuccess()) {
return result.success;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "invokeMethod failed: unknown result");
+ throw new org.apache.thrift.TApplicationException(
+ org.apache.thrift.TApplicationException.MISSING_RESULT,
+ "invokeMethod 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 registerInterpreterProcess(RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void registerInterpreterProcess(
+ RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- registerInterpreterProcess_call method_call = new registerInterpreterProcess_call(registerInfo, resultHandler, this, ___protocolFactory, ___transport);
+ registerInterpreterProcess_call method_call =
+ new registerInterpreterProcess_call(
+ registerInfo, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- public static class registerInterpreterProcess_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class registerInterpreterProcess_call
+ extends org.apache.thrift.async.TAsyncMethodCall {
private RegisterInfo registerInfo;
- public registerInterpreterProcess_call(RegisterInfo registerInfo, 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 registerInterpreterProcess_call(
+ RegisterInfo registerInfo,
+ 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.registerInfo = registerInfo;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("registerInterpreterProcess", 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(
+ "registerInterpreterProcess", org.apache.thrift.protocol.TMessageType.CALL, 0));
registerInterpreterProcess_args args = new registerInterpreterProcess_args();
args.setRegisterInfo(registerInfo);
args.write(prot);
@@ -502,28 +543,43 @@ public class RemoteInterpreterEventService {
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_registerInterpreterProcess();
}
}
- public void appendOutput(OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void appendOutput(
+ OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- appendOutput_call method_call = new appendOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ appendOutput_call method_call =
+ new appendOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class appendOutput_call extends org.apache.thrift.async.TAsyncMethodCall {
private OutputAppendEvent event;
- public appendOutput_call(OutputAppendEvent event, 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 appendOutput_call(
+ OutputAppendEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("appendOutput", 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(
+ "appendOutput", org.apache.thrift.protocol.TMessageType.CALL, 0));
appendOutput_args args = new appendOutput_args();
args.setEvent(event);
args.write(prot);
@@ -534,28 +590,43 @@ public class RemoteInterpreterEventService {
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_appendOutput();
}
}
- public void updateOutput(OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void updateOutput(
+ OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- updateOutput_call method_call = new updateOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ updateOutput_call method_call =
+ new updateOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class updateOutput_call extends org.apache.thrift.async.TAsyncMethodCall {
private OutputUpdateEvent event;
- public updateOutput_call(OutputUpdateEvent event, 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 updateOutput_call(
+ OutputUpdateEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateOutput", 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(
+ "updateOutput", org.apache.thrift.protocol.TMessageType.CALL, 0));
updateOutput_args args = new updateOutput_args();
args.setEvent(event);
args.write(prot);
@@ -566,28 +637,43 @@ public class RemoteInterpreterEventService {
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_updateOutput();
}
}
- public void updateAllOutput(OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void updateAllOutput(
+ OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- updateAllOutput_call method_call = new updateAllOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ updateAllOutput_call method_call =
+ new updateAllOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class updateAllOutput_call extends org.apache.thrift.async.TAsyncMethodCall {
private OutputUpdateAllEvent event;
- public updateAllOutput_call(OutputUpdateAllEvent event, 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 updateAllOutput_call(
+ OutputUpdateAllEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAllOutput", 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(
+ "updateAllOutput", org.apache.thrift.protocol.TMessageType.CALL, 0));
updateAllOutput_args args = new updateAllOutput_args();
args.setEvent(event);
args.write(prot);
@@ -598,28 +684,43 @@ public class RemoteInterpreterEventService {
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_updateAllOutput();
}
}
- public void appendAppOutput(AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void appendAppOutput(
+ AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- appendAppOutput_call method_call = new appendAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ appendAppOutput_call method_call =
+ new appendAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class appendAppOutput_call extends org.apache.thrift.async.TAsyncMethodCall {
private AppOutputAppendEvent event;
- public appendAppOutput_call(AppOutputAppendEvent event, 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 appendAppOutput_call(
+ AppOutputAppendEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("appendAppOutput", 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(
+ "appendAppOutput", org.apache.thrift.protocol.TMessageType.CALL, 0));
appendAppOutput_args args = new appendAppOutput_args();
args.setEvent(event);
args.write(prot);
@@ -630,28 +731,43 @@ public class RemoteInterpreterEventService {
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_appendAppOutput();
}
}
- public void updateAppOutput(AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void updateAppOutput(
+ AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- updateAppOutput_call method_call = new updateAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ updateAppOutput_call method_call =
+ new updateAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class updateAppOutput_call extends org.apache.thrift.async.TAsyncMethodCall {
private AppOutputUpdateEvent event;
- public updateAppOutput_call(AppOutputUpdateEvent event, 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 updateAppOutput_call(
+ AppOutputUpdateEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAppOutput", 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(
+ "updateAppOutput", org.apache.thrift.protocol.TMessageType.CALL, 0));
updateAppOutput_args args = new updateAppOutput_args();
args.setEvent(event);
args.write(prot);
@@ -662,28 +778,43 @@ public class RemoteInterpreterEventService {
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_updateAppOutput();
}
}
- public void updateAppStatus(AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void updateAppStatus(
+ AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- updateAppStatus_call method_call = new updateAppStatus_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ updateAppStatus_call method_call =
+ new updateAppStatus_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class updateAppStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
private AppStatusUpdateEvent event;
- public updateAppStatus_call(AppStatusUpdateEvent event, 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 updateAppStatus_call(
+ AppStatusUpdateEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAppStatus", 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(
+ "updateAppStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
updateAppStatus_args args = new updateAppStatus_args();
args.setEvent(event);
args.write(prot);
@@ -694,28 +825,43 @@ public class RemoteInterpreterEventService {
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_updateAppStatus();
}
}
- public void runParagraphs(RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void runParagraphs(
+ RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- runParagraphs_call method_call = new runParagraphs_call(event, resultHandler, this, ___protocolFactory, ___transport);
+ runParagraphs_call method_call =
+ new runParagraphs_call(event, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class runParagraphs_call extends org.apache.thrift.async.TAsyncMethodCall {
private RunParagraphsEvent event;
- public runParagraphs_call(RunParagraphsEvent event, 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 runParagraphs_call(
+ RunParagraphsEvent event,
+ 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.event = event;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("runParagraphs", 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(
+ "runParagraphs", org.apache.thrift.protocol.TMessageType.CALL, 0));
runParagraphs_args args = new runParagraphs_args();
args.setEvent(event);
args.write(prot);
@@ -726,15 +872,21 @@ public class RemoteInterpreterEventService {
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_runParagraphs();
}
}
- public void addAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void addAngularObject(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- addAngularObject_call method_call = new addAngularObject_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
+ addAngularObject_call method_call =
+ new addAngularObject_call(
+ intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -742,14 +894,25 @@ public class RemoteInterpreterEventService {
public static class addAngularObject_call extends org.apache.thrift.async.TAsyncMethodCall {
private String intpGroupId;
private String json;
- public addAngularObject_call(String intpGroupId, String json, 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 addAngularObject_call(
+ String intpGroupId,
+ String json,
+ 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.json = json;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addAngularObject", 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(
+ "addAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0));
addAngularObject_args args = new addAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
@@ -761,15 +924,21 @@ public class RemoteInterpreterEventService {
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_addAngularObject();
}
}
- public void updateAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void updateAngularObject(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- updateAngularObject_call method_call = new updateAngularObject_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
+ updateAngularObject_call method_call =
+ new updateAngularObject_call(
+ intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -777,14 +946,25 @@ public class RemoteInterpreterEventService {
public static class updateAngularObject_call extends org.apache.thrift.async.TAsyncMethodCall {
private String intpGroupId;
private String json;
- public updateAngularObject_call(String intpGroupId, String json, 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 updateAngularObject_call(
+ String intpGroupId,
+ String json,
+ 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.json = json;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAngularObject", 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(
+ "updateAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0));
updateAngularObject_args args = new updateAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
@@ -796,15 +976,32 @@ public class RemoteInterpreterEventService {
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_updateAngularObject();
}
}
- public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void removeAngularObject(
+ String intpGroupId,
+ String noteId,
+ String paragraphId,
+ String name,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- removeAngularObject_call method_call = new removeAngularObject_call(intpGroupId, noteId, paragraphId, name, resultHandler, this, ___protocolFactory, ___transport);
+ removeAngularObject_call method_call =
+ new removeAngularObject_call(
+ intpGroupId,
+ noteId,
+ paragraphId,
+ name,
+ resultHandler,
+ this,
+ ___protocolFactory,
+ ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -814,7 +1011,17 @@ public class RemoteInterpreterEventService {
private String noteId;
private String paragraphId;
private String name;
- public removeAngularObject_call(String intpGroupId, String noteId, String paragraphId, String name, 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 removeAngularObject_call(
+ String intpGroupId,
+ String noteId,
+ String paragraphId,
+ String name,
+ 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.noteId = noteId;
@@ -822,8 +1029,11 @@ public class RemoteInterpreterEventService {
this.name = name;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeAngularObject", 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(
+ "removeAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0));
removeAngularObject_args args = new removeAngularObject_args();
args.setIntpGroupId(intpGroupId);
args.setNoteId(noteId);
@@ -837,15 +1047,21 @@ public class RemoteInterpreterEventService {
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_removeAngularObject();
}
}
- public void sendParagraphInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void sendParagraphInfo(
+ String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- sendParagraphInfo_call method_call = new sendParagraphInfo_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
+ sendParagraphInfo_call method_call =
+ new sendParagraphInfo_call(
+ intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -853,14 +1069,25 @@ public class RemoteInterpreterEventService {
public static class sendParagraphInfo_call extends org.apache.thrift.async.TAsyncMethodCall {
private String intpGroupId;
private String json;
- public sendParagraphInfo_call(String intpGroupId, String json, 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 sendParagraphInfo_call(
+ String intpGroupId,
+ String json,
+ 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.json = json;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sendParagraphInfo", 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(
+ "sendParagraphInfo", org.apache.thrift.protocol.TMessageType.CALL, 0));
sendParagraphInfo_args args = new sendParagraphInfo_args();
args.setIntpGroupId(intpGroupId);
args.setJson(json);
@@ -872,28 +1099,44 @@ public class RemoteInterpreterEventService {
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_sendParagraphInfo();
}
}
- public void getAllResources(String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void getAllResources(
+ String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- getAllResources_call method_call = new getAllResources_call(intpGroupId, resultHandler, this, ___protocolFactory, ___transport);
+ getAllResources_call method_call =
+ new getAllResources_call(
+ intpGroupId, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class getAllResources_call extends org.apache.thrift.async.TAsyncMethodCall {
private String intpGroupId;
- public getAllResources_call(String intpGroupId, 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 getAllResources_call(
+ String intpGroupId,
+ 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;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllResources", 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(
+ "getAllResources", org.apache.thrift.protocol.TMessageType.CALL, 0));
getAllResources_args args = new getAllResources_args();
args.setIntpGroupId(intpGroupId);
args.write(prot);
@@ -904,28 +1147,44 @@ public class RemoteInterpreterEventService {
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_getAllResources();
}
}
- public void getResource(String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void getResource(
+ String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- getResource_call method_call = new getResource_call(resourceIdJson, resultHandler, this, ___protocolFactory, ___transport);
+ getResource_call method_call =
+ new getResource_call(
+ resourceIdJson, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class getResource_call extends org.apache.thrift.async.TAsyncMethodCall {
private String resourceIdJson;
- public getResource_call(String resourceIdJson, 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 getResource_call(
+ String resourceIdJson,
+ 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.resourceIdJson = resourceIdJson;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getResource", 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(
+ "getResource", org.apache.thrift.protocol.TMessageType.CALL, 0));
getResource_args args = new getResource_args();
args.setResourceIdJson(resourceIdJson);
args.write(prot);
@@ -936,15 +1195,23 @@ public class RemoteInterpreterEventService {
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_getResource();
}
}
- public void invokeMethod(String intpGroupId, String invokeMethodJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ public void invokeMethod(
+ String intpGroupId,
+ String invokeMethodJson,
+ org.apache.thrift.async.AsyncMethodCallback resultHandler)
+ throws org.apache.thrift.TException {
checkReady();
- invokeMethod_call method_call = new invokeMethod_call(intpGroupId, invokeMethodJson, resultHandler, this, ___protocolFactory, ___transport);
+ invokeMethod_call method_call =
+ new invokeMethod_call(
+ intpGroupId, invokeMethodJson, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
@@ -952,14 +1219,25 @@ public class RemoteInterpreterEventService {
public static class invokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall {
private String intpGroupId;
private String invokeMethodJson;
- public invokeMethod_call(String intpGroupId, String invokeMethodJson, 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 invokeMethod_call(
+ String intpGroupId,
+ String invokeMethodJson,
+ 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.invokeMethodJson = invokeMethodJson;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("invokeMethod", 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(
+ "invokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0));
invokeMethod_args args = new invokeMethod_args();
args.setIntpGroupId(intpGroupId);
args.setInvokeMethodJson(invokeMethodJson);
@@ -971,25 +1249,40 @@ public class RemoteInterpreterEventService {
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_invokeMethod();
}
}
-
}
- public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
+ public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I>
+ implements org.apache.thrift.TProcessor {
private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
- public Processor(I iface) {
- super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
- }
- protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ public Processor(I iface) {
+ super(
+ iface,
+ getProcessMap(
+ new HashMap<
+ String,
+ org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
+ }
+
+ protected Processor(
+ I iface,
+ Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
+ processMap) {
super(iface, getProcessMap(processMap));
}
- private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ private static <I extends Iface>
+ Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
+ getProcessMap(
+ Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
+ processMap) {
processMap.put("registerInterpreterProcess", new registerInterpreterProcess());
processMap.put("appendOutput", new appendOutput());
processMap.put("updateOutput", new updateOutput());
@@ -1008,7 +1301,8 @@ public class RemoteInterpreterEventService {
return processMap;
}
- public static class registerInterpreterProcess<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerInterpreterProcess_args> {
+ public static class registerInterpreterProcess<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, registerInterpreterProcess_args> {
public registerInterpreterProcess() {
super("registerInterpreterProcess");
}
@@ -1021,14 +1315,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public registerInterpreterProcess_result getResult(I iface, registerInterpreterProcess_args args) throws org.apache.thrift.TException {
+ public registerInterpreterProcess_result getResult(
+ I iface, registerInterpreterProcess_args args) throws org.apache.thrift.TException {
registerInterpreterProcess_result result = new registerInterpreterProcess_result();
iface.registerInterpreterProcess(args.registerInfo);
return result;
}
}
- public static class appendOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, appendOutput_args> {
+ public static class appendOutput<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, appendOutput_args> {
public appendOutput() {
super("appendOutput");
}
@@ -1041,14 +1337,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public appendOutput_result getResult(I iface, appendOutput_args args) throws org.apache.thrift.TException {
+ public appendOutput_result getResult(I iface, appendOutput_args args)
+ throws org.apache.thrift.TException {
appendOutput_result result = new appendOutput_result();
iface.appendOutput(args.event);
return result;
}
}
- public static class updateOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateOutput_args> {
+ public static class updateOutput<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, updateOutput_args> {
public updateOutput() {
super("updateOutput");
}
@@ -1061,14 +1359,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public updateOutput_result getResult(I iface, updateOutput_args args) throws org.apache.thrift.TException {
+ public updateOutput_result getResult(I iface, updateOutput_args args)
+ throws org.apache.thrift.TException {
updateOutput_result result = new updateOutput_result();
iface.updateOutput(args.event);
return result;
}
}
- public static class updateAllOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAllOutput_args> {
+ public static class updateAllOutput<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, updateAllOutput_args> {
public updateAllOutput() {
super("updateAllOutput");
}
@@ -1081,14 +1381,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public updateAllOutput_result getResult(I iface, updateAllOutput_args args) throws org.apache.thrift.TException {
+ public updateAllOutput_result getResult(I iface, updateAllOutput_args args)
+ throws org.apache.thrift.TException {
updateAllOutput_result result = new updateAllOutput_result();
iface.updateAllOutput(args.event);
return result;
}
}
- public static class appendAppOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, appendAppOutput_args> {
+ public static class appendAppOutput<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, appendAppOutput_args> {
public appendAppOutput() {
super("appendAppOutput");
}
@@ -1101,14 +1403,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public appendAppOutput_result getResult(I iface, appendAppOutput_args args) throws org.apache.thrift.TException {
+ public appendAppOutput_result getResult(I iface, appendAppOutput_args args)
+ throws org.apache.thrift.TException {
appendAppOutput_result result = new appendAppOutput_result();
iface.appendAppOutput(args.event);
return result;
}
}
- public static class updateAppOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAppOutput_args> {
+ public static class updateAppOutput<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, updateAppOutput_args> {
public updateAppOutput() {
super("updateAppOutput");
}
@@ -1121,14 +1425,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public updateAppOutput_result getResult(I iface, updateAppOutput_args args) throws org.apache.thrift.TException {
+ public updateAppOutput_result getResult(I iface, updateAppOutput_args args)
+ throws org.apache.thrift.TException {
updateAppOutput_result result = new updateAppOutput_result();
iface.updateAppOutput(args.event);
return result;
}
}
- public static class updateAppStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAppStatus_args> {
+ public static class updateAppStatus<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, updateAppStatus_args> {
public updateAppStatus() {
super("updateAppStatus");
}
@@ -1141,14 +1447,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public updateAppStatus_result getResult(I iface, updateAppStatus_args args) throws org.apache.thrift.TException {
+ public updateAppStatus_result getResult(I iface, updateAppStatus_args args)
+ throws org.apache.thrift.TException {
updateAppStatus_result result = new updateAppStatus_result();
iface.updateAppStatus(args.event);
return result;
}
}
- public static class runParagraphs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, runParagraphs_args> {
+ public static class runParagraphs<I extends Iface>
+ extends org.apache.thrift.ProcessFunction<I, runParagraphs_args> {
public runParagraphs() {
super("runParagraphs");
}
@@ -1161,14 +1469,16 @@ public class RemoteInterpreterEventService {
return false;
}
- public runParagraphs_result getResult(I iface, runParagraphs_args args) throws org.apache.thrift.TExce
<TRUNCATED>