You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2018/01/09 01:26:10 UTC
[29/33] samza-hello-samza git commit: Fixed stateful operator name
Fixed stateful operator name
Author: Prateek Maheshwari <pm...@linkedin.com>
Reviewers: Jagadish<ja...@apache.org>
Closes #25 from prateekm/latest
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/004e03fa
Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/004e03fa
Diff: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/diff/004e03fa
Branch: refs/heads/master
Commit: 004e03fadc60aef0f5e0b345c3d0a43ed6b5e5dc
Parents: f48c7f9
Author: Prateek Maheshwari <pm...@linkedin.com>
Authored: Mon Dec 11 18:24:10 2017 -0800
Committer: Jagadish <jv...@linkedin.com>
Committed: Mon Dec 11 18:24:10 2017 -0800
----------------------------------------------------------------------
.../samza/examples/wikipedia/application/WikipediaApplication.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/004e03fa/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java
----------------------------------------------------------------------
diff --git a/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java b/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java
index 659e373..032608f 100644
--- a/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java
+++ b/src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java
@@ -113,7 +113,7 @@ public class WikipediaApplication implements StreamApplication {
allWikipediaEvents
.map(WikipediaParser::parseEvent)
.window(Windows.tumblingWindow(Duration.ofSeconds(10), WikipediaStats::new,
- new WikipediaStatsAggregator(), WikipediaStats.serde()), "Tumbling window of WikipediaStats")
+ new WikipediaStatsAggregator(), WikipediaStats.serde()), "statsWindow")
.map(this::formatOutput)
.sendTo(wikipediaStats);
}