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....@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> ja...@data-artisans.com
