beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/4] beam git commit: Mark AuctionOrBidWindowCoder as consistentWithEquals
Date Thu, 21 Sep 2017 22:49:07 GMT
Repository: beam
Updated Branches:
  refs/heads/master 766513bc8 -> d6c63396a


Mark AuctionOrBidWindowCoder as consistentWithEquals


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bdc738e0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bdc738e0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bdc738e0

Branch: refs/heads/master
Commit: bdc738e0c010829af7f7649f6ea57dc044a18285
Parents: 8e391d9
Author: Daniel Mills <millsd@google.com>
Authored: Tue Sep 12 16:54:36 2017 -0700
Committer: Daniel Mills <millsd@google.com>
Committed: Tue Sep 12 16:58:01 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/nexmark/queries/WinningBids.java   | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/bdc738e0/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java
----------------------------------------------------------------------
diff --git a/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java
b/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java
index 816a81f..efdbe21 100644
--- a/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java
+++ b/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java
@@ -192,6 +192,11 @@ public class WinningBids extends PTransform<PCollection<Event>,
PCollection<Auct
     }
 
     @Override public void verifyDeterministic() throws NonDeterministicException {}
+
+    @Override
+    public boolean consistentWithEquals() {
+      return true;
+    }
   }
 
   /** Assign events to auction windows and merges them intelligently. */


Mime
View raw message