GitHub user scwhittle opened a pull request:
https://github.com/apache/incubator-beam/pull/1564
[Beam-986] Fix LateDataDroppingDoFnRunner to not increment the counter on
reiterâ¦
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user scwhittle opened a pull request:
https://github.com/apache/incubator-beam/pull/1519
[BEAM-986] Improvements to ReduceFnRunner prefetching
- add prefetch* methods for prefetching state matching existing methods
- replace onTimer with batched onTimers method to allow
GitHub user scwhittle opened a pull request:
https://github.com/apache/incubator-beam/pull/1493
[BEAM-986] Deprecate TimerCallback and InMemoryTimerInternals methods using
it.
Deprecate TimerCallback and InMemoryTimerInternals methods using it.
Instead separate advancing
GitHub user scwhittle opened a pull request:
https://github.com/apache/incubator-beam/pull/1366
[BEAM-986] Improve ReduceFnRunner prefetching
Hi @kennknowles , can you please take a look?
This refactoring ensures that for batches of elements or timers we have at
most 2
