Testing

For unit testing, these PTransform classes test that a PCollection is in a certain state:

                           [T] ==PAssert.GroupThenAssert==>

               [Iterable] ==PAssert.GroupThenAssertForSingleton==>

The TestStream outputs an unbounded PCollection of a particular set of values and timestamps that you can specify using a builder pattern

                                    ==TestStream==> [T]

Subscribe to All Posts - Wesley Tanaka