Change UnboundedSourceAsSdfWrapperFn to share the cache across instances.#33901

Merged

scwhittle merged 6 commits intoapache:masterfrom

scwhittle:reader_cache

Feb 25, 2025

Commits on Feb 7, 2025

Add a utility class to enable sharing across all deserialized instances of a DoFn and use it in UnboundedSourceAsSdfWrapperFn to cache Readers across dofn instances
scwhittle
committed

Commits on Feb 13, 2025

Commits on Feb 19, 2025

Use remove to avoid possible shared unbounded reader.
scwhittle
committed

Commits on Feb 20, 2025

address comment
scwhittle
committed