回复： flinkSQL eventtime问题

Wed, 19 Aug 2020 02:58:00 -0700 

Hi:
create table kafka (
nested_field Row(event_time timestamp(3), other_field string),
watermark for nested_field.event_time as {watermark_definition}
) with (
‘connector' = ‘kafka'
)
看看这样能够使用


Best,
xiao cai


 原始邮件 
发件人: ★猛★<[email protected]>
收件人: user-zh<[email protected]>
发送时间: 2020年8月19日(周三) 17:48
主题: 回复： flinkSQL eventtime问题


我是通过kafka直接注册tablesource ，数据是avro的。 
descriptor.inAppendMode().registerTableSource(source_table_name); 
我们在想怎么把avro里嵌套的某个字段用作eventime 
------------------&nbsp;原始邮件&nbsp;------------------ 发件人: "user-zh" 
<[email protected]&gt;; 发送时间:&nbsp;2020年8月19日(星期三) 下午5:30 
收件人:&nbsp;"user-zh"<[email protected]&gt;; 主题:&nbsp;Re: flinkSQL 
eventtime问题 hi 可以在转换为table之前把map的eventtime字段提取出来注册 ★猛★ 
<[email protected]&gt; 于2020年8月19日周三 下午5:23写道： &gt; hi, &gt; &gt; &gt; 
&amp;nbsp;&amp;nbsp;&amp;nbsp; 
咨询一下，我有个table里边有个map字段，我想用map里的某个字段作为eventtime，有没有办法实现？

回复