Details
-
Sub-task
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
Description
Add a simple unit test to validate that user DoFns can observe windows.
In particular add a Go unit test to the exec package, in the style of the ParDo execution unit test https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/core/runtime/exec/pardo_test.go#L50
This requires writing a small but observable DoFn that observes windows, and configures inputs to achieve expected outputs for given window assignements. There may be a need to add a utility functions to configure the windows and event times in a FullValue conveniently for the test.
Tests should cover single and multiple windows cases.
Attachments
Issue Links
- links to
- mentioned in
-
Page Loading...