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 at
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
attribute from within TableFunction, as far as I know.
What you could do is to do the splitting logic in DataStream API and
register a proper table with
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
