timer_wordcap command
timer_wordcap is a toy streaming pipeline that demonstrates the use of State and Timers. Periodic Impulse is used as a streaming source that produces sequence of elements upto 5 minutes from the start of the pipeline every 5 seconds. These elements are keyed and fed to the Stateful DoFn where state and timers are set and cleared. Since this pipeline uses a Periodic Impulse, the pipeline is terminated automatically after it is done producing elements for 5 minutes.
- Version
- v2.65.0 (latest)
- Published
- May 6, 2025
- Platform
- linux/amd64
- Imports
- 12 packages
- Last checked
- 1 day ago –
Tools for package owners.