Thomas Groh created BEAM-155: -------------------------------- Summary: Support asserting the contents of windows and panes in PAssert Key: BEAM-155 URL: https://issues.apache.org/jira/browse/BEAM-155 Project: Beam Issue Type: Improvement Components: sdk-java-core Reporter: Thomas Groh Assignee: Davor Bonaci
This consists of reifying the output windows and panes, and running asserts per-window about the contents of panes. This includes aggregated matching and final pane matching, e.g. PAssert.that(output).byOnTimePane().hasOutputElements(foo, bar); // For discarding mode - could have emitted (say) [spam, eggs], [spam], [], [sausage], [] PAssert.that(output).byFinalPane().hasOutputElements(spam, eggs, sausage, spam); // For accumulating mode without late data PAssert.that(output).finalPane().containsInAnyOrder(spam, eggs, sausage, spam); // For accumulating mode with late data PAssert.that(output).finalPane().containsInAnyOrder(foo, bar).mayAlsoContain(baz, rab); See also: https://docs.google.com/document/d/1fZUUbG2LxBtqCVabQshldXIhkMcXepsbv2vuuny8Ix4/edit# -- This message was sent by Atlassian JIRA (v6.3.4#6332)