I’ve got the concept figured out, but don’t know how. For example, I have 2 kafka tables `a` and `b`, and want to execute a continuous query like ’select a.f1,b.f1 from a left join b on a .f0 = b.f0’. How to write the sql to tell flink that it’s a continuous query?
> 2023年3月8日 09:24，yuxia <luoyu...@alumni.sjtu.edu.cn> 写道： > > What do your mean "try the feature of dynamic table", do you want to know the > concept of dynamic table[1] or User-defined Sources & Sinks[2] with dynamic > table? > [1]: > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/concepts/dynamic_tables/ > [2]: > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/ > > Best regards, > Yuxia > > ----- 原始邮件 ----- > 发件人: "Jie Han" <tunyu...@gmail.com> > 收件人: "User" <user@flink.apache.org> > 发送时间: 星期三, 2023年 3 月 08日 上午 7:54:06 > 主题: Example of dynamic table > > Hello community! > I want to try the feature of dynamic table but do not find examples in the > official doc. > Is this part missing?
