Make AuctionOrBidWindowCoder use structuralValue instead of consistentWithEquals
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e3abd698 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e3abd698 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e3abd698 Branch: refs/heads/master Commit: e3abd6988b9e9bf0ad465dda573870650ddceb2e Parents: e93c035 Author: Daniel Mills <[email protected]> Authored: Wed Sep 13 10:21:01 2017 -0700 Committer: Daniel Mills <[email protected]> Committed: Wed Sep 13 10:21:01 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/nexmark/queries/WinningBids.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/e3abd698/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 be64958..d73b8ae 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 @@ -167,8 +167,6 @@ public class WinningBids extends PTransform<PCollection<Event>, PCollection<Auct private static final Coder<IntervalWindow> SUPER_CODER = IntervalWindow.getCoder(); private static final Coder<Long> ID_CODER = VarLongCoder.of(); private static final Coder<Integer> INT_CODER = VarIntCoder.of(); - private static final boolean CONSISTENT_WITH_EQUALS = SUPER_CODER.consistentWithEquals() - && ID_CODER.consistentWithEquals() && INT_CODER.consistentWithEquals(); @JsonCreator public static AuctionOrBidWindowCoder of() { @@ -196,8 +194,8 @@ public class WinningBids extends PTransform<PCollection<Event>, PCollection<Auct @Override public void verifyDeterministic() throws NonDeterministicException {} @Override - public boolean consistentWithEquals() { - return CONSISTENT_WITH_EQUALS; + public Object structuralValue(AuctionOrBidWindow value) { + return value; } }
