1、设置ksql语句:
2、执行ksql并放入到table中:
Table table1 = KSQL.select(ksql1, null, "/OA/attendance/data", null);
3、使用iterator,循环找到数据
Iterator<Row> iterator1 = table1.iterator(); var name = "";
while (iterator1.hasNext()) { Row info = iterator1.next();
var name = info.getString("fName"); }