flinkSQL eventtime问题

[★猛★]

hi,


    咨询一下，我有个table里边有个map字段，我想用map里的某个字段作为eventtime，有没有办法实现？

[Dream-底限]

hi
可以在转换为table之前把map的eventtime字段提取出来注册

★猛★ <[hidden email]> 于2020年8月19日周三 下午5:23写道：

> hi,
>
>
> &nbsp;&nbsp;&nbsp; 咨询一下，我有个table里边有个map字段，我想用map里的某个字段作为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，有没有办法实现？