[Python] Implement combiner deferred side inputs - #35601

Merged

damccorm merged 26 commits into

apache:masterfrom

hjtran:combine_sideinputs

Jul 22, 2025

Commits on Mar 26, 2024

squash
hjtran
committed
10d4c43
revert unnecessary fn_runner change
hjtran
committed
117a182

Commits on Jul 10, 2025

Merge branch 'master' into combine_sideinputs
hjtran
committed
9599fdf
improve test
hjtran
committed
49fb167
add a test with streaming
hjtran
committed
63cd8e5

Commits on Jul 11, 2025

add streaming with matching window test
hjtran
committed
5704a43

Commits on Jul 14, 2025

implement streaming support
hjtran
committed
5b6fe8c
add combiner support
hjtran
committed
adffdec

Commits on Jul 15, 2025

implement args support
hjtran
committed
1c2decf
more rigorously test which combinefn methods are called with side inputs
hjtran
committed
3503bd4
clean up
hjtran
committed
bdeb318
use pack/unpack terminology
hjtran
committed
76036db
add an explanatory comment
hjtran
committed
2a6c952
revert old unneeded changes
hjtran
committed
abf311a
tidy
hjtran
committed
6555e6a
use temp dir for json test file
hjtran
committed
9ff318b
add combineglobally test
hjtran
committed
d26ab6f
connect args/kwargs to all combinefn methods after all
hjtran
committed
fb5cc08

Commits on Jul 16, 2025

enable streaming for streaming tests
hjtran
committed
469c3eb
remove streaming options
hjtran
committed
c96faea
move liftedcombineperkey
hjtran
committed
48bfe03
add additional docstring to liftedcombineperkey
hjtran
committed
f4127e0
Merge branch 'master' into combine_sideinputs
hjtran
committed
440dc2a

Commits on Jul 17, 2025

isort
hjtran
committed
42d5929

Commits on Jul 22, 2025

Update sdks/python/apache_beam/transforms/combiners.py
hjtran
and
damccorm
authored
ffd9ba6
privatize a couple transforms
hjtran
committed
1d3488c