回复： flinkSQL eventtime问题

[xiao cai]

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


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


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