chamikaramj edited a comment on pull request #11596: URL: https://github.com/apache/beam/pull/11596#issuecomment-623741333
Is using SplittableDoFn API here intentional ? I think this API is being updated. cc: @lukecwik If you need dynamic work rebalancing, consider using the BoundedSource interface. Otherwise we can just implement the source using regular DoFns and wait for SplittableDoFn API to stabilize before adding support for dynamic work rebalancing. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org