The GroupIntoBatches transform can be significantly optimized on Dataflow since it always ensures that a key K appears in only one bundle after a GroupByKey. This removes the usage of state and timers in the generic GroupIntoBatches transform.
Imported from Jira BEAM-7912. Original Jira may contain additional context.
Reported by: lcwik.
The GroupIntoBatches transform can be significantly optimized on Dataflow since it always ensures that a key K appears in only one bundle after a GroupByKey. This removes the usage of state and timers in the generic GroupIntoBatches transform.
Imported from Jira BEAM-7912. Original Jira may contain additional context.
Reported by: lcwik.