flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From madhu phatak <phatak....@gmail.com>
Subject Re: Timewindow watermarks specific to keys of stream
Date Thu, 07 Jul 2016 06:22:42 GMT
Hi,
It makes sense now. Thank  you.

On Wed, Jul 6, 2016 at 8:05 AM, Jamie Grier <jamie@data-artisans.com> wrote:

> Hi Madhu,
>
> This is not possible right now but are you sure this is necessary in your
> application?  Would the timestamps for stock data really be radically
> different for different symbols that occur close together in the input
> stream.  The windows themselves are for each key but event time advances at
> the operator level, not the key level.  For most applications this works
> very well.  If you explain more about why this won't work for you maybe I
> can help more.
>
> -Jamie
>
>
> On Tue, Jul 5, 2016 at 1:14 AM, madhu phatak <phatak.dev@gmail.com> wrote:
>
>> Hi,
>> I am trying to analyse the stock market data. In this, for every symbol i
>> want to find max of stock price in last 10 mins. I want to generate
>> watermarks specific to key rather than across the stream. Is this possible
>> in flink?
>>
>> --
>> Regards,
>> Madhukara Phatak
>> http://datamantra.io/
>>
>
>
>
> --
>
> Jamie Grier
> data Artisans, Director of Applications Engineering
> @jamiegrier <https://twitter.com/jamiegrier>
> jamie@data-artisans.com
>
>


-- 
Regards,
Madhukara Phatak
http://datamantra.io/

Mime
View raw message