apache / beam

Apache Beam is a unified programming model for Batch and Streaming data processing.
https://beam.apache.org/
Apache License 2.0
7.68k stars 4.19k forks source link

Add support for Batched DoFns in the Python SDK #21650

Open damccorm opened 2 years ago

damccorm commented 2 years ago

Add an implementation for https://s.apache.org/batched-dofns to the Python SDK.

Imported from Jira BEAM-14213. Original Jira may contain additional context. Reported by: bhulette.

damccorm commented 2 years ago

The following subtask(s) are associated with this issue: #21651, #21652, #21653, #21654, #21655, #21656

TheNeuralBit commented 1 year ago

Subtasks: