[21/49] zeppelin git commit: [ZEPPELIN-3740] Adopt `google-java-format` and `fmt-maven-plugin`

[jongyoul]

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

<TRUNCATED>