Description
FromĀ https://godoc.org/github.com/apache/beam/sdks/go/pkg/beam/testing/passert#Sum:
> Sum validates that the incoming PCollection<int> is a singleton with the given value.
Why is there a size argument if the input is supposed to be a singleton?
From the implementation, it seems that Sum sums all elements from the input PCollection (which must be int, apparently?), and checks both the number of elements and their sum.
Attachments
Issue Links
- links to