flink sql ??????ROW<`age` INT>??????INT??
streamTableEnv.sqlUpdate( """ | |insert into user_age |SELECT rowkey, cast(cf as int) as age |FROM | users | |""".stripMargin)??????????????
flink sql ??????ROW<`age` INT>??????INT??
streamTableEnv.sqlUpdate( """ | |insert into user_age |SELECT rowkey, cast(cf as int) as age |FROM | users | |""".stripMargin)??????????????