Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

change defined protocol for thrift

Browse source
This commit is contained in:
CloverHearts 2016-11-24 02:34:03 +09:00
parent 7562535a16
commit 5ec4640af0
23 changed files with 313 additions and 776 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
scalding/src/main/java/org/apache/zeppelin/scalding/ScaldingInterpreter.java
View file

@ -24,7 +24,6 @@ import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterPropertyBuilder;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;

1
shell/src/main/java/org/apache/zeppelin/shell/ShellInterpreter.java
View file

@ -36,7 +36,6 @@ import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;

1
spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java
View file

@ -47,7 +47,6 @@ import org.apache.spark.ui.SparkUI;
import org.apache.spark.ui.jobs.JobProgressListener;
import org.apache.zeppelin.interpreter.*;
import org.apache.zeppelin.interpreter.InterpreterResult.Code;
import org.apache.zeppelin.interpreter.thrift.RemoteZeppelinServerController;
import org.apache.zeppelin.interpreter.InterpreterUtils;
import org.apache.zeppelin.interpreter.WrappedInterpreter;
import org.apache.zeppelin.interpreter.util.InterpreterOutputStream;

58
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/RemoteZeppelinServerResource.java Normal file
View file

@ -0,0 +1,58 @@
/*
* 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
*
* 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.
*/
package org.apache.zeppelin.interpreter;
/**
* Remote Zeppelin Server Resource
*/
public class RemoteZeppelinServerResource {
/**
* Resource Type for Zeppelin Server
*/
public enum Type{
PARAGRAPH_RUNNERS
}
private String ownerKey;
private Type resourceType;
private Object data;
public Type getResourceType() {
return resourceType;
}
public String getOwnerKey() {
return ownerKey;
}
public void setOwnerKey(String ownerKey) {
this.ownerKey = ownerKey;
}
public void setResourceType(Type resourceType) {
this.resourceType = resourceType;
}
public Object getData() {
return data;
}
public void setData(Object data) {
this.data = data;
}
}

11
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventClient.java
View file

@ -19,9 +19,9 @@ package org.apache.zeppelin.interpreter.remote;
import com.google.gson.Gson;
import org.apache.zeppelin.display.AngularObject;
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
import org.apache.zeppelin.interpreter.RemoteZeppelinServerResource;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEvent;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEventType;
import org.apache.zeppelin.interpreter.thrift.RemoteZeppelinServerController;
import org.apache.zeppelin.interpreter.thrift.ZeppelinServerResourceParagraphRunner;
import org.apache.zeppelin.resource.*;
import org.slf4j.Logger;
@ -56,12 +56,13 @@ public class RemoteInterpreterEventClient implements ResourcePoolConnector {
*/
public void getZeppelinServerNoteRunner(
String eventOwnerKey, ZeppelinServerResourceParagraphRunner runner) {
RemoteZeppelinServerController eventBody = new RemoteZeppelinServerController();
eventBody.setEventOwnerKey(eventOwnerKey);
eventBody.setMsg(gson.toJson(runner));
RemoteZeppelinServerResource eventBody = new RemoteZeppelinServerResource();
eventBody.setResourceType(RemoteZeppelinServerResource.Type.PARAGRAPH_RUNNERS);
eventBody.setOwnerKey(eventOwnerKey);
eventBody.setData(runner);
sendEvent(new RemoteInterpreterEvent(
RemoteInterpreterEventType.RESOURCE_PARAGRAPH_RUN_CONTEXT,
RemoteInterpreterEventType.REMOTE_ZEPPELIN_SERVER_RESOURCE,
gson.toJson(eventBody)));
}

107
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterEventPoller.java
View file

@ -25,11 +25,10 @@ import org.apache.zeppelin.display.AngularObjectRegistry;
import org.apache.zeppelin.helium.ApplicationEventListener;
import org.apache.zeppelin.interpreter.InterpreterContextRunner;
import org.apache.zeppelin.interpreter.InterpreterGroup;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.RemoteZeppelinServerResource;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEvent;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterEventType;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService.Client;
import org.apache.zeppelin.interpreter.thrift.RemoteZeppelinServerController;
import org.apache.zeppelin.interpreter.thrift.ZeppelinServerResourceParagraphRunner;
import org.apache.zeppelin.resource.Resource;
import org.apache.zeppelin.resource.ResourceId;
@ -199,10 +198,11 @@ public class RemoteInterpreterEventPoller extends Thread {
String status = appStatusUpdate.get("status");
appListener.onStatusChange(noteId, paragraphId, appId, status);
} else if (event.getType() == RemoteInterpreterEventType.RESOURCE_PARAGRAPH_RUN_CONTEXT) {
RemoteZeppelinServerController remoteControlEvent = gson.fromJson(
event.getData(), RemoteZeppelinServerController.class);
progressRemoteZeppelinControlEvent(event.getType(), listener, remoteControlEvent);
} else if (event.getType() == RemoteInterpreterEventType.REMOTE_ZEPPELIN_SERVER_RESOURCE) {
RemoteZeppelinServerResource reqResourceBody = gson.fromJson(
event.getData(), RemoteZeppelinServerResource.class);
progressRemoteZeppelinControlEvent(
reqResourceBody.getResourceType(), listener, reqResourceBody);
} else if (event.getType() == RemoteInterpreterEventType.META_INFOS) {
Map<String, String> metaInfos = gson.fromJson(event.getData(),
@ -224,58 +224,70 @@ public class RemoteInterpreterEventPoller extends Thread {
}
private void progressRemoteZeppelinControlEvent(
RemoteInterpreterEventType event,
RemoteZeppelinServerResource.Type resourceType,
RemoteInterpreterProcessListener remoteWorksEventListener,
RemoteZeppelinServerController data) {
RemoteZeppelinServerResource reqResourceBody) throws Exception {
boolean broken = false;
final Gson gson = new Gson();
String eventOwnerKey = data.getEventOwnerKey();
final String eventOwnerKey = reqResourceBody.getOwnerKey();
Client interpreterServerMain = null;
try {
interpreterServerMain = interpreterProcess.getClient();
final Client eventClient = interpreterServerMain;
if (event == RemoteInterpreterEventType.RESOURCE_PARAGRAPH_RUN_CONTEXT) {
if (resourceType == RemoteZeppelinServerResource.Type.PARAGRAPH_RUNNERS) {
final List<ZeppelinServerResourceParagraphRunner> remoteRunners = new LinkedList<>();
ZeppelinServerResourceParagraphRunner runner = gson.fromJson(
data.getMsg(), ZeppelinServerResourceParagraphRunner.class);
final RemoteZeppelinServerController resResource = new RemoteZeppelinServerController();
resResource.setEventOwnerKey(eventOwnerKey);
ZeppelinServerResourceParagraphRunner reqRunnerContext =
new ZeppelinServerResourceParagraphRunner();
remoteWorksEventListener.onGetParagraphRunners(runner.getNoteId(), runner.getParagraphId(),
new RemoteInterpreterProcessListener.RemoteWorksEventListener() {
@Override
public void onFinished(Object resultObject) {
boolean clientBroken = false;
if (resultObject != null && resultObject instanceof List) {
List<InterpreterContextRunner> runnerList =
(List<InterpreterContextRunner>) resultObject;
for (InterpreterContextRunner r : runnerList) {
remoteRunners.add(
new ZeppelinServerResourceParagraphRunner(r.getNoteId(), r.getParagraphId())
);
}
resResource.setMsg(gson.toJson(remoteRunners));
RemoteInterpreterEvent response = new RemoteInterpreterEvent(
RemoteInterpreterEventType.RESOURCE_PARAGRAPH_RUN_CONTEXT,
gson.toJson(resResource));
try {
eventClient.onReceivedResourceParagraphRunners(response);
} catch (Exception e) {
clientBroken = true;
logger.error("Can't get RemoteInterpreterEvent", e);
waitQuietly();
} finally {
interpreterProcess.releaseClient(eventClient, clientBroken);
Map<String, Object> reqResourceMap = (Map<String, Object>) reqResourceBody.getData();
String noteId = (String) reqResourceMap.get("noteId");
String paragraphId = (String) reqResourceMap.get("paragraphId");
reqRunnerContext.setNoteId(noteId);
reqRunnerContext.setParagraphId(paragraphId);
RemoteInterpreterProcessListener.RemoteWorksEventListener callBackEvent =
new RemoteInterpreterProcessListener.RemoteWorksEventListener() {
@Override
public void onFinished(Object resultObject) {
boolean clientBroken = false;
if (resultObject != null && resultObject instanceof List) {
List<InterpreterContextRunner> runnerList =
(List<InterpreterContextRunner>) resultObject;
for (InterpreterContextRunner r : runnerList) {
remoteRunners.add(
new ZeppelinServerResourceParagraphRunner(r.getNoteId(), r.getParagraphId())
);
}
final RemoteZeppelinServerResource resResource =
new RemoteZeppelinServerResource();
resResource.setOwnerKey(eventOwnerKey);
resResource.setResourceType(RemoteZeppelinServerResource.Type.PARAGRAPH_RUNNERS);
resResource.setData(remoteRunners);
try {
eventClient.onReceivedZeppelinResource(gson.toJson(resResource));
} catch (Exception e) {
clientBroken = true;
logger.error("Can't get RemoteInterpreterEvent", e);
waitQuietly();
} finally {
interpreterProcess.releaseClient(eventClient, clientBroken);
}
}
}
}
@Override
public void onError() {
logger.info("onGetParagraphRunners onError");
}
});
@Override
public void onError() {
logger.info("onGetParagraphRunners onError");
}
};
remoteWorksEventListener.onGetParagraphRunners(
reqRunnerContext.getNoteId(), reqRunnerContext.getParagraphId(), callBackEvent);
}
} catch (Exception e) {
broken = true;
@ -285,11 +297,6 @@ public class RemoteInterpreterEventPoller extends Thread {
} finally {
interpreterProcess.releaseClient(interpreterServerMain, broken);
}
if (broken == true) {
return;
}
}
private void sendResourcePoolResponseGetAll(ResourceSet resourceSet) {

1
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterManagedProcess.java
View file

@ -21,7 +21,6 @@ import org.apache.commons.exec.*;
import org.apache.commons.exec.environment.EnvironmentUtils;
import org.apache.zeppelin.helium.ApplicationEventListener;
import org.apache.zeppelin.interpreter.InterpreterException;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

1
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterRunningProcess.java
View file

@ -17,7 +17,6 @@
package org.apache.zeppelin.interpreter.remote;
import org.apache.zeppelin.helium.ApplicationEventListener;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

50
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java
View file

@ -344,29 +344,39 @@ public class RemoteInterpreterServer
}
@Override
public void onReceivedResourceParagraphRunners(
RemoteInterpreterEvent response) throws TException {
if (response.getType() == RemoteInterpreterEventType.RESOURCE_PARAGRAPH_RUN_CONTEXT) {
List<InterpreterContextRunner> intpContextRunners = new LinkedList<>();
public void onReceivedZeppelinResource(String responseJson) throws TException {
RemoteZeppelinServerResource response = gson.fromJson(
responseJson, RemoteZeppelinServerResource.class);
RemoteZeppelinServerController remoteZeppelinServerController = gson.fromJson(
response.getData(), RemoteZeppelinServerController.class);
if (response == null) {
throw new TException("Bad response for remote resource");
}
if (remoteZeppelinServerController == null) {
throw new TException("can not found Resource paragraph runners");
}
try {
if (response.getResourceType() == RemoteZeppelinServerResource.Type.PARAGRAPH_RUNNERS) {
List<InterpreterContextRunner> intpContextRunners = new LinkedList<>();
List<Map<String, Object>> remoteRunnersMap =
(List<Map<String, Object>>) response.getData();
List<ZeppelinServerResourceParagraphRunner> runners = gson.fromJson(
remoteZeppelinServerController.getMsg(),
new TypeToken<List<ZeppelinServerResourceParagraphRunner>>() {}.getType());
for (ZeppelinServerResourceParagraphRunner r : runners) {
intpContextRunners.add(new ParagraphRunner(this, r.getNoteId(), r.getParagraphId()));
}
synchronized (this.remoteWorksResponsePool) {
this.remoteWorksResponsePool.put(
remoteZeppelinServerController.getEventOwnerKey(),
intpContextRunners);
String noteId = null;
String paragraphId = null;
for (Map<String, Object> runnerItem : remoteRunnersMap) {
noteId = (String) runnerItem.get("noteId");
paragraphId = (String) runnerItem.get("paragraphId");
intpContextRunners.add(
new ParagraphRunner(this, noteId, paragraphId)
);
}
synchronized (this.remoteWorksResponsePool) {
this.remoteWorksResponsePool.put(
response.getOwnerKey(),
intpContextRunners);
}
}
} catch (Exception e) {
throw e;
}
}
@ -626,7 +636,7 @@ public class RemoteInterpreterServer
Logger logger = LoggerFactory.getLogger(ZeppelinRemoteWorksController.class);
private final long DEFAULT_TIMEOUT_VALUE = 300000;
private Map<String, Object> remoteWorksResponsePool;
private final Map<String, Object> remoteWorksResponsePool;
private RemoteInterpreterServer server;
public ZeppelinRemoteWorksController(
RemoteInterpreterServer server, Map<String, Object> remoteWorksResponsePool) {

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/InterpreterCompletion.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class InterpreterCompletion implements org.apache.thrift.TBase<InterpreterCompletion, InterpreterCompletion._Fields>, java.io.Serializable, Cloneable, Comparable<InterpreterCompletion> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("InterpreterCompletion");

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteApplicationResult.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class RemoteApplicationResult implements org.apache.thrift.TBase<RemoteApplicationResult, RemoteApplicationResult._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteApplicationResult> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteApplicationResult");

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterContext.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class RemoteInterpreterContext implements org.apache.thrift.TBase<RemoteInterpreterContext, RemoteInterpreterContext._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterContext> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterContext");

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEvent.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class RemoteInterpreterEvent implements org.apache.thrift.TBase<RemoteInterpreterEvent, RemoteInterpreterEvent._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterEvent> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterEvent");

4
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventType.java
View file

@ -41,7 +41,7 @@ public enum RemoteInterpreterEventType implements org.apache.thrift.TEnum {
ANGULAR_REGISTRY_PUSH(10),
APP_STATUS_UPDATE(11),
META_INFOS(12),
RESOURCE_PARAGRAPH_RUN_CONTEXT(13);
REMOTE_ZEPPELIN_SERVER_RESOURCE(13);
private final int value;
@ -87,7 +87,7 @@ public enum RemoteInterpreterEventType implements org.apache.thrift.TEnum {
case 12:
return META_INFOS;
case 13:
return RESOURCE_PARAGRAPH_RUN_CONTEXT;
return REMOTE_ZEPPELIN_SERVER_RESOURCE;
default:
return null;
}

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterResult.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class RemoteInterpreterResult implements org.apache.thrift.TBase<RemoteInterpreterResult, RemoteInterpreterResult._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteInterpreterResult> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteInterpreterResult");

309
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterService.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class RemoteInterpreterService {
public interface Iface {
@ -102,7 +102,7 @@ public class RemoteInterpreterService {
public RemoteApplicationResult runApplication(String applicationInstanceId) throws org.apache.thrift.TException;
public void onReceivedResourceParagraphRunners(RemoteInterpreterEvent response) throws org.apache.thrift.TException;
public void onReceivedZeppelinResource(String object) throws org.apache.thrift.TException;
}
@ -154,7 +154,7 @@ public class RemoteInterpreterService {
public void runApplication(String applicationInstanceId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void onReceivedResourceParagraphRunners(RemoteInterpreterEvent response, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void onReceivedZeppelinResource(String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
}
@ -704,23 +704,23 @@ public class RemoteInterpreterService {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "runApplication failed: unknown result");
}
public void onReceivedResourceParagraphRunners(RemoteInterpreterEvent response) throws org.apache.thrift.TException
public void onReceivedZeppelinResource(String object) throws org.apache.thrift.TException
{
send_onReceivedResourceParagraphRunners(response);
recv_onReceivedResourceParagraphRunners();
send_onReceivedZeppelinResource(object);
recv_onReceivedZeppelinResource();
}
public void send_onReceivedResourceParagraphRunners(RemoteInterpreterEvent response) throws org.apache.thrift.TException
public void send_onReceivedZeppelinResource(String object) throws org.apache.thrift.TException
{
onReceivedResourceParagraphRunners_args args = new onReceivedResourceParagraphRunners_args();
args.setResponse(response);
sendBase("onReceivedResourceParagraphRunners", args);
onReceivedZeppelinResource_args args = new onReceivedZeppelinResource_args();
args.setObject(object);
sendBase("onReceivedZeppelinResource", args);
}
public void recv_onReceivedResourceParagraphRunners() throws org.apache.thrift.TException
public void recv_onReceivedZeppelinResource() throws org.apache.thrift.TException
{
onReceivedResourceParagraphRunners_result result = new onReceivedResourceParagraphRunners_result();
receiveBase(result, "onReceivedResourceParagraphRunners");
onReceivedZeppelinResource_result result = new onReceivedZeppelinResource_result();
receiveBase(result, "onReceivedZeppelinResource");
return;
}
@ -1568,24 +1568,24 @@ public class RemoteInterpreterService {
}
}
public void onReceivedResourceParagraphRunners(RemoteInterpreterEvent response, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
public void onReceivedZeppelinResource(String object, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
checkReady();
onReceivedResourceParagraphRunners_call method_call = new onReceivedResourceParagraphRunners_call(response, resultHandler, this, ___protocolFactory, ___transport);
onReceivedZeppelinResource_call method_call = new onReceivedZeppelinResource_call(object, resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
public static class onReceivedResourceParagraphRunners_call extends org.apache.thrift.async.TAsyncMethodCall {
private RemoteInterpreterEvent response;
public onReceivedResourceParagraphRunners_call(RemoteInterpreterEvent response, 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 static class onReceivedZeppelinResource_call extends org.apache.thrift.async.TAsyncMethodCall {
private String object;
public onReceivedZeppelinResource_call(String object, 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.response = response;
this.object = object;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("onReceivedResourceParagraphRunners", org.apache.thrift.protocol.TMessageType.CALL, 0));
onReceivedResourceParagraphRunners_args args = new onReceivedResourceParagraphRunners_args();
args.setResponse(response);
prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("onReceivedZeppelinResource", org.apache.thrift.protocol.TMessageType.CALL, 0));
onReceivedZeppelinResource_args args = new onReceivedZeppelinResource_args();
args.setObject(object);
args.write(prot);
prot.writeMessageEnd();
}
@ -1596,7 +1596,7 @@ public class RemoteInterpreterService {
}
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_onReceivedResourceParagraphRunners();
(new Client(prot)).recv_onReceivedZeppelinResource();
}
}
@ -1636,7 +1636,7 @@ public class RemoteInterpreterService {
processMap.put("loadApplication", new loadApplication());
processMap.put("unloadApplication", new unloadApplication());
processMap.put("runApplication", new runApplication());
processMap.put("onReceivedResourceParagraphRunners", new onReceivedResourceParagraphRunners());
processMap.put("onReceivedZeppelinResource", new onReceivedZeppelinResource());
return processMap;
}
@ -2102,22 +2102,22 @@ public class RemoteInterpreterService {
}
}
public static class onReceivedResourceParagraphRunners<I extends Iface> extends org.apache.thrift.ProcessFunction<I, onReceivedResourceParagraphRunners_args> {
public onReceivedResourceParagraphRunners() {
super("onReceivedResourceParagraphRunners");
public static class onReceivedZeppelinResource<I extends Iface> extends org.apache.thrift.ProcessFunction<I, onReceivedZeppelinResource_args> {
public onReceivedZeppelinResource() {
super("onReceivedZeppelinResource");
}
public onReceivedResourceParagraphRunners_args getEmptyArgsInstance() {
return new onReceivedResourceParagraphRunners_args();
public onReceivedZeppelinResource_args getEmptyArgsInstance() {
return new onReceivedZeppelinResource_args();
}
protected boolean isOneway() {
return false;
}
public onReceivedResourceParagraphRunners_result getResult(I iface, onReceivedResourceParagraphRunners_args args) throws org.apache.thrift.TException {
onReceivedResourceParagraphRunners_result result = new onReceivedResourceParagraphRunners_result();
iface.onReceivedResourceParagraphRunners(args.response);
public onReceivedZeppelinResource_result getResult(I iface, onReceivedZeppelinResource_args args) throws org.apache.thrift.TException {
onReceivedZeppelinResource_result result = new onReceivedZeppelinResource_result();
iface.onReceivedZeppelinResource(args.object);
return result;
}
}
@ -2158,7 +2158,7 @@ public class RemoteInterpreterService {
processMap.put("loadApplication", new loadApplication());
processMap.put("unloadApplication", new unloadApplication());
processMap.put("runApplication", new runApplication());
processMap.put("onReceivedResourceParagraphRunners", new onReceivedResourceParagraphRunners());
processMap.put("onReceivedZeppelinResource", new onReceivedZeppelinResource());
return processMap;
}
@ -3326,20 +3326,20 @@ public class RemoteInterpreterService {
}
}
public static class onReceivedResourceParagraphRunners<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, onReceivedResourceParagraphRunners_args, Void> {
public onReceivedResourceParagraphRunners() {
super("onReceivedResourceParagraphRunners");
public static class onReceivedZeppelinResource<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, onReceivedZeppelinResource_args, Void> {
public onReceivedZeppelinResource() {
super("onReceivedZeppelinResource");
}
public onReceivedResourceParagraphRunners_args getEmptyArgsInstance() {
return new onReceivedResourceParagraphRunners_args();
public onReceivedZeppelinResource_args getEmptyArgsInstance() {
return new onReceivedZeppelinResource_args();
}
public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
final org.apache.thrift.AsyncProcessFunction fcall = this;
return new AsyncMethodCallback<Void>() {
public void onComplete(Void o) {
onReceivedResourceParagraphRunners_result result = new onReceivedResourceParagraphRunners_result();
onReceivedZeppelinResource_result result = new onReceivedZeppelinResource_result();
try {
fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid);
return;
@ -3351,7 +3351,7 @@ public class RemoteInterpreterService {
public void onError(Exception e) {
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
org.apache.thrift.TBase msg;
onReceivedResourceParagraphRunners_result result = new onReceivedResourceParagraphRunners_result();
onReceivedZeppelinResource_result result = new onReceivedZeppelinResource_result();
{
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
@ -3371,8 +3371,8 @@ public class RemoteInterpreterService {
return false;
}
public void start(I iface, onReceivedResourceParagraphRunners_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
iface.onReceivedResourceParagraphRunners(args.response,resultHandler);
public void start(I iface, onReceivedZeppelinResource_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException {
iface.onReceivedZeppelinResource(args.object,resultHandler);
}
}
@ -22129,22 +22129,22 @@ public class RemoteInterpreterService {
}
public static class onReceivedResourceParagraphRunners_args implements org.apache.thrift.TBase<onReceivedResourceParagraphRunners_args, onReceivedResourceParagraphRunners_args._Fields>, java.io.Serializable, Cloneable, Comparable<onReceivedResourceParagraphRunners_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("onReceivedResourceParagraphRunners_args");
public static class onReceivedZeppelinResource_args implements org.apache.thrift.TBase<onReceivedZeppelinResource_args, onReceivedZeppelinResource_args._Fields>, java.io.Serializable, Cloneable, Comparable<onReceivedZeppelinResource_args> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("onReceivedZeppelinResource_args");
private static final org.apache.thrift.protocol.TField RESPONSE_FIELD_DESC = new org.apache.thrift.protocol.TField("response", org.apache.thrift.protocol.TType.STRUCT, (short)1);
private static final org.apache.thrift.protocol.TField OBJECT_FIELD_DESC = new org.apache.thrift.protocol.TField("object", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
schemes.put(StandardScheme.class, new onReceivedResourceParagraphRunners_argsStandardSchemeFactory());
schemes.put(TupleScheme.class, new onReceivedResourceParagraphRunners_argsTupleSchemeFactory());
schemes.put(StandardScheme.class, new onReceivedZeppelinResource_argsStandardSchemeFactory());
schemes.put(TupleScheme.class, new onReceivedZeppelinResource_argsTupleSchemeFactory());
}
public RemoteInterpreterEvent response; // required
public String object; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
RESPONSE((short)1, "response");
OBJECT((short)1, "object");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@ -22159,8 +22159,8 @@ public class RemoteInterpreterService {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 1: // RESPONSE
return RESPONSE;
case 1: // OBJECT
return OBJECT;
default:
return null;
}
@ -22204,71 +22204,71 @@ public class RemoteInterpreterService {
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.RESPONSE, new org.apache.thrift.meta_data.FieldMetaData("response", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, RemoteInterpreterEvent.class)));
tmpMap.put(_Fields.OBJECT, new org.apache.thrift.meta_data.FieldMetaData("object", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(onReceivedResourceParagraphRunners_args.class, metaDataMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(onReceivedZeppelinResource_args.class, metaDataMap);
}
public onReceivedResourceParagraphRunners_args() {
public onReceivedZeppelinResource_args() {
}
public onReceivedResourceParagraphRunners_args(
RemoteInterpreterEvent response)
public onReceivedZeppelinResource_args(
String object)
{
this();
this.response = response;
this.object = object;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public onReceivedResourceParagraphRunners_args(onReceivedResourceParagraphRunners_args other) {
if (other.isSetResponse()) {
this.response = new RemoteInterpreterEvent(other.response);
public onReceivedZeppelinResource_args(onReceivedZeppelinResource_args other) {
if (other.isSetObject()) {
this.object = other.object;
}
}
public onReceivedResourceParagraphRunners_args deepCopy() {
return new onReceivedResourceParagraphRunners_args(this);
public onReceivedZeppelinResource_args deepCopy() {
return new onReceivedZeppelinResource_args(this);
}
@Override
public void clear() {
this.response = null;
this.object = null;
}
public RemoteInterpreterEvent getResponse() {
return this.response;
public String getObject() {
return this.object;
}
public onReceivedResourceParagraphRunners_args setResponse(RemoteInterpreterEvent response) {
this.response = response;
public onReceivedZeppelinResource_args setObject(String object) {
this.object = object;
return this;
}
public void unsetResponse() {
this.response = null;
public void unsetObject() {
this.object = null;
}
/** Returns true if field response is set (has been assigned a value) and false otherwise */
public boolean isSetResponse() {
return this.response != null;
/** Returns true if field object is set (has been assigned a value) and false otherwise */
public boolean isSetObject() {
return this.object != null;
}
public void setResponseIsSet(boolean value) {
public void setObjectIsSet(boolean value) {
if (!value) {
this.response = null;
this.object = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case RESPONSE:
case OBJECT:
if (value == null) {
unsetResponse();
unsetObject();
} else {
setResponse((RemoteInterpreterEvent)value);
setObject((String)value);
}
break;
@ -22277,8 +22277,8 @@ public class RemoteInterpreterService {
public Object getFieldValue(_Fields field) {
switch (field) {
case RESPONSE:
return getResponse();
case OBJECT:
return getObject();
}
throw new IllegalStateException();
@ -22291,8 +22291,8 @@ public class RemoteInterpreterService {
}
switch (field) {
case RESPONSE:
return isSetResponse();
case OBJECT:
return isSetObject();
}
throw new IllegalStateException();
}
@ -22301,21 +22301,21 @@ public class RemoteInterpreterService {
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof onReceivedResourceParagraphRunners_args)
return this.equals((onReceivedResourceParagraphRunners_args)that);
if (that instanceof onReceivedZeppelinResource_args)
return this.equals((onReceivedZeppelinResource_args)that);
return false;
}
public boolean equals(onReceivedResourceParagraphRunners_args that) {
public boolean equals(onReceivedZeppelinResource_args that) {
if (that == null)
return false;
boolean this_present_response = true && this.isSetResponse();
boolean that_present_response = true && that.isSetResponse();
if (this_present_response || that_present_response) {
if (!(this_present_response && that_present_response))
boolean this_present_object = true && this.isSetObject();
boolean that_present_object = true && that.isSetObject();
if (this_present_object || that_present_object) {
if (!(this_present_object && that_present_object))
return false;
if (!this.response.equals(that.response))
if (!this.object.equals(that.object))
return false;
}
@ -22326,28 +22326,28 @@ public class RemoteInterpreterService {
public int hashCode() {
List<Object> list = new ArrayList<Object>();
boolean present_response = true && (isSetResponse());
list.add(present_response);
if (present_response)
list.add(response);
boolean present_object = true && (isSetObject());
list.add(present_object);
if (present_object)
list.add(object);
return list.hashCode();
}
@Override
public int compareTo(onReceivedResourceParagraphRunners_args other) {
public int compareTo(onReceivedZeppelinResource_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = Boolean.valueOf(isSetResponse()).compareTo(other.isSetResponse());
lastComparison = Boolean.valueOf(isSetObject()).compareTo(other.isSetObject());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetResponse()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.response, other.response);
if (isSetObject()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.object, other.object);
if (lastComparison != 0) {
return lastComparison;
}
@ -22369,14 +22369,14 @@ public class RemoteInterpreterService {
@Override
public String toString() {
StringBuilder sb = new StringBuilder("onReceivedResourceParagraphRunners_args(");
StringBuilder sb = new StringBuilder("onReceivedZeppelinResource_args(");
boolean first = true;
sb.append("response:");
if (this.response == null) {
sb.append("object:");
if (this.object == null) {
sb.append("null");
} else {
sb.append(this.response);
sb.append(this.object);
}
first = false;
sb.append(")");
@ -22386,9 +22386,6 @@ public class RemoteInterpreterService {
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
if (response != null) {
response.validate();
}
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@ -22407,15 +22404,15 @@ public class RemoteInterpreterService {
}
}
private static class onReceivedResourceParagraphRunners_argsStandardSchemeFactory implements SchemeFactory {
public onReceivedResourceParagraphRunners_argsStandardScheme getScheme() {
return new onReceivedResourceParagraphRunners_argsStandardScheme();
private static class onReceivedZeppelinResource_argsStandardSchemeFactory implements SchemeFactory {
public onReceivedZeppelinResource_argsStandardScheme getScheme() {
return new onReceivedZeppelinResource_argsStandardScheme();
}
}
private static class onReceivedResourceParagraphRunners_argsStandardScheme extends StandardScheme<onReceivedResourceParagraphRunners_args> {
private static class onReceivedZeppelinResource_argsStandardScheme extends StandardScheme<onReceivedZeppelinResource_args> {
public void read(org.apache.thrift.protocol.TProtocol iprot, onReceivedResourceParagraphRunners_args struct) throws org.apache.thrift.TException {
public void read(org.apache.thrift.protocol.TProtocol iprot, onReceivedZeppelinResource_args struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@ -22425,11 +22422,10 @@ public class RemoteInterpreterService {
break;
}
switch (schemeField.id) {
case 1: // RESPONSE
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
struct.response = new RemoteInterpreterEvent();
struct.response.read(iprot);
struct.setResponseIsSet(true);
case 1: // OBJECT
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.object = iprot.readString();
struct.setObjectIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@ -22445,13 +22441,13 @@ public class RemoteInterpreterService {
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, onReceivedResourceParagraphRunners_args struct) throws org.apache.thrift.TException {
public void write(org.apache.thrift.protocol.TProtocol oprot, onReceivedZeppelinResource_args struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.response != null) {
oprot.writeFieldBegin(RESPONSE_FIELD_DESC);
struct.response.write(oprot);
if (struct.object != null) {
oprot.writeFieldBegin(OBJECT_FIELD_DESC);
oprot.writeString(struct.object);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
@ -22460,49 +22456,48 @@ public class RemoteInterpreterService {
}
private static class onReceivedResourceParagraphRunners_argsTupleSchemeFactory implements SchemeFactory {
public onReceivedResourceParagraphRunners_argsTupleScheme getScheme() {
return new onReceivedResourceParagraphRunners_argsTupleScheme();
private static class onReceivedZeppelinResource_argsTupleSchemeFactory implements SchemeFactory {
public onReceivedZeppelinResource_argsTupleScheme getScheme() {
return new onReceivedZeppelinResource_argsTupleScheme();
}
}
private static class onReceivedResourceParagraphRunners_argsTupleScheme extends TupleScheme<onReceivedResourceParagraphRunners_args> {
private static class onReceivedZeppelinResource_argsTupleScheme extends TupleScheme<onReceivedZeppelinResource_args> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, onReceivedResourceParagraphRunners_args struct) throws org.apache.thrift.TException {
public void write(org.apache.thrift.protocol.TProtocol prot, onReceivedZeppelinResource_args struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
if (struct.isSetResponse()) {
if (struct.isSetObject()) {
optionals.set(0);
}
oprot.writeBitSet(optionals, 1);
if (struct.isSetResponse()) {
struct.response.write(oprot);
if (struct.isSetObject()) {
oprot.writeString(struct.object);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, onReceivedResourceParagraphRunners_args struct) throws org.apache.thrift.TException {
public void read(org.apache.thrift.protocol.TProtocol prot, onReceivedZeppelinResource_args struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.response = new RemoteInterpreterEvent();
struct.response.read(iprot);
struct.setResponseIsSet(true);
struct.object = iprot.readString();
struct.setObjectIsSet(true);
}
}
}
}
public static class onReceivedResourceParagraphRunners_result implements org.apache.thrift.TBase<onReceivedResourceParagraphRunners_result, onReceivedResourceParagraphRunners_result._Fields>, java.io.Serializable, Cloneable, Comparable<onReceivedResourceParagraphRunners_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("onReceivedResourceParagraphRunners_result");
public static class onReceivedZeppelinResource_result implements org.apache.thrift.TBase<onReceivedZeppelinResource_result, onReceivedZeppelinResource_result._Fields>, java.io.Serializable, Cloneable, Comparable<onReceivedZeppelinResource_result> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("onReceivedZeppelinResource_result");
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
schemes.put(StandardScheme.class, new onReceivedResourceParagraphRunners_resultStandardSchemeFactory());
schemes.put(TupleScheme.class, new onReceivedResourceParagraphRunners_resultTupleSchemeFactory());
schemes.put(StandardScheme.class, new onReceivedZeppelinResource_resultStandardSchemeFactory());
schemes.put(TupleScheme.class, new onReceivedZeppelinResource_resultTupleSchemeFactory());
}
@ -22565,20 +22560,20 @@ public class RemoteInterpreterService {
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(onReceivedResourceParagraphRunners_result.class, metaDataMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(onReceivedZeppelinResource_result.class, metaDataMap);
}
public onReceivedResourceParagraphRunners_result() {
public onReceivedZeppelinResource_result() {
}
/**
* Performs a deep copy on <i>other</i>.
*/
public onReceivedResourceParagraphRunners_result(onReceivedResourceParagraphRunners_result other) {
public onReceivedZeppelinResource_result(onReceivedZeppelinResource_result other) {
}
public onReceivedResourceParagraphRunners_result deepCopy() {
return new onReceivedResourceParagraphRunners_result(this);
public onReceivedZeppelinResource_result deepCopy() {
return new onReceivedZeppelinResource_result(this);
}
@Override
@ -22611,12 +22606,12 @@ public class RemoteInterpreterService {
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof onReceivedResourceParagraphRunners_result)
return this.equals((onReceivedResourceParagraphRunners_result)that);
if (that instanceof onReceivedZeppelinResource_result)
return this.equals((onReceivedZeppelinResource_result)that);
return false;
}
public boolean equals(onReceivedResourceParagraphRunners_result that) {
public boolean equals(onReceivedZeppelinResource_result that) {
if (that == null)
return false;
@ -22631,7 +22626,7 @@ public class RemoteInterpreterService {
}
@Override
public int compareTo(onReceivedResourceParagraphRunners_result other) {
public int compareTo(onReceivedZeppelinResource_result other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
@ -22655,7 +22650,7 @@ public class RemoteInterpreterService {
@Override
public String toString() {
StringBuilder sb = new StringBuilder("onReceivedResourceParagraphRunners_result(");
StringBuilder sb = new StringBuilder("onReceivedZeppelinResource_result(");
boolean first = true;
sb.append(")");
@ -22683,15 +22678,15 @@ public class RemoteInterpreterService {
}
}
private static class onReceivedResourceParagraphRunners_resultStandardSchemeFactory implements SchemeFactory {
public onReceivedResourceParagraphRunners_resultStandardScheme getScheme() {
return new onReceivedResourceParagraphRunners_resultStandardScheme();
private static class onReceivedZeppelinResource_resultStandardSchemeFactory implements SchemeFactory {
public onReceivedZeppelinResource_resultStandardScheme getScheme() {
return new onReceivedZeppelinResource_resultStandardScheme();
}
}
private static class onReceivedResourceParagraphRunners_resultStandardScheme extends StandardScheme<onReceivedResourceParagraphRunners_result> {
private static class onReceivedZeppelinResource_resultStandardScheme extends StandardScheme<onReceivedZeppelinResource_result> {
public void read(org.apache.thrift.protocol.TProtocol iprot, onReceivedResourceParagraphRunners_result struct) throws org.apache.thrift.TException {
public void read(org.apache.thrift.protocol.TProtocol iprot, onReceivedZeppelinResource_result struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
@ -22712,7 +22707,7 @@ public class RemoteInterpreterService {
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, onReceivedResourceParagraphRunners_result struct) throws org.apache.thrift.TException {
public void write(org.apache.thrift.protocol.TProtocol oprot, onReceivedZeppelinResource_result struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@ -22722,21 +22717,21 @@ public class RemoteInterpreterService {
}
private static class onReceivedResourceParagraphRunners_resultTupleSchemeFactory implements SchemeFactory {
public onReceivedResourceParagraphRunners_resultTupleScheme getScheme() {
return new onReceivedResourceParagraphRunners_resultTupleScheme();
private static class onReceivedZeppelinResource_resultTupleSchemeFactory implements SchemeFactory {
public onReceivedZeppelinResource_resultTupleScheme getScheme() {
return new onReceivedZeppelinResource_resultTupleScheme();
}
}
private static class onReceivedResourceParagraphRunners_resultTupleScheme extends TupleScheme<onReceivedResourceParagraphRunners_result> {
private static class onReceivedZeppelinResource_resultTupleScheme extends TupleScheme<onReceivedZeppelinResource_result> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, onReceivedResourceParagraphRunners_result struct) throws org.apache.thrift.TException {
public void write(org.apache.thrift.protocol.TProtocol prot, onReceivedZeppelinResource_result struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, onReceivedResourceParagraphRunners_result struct) throws org.apache.thrift.TException {
public void read(org.apache.thrift.protocol.TProtocol prot, onReceivedZeppelinResource_result struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
}
}

520
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteZeppelinServerController.java
View file

@ -1,520 +0,0 @@
/**
* 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
*
* 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
*/
package org.apache.zeppelin.interpreter.thrift;
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;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
public class RemoteZeppelinServerController implements org.apache.thrift.TBase<RemoteZeppelinServerController, RemoteZeppelinServerController._Fields>, java.io.Serializable, Cloneable, Comparable<RemoteZeppelinServerController> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RemoteZeppelinServerController");
private static final org.apache.thrift.protocol.TField EVENT_OWNER_KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("eventOwnerKey", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
schemes.put(StandardScheme.class, new RemoteZeppelinServerControllerStandardSchemeFactory());
schemes.put(TupleScheme.class, new RemoteZeppelinServerControllerTupleSchemeFactory());
}
public String eventOwnerKey; // required
public String msg; // required
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
EVENT_OWNER_KEY((short)2, "eventOwnerKey"),
MSG((short)3, "msg");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
static {
for (_Fields field : EnumSet.allOf(_Fields.class)) {
byName.put(field.getFieldName(), field);
}
}
/**
* Find the _Fields constant that matches fieldId, or null if its not found.
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 2: // EVENT_OWNER_KEY
return EVENT_OWNER_KEY;
case 3: // MSG
return MSG;
default:
return null;
}
}
/**
* Find the _Fields constant that matches fieldId, throwing an exception
* if it is not found.
*/
public static _Fields findByThriftIdOrThrow(int fieldId) {
_Fields fields = findByThriftId(fieldId);
if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
return fields;
}
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
public static _Fields findByName(String name) {
return byName.get(name);
}
private final short _thriftId;
private final String _fieldName;
_Fields(short thriftId, String fieldName) {
_thriftId = thriftId;
_fieldName = fieldName;
}
public short getThriftFieldId() {
return _thriftId;
}
public String getFieldName() {
return _fieldName;
}
}
// isset id assignments
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.EVENT_OWNER_KEY, new org.apache.thrift.meta_data.FieldMetaData("eventOwnerKey", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RemoteZeppelinServerController.class, metaDataMap);
}
public RemoteZeppelinServerController() {
}
public RemoteZeppelinServerController(
String eventOwnerKey,
String msg)
{
this();
this.eventOwnerKey = eventOwnerKey;
this.msg = msg;
}
/**
* Performs a deep copy on <i>other</i>.
*/
public RemoteZeppelinServerController(RemoteZeppelinServerController other) {
if (other.isSetEventOwnerKey()) {
this.eventOwnerKey = other.eventOwnerKey;
}
if (other.isSetMsg()) {
this.msg = other.msg;
}
}
public RemoteZeppelinServerController deepCopy() {
return new RemoteZeppelinServerController(this);
}
@Override
public void clear() {
this.eventOwnerKey = null;
this.msg = null;
}
public String getEventOwnerKey() {
return this.eventOwnerKey;
}
public RemoteZeppelinServerController setEventOwnerKey(String eventOwnerKey) {
this.eventOwnerKey = eventOwnerKey;
return this;
}
public void unsetEventOwnerKey() {
this.eventOwnerKey = null;
}
/** Returns true if field eventOwnerKey is set (has been assigned a value) and false otherwise */
public boolean isSetEventOwnerKey() {
return this.eventOwnerKey != null;
}
public void setEventOwnerKeyIsSet(boolean value) {
if (!value) {
this.eventOwnerKey = null;
}
}
public String getMsg() {
return this.msg;
}
public RemoteZeppelinServerController setMsg(String msg) {
this.msg = msg;
return this;
}
public void unsetMsg() {
this.msg = null;
}
/** Returns true if field msg is set (has been assigned a value) and false otherwise */
public boolean isSetMsg() {
return this.msg != null;
}
public void setMsgIsSet(boolean value) {
if (!value) {
this.msg = null;
}
}
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case EVENT_OWNER_KEY:
if (value == null) {
unsetEventOwnerKey();
} else {
setEventOwnerKey((String)value);
}
break;
case MSG:
if (value == null) {
unsetMsg();
} else {
setMsg((String)value);
}
break;
}
}
public Object getFieldValue(_Fields field) {
switch (field) {
case EVENT_OWNER_KEY:
return getEventOwnerKey();
case MSG:
return getMsg();
}
throw new IllegalStateException();
}
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
public boolean isSet(_Fields field) {
if (field == null) {
throw new IllegalArgumentException();
}
switch (field) {
case EVENT_OWNER_KEY:
return isSetEventOwnerKey();
case MSG:
return isSetMsg();
}
throw new IllegalStateException();
}
@Override
public boolean equals(Object that) {
if (that == null)
return false;
if (that instanceof RemoteZeppelinServerController)
return this.equals((RemoteZeppelinServerController)that);
return false;
}
public boolean equals(RemoteZeppelinServerController that) {
if (that == null)
return false;
boolean this_present_eventOwnerKey = true && this.isSetEventOwnerKey();
boolean that_present_eventOwnerKey = true && that.isSetEventOwnerKey();
if (this_present_eventOwnerKey || that_present_eventOwnerKey) {
if (!(this_present_eventOwnerKey && that_present_eventOwnerKey))
return false;
if (!this.eventOwnerKey.equals(that.eventOwnerKey))
return false;
}
boolean this_present_msg = true && this.isSetMsg();
boolean that_present_msg = true && that.isSetMsg();
if (this_present_msg || that_present_msg) {
if (!(this_present_msg && that_present_msg))
return false;
if (!this.msg.equals(that.msg))
return false;
}
return true;
}
@Override
public int hashCode() {
List<Object> list = new ArrayList<Object>();
boolean present_eventOwnerKey = true && (isSetEventOwnerKey());
list.add(present_eventOwnerKey);
if (present_eventOwnerKey)
list.add(eventOwnerKey);
boolean present_msg = true && (isSetMsg());
list.add(present_msg);
if (present_msg)
list.add(msg);
return list.hashCode();
}
@Override
public int compareTo(RemoteZeppelinServerController other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
lastComparison = Boolean.valueOf(isSetEventOwnerKey()).compareTo(other.isSetEventOwnerKey());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetEventOwnerKey()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.eventOwnerKey, other.eventOwnerKey);
if (lastComparison != 0) {
return lastComparison;
}
}
lastComparison = Boolean.valueOf(isSetMsg()).compareTo(other.isSetMsg());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetMsg()) {
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg);
if (lastComparison != 0) {
return lastComparison;
}
}
return 0;
}
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
}
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder("RemoteZeppelinServerController(");
boolean first = true;
sb.append("eventOwnerKey:");
if (this.eventOwnerKey == null) {
sb.append("null");
} else {
sb.append(this.eventOwnerKey);
}
first = false;
if (!first) sb.append(", ");
sb.append("msg:");
if (this.msg == null) {
sb.append("null");
} else {
sb.append(this.msg);
}
first = false;
sb.append(")");
return sb.toString();
}
public void validate() throws org.apache.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
try {
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
} catch (org.apache.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private static class RemoteZeppelinServerControllerStandardSchemeFactory implements SchemeFactory {
public RemoteZeppelinServerControllerStandardScheme getScheme() {
return new RemoteZeppelinServerControllerStandardScheme();
}
}
private static class RemoteZeppelinServerControllerStandardScheme extends StandardScheme<RemoteZeppelinServerController> {
public void read(org.apache.thrift.protocol.TProtocol iprot, RemoteZeppelinServerController struct) throws org.apache.thrift.TException {
org.apache.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 2: // EVENT_OWNER_KEY
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.eventOwnerKey = iprot.readString();
struct.setEventOwnerKeyIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
case 3: // MSG
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
struct.msg = iprot.readString();
struct.setMsgIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
iprot.readFieldEnd();
}
iprot.readStructEnd();
// check for required fields of primitive type, which can't be checked in the validate method
struct.validate();
}
public void write(org.apache.thrift.protocol.TProtocol oprot, RemoteZeppelinServerController struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.eventOwnerKey != null) {
oprot.writeFieldBegin(EVENT_OWNER_KEY_FIELD_DESC);
oprot.writeString(struct.eventOwnerKey);
oprot.writeFieldEnd();
}
if (struct.msg != null) {
oprot.writeFieldBegin(MSG_FIELD_DESC);
oprot.writeString(struct.msg);
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}
}
private static class RemoteZeppelinServerControllerTupleSchemeFactory implements SchemeFactory {
public RemoteZeppelinServerControllerTupleScheme getScheme() {
return new RemoteZeppelinServerControllerTupleScheme();
}
}
private static class RemoteZeppelinServerControllerTupleScheme extends TupleScheme<RemoteZeppelinServerController> {
@Override
public void write(org.apache.thrift.protocol.TProtocol prot, RemoteZeppelinServerController struct) throws org.apache.thrift.TException {
TTupleProtocol oprot = (TTupleProtocol) prot;
BitSet optionals = new BitSet();
if (struct.isSetEventOwnerKey()) {
optionals.set(0);
}
if (struct.isSetMsg()) {
optionals.set(1);
}
oprot.writeBitSet(optionals, 2);
if (struct.isSetEventOwnerKey()) {
oprot.writeString(struct.eventOwnerKey);
}
if (struct.isSetMsg()) {
oprot.writeString(struct.msg);
}
}
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, RemoteZeppelinServerController struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.eventOwnerKey = iprot.readString();
struct.setEventOwnerKeyIsSet(true);
}
if (incoming.get(1)) {
struct.msg = iprot.readString();
struct.setMsgIsSet(true);
}
}
}
}

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/ZeppelinServerResourceParagraphRunner.java
View file

@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-18")
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2016-11-24")
public class ZeppelinServerResourceParagraphRunner implements org.apache.thrift.TBase<ZeppelinServerResourceParagraphRunner, ZeppelinServerResourceParagraphRunner._Fields>, java.io.Serializable, Cloneable, Comparable<ZeppelinServerResourceParagraphRunner> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ZeppelinServerResourceParagraphRunner");

9
zeppelin-interpreter/src/main/thrift/RemoteInterpreterService.thrift
View file

@ -51,7 +51,7 @@ enum RemoteInterpreterEventType {
ANGULAR_REGISTRY_PUSH = 10,
APP_STATUS_UPDATE = 11,
META_INFOS = 12,
RESOURCE_PARAGRAPH_RUN_CONTEXT = 13
REMOTE_ZEPPELIN_SERVER_RESOURCE = 13
}
@ -70,11 +70,6 @@ struct ZeppelinServerResourceParagraphRunner {
2: string paragraphId
}
struct RemoteZeppelinServerController {
2: string eventOwnerKey
3: string msg
}
/*
* The below variables(name, value) will be connected to getCompletions in paragraph.controller.js
*
@ -123,5 +118,5 @@ service RemoteInterpreterService {
RemoteApplicationResult unloadApplication(1: string applicationInstanceId);
RemoteApplicationResult runApplication(1: string applicationInstanceId);
void onReceivedResourceParagraphRunners(1: RemoteInterpreterEvent response);
void onReceivedZeppelinResource(1: string object);
}

1
zeppelin-server/src/test/java/org/apache/zeppelin/interpreter/mock/MockInterpreter1.java
View file

@ -24,7 +24,6 @@ import java.util.Properties;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;

1
zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/mock/MockInterpreter1.java
View file

@ -25,7 +25,6 @@ import java.util.Properties;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;

1
zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/mock/MockInterpreter11.java
View file

@ -25,7 +25,6 @@ import java.util.Properties;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;

1
zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/mock/MockInterpreter2.java
View file

@ -25,7 +25,6 @@ import java.util.Properties;
import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterResult;
import org.apache.zeppelin.interpreter.RemoteWorksController;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.scheduler.Scheduler;
import org.apache.zeppelin.scheduler.SchedulerFactory;