00 Fabian Hueske :
>
>> Hi,
>>
>> Assuming you are using event time, the right function to generate a row
>> time attribute from a window would be "w1.rowtime" instead of "w1.start".
>>
>> The reason why Flink is picky about this is that we mu
code hard to read. I’m thinking about watermark,
but not sure how to do this.
--
Thanks
Ivan
From: TechnoMage
Date: Thursday, 12 April 2018 at 3:21 AM
To: Ivan Wang
Cc: "user@flink.apache.org"
Subject: Re: Is Flink able to do real time stock market analysis?
I am new to Flink so
Hi all,
I've spent nearly 2 weeks trying to figure a solution to my requirement as
below. If anyone can advise, that would be great.
1. There're going to be 2000 transactions per second as StreamRaw, I'm
going to tumbleWindow them as StreamA, let's say every 15 seconds. Then I'm
going to countWin
Hi all,
I'd like to use 2 window group in a chain in my program as below.
Table myTable = cTable
.window(Tumble.*over*("15.seconds").on("timeMill").as("w1"))
.groupBy("symbol, w1").select("w1.start as start, w1.end as end,
symbol, price.max as p_max, price.min as p_min")
