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

[星夜]

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