Port DebuggingWordCount example from OldDoFn to DoFn
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/49d2f170 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/49d2f170 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/49d2f170 Branch: refs/heads/master Commit: 49d2f1706f69c5106a9082ffd2fecaf69b2d868c Parents: ca9e337 Author: Kenneth Knowles <k...@google.com> Authored: Fri Jul 22 14:29:18 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Aug 3 18:25:53 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/examples/DebuggingWordCount.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/49d2f170/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 3c43152..c1b273c 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 @@ -24,7 +24,7 @@ import org.apache.beam.sdk.options.Description; import org.apache.beam.sdk.options.PipelineOptionsFactory; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.transforms.Aggregator; -import org.apache.beam.sdk.transforms.OldDoFn; +import org.apache.beam.sdk.transforms.DoFn; import org.apache.beam.sdk.transforms.ParDo; import org.apache.beam.sdk.transforms.Sum; import org.apache.beam.sdk.values.KV; @@ -106,8 +106,8 @@ import java.util.regex.Pattern; * overridden with {@code --inputFile}. */ public class DebuggingWordCount { - /** A OldDoFn that filters for a specific key based upon a regular expression. */ - public static class FilterTextFn extends OldDoFn<KV<String, Long>, KV<String, Long>> { + /** A DoFn that filters for a specific key based upon a regular expression. */ + public static class FilterTextFn extends DoFn<KV<String, Long>, KV<String, Long>> { /** * Concept #1: The logger below uses the fully qualified class name of FilterTextFn * as the logger. All log statements emitted by this logger will be referenced by this name @@ -133,7 +133,7 @@ public class DebuggingWordCount { private final Aggregator<Long, Long> unmatchedWords = createAggregator("umatchedWords", new Sum.SumLongFn()); - @Override + @ProcessElement public void processElement(ProcessContext c) { if (filter.matcher(c.element().getKey()).matches()) { // Log at the "DEBUG" level each element that we match. When executing this pipeline