Hi Nirmalya,
please find my answers in line.
2015-12-02 3:26 GMT+01:00 Nirmalya Sengupta :
> Hello Fabian (),
>
> Many thanks for your encouraging words about the blogs. I want to make a
> sincere attempt.
>
> To summarise my understanding of the rule of removal of the elements from
> the window
Hello Fabian (),
Many thanks for your encouraging words about the blogs. I want to make a
sincere attempt.
To summarise my understanding of the rule of removal of the elements from
the window (after going through your last mail), here are two corollaries:
1) If my workflow has no triggers (and h
Hi Nirmalya,
please don't feel discouraged to write blog posts! There are many things
you could write about Flink's support for windows, e.g., you could discuss
use cases / applications that require advanced window semantics.
Regarding my comment on how/when elements are removed from a window:
El
Hello Fabian,
Thanks for going through my long mail and concise responses. I am just
happy that I was not way off the mark in my understanding.
It seems to me that I would rather wait for your blog before asking more
questions. Not sure, if I will left with enough drive to write my (planned)
blog
Sorry, I have to correct myself. The windowing semantics are not easy ;-)
2015-11-30 15:34 GMT+01:00 Fabian Hueske :
> Hi Nirmalya,
>
> thanks for the detailed description of your understanding of Flink's
> window semantics.
> Most of it is correct, but a few things need a bit of correction ;-)
Hi Nirmalya,
thanks for the detailed description of your understanding of Flink's window
semantics.
Most of it is correct, but a few things need a bit of correction ;-)
Please see my comments inline.
2015-11-28 4:36 GMT+01:00 Nirmalya Sengupta :
> Hello Fabian,
>
>
> A little long mail; please
Hello Fabian,
A little long mail; please have some patience.
>From your response: ' Let's start by telling me what you actually want to
do ;-) '
At a broad level, I want to write a (series of, perhaps) tutorial of Flink,
where these concepts are brought out by a mix of definition, elaboration,
Hi Nirmalya,
can you describe the semantics that you want to implement?
Do you want to find the max temperature every 5 milliseconds or the max of
every 5 records?
Right now, you are using a non-keyed timeWindow of 5 milliseconds. This
will create a window for the complete stream every 5 msecs.
H
