Repository: beam Updated Branches: refs/heads/master 09d131ced -> ddde35327
Fix typo of DebuggingWordCount.java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3541b3cb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3541b3cb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3541b3cb Branch: refs/heads/master Commit: 3541b3cb628026681e3c9db60918597e0b3d77bb Parents: 09d131c Author: Keiji Yoshida <[email protected]> Authored: Sun Jan 22 20:35:04 2017 +0900 Committer: Keiji Yoshida <[email protected]> Committed: Sun Jan 22 20:35:04 2017 +0900 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/examples/DebuggingWordCount.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/3541b3cb/examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java ---------------------------------------------------------------------- diff --git a/examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java b/examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java index 997d590..f7493f3 100644 --- a/examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java +++ b/examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java @@ -97,7 +97,7 @@ public class DebuggingWordCount { private final Aggregator<Long, Long> matchedWords = createAggregator("matchedWords", Sum.ofLongs()); private final Aggregator<Long, Long> unmatchedWords = - createAggregator("umatchedWords", Sum.ofLongs()); + createAggregator("unmatchedWords", Sum.ofLongs()); @ProcessElement public void processElement(ProcessContext c) {
