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 <[email protected]> Authored: Tue Sep 12 16:54:36 2017 -0700 Committer: Daniel Mills <[email protected]> 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. */
