You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 星夜 <16...@qq.com> on 2021/03/04 14:13:30 UTC

Flink能否实现从一个流中读取sql并动态执行？

&nbsp; &nbsp; &nbsp;flink新手一枚，现在有个需求需要对数据流进行监控，其中监控规则是一条条的sql，且是动态变化的。请教下各位，是否有办法动态的提交sql?
&nbsp; &nbsp; &nbsp;&nbsp;
&nbsp; &nbsp; &nbsp; example:
&nbsp; &nbsp; &nbsp;&nbsp;tEnv.registerDataStream("tableName", dataStream, "id, name, age ,time");
&nbsp; &nbsp; &nbsp;&nbsp;Table result = tEnv.sqlQuery("SQL语句" ); 
  
    这里的SQL语句能否从另一个流里读进来，然后提交上去？