egalpin commented on issue #21690: URL: https://github.com/apache/beam/issues/21690#issuecomment-1156690551
That’s a good point. I’ve honestly debated whether or not an IO ought to preserve windows at all given that responses from a Sink could be viewed as effectively a new Source. But I suppose preserving windows could be useful for joining data sent to a sink and data returned from that sink via CoGroupByKey. Back to your original idea of just using the windowing function, I’ll give that a try. Thanks! -- 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]
