Timely (and Stateful) Processing with Apache Beam

In a prior blog post, I introduced the basics of stateful processing in Apache Beam, focusing on the addition of state to per-element processing. So-called timely processing complements stateful processing in Beam by letting you set timers to request a (stateful) callback at some point in the future. What can you do with timers in Beam? Here are some examples: You can output data buffered in state

[kimutansk]

Beamの文書、全般的にこれやるにはこれ必要だよな、というのがきちんと書かれているあたりがいいですね。そう簡単にはできないよ、これをやるためにはこの前提必要だよというは大事です。