SAMZA-1131: RemoteApplicationRunner for cluster-based Samza applications
authorXinyu Liu <xiliu@xiliu-ld.linkedin.biz>
Fri, 17 Mar 2017 18:54:57 +0000 (11:54 -0700)
committerXinyu Liu <xiliu@xiliu-ld.linkedin.biz>
Fri, 17 Mar 2017 18:54:57 +0000 (11:54 -0700)
commiteb5d452aec39e34ef4ea3b3464cc4c84f1bf32c0
treed01b6853b411bbe9d49d30cec5a71f43f020307a
parenta080ca21ba24c476fe2136134db93eadc5748a90
SAMZA-1131: RemoteApplicationRunner for cluster-based Samza applications

RemoteApplicationRunner starts the Samza StreamApplication on the remote cluster, e.g. Yarn. It uses ExecutionPlanner for planning physical execution, and JobRunner to start each stage of the application.

Author: Xinyu Liu <xiliu@xiliu-ld.linkedin.biz>

Reviewers: Jacob Maes <jmakes@apache.org>

Closes #88 from xinyuiscool/SAMZA-1131
14 files changed:
samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java
samza-core/src/main/java/org/apache/samza/execution/ProcessorGraph.java
samza-core/src/main/java/org/apache/samza/runtime/AbstractApplicationRunner.java
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java
samza-core/src/test/java/org/apache/samza/example/KeyValueStoreExample.java
samza-core/src/test/java/org/apache/samza/example/NoContextStreamExample.java
samza-core/src/test/java/org/apache/samza/example/OrderShipmentJoinExample.java
samza-core/src/test/java/org/apache/samza/example/PageViewCounterExample.java
samza-core/src/test/java/org/apache/samza/example/RepartitionExample.java
samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java
samza-core/src/test/java/org/apache/samza/runtime/TestAbstractApplicationRunner.java [moved from samza-core/src/test/java/org/apache/samza/runtime/TestAbstractExecutionEnvironment.java with 99% similarity]
samza-shell/src/main/bash/run-app.sh [new file with mode: 0644]