Merge pull request #364 from NFLabs/new/separate_process_interpreter Run interpreter on separate JVM
Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/6f100f53 Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/6f100f53 Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/6f100f53 Branch: refs/heads/master Commit: 6f100f537428aff6093146caf09411513927f4b5 Parents: 135117b a3df56a Author: Lee moon soo <[email protected]> Authored: Sat Mar 14 02:26:49 2015 +0900 Committer: Lee moon soo <[email protected]> Committed: Sat Mar 14 02:26:49 2015 +0900 ---------------------------------------------------------------------- bin/common.sh | 16 +- bin/interpreter.sh | 85 + bin/zeppelin-daemon.sh | 30 +- conf/zeppelin-env.sh.template | 2 + markdown/pom.xml | 2 +- .../com/nflabs/zeppelin/markdown/Markdown.java | 8 - pom.xml | 2 + shell/pom.xml | 2 +- .../nflabs/zeppelin/shell/ShellInterpreter.java | 7 - spark/pom.xml | 5 +- .../nflabs/zeppelin/spark/DepInterpreter.java | 30 +- .../nflabs/zeppelin/spark/SparkInterpreter.java | 28 +- .../zeppelin/spark/SparkSqlInterpreter.java | 39 +- .../nflabs/zeppelin/spark/ZeppelinContext.java | 20 +- .../com/nflabs/zeppelin/spark/dep/Booter.java | 24 +- .../zeppelin/spark/dep/DependencyContext.java | 6 +- .../zeppelin/spark/dep/DependencyResolver.java | 5 +- .../zeppelin/spark/DepInterpreterTest.java | 5 +- .../zeppelin/spark/SparkInterpreterTest.java | 5 +- .../zeppelin/spark/SparkSqlInterpreterTest.java | 5 +- zeppelin-interpreter/pom.xml | 60 + .../java/com/nflabs/zeppelin/display/GUI.java | 68 + .../java/com/nflabs/zeppelin/display/Input.java | 458 + .../interpreter/ClassloaderInterpreter.java | 261 + .../zeppelin/interpreter/Interpreter.java | 267 + .../interpreter/InterpreterContext.java | 51 + .../interpreter/InterpreterException.java | 17 + .../zeppelin/interpreter/InterpreterGroup.java | 48 + .../interpreter/InterpreterProperty.java | 32 + .../interpreter/InterpreterPropertyBuilder.java | 20 + .../zeppelin/interpreter/InterpreterResult.java | 120 + .../interpreter/LazyOpenInterpreter.java | 132 + .../interpreter/WrappedInterpreter.java | 8 + .../interpreter/remote/ClientFactory.java | 63 + .../interpreter/remote/RemoteInterpreter.java | 337 + .../remote/RemoteInterpreterProcess.java | 192 + .../remote/RemoteInterpreterServer.java | 323 + .../remote/RemoteInterpreterUtils.java | 32 + .../thrift/RemoteInterpreterContext.java | 786 ++ .../thrift/RemoteInterpreterResult.java | 786 ++ .../thrift/RemoteInterpreterService.java | 8174 ++++++++++++++++++ .../zeppelin/scheduler/FIFOScheduler.java | 134 + .../java/com/nflabs/zeppelin/scheduler/Job.java | 240 + .../nflabs/zeppelin/scheduler/JobListener.java | 15 + .../zeppelin/scheduler/JobProgressPoller.java | 50 + .../zeppelin/scheduler/ParallelScheduler.java | 162 + .../zeppelin/scheduler/RemoteScheduler.java | 286 + .../nflabs/zeppelin/scheduler/Scheduler.java | 21 + .../zeppelin/scheduler/SchedulerFactory.java | 129 + .../zeppelin/scheduler/SchedulerListener.java | 13 + .../main/thrift/RemoteInterpreterService.thrift | 33 + .../com/nflabs/zeppelin/display/InputTest.java | 24 + .../remote/RemoteInterpreterProcessTest.java | 46 + .../remote/RemoteInterpreterServerTest.java | 57 + .../remote/RemoteInterpreterTest.java | 156 + .../remote/RemoteInterpreterUtilsTest.java | 16 + .../remote/mock/MockInterpreterA.java | 72 + .../remote/mock/MockInterpreterB.java | 80 + .../zeppelin/scheduler/FIFOSchedulerTest.java | 74 + .../scheduler/ParallelSchedulerTest.java | 49 + .../zeppelin/scheduler/RemoteSchedulerTest.java | 90 + .../nflabs/zeppelin/scheduler/SleepingJob.java | 51 + .../src/test/resources/log4j.properties | 12 + .../zeppelin/rest/InterpreterRestApi.java | 11 +- .../message/NewInterpreterSettingRequest.java | 11 +- .../UpdateInterpreterSettingRequest.java | 28 + .../nflabs/zeppelin/server/ZeppelinServer.java | 47 +- .../nflabs/zeppelin/socket/NotebookServer.java | 2 +- .../app/scripts/controllers/interpreter.js | 20 +- zeppelin-zengine/pom.xml | 6 + .../zeppelin/conf/ZeppelinConfiguration.java | 5 + .../interpreter/ClassloaderInterpreter.java | 288 - .../zeppelin/interpreter/Interpreter.java | 187 - .../interpreter/InterpreterContext.java | 22 - .../interpreter/InterpreterException.java | 17 - .../interpreter/InterpreterFactory.java | 125 +- .../zeppelin/interpreter/InterpreterGroup.java | 31 - .../interpreter/InterpreterInfoSaving.java | 12 + .../zeppelin/interpreter/InterpreterOption.java | 24 + .../interpreter/InterpreterProperty.java | 32 - .../interpreter/InterpreterPropertyBuilder.java | 20 - .../zeppelin/interpreter/InterpreterResult.java | 114 - .../interpreter/InterpreterSerializer.java | 14 +- .../interpreter/InterpreterSetting.java | 23 +- .../interpreter/LazyOpenInterpreter.java | 138 - .../interpreter/WrappedInterpreter.java | 8 - .../com/nflabs/zeppelin/notebook/Paragraph.java | 24 +- .../nflabs/zeppelin/notebook/form/Input.java | 458 - .../nflabs/zeppelin/notebook/form/Setting.java | 70 - .../zeppelin/scheduler/FIFOScheduler.java | 106 - .../java/com/nflabs/zeppelin/scheduler/Job.java | 240 - .../nflabs/zeppelin/scheduler/JobListener.java | 15 - .../zeppelin/scheduler/JobProgressPoller.java | 50 - .../zeppelin/scheduler/ParallelScheduler.java | 129 - .../nflabs/zeppelin/scheduler/Scheduler.java | 21 - .../zeppelin/scheduler/SchedulerFactory.java | 105 - .../zeppelin/scheduler/SchedulerListener.java | 13 - .../interpreter/InterpreterFactoryTest.java | 27 +- .../interpreter/mock/MockInterpreter1.java | 10 - .../interpreter/mock/MockInterpreter2.java | 10 - .../nflabs/zeppelin/notebook/NotebookTest.java | 46 +- .../zeppelin/notebook/form/InputTest.java | 24 - .../zeppelin/scheduler/FIFOSchedulerTest.java | 72 - .../scheduler/ParallelSchedulerTest.java | 49 - .../nflabs/zeppelin/scheduler/SleepingJob.java | 51 - 105 files changed, 14581 insertions(+), 2495 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/6f100f53/bin/common.sh ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/6f100f53/bin/zeppelin-daemon.sh ----------------------------------------------------------------------
