????????????????

[Natasha]

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