http://git-wip-us.apache.org/repos/asf/zeppelin/blob/0d746fa2/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 2dbfd01..1290b74 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,45 +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.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; @@ -49,8 +56,7 @@ 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; @@ -66,311 +72,286 @@ 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); @@ -379,160 +360,138 @@ 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); @@ -543,43 +502,28 @@ 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); @@ -590,43 +534,28 @@ 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); @@ -637,43 +566,28 @@ 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); @@ -684,43 +598,28 @@ 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); @@ -731,43 +630,28 @@ 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); @@ -778,43 +662,28 @@ 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); @@ -825,43 +694,28 @@ 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); @@ -872,21 +726,15 @@ 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); } @@ -894,25 +742,14 @@ 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); @@ -924,21 +761,15 @@ 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); } @@ -946,25 +777,14 @@ 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); @@ -976,32 +796,15 @@ 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); } @@ -1011,17 +814,7 @@ 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; @@ -1029,11 +822,8 @@ 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); @@ -1047,21 +837,15 @@ 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); } @@ -1069,25 +853,14 @@ 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); @@ -1099,44 +872,28 @@ 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); @@ -1147,44 +904,28 @@ 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); @@ -1195,23 +936,15 @@ 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); } @@ -1219,25 +952,14 @@ 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); @@ -1249,40 +971,25 @@ 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) { + 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()); @@ -1301,8 +1008,7 @@ 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"); } @@ -1315,16 +1021,14 @@ 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"); } @@ -1337,16 +1041,14 @@ 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"); } @@ -1359,16 +1061,14 @@ 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"); } @@ -1381,16 +1081,14 @@ 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"); } @@ -1403,16 +1101,14 @@ 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"); } @@ -1425,16 +1121,14 @@ 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"); } @@ -1447,16 +1141,14 @@ 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"); } @@ -1469,16 +1161,14 @@ public class RemoteInterpreterEventService { return false; } - public runParagraphs_result getResult(I iface, runParagraphs_args args) - throws org.apache.thrift.TException { + pu
<TRUNCATED>
