Port Filter to the new 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/d798413b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d798413b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d798413b Branch: refs/heads/master Commit: d798413be41fa5941d12049d899aa6ad970b8515 Parents: 7629f97 Author: Kenneth Knowles <[email protected]> Authored: Fri Aug 5 11:46:53 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Aug 8 11:35:17 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/transforms/Filter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d798413b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java index 37cbec1..2d9bdee 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java @@ -202,8 +202,8 @@ public class Filter<T> extends PTransform<PCollection<T>, PCollection<T>> { @Override public PCollection<T> apply(PCollection<T> input) { - return input.apply(ParDo.of(new OldDoFn<T, T>() { - @Override + return input.apply(ParDo.of(new DoFn<T, T>() { + @ProcessElement public void processElement(ProcessContext c) { if (predicate.apply(c.element())) { c.output(c.element());
