Hi Jan,
Another solution is to insert Heartbeat-events at the source for each
sensor. The solution is very similar to how to advance watermarks when
there are no elements in the respective source partition.
However, it's only easy to implement if you have your own source and know
all sensors on a
Hi,
I also think there should be different ways to achieve the target. For the
first option listed previously,
the pseudo-code roughly like
class MyFunciton extends KeyedProcessFunction {
ValueState count;
void open() {
count = ... // Create the value state
}
​void pr
