Implement Asynchronous wrapper for DoFn in Java SDK#38609

Open

tejasiyer-dev wants to merge 2 commits into

apache:masterfrom

tejasiyer-dev:add-async-dofn-wrapper

Commits on May 22, 2026

Created an Asynchronous Wrapper for DoFn as well as JUnit tests for the Apache Beam Java SDK (#38529)
tejasiyer-dev
committed
Optimize State reconciliation loop and eliminate O(N^2) complexity. Removed O(N) global activeElements scan. Fixed logic bug where duplicate elements were incorrectly marked for rescheduling. Optim…
tejasiyer-dev
committed