flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Regarding time window based on the values received in the stream
Date Fri, 18 Nov 2016 08:50:07 GMT
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

On thing that came to my mind reading your description, are you sure that
the events arrive in the correct order?

Best,
Fabian

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/windows.html
[2] http://flink.apache.org/news/2015/12/04/Introducing-windows.html

2016-11-18 1:04 GMT+01:00 Abdul Salam Shaikh <abd.salam.shaikh@gmail.com>:

> 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 is triggered which performs a calculation based on the values
> collected.
>
> DataStream<Tuple4<String,Double,String,Integer>> detectorEventStream =
> streamMatchedTuples
>         .keyBy(Based on the first param of the tuple)
>         .timeWindow(based on the second param of the tuple)
>         .apply(new PhaseCalculator());
>
> I am relatively new in flink so I would like to have ideas on how to
> proceed.
>
> --
> Thanks & Regards,
>
> *Abdul Salam Shaikh*
>
>

Mime
View raw message