Function assertDeepEqual

A PTransform that will fail the pipeline if the input PCollection does not contain exactly the given elements (in any order). Useful for writing test, e.g.

pcoll.apply(assertDeepEqual(1, 2, 3));