This was very helpful. Thank you very much :)
| |
maidangdang44
|
|
maidangdan...@126.com
|
签名由网易邮箱大师定制
On 10/23/2018 15:20，Dawid Wysakowicz wrote：
Hi,
The problem is that sTime is not a Time Attribute[1], which has to be aligned
with watermarks mechanism. Right now you cannot create a time
below is one line of my source, the body containes the user logs:
{
body: [
"user1,url1,2018-10-23 00:00:00;user2,url2,2018-10-23
00:01:00;user3,url3,2018-10-23 00:02:00"
]
}
I user LATERAL TABLE and a User-Defined TableFunction flatmap the source to a
new table log, and I wan
