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

add interpreter to navigation.html and remove extra spaces and lines

Browse source
This commit is contained in:
mahmoudelgamal 2016-08-17 22:15:24 +02:00
parent 9b1b385b7c
commit 75fc4f7eeb
4 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
beam/pom.xml
View file

@ -14,10 +14,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>zeppelin</artifactId>
<groupId>org.apache.zeppelin</groupId>

12
beam/src/main/java/org/apache/zeppelin/beam/StaticRepl.java
View file

@ -84,8 +84,10 @@ public class StaticRepl {
}
// if there isn't Main method, will retuen error
if (mainClassName == null)
if (mainClassName == null) {
LOGGER.error("Exception for Main method", "There isn't any class containing Main method.");
throw new Exception("There isn't any class containing Main method.");
}
// replace name of class containing Main method with generated name
code = code.replace(mainClassName, generatedClassName);
@ -150,22 +152,22 @@ public class StaticRepl {
LOGGER.error("Exception in Interpreter while Class not found", e);
System.err.println("Class not found: " + e);
throw new Exception(baosErr.toString());
} catch (NoSuchMethodException e) {
LOGGER.error("Exception in Interpreter while No such method", e);
System.err.println("No such method: " + e);
throw new Exception(baosErr.toString());
} catch (IllegalAccessException e) {
LOGGER.error("Exception in Interpreter while Illegal access", e);
System.err.println("Illegal access: " + e);
throw new Exception(baosErr.toString());
} catch (InvocationTargetException e) {
LOGGER.error("Exception in Interpreter while Invocation target", e);
System.err.println("Invocation target: " + e);
throw new Exception(baosErr.toString());
} finally {
System.out.flush();

1
docs/_includes/themes/zeppelin/_navigation.html
View file

@ -47,6 +47,7 @@
<li role="separator" class="divider"></li>
<li class="title"><span><b>Available Interpreters</b><span></li>
<li><a href="{{BASE_PATH}}/interpreter/alluxio.html">Alluxio</a></li>
<li><a href="{{BASE_PATH}}/interpreter/beam.html">Beam</a></li>
<li><a href="{{BASE_PATH}}/interpreter/bigquery.html">BigQuery</a></li>
<li><a href="{{BASE_PATH}}/interpreter/cassandra.html">Cassandra</a></li>
<li><a href="{{BASE_PATH}}/interpreter/elasticsearch.html">Elasticsearch</a></li>

6
docs/interpreter/beam.md
View file

@ -26,12 +26,12 @@ limitations under the License.
## Overview
[Apache Beam](http://beam.incubator.apache.org) 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.
The execution of the pipeline is done by different Runners. Currently, Beam supports Apache Flink Runner, Apache Spark Runner, and Google Dataflow Runner.
## How to use
Basically, you can write normal Beam java code where you can determine the Runner. You should write the main method inside a class becuase the interpreter invoke this main to execute the pipline. Unlike Zeppelin normal pattern, each paragraph is considered a separate job, there isn't any relation to any other paragraph.
Basically, you can write normal Beam java code where you can determine the Runner. You should write the main method inside a class becuase the interpreter invoke this main to execute the pipline. Unlike Zeppelin normal pattern, each paragraph is considered a separate job, there isn't any relation to any other paragraph.
The following is a demonstration of a word count example
The following is a demonstration of a word count example
```
%beam