-1
We use union state to generate sequences, each operator generates offset0 +
number-of-tasks - task-index + task-specific-counter * number-of-tasks (e.g.
for 2 instances of operator -one instance produce even number, another odd).
Last generated sequence number is stored union list state, on
Hello Robert,
I'm not sure why the screenshot I attached in the previous post was not
shown. I'm trying to re-attach in this post.
As shown in this screenshot, part-1-33, part-1-34, and part-1-35 have
already been closed, but the temp file for part-1-33 is still there.
Thanks and regards
Averell
Deal All
I use the reduce operator after the TimeWindow
operator, whether to output one element after all elements in the current
window have been calculated according to reduce logic??
Thanks
Jiazhi
