Repository: beam Updated Branches: refs/heads/master 2685ba528 -> 9061c65e3
Match Pane in WindowedValueMatcher Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4e69a797 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4e69a797 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4e69a797 Branch: refs/heads/master Commit: 4e69a7976faf32863eb796bfebf470332fcbd709 Parents: 2685ba5 Author: Thomas Groh <tg...@google.com> Authored: Tue Feb 14 16:32:08 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Tue Feb 14 17:31:33 2017 -0800 ---------------------------------------------------------------------- .../test/java/org/apache/beam/runners/core/WindowMatchers.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/4e69a797/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java index 6c3a7e2..9769d10 100644 --- a/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java +++ b/runners/core-java/src/test/java/org/apache/beam/runners/core/WindowMatchers.java @@ -198,7 +198,8 @@ public class WindowMatchers { protected boolean matchesSafely(WindowedValue<? extends T> windowedValue) { return valueMatcher.matches(windowedValue.getValue()) && timestampMatcher.matches(windowedValue.getTimestamp()) - && windowsMatcher.matches(windowedValue.getWindows()); + && windowsMatcher.matches(windowedValue.getWindows()) + && paneInfoMatcher.matches(windowedValue.getPane()); } } }
