A stream source that: 1) emits a list of elements without allowing checkpoints, 2) then waits for two more checkpoints to complete, 3) then re-emits the same elements before 4) waiting for another two checkpoints and 5) exiting.
A simple utility for collecting all the elements in a
Granularity for latency metrics.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.