Flink 如何支持动态sql ? -问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

Flink 如何支持动态sql ?

krystal.xu 2019-01-16 17:48:29 1343

flnk 新手一枚。。
我理解flink stream = 动态table, 但是sql里的 where语句条件能否使用stream/source的值。
example:

    DataStream<String> input = env.socketTextStream("localhost", 9000, "\n");
    DataStream clickStream = input.flatMap(new ClickHbaseMapFunc());
    tEnv.registerDataStream("clickTable", clickStream, "id, studentid, url, itemtype, quantity");

    Table result = tEnv.sqlQuery("SELECT * FROM clickTable WHERE studentid =  '"+ ????+"'" );
    当中的 where语句条件 如何 能 从 input stream中 获取 ?
SQL 流计算
分享到
取消 提交回答
全部回答(1)
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

推荐文章
相似问题
推荐课程