Adds backlog reporting support for non-fnapi based SDF's. - #38346

Merged

chamikaramj merged 7 commits into

apache:masterfrom

acrites:sdf-backlog

May 21, 2026

Commits on Apr 30, 2026

Adds backlog reporting support for non-fnapi based SDF's.
acrites
committed
a8ed2f2

Commits on May 1, 2026

Adds call to newTracker invoker for when GetSize is not defined on an SDF.
acrites
committed
71ffc9a
Trigger validates runner tests
acrites
committed
2f06938
Adding side input to GetSize arguments. It is not technically part of the API in DoFn.java, but some tests are using it.
acrites
committed
43222da

Commits on May 8, 2026

Replaces magic -1 with a named constant.
acrites
committed
dcb239b

Commits on May 11, 2026

Replaces new inline ArugmentProvider for getSize, with a Delegating ArgumentProvider to reuse most of the arguments passed to the process element invoker.
acrites
committed
26e498e

Commits on May 20, 2026

Adds mock spanner call for GetSize method used by SpannerChangeStream source.
acrites
committed
35769fa