Question: how to change data timestamp for late arriving data about differential-dataflow HOT 4 OPEN

You are able to use update_at, but you must maintain the property that you do not advance the input session's time past the times you would like to use. The input session's time is a promise to the rest of the system that your times will be at least whatever that time is. This can be a problem if you can receive arbitrarily delayed inputs, but there isn't too much to do if you want "correct" outputs that are not indefinitely delayed. Another option is to look into multi-temporal timestamps, which allow you to track both event time and system time at the same time.

from differential-dataflow.

Hi, check out UnorderedInput

from differential-dataflow.

Thanks @nooberfsh , I will check it. And I found update_at function for InputSession, should I also can use update_at function?

Update: Looks like shouldn't use update_at as it's require parameter time must greater than current time.
assert!(self.time.less_equal(&time));

from differential-dataflow.

Thanks @frankmcsherry for the comments. I will study the post first, the post you shared is very useful for understanding some concepts which confused me before. I read some of blog but not noticed this one...

Thanks again.

from differential-dataflow.