Fix typo of DebuggingWordCount.java

apache · Jan 22, 2017 · 3541b3c · 3541b3c
1 parent 09d131c
commit 3541b3c
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -97,7 +97,7 @@ public FilterTextFn(String pattern) {
     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) {