Repository: samza-hello-samza Updated Branches: refs/heads/latest f48c7f9f3 -> 004e03fad
Fixed stateful operator name Author: Prateek Maheshwari <[email protected]> Reviewers: Jagadish<[email protected]> 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/latest Commit: 004e03fadc60aef0f5e0b345c3d0a43ed6b5e5dc Parents: f48c7f9 Author: Prateek Maheshwari <[email protected]> Authored: Mon Dec 11 18:24:10 2017 -0800 Committer: Jagadish <[email protected]> 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); }
