This is an automated email from the ASF dual-hosted git repository. zjffdu pushed a change to branch web_angular in repository https://gitbox.apache.org/repos/asf/zeppelin.git.
discard 6bdd971 [ZEPPELIN-4503] Support note scope dynamic forms discard 44f2a78 [ZEPPELIN-4502] Adjust global styles and theming the visualization discard b1a1957 [ZEPPELIN-4501] Use secondary entry imports discard 762a8cd [ZEPPELIN-4398] Add notebook repository page discard cc45a8b [ZEPPELIN-4399] Add credential page discard cad960d [ZEPPELIN-4401] Add configuration page discard 404852e [ZEPPELIN-4403] Support publishable for paragraph discard 831c6ef [ZEPPELIN-4450] Provide Angular.js Template Migration Tool omit c513681 [ZEPPELIN-4321] Support shortcuts for the paragraphs omit b6244f2 [ZEPPELIN-4321] Rework Zeppelin with Latest Angular add 8f331c8 [HOTFIX][DOCS] Fix format of PYSPARK_PYTHON & PYSPARK_DRIVER_PYTHON add 7c00e51 [ZEPPELIN-4386] Resource.invokeMethod() doesn't find the right method to call add 3a4bedc [ZEPPELIN-3548] KSQL Interpreter for Zeppelin add 0566354 [ZEPPELIN-4375]. Add more flink tutorial notes add 5806756 [ZEPPELIN-4354]. Enhance z.angular for more flexiable data sharing add 79197d9 [ZEPPELIN-4341] update getRoles to handle any upstream exception add a22eba2 [ZEPPELIN-4389]. Add new interpreter if it is newly detected in interpreter folder add 64bf4bb [ZEPPELIN-4390]. ExecutorService is not properly shutdown add e590e4c [ZEPPELIN-4411] Added current notebook location and name to ui header add 5750a98 [ZEPPELIN-4410] Added exception handling when converting old notebooks to newer format add 527a69b [ZEPPELIN-4436]. Interpreter PID file should contain interpreter group id add bf3a0ee [ZEPPELIN-4396]. HvPlot is broken add 660c476 [ZEPPELIN-3644] SPARQL-Interpreter support via Apache Jena ARQ add 275b621 ZEPPELIN-3617. Allow to specify saving resourceName as paragraph property add 7a07454 [ZEPPELIN-4417]. Logging Interpreter launch command in log4j add 7fa7e91 [ZEPPELIN-4416]. Don't merge properties from inteprreter-setting.json if it already exists add 83006c2 [HOTFIX] Disable test GCSNotebookRepoTest add 2b251b6 [ZEPPELIN-4419]. Align functions in ZeppelinContext of Scala/Python/R add a15b8f6 [ZEPPELIN-4373]. Specify ZEPPELIN_ADDR to 0.0.0.0 in Dockerfile add ee2613f [ZEPPELIN-4323] Kotlin support for Spark interpreter add 9bdcae2 [ZEPPELIN-4448] delete unused variable in ZeppelinServer.java add 28187a6 [ZEPPELIN-4408] Return exception message when Interpreter code is incomplete add 99ebf07 [HOTFIX] Fix test fails after ZEPPELIN-4408 add dcae640 [ZEPPELIN-3916] Fix bug - notebook icon can not hide correctly when move inside the tooltip add d9be35d Bump jackson-databind from 2.9.9.1 to 2.9.10.1 in /zeppelin-server add 27ff90f Bump netty-all from 4.1.1.Final to 4.1.42.Final in /beam add b4e297d Bump lodash from 3.9.3 to 4.17.15 in /zeppelin-web/src/app/visualization add 8c8dbc3 Bump lodash from 3.9.3 to 4.17.15 in /zeppelin-web/src/app/tabledata add 02e3389 [ZEPPELIN-4456]. Travis CI fails add d344b78 [ZEPPELIN-4428] Fix bug - Highlighted line number disappears add 2305024 [ZEPPELIN-4323] Fix Kotlin interpreter documentation page add e97edf6 [ZEPPELIN-3644] fixed sparql interpreter documentation add 4d9a2d0 [ZEPPELIN-4449] Fix Credentials update errors add b896e6f [security] Fix spark interpreter command injection add c2f9c72 ZEPPELIN-4466. Cron is not enabled after configuration is changed add b0e45ef [ZEPPELIN-4443]. Unclear message when R is not installed add edfe3eb [minor] Minor code clean add 697addb [ZEPPELIN-4462] Upgrade commons-beanutils to 1.9.4 add eab9a52 [ZEPPELIN-4472] Upgrade Shiro to 1.4.2 to fix CVEs add 6ed42d2 [ZEPPELIN-4444] Fix schema disagreement when execute DDL statements add 86d37fe [hotfix] Fix test fail add 32e2231 [MINOR] Fix notebook filter search add 04b3f47 [ZEPPELIN-4469]. Cron is disabled after zeppelin restart add a92aac2 [ZEPPELIN-4464] Fix Regression in InterpreterSetting isUserAuthorized add af25f00 ZEPPELIN-4463. Remove table name prefix in column name add bbdc641 [ZEPPELIN-4476] Running Trash Restore will result in an error add 116f4ea [ZEPPELIN-4468]. Allow user to set form type via interpreter local properties add e27bef1 [ZEPPELIN-4475]. Spark job progress is not correct add 106f127 [ZEPPELIN-4471] Add HTTP security header X-Content-Type-Options add f2d1d4f [ZEPPELIN-4446]. Allow to show/hide dynamics forms of paragraph add a9ebfb4 [hotfix] error message is duplicated add dd19599 [hotfix] Fix ci failure due to pty4j is missing add 3e18659 [ZEPPELIN-4487] Fix quartz url. add c07a52b [ZEPPELIN-4301] js double precision loss problem add a8b8ca4 ZEPPELIN-4483. Job stautus in zeppelin server side may be always in RUNNING while the job is finished in interpreter process add d66065e [ZEPPELIN-4489] remove zeppelin.anonymous.allowed configuration add 9320d14 [ZEPPELIN-4474]. Move r interpreter of spark into a separated interpreter add e7e45a5 [ZEPPELIN-4480]. Move the ipython code into a general jupyter kernel bridge add 14f2b76 [MINOR] Use the deprecated setSoLingerTime Jetty method, a warning is displayed add 1a6bce6 ZEPPELIN-4437. Update python document add 3fdc590 [ZEPPELIN-4497] Change zeppelin-jupyter-adapter to zeppelin-jupyter-interpreter add 409ef7b [ZEPPELIN-4499]. Corrupted note make all the notes unavailable add 13d3912 [ZEPPELIN-4508]. Completion doesn't work in jupyter interpreter add 95420bf [ZEPPELIN-4500] Refactor getEditorSetting by leverage the paragraph local properties add e9cae61 [ZEPPELIN-4509]. Make JupyterKernelInterpreter extends AbstractInterpreter add aea44a4 [ZEPPELIN-4512]. Move SqlSplitter from jdbc interpreter to zeppelin-interpreter new 896b8dd [ZEPPELIN-4321] Rework Zeppelin with Latest Angular new 27bbeb5 [ZEPPELIN-4321] Support shortcuts for the paragraphs new 983cf40 [ZEPPELIN-4450] Provide Angular.js Template Migration Tool new 7d53c2b [ZEPPELIN-4403] Support publishable for paragraph new f8cc53a [ZEPPELIN-4401] Add configuration page new d41431b [ZEPPELIN-4399] Add credential page new 4fd25c7 [ZEPPELIN-4398] Add notebook repository page new c5658b2 [ZEPPELIN-4501] Use secondary entry imports new 7080953 [ZEPPELIN-4502] Adjust global styles and theming the visualization new ff7938f [ZEPPELIN-4503] Support note scope dynamic forms This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (6bdd971) \ N -- N -- N refs/heads/web_angular (ff7938f) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 10 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .travis.yml | 20 +- LICENSE | 1 + beam/pom.xml | 2 +- bin/common.sh | 2 +- bin/interpreter.sh | 2 +- .../zeppelin/cassandra/EnhancedSession.scala | 43 +- .../zeppelin/cassandra/InterpreterLogic.scala | 4 +- .../zeppelin/cassandra/InterpreterLogicTest.java | 2 +- .../zeppelin/cassandra/EnhancedSessionTest.scala | 74 + conf/interpreter-list | 2 + conf/zeppelin-site.xml.template | 14 +- docs/_includes/themes/zeppelin/_navigation.html | 2 + .../img/docs-img/ipython_code_completion.png | Bin 0 -> 56915 bytes .../themes/zeppelin/img/docs-img/ipython_error.png | Bin 0 -> 57506 bytes .../zeppelin/img/docs-img/ipython_hvplot.png | Bin 0 -> 293938 bytes .../assets/themes/zeppelin/img/docs-img/ksql.1.png | Bin 0 -> 197688 bytes .../assets/themes/zeppelin/img/docs-img/ksql.2.png | Bin 0 -> 133453 bytes .../assets/themes/zeppelin/img/docs-img/ksql.3.png | Bin 0 -> 235272 bytes .../zeppelin/img/docs-img/sparql-example.png | Bin 0 -> 68474 bytes docs/index.md | 2 + docs/interpreter/flink.md | 35 +- docs/interpreter/kotlin.md | 84 + docs/interpreter/ksql.md | 78 + docs/interpreter/python.md | 462 +- docs/interpreter/spark.md | 15 +- docs/interpreter/sparql.md | 71 + docs/setup/operation/configuration.md | 6 - docs/setup/operation/upgrading.md | 7 +- docs/setup/security/http_security_headers.md | 14 + docs/setup/security/shiro_authentication.md | 7 +- docs/usage/interpreter/installation.md | 10 + docs/usage/rest_api/configuration.md | 1 - .../apache/zeppelin/flink/IPyFlinkInterpreter.java | 4 +- .../org/apache/zeppelin/jdbc/JDBCInterpreter.java | 96 +- .../apache/zeppelin/jdbc/JDBCInterpreterTest.java | 4 +- kotlin/README.md | 83 + kotlin/pom.xml | 125 + .../apache/zeppelin/kotlin/KotlinInterpreter.java | 189 + .../kotlin/completion/KotlinCompleter.java | 68 + .../zeppelin/kotlin/completion/KotlinKeywords.java | 104 + .../zeppelin/kotlin/context/KotlinReceiver.java | 34 +- .../zeppelin/kotlin/reflect/ContextUpdater.java | 160 + .../kotlin/reflect/KotlinFunctionInfo.java | 69 + .../zeppelin/kotlin/reflect/KotlinReflectUtil.java | 28 +- .../kotlin/reflect/KotlinVariableInfo.java | 60 + .../apache/zeppelin/kotlin/repl/ClassWriter.java | 91 + .../apache/zeppelin/kotlin/repl/KotlinRepl.java | 272 + .../kotlin/repl/building/KotlinReplProperties.java | 129 + .../kotlin/repl/building/ReplBuilding.java | 108 + kotlin/src/main/resources/interpreter-setting.json | 28 + .../zeppelin/kotlin/KotlinInterpreterTest.java | 326 + ksql/README.md | 10 + ksql/pom.xml | 93 + .../apache/zeppelin/ksql/BasicKSQLHttpClient.java | 175 + .../org/apache/zeppelin/ksql/KSQLInterpreter.java | 169 + .../java/org/apache/zeppelin/ksql/KSQLRequest.java | 51 + .../org/apache/zeppelin/ksql/KSQLResponse.java | 86 + .../org/apache/zeppelin/ksql/KSQLRestService.java | 257 + ksql/src/main/resources/interpreter-setting.json | 21 + .../apache/zeppelin/ksql/KSQLInterpreterTest.java | 169 + .../Flink Batch Tutorial_2EN1E1ATY.zpln | 602 + .../Flink Stream Tutorial_2ER62Y5VJ.zpln | 427 + pom.xml | 58 +- python/pom.xml | 25 +- .../apache/zeppelin/python/IPythonInterpreter.java | 379 +- .../apache/zeppelin/python/PythonInterpreter.java | 4 +- .../src/main/resources/python/zeppelin_context.py | 78 +- .../zeppelin_ipython.py} | 0 .../zeppelin/python/BasePythonInterpreterTest.java | 4 +- .../zeppelin/python/IPythonInterpreterTest.java | 124 +- python/src/test/resources/log4j.properties | 5 +- rlang/pom.xml | 188 + .../java/org/apache/zeppelin/r/RInterpreter.java | 205 + .../org/apache/zeppelin/r/RZeppelinContext.java | 34 +- .../java/org/apache/zeppelin/r/SparkRBackend.java | 90 + .../java/org/apache/zeppelin/r}/ZeppelinR.java | 390 +- .../org/apache/zeppelin/r/ZeppelinRDisplay.java | 147 + .../src/main/resources/R/zeppelin_sparkr.R | 86 +- rlang/src/main/resources/interpreter-setting.json | 37 + .../org/apache/zeppelin/r/RInterpreterTest.java | 131 + .../src/test/resources/log4j.properties | 3 - scalding/pom.xml | 7 + scripts/docker/zeppelin/bin/Dockerfile | 4 +- spark/interpreter/pom.xml | 20 +- .../apache/zeppelin/spark/IPySparkInterpreter.java | 6 +- .../zeppelin/spark/KotlinSparkInterpreter.java | 198 + .../apache/zeppelin/spark/PySparkInterpreter.java | 1 + .../apache/zeppelin/spark/SparkRInterpreter.java | 140 +- .../spark/kotlin/KotlinZeppelinBindings.java | 52 + .../zeppelin/spark/kotlin/SparkKotlinReceiver.java | 43 + .../src/main/resources/interpreter-setting.json | 34 + .../scala/org/apache/spark/SparkRBackend.scala | 61 - .../apache/zeppelin/spark/ZeppelinRDisplay.scala | 117 - .../apache/zeppelin/spark/utils/DisplayUtils.scala | 90 - .../zeppelin/spark/IPySparkInterpreterTest.java | 40 +- .../zeppelin/spark/KotlinSparkInterpreterTest.java | 246 + .../zeppelin/spark/SparkInterpreterTest.java | 5 +- .../zeppelin/spark/SparkRInterpreterTest.java | 33 +- .../org/apache/zeppelin/spark/SparkShimsTest.java | 9 +- .../src/test/resources/log4j.properties | 6 +- .../spark/utils/DisplayFunctionsTest.scala | 173 - .../zeppelin/spark/BaseSparkScalaInterpreter.scala | 15 +- .../apache/zeppelin/spark/JobProgressUtil.scala | 34 +- .../zeppelin/spark/SparkZeppelinContext.scala | 187 +- .../org/apache/zeppelin/spark/SparkShims.java | 18 +- .../org/apache/zeppelin/spark/Spark1Shims.java | 29 +- .../org/apache/zeppelin/spark/Spark2Shims.java | 27 +- sparql/pom.xml | 80 + .../apache/zeppelin/sparql/JenaInterpreter.java | 143 + .../org/apache/zeppelin/sparql/SparqlEngine.java | 25 +- .../apache/zeppelin/sparql/SparqlInterpreter.java | 107 + sparql/src/main/resources/interpreter-setting.json | 42 + .../zeppelin/sparql/SparqlJenaEngineTest.java | 198 + sparql/src/test/resources/data.ttl | 18 + submarine/pom.xml | 8 + .../zeppelin/submarine/SubmarineInterpreter.java | 2 +- testing/install_external_dependencies.sh | 12 +- zeppelin-distribution/pom.xml | 19 +- zeppelin-distribution/src/bin_license/LICENSE | 3 +- .../integration/InterpreterModeActionsIT.java | 2 +- .../zeppelin/integration/ParagraphActionsIT.java | 2 +- zeppelin-interpreter-integration/pom.xml | 4 + .../zeppelin/integration/JdbcIntegrationTest.java | 23 + .../integration/ZeppelinSparkClusterTest.java | 268 +- .../src/test/resources/log4j.properties | 3 - zeppelin-interpreter-parent/pom.xml | 13 +- .../zeppelin/conf/ZeppelinConfiguration.java | 17 +- .../zeppelin/display/AngularObjectRegistry.java | 4 +- .../main/java/org/apache/zeppelin/display/GUI.java | 12 +- .../java/org/apache/zeppelin/display/Input.java | 26 +- .../zeppelin/interpreter/BaseZeppelinContext.java | 401 +- .../zeppelin/interpreter/InterpreterGroup.java | 1 + .../interpreter/launcher/InterpreterLauncher.java | 13 + .../remote/RemoteInterpreterServer.java | 36 +- .../zeppelin/interpreter/util/ProcessLauncher.java | 19 +- .../zeppelin/interpreter/util/SqlSplitter.java | 164 + .../zeppelin/resource/DistributedResourcePool.java | 2 + .../org/apache/zeppelin/resource/Resource.java | 51 +- .../org/apache/zeppelin/resource/ResourceId.java | 1 + .../zeppelin/scheduler/AbstractScheduler.java | 39 +- .../apache/zeppelin/scheduler/FIFOScheduler.java | 12 +- .../zeppelin/scheduler/SchedulerFactory.java | 9 +- .../java/org/apache/zeppelin/display/GUITest.java | 10 +- .../launcher/InterpreterLauncherTest.java} | 26 +- .../zeppelin/interpreter/util/SqlSplitterTest.java | 286 + .../org/apache/zeppelin/resource/ResourceTest.java | 13 +- {python => zeppelin-jupyter-interpreter}/pom.xml | 84 +- .../zeppelin/jupyter/JupyterInterpreter.java | 130 + .../zeppelin/jupyter/JupyterKernelClient.java | 58 +- .../zeppelin/jupyter/JupyterKernelInterpreter.java | 355 + .../zeppelin/jupyter/JupyterZeppelinContext.java | 37 +- .../src/main/proto/kernel.proto | 108 + .../src/main/resources/grpc/generate_rpc.sh | 2 +- .../main/resources/grpc/jupyter/kernel_client.py | 10 +- .../src/main/resources/grpc/jupyter/kernel_pb2.py | 181 +- .../main/resources/grpc/jupyter/kernel_pb2_grpc.py | 71 +- .../main/resources/grpc/jupyter/kernel_server.py | 82 +- .../src/main/resources/interpreter-setting.json | 15 + .../apache/zeppelin/jupyter/IPythonKernelTest.java | 225 +- .../notebook/repo/FileSystemNotebookRepoTest.java | 1 + .../notebook/repo/GCSNotebookRepoTest.java | 3 + .../zeppelin/notebook/repo/MongoNotebookRepo.java | 2 +- .../notebook/repo/OldMongoNotebookRepo.java | 2 +- .../zeppelin/notebook/repo/OldS3NotebookRepo.java | 4 +- zeppelin-server/pom.xml | 4 +- .../java/org/apache/zeppelin/realm/LdapRealm.java | 4 +- .../org/apache/zeppelin/rest/HeliumRestApi.java | 17 +- .../org/apache/zeppelin/rest/NotebookRestApi.java | 1 + .../org/apache/zeppelin/server/CorsFilter.java | 1 + .../org/apache/zeppelin/server/ZeppelinServer.java | 3 - .../apache/zeppelin/service/JobManagerService.java | 3 + .../apache/zeppelin/service/NotebookService.java | 19 +- .../org/apache/zeppelin/socket/NotebookServer.java | 124 +- .../zeppelin/utils/InterpreterBindingUtils.java | 42 - .../cluster/ClusterNoteEventListenerTest.java | 7 +- .../apache/zeppelin/rest/AbstractTestRestApi.java | 7 +- .../zeppelin/rest/InterpreterRestApiTest.java | 6 +- .../zeppelin/rest/NotebookSecurityRestApiTest.java | 52 - .../apache/zeppelin/rest/ZeppelinRestApiTest.java | 25 +- .../apache/zeppelin/socket/NotebookServerTest.java | 11 +- zeppelin-web/bower.json | 2 + zeppelin-web/karma.conf.js | 2 + zeppelin-web/package-lock.json | 11578 ++++++++++--------- zeppelin-web/src/app/app.controller.js | 6 + .../src/app/credential/credential.controller.js | 6 +- zeppelin-web/src/app/home/home.controller.js | 6 +- zeppelin-web/src/app/home/home.css | 8 + zeppelin-web/src/app/home/notebook-template.html | 139 +- .../src/app/notebook/notebook-actionBar.html | 4 +- .../app/notebook/paragraph/paragraph.controller.js | 13 +- .../src/app/notebook/paragraph/paragraph.css | 5 +- .../src/app/notebook/paragraph/paragraph.html | 2 +- zeppelin-web/src/app/tabledata/package.json | 2 +- zeppelin-web/src/app/tabledata/tabledata.js | 2 +- zeppelin-web/src/app/visualization/package.json | 2 +- .../array-ordering/array-ordering.service.js | 8 + .../websocket/websocket-message.service.js | 4 +- zeppelin-web/src/index.html | 2 + .../zeppelin/helium/HeliumApplicationFactory.java | 12 +- .../zeppelin/interpreter/InterpreterSetting.java | 19 +- .../interpreter/InterpreterSettingManager.java | 182 +- .../interpreter/RemoteInterpreterEventServer.java | 8 +- .../launcher/SparkInterpreterLauncher.java | 14 +- .../interpreter/remote/RemoteInterpreter.java | 6 +- .../remote/RemoteInterpreterProcessListener.java | 2 +- .../zeppelin/notebook/AuthorizationService.java | 212 +- .../java/org/apache/zeppelin/notebook/Note.java | 56 +- .../org/apache/zeppelin/notebook/NoteManager.java | 9 +- .../org/apache/zeppelin/notebook/Notebook.java | 114 +- .../org/apache/zeppelin/notebook/Paragraph.java | 10 +- .../zeppelin/notebook/ParagraphTextParser.java | 112 + .../zeppelin/notebook/repo/NotebookRepoSync.java | 2 +- .../repo/zeppelinhub/security/Authentication.java | 4 +- .../repo/zeppelinhub/websocket/ZeppelinClient.java | 4 +- .../zeppelin/notebook/scheduler/CronJob.java | 16 +- .../notebook/scheduler/QuartzSchedulerService.java | 21 +- .../apache/zeppelin/scheduler/RemoteScheduler.java | 86 +- .../zeppelin/storage/LocalConfigStorage.java | 3 +- .../helium/HeliumApplicationFactoryTest.java | 2 +- .../interpreter/InterpreterSettingManagerTest.java | 8 +- .../interpreter/InterpreterSettingTest.java | 53 + .../launcher/SparkInterpreterLauncherTest.java | 52 +- .../interpreter/remote/RemoteInterpreterTest.java | 4 +- .../org/apache/zeppelin/notebook/NoteTest.java | 3 +- .../org/apache/zeppelin/notebook/NotebookTest.java | 21 +- .../apache/zeppelin/notebook/ParagraphTest.java | 4 + .../zeppelin/notebook/ParagraphTextParserTest.java | 62 + 227 files changed, 16691 insertions(+), 8592 deletions(-) create mode 100644 cassandra/src/test/scala/org/apache/zeppelin/cassandra/EnhancedSessionTest.scala create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ipython_code_completion.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ipython_error.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ipython_hvplot.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ksql.1.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ksql.2.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/ksql.3.png create mode 100644 docs/assets/themes/zeppelin/img/docs-img/sparql-example.png create mode 100644 docs/interpreter/kotlin.md create mode 100644 docs/interpreter/ksql.md create mode 100644 docs/interpreter/sparql.md create mode 100644 kotlin/README.md create mode 100644 kotlin/pom.xml create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/KotlinInterpreter.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/completion/KotlinCompleter.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/completion/KotlinKeywords.java copy zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => kotlin/src/main/java/org/apache/zeppelin/kotlin/context/KotlinReceiver.java (57%) create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/ContextUpdater.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinFunctionInfo.java copy zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinReflectUtil.java (58%) create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinVariableInfo.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/ClassWriter.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/KotlinRepl.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/building/KotlinReplProperties.java create mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/building/ReplBuilding.java create mode 100644 kotlin/src/main/resources/interpreter-setting.json create mode 100644 kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java create mode 100644 ksql/README.md create mode 100644 ksql/pom.xml create mode 100644 ksql/src/main/java/org/apache/zeppelin/ksql/BasicKSQLHttpClient.java create mode 100644 ksql/src/main/java/org/apache/zeppelin/ksql/KSQLInterpreter.java create mode 100644 ksql/src/main/java/org/apache/zeppelin/ksql/KSQLRequest.java create mode 100644 ksql/src/main/java/org/apache/zeppelin/ksql/KSQLResponse.java create mode 100644 ksql/src/main/java/org/apache/zeppelin/ksql/KSQLRestService.java create mode 100644 ksql/src/main/resources/interpreter-setting.json create mode 100644 ksql/src/test/java/org/apache/zeppelin/ksql/KSQLInterpreterTest.java create mode 100644 notebook/Zeppelin Tutorial/Flink Batch Tutorial_2EN1E1ATY.zpln create mode 100644 notebook/Zeppelin Tutorial/Flink Stream Tutorial_2ER62Y5VJ.zpln rename python/src/main/resources/{grpc/python/zeppelin_python.py => python/zeppelin_ipython.py} (100%) create mode 100644 rlang/pom.xml create mode 100644 rlang/src/main/java/org/apache/zeppelin/r/RInterpreter.java copy zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => rlang/src/main/java/org/apache/zeppelin/r/RZeppelinContext.java (55%) create mode 100644 rlang/src/main/java/org/apache/zeppelin/r/SparkRBackend.java rename {spark/interpreter/src/main/java/org/apache/zeppelin/spark => rlang/src/main/java/org/apache/zeppelin/r}/ZeppelinR.java (50%) create mode 100644 rlang/src/main/java/org/apache/zeppelin/r/ZeppelinRDisplay.java rename {spark/interpreter => rlang}/src/main/resources/R/zeppelin_sparkr.R (52%) create mode 100644 rlang/src/main/resources/interpreter-setting.json create mode 100644 rlang/src/test/java/org/apache/zeppelin/r/RInterpreterTest.java copy {python => rlang}/src/test/resources/log4j.properties (95%) create mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/KotlinSparkInterpreter.java create mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/kotlin/KotlinZeppelinBindings.java create mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/kotlin/SparkKotlinReceiver.java delete mode 100644 spark/interpreter/src/main/scala/org/apache/spark/SparkRBackend.scala delete mode 100644 spark/interpreter/src/main/scala/org/apache/zeppelin/spark/ZeppelinRDisplay.scala delete mode 100644 spark/interpreter/src/main/scala/org/apache/zeppelin/spark/utils/DisplayUtils.scala create mode 100644 spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java delete mode 100644 spark/interpreter/src/test/scala/org/apache/zeppelin/spark/utils/DisplayFunctionsTest.scala create mode 100644 sparql/pom.xml create mode 100644 sparql/src/main/java/org/apache/zeppelin/sparql/JenaInterpreter.java copy zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => sparql/src/main/java/org/apache/zeppelin/sparql/SparqlEngine.java (58%) create mode 100644 sparql/src/main/java/org/apache/zeppelin/sparql/SparqlInterpreter.java create mode 100644 sparql/src/main/resources/interpreter-setting.json create mode 100644 sparql/src/test/java/org/apache/zeppelin/sparql/SparqlJenaEngineTest.java create mode 100644 sparql/src/test/resources/data.ttl create mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/util/SqlSplitter.java copy zeppelin-interpreter/src/{main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => test/java/org/apache/zeppelin/interpreter/launcher/InterpreterLauncherTest.java} (58%) create mode 100644 zeppelin-interpreter/src/test/java/org/apache/zeppelin/interpreter/util/SqlSplitterTest.java copy {python => zeppelin-jupyter-interpreter}/pom.xml (69%) create mode 100644 zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/JupyterInterpreter.java rename python/src/main/java/org/apache/zeppelin/python/IPythonClient.java => zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/JupyterKernelClient.java (81%) create mode 100644 zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/JupyterKernelInterpreter.java copy zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/FIFOScheduler.java => zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/JupyterZeppelinContext.java (53%) create mode 100644 zeppelin-jupyter-interpreter/src/main/proto/kernel.proto rename {python => zeppelin-jupyter-interpreter}/src/main/resources/grpc/generate_rpc.sh (87%) rename python/src/main/resources/grpc/python/ipython_client.py => zeppelin-jupyter-interpreter/src/main/resources/grpc/jupyter/kernel_client.py (79%) rename python/src/main/resources/grpc/python/ipython_pb2.py => zeppelin-jupyter-interpreter/src/main/resources/grpc/jupyter/kernel_pb2.py (72%) rename python/src/main/resources/grpc/python/ipython_pb2_grpc.py => zeppelin-jupyter-interpreter/src/main/resources/grpc/jupyter/kernel_pb2_grpc.py (60%) rename python/src/main/resources/grpc/python/ipython_server.py => zeppelin-jupyter-interpreter/src/main/resources/grpc/jupyter/kernel_server.py (75%) create mode 100644 zeppelin-jupyter-interpreter/src/main/resources/interpreter-setting.json copy python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java => zeppelin-jupyter-interpreter/src/test/java/org/apache/zeppelin/jupyter/IPythonKernelTest.java (56%) delete mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/utils/InterpreterBindingUtils.java create mode 100644 zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/ParagraphTextParser.java create mode 100644 zeppelin-zengine/src/test/java/org/apache/zeppelin/notebook/ParagraphTextParserTest.java