You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2016/12/19 14:00:28 UTC
incubator-gearpump git commit: [GEARPUMP-255] Return application id when submitting application in J…
Repository: incubator-gearpump
Updated Branches:
refs/heads/master 1bf6a9ba8 -> 177a1d443
[GEARPUMP-255] Return application id when submitting application in J\u2026
\u2026ava DSL
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make sure the commit message is formatted like:
`[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
- [x] Make sure tests pass via `sbt clean test`.
- [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.
Author: manuzhang <ow...@gmail.com>
Closes #124 from manuzhang/GEARPUMP-255.
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/177a1d44
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/177a1d44
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/177a1d44
Branch: refs/heads/master
Commit: 177a1d4436dc88ade5283efcd483e5fdd6128f00
Parents: 1bf6a9b
Author: manuzhang <ow...@gmail.com>
Authored: Mon Dec 19 21:59:51 2016 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Mon Dec 19 21:59:51 2016 +0800
----------------------------------------------------------------------
.../gearpump/streaming/examples/wordcountjava/dsl/WordCount.java | 2 +-
.../org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/177a1d44/examples/streaming/wordcount-java/src/main/java/org/apache/gearpump/streaming/examples/wordcountjava/dsl/WordCount.java
----------------------------------------------------------------------
diff --git a/examples/streaming/wordcount-java/src/main/java/org/apache/gearpump/streaming/examples/wordcountjava/dsl/WordCount.java b/examples/streaming/wordcount-java/src/main/java/org/apache/gearpump/streaming/examples/wordcountjava/dsl/WordCount.java
index a453d8c..d4866ed 100644
--- a/examples/streaming/wordcount-java/src/main/java/org/apache/gearpump/streaming/examples/wordcountjava/dsl/WordCount.java
+++ b/examples/streaming/wordcount-java/src/main/java/org/apache/gearpump/streaming/examples/wordcountjava/dsl/WordCount.java
@@ -58,7 +58,7 @@ public class WordCount {
wordcount.log();
- app.run();
+ app.submit();
context.close();
}
http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/177a1d44/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala
----------------------------------------------------------------------
diff --git a/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala b/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala
index 0d841be..82a284e 100644
--- a/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala
+++ b/streaming/src/main/scala/org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.scala
@@ -41,7 +41,7 @@ class JavaStreamApp(name: String, context: ClientContext, userConfig: UserConfig
new JavaStream[T](streamApp.source(dataSource, parallelism, conf, description))
}
- def run(): Unit = {
+ def submit(): Int = {
context.submit(streamApp)
}
}