kennknowles commented on pull request #16773: URL: https://github.com/apache/beam/pull/16773#issuecomment-1051066745
Based on my reading of the code, use of `withStopReadTime` depends on the new SDF functionality and goes through a `Watch` style of transform that tends to be targeting streaming. Semantically, it seems like this should result in bounded PCollections, even though the batch read of those PCollections may be inefficient and/or blocking. I don't know what pitfalls might occur with all this. Pinging @chamikaramj and @lukecwik who will have more details expertise about the implementations. -- 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]
