beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [04/13] incubator-beam git commit: Port Filter to the new DoFn
Date Mon, 08 Aug 2016 20:40:39 GMT
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 <klk@google.com>
Authored: Fri Aug 5 11:46:53 2016 -0700
Committer: Kenneth Knowles <klk@google.com>
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());


Mime
View raw message