Hi,
sorry for the late reply.
There is a repository [1] with an example application that uses a custom
trigger [2] (though together with a TimeWIndow and not with a GlobalWindow).
I'm not aware of a repo with an example of a GlobalWIndow.
Regarding the question about timestamps and watermarks: I
Hello Mr Hueske,
Thank you for reaching out to my query.
The example stated in the documentation is the same use case for me where I
am trying to build a prototype regarding a traffic metric in Germany as a
part of my thesis.
The data is received from multiple detectors and there is a field whic
Hi,
that does not sound like a time window problem because there is not
time-related condition to split the windows.
I think you can implement that with a GlobalWindow and a custom trigger.
The documentation about global windows, triggers, and evictors [1] and this
blogpost [2] might be helpful
O
Hi,
I have a requirement for my thesis project where I need to set the time
window based on the value which I received in the event stream.
I need to collect the values when the value starts at 0 and increments to a
max value(which is unknown) till the value resets to 0 again on which a
trigger i
