SAMZA-1089: Runner should support kill and status commands
authorJacob Maes <jmaes@linkedin.com>
Mon, 3 Apr 2017 16:50:27 +0000 (09:50 -0700)
committerJacob Maes <jmaes@linkedin.com>
Mon, 3 Apr 2017 16:50:27 +0000 (09:50 -0700)
commit311f9d12e983ac3c3ab7dc62a16a145e3d05e1ab
treee0b3ff645b5085655bd7d570e2ad8f5c05704087
parent101ca439b8b22926db7423309a3ff880f396271a
SAMZA-1089: Runner should support kill and status commands

Author: Jacob Maes <jmaes@linkedin.com>

Reviewers: Prateek Maheshwari <pmaheshw@linkedin.com>,Xinyu Liu <xiliu@linkedin.com>

Closes #106 from jmakes/samza-1089-2
18 files changed:
samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java
samza-core/src/main/java/org/apache/samza/config/JavaSystemConfig.java
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java
samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java
samza-core/src/main/java/org/apache/samza/execution/StreamManager.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java
samza-core/src/main/java/org/apache/samza/runtime/AbstractApplicationRunner.java
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerOperation.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/LocalContainerRunner.java
samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java
samza-core/src/main/scala/org/apache/samza/config/SystemConfig.scala
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala
samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java
samza-core/src/test/java/org/apache/samza/runtime/TestAbstractApplicationRunner.java
samza-core/src/test/java/org/apache/samza/runtime/TestApplicationRunnerMain.java [new file with mode: 0644]
samza-core/src/test/scala/org/apache/samza/job/TestJobRunner.scala