Hello, I'm Tejas, and I am planning to implement an asynchronous DoFn wrapper for the Apache Beam Java SDK. Currently, this capability exists in the Python SDK, and I would like to mirror this functionality in Java to allow developers write and manage asynchronous DoFns in their pipelines.
I have created a feature request to track this work here: https://github.com/apache/beam/issues/38529 Because this is a straightforward implementation based on the existing Python SDK, it shouldn't warrant a full design doc, but I wanted to give the community a heads-up. Please let me know if you have any early feedback, concerns, or if anyone would be interested in reviewing the code once the PR is ready. Thanks, Tejas
