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
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/
