Hi,
sorry for the long wait, we are currently very busy with finalizing the 1.0
release.
I think I don’t yet completely get your use case. Could you maybe give some
example input data and what the expected behavior would be? And maybe some
code? If you already have coded something.
Cheers,
Alj
Hello,
Thanks for the reply.
Target: I have a stream of tuples(append-only, no updates) that are appended to
a file. These records have priority that is changing over time and is
calculated as a function of the tuple’s timestamp and current system time. Once
any tuple’s priority reaches some M
Hi,
in addition to the video I would also like to point out that the Continuous
triggers should only be used with the GlobalWindows assigner. For TimeWindows
the right thing to do would be using the EventTimeTrigger (or
ProcessingTimeTrigger in case you are doing processing time windows).
Could
Hi,
how about this video ?
https://www.youtube.com/watch?v=T7hiwcwCXGI
Gavin.Lin
2016-02-25 3:55 GMT+08:00 Ankur Sharma :
> Hey,
>
> Can you guide me to some example of ContinuousProcessingTimeTrigger?
> I want to partition input stream into TimeWindow that should fire at
> continuous time inte
