GitHub user mfelgamal opened a pull request: https://github.com/apache/zeppelin/pull/1334
[ZEPPELIN-682] New interpreter for Apache Beam (incubating)/DataFlow ## What is this PR for? The PR is a interpreter for [Apache Beam](http://beam.incubator.apache.org) which is an open source unified platform for data processing pipelines. A pipeline can be build using one of the Beam SDKs. The execution of the pipeline is done by different Runners . Currently, Beam supports Apache Flink Runner, Apache Spark Runner, and Google Dataflow Runner. ### What type of PR is it? - Feature ### Todos * Test case * Review Comments * Documentation ### What is the Jira issue? * [ZEPPELIN-682] ### How should this be tested? - Start the Zeppelin server - The prefix of interpreter is `%beam` and then write your code with required imports and the runner ### Screenshots (if appropriate) ![](https://s9.postimg.org/s6eiwrbxb/beam_interpreter.png) ![](https://s9.postimg.org/eq3h8wsrz/visualisation_with_table.png) ### Questions: * Does the licenses files need update? no * Is there breaking changes for older versions? no * Does this needs documentation? yes You can merge this pull request into a Git repository by running: $ git pull https://github.com/novelari/incubator-zeppelin beam-interpreter-static-repl-7 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/zeppelin/pull/1334.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1334 ---- commit 2586651ab9768e484e04a840978d6db8d5659f48 Author: Fouad <fuad.assay...@gmail.com> Date: 2016-05-29T14:39:08Z Merge pull request #2 from apache/master update from original commit 03a1e80f8f3115a75c42fa25fdaa06e7dd2cbc28 Author: mfelgamal <mahmoudf.elga...@gmail.com> Date: 2016-07-19T18:28:46Z Merge pull request #4 from apache/master merge master commit 1b42276c6799428ce84248ec58222ab4c9dfaf95 Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-06-25T22:03:06Z beam interpreter commit 1c234caebfb5a05745f07e9536f94a8c2976474f Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-07-20T14:26:49Z Adding the beam to zeppelin 7 commit aeedccee92513e9e81385537fcded508133b4181 Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-08-01T08:53:12Z Refactoring of the code commit ae1053d0f983c812fcdbcdfc1e7ad43cc72950db Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-08-01T10:23:48Z Modifying pom file and Making documentation commit c2e206655a65a92ff67254f662de6c7d1bd5ccb8 Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-08-03T22:55:32Z Modifying the documentation commit 0f7338771fb3789ed16d3b9e97def8034ef04d0f Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-08-08T08:37:52Z Adding some tests commit b88ff7537f6e9428076aab7461752e6ae006d1f3 Author: mahmoudelgamal <mahmoudf.elga...@gmail.com> Date: 2016-08-08T13:10:27Z changing class name to StaticRepl and adding some modifications ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---