lostluck opened a new issue, #23106: URL: https://github.com/apache/beam/issues/23106
### What would you like to happen? Requires implementing a Periodic Impulse and Periodic Sequence transform for occasional re-reads of some data, in a large window. Requires using those re-reads as a side input. Requires allowing the map_windows urn: https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto#L296 So that the SDK can map windows from one to another, this needs to be added to the big switch in exec/translate.go. Currently, trying to manually use this pattern leads to a panic on execution when a runner makes the mapping request: https://github.com/apache/beam/blob/master/sdks/go/pkg/beam/core/runtime/exec/translate.go#L734 ### Issue Priority Priority: 1 ### Issue Component Component: sdk-go -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
