hi,all
??????????????????????????????????????????????
tableEnv.createTemporaryView("sensor", sensorTable);
val resultSqlTable = tableEnv.sqlQuery("select country, count(order_id) as cnt
from sensor group by country");
??????socket??????????????
001 usa
002 usa
003 china
002 china
004 usa
??????????????????????????????
usa, 2
china, 2
??????????????
usa, 3
china, 2
??????usa??????????????????????????????????????usa????????????
????????????????????????
??????????????????????????????????????????
thanks
