开发者社区> 问答> 正文

Flink 如何支持动态sql ?

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

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中 获取 ?
分享到
取消 提交回答
全部回答(0)