Flink 如何支持动态sql ？

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中 获取 ？