API??????TableEnvironment??????scan????????tablePath????????????tablePath? 
 
 
??????https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/time_attributes.html
 ???????????????????? 
 
 
????????????UserActions??TableSource????????scan??????TableSource????????????????????????????????????????????????????????????
 
 ?????????????? 
 
 ?????????????? 
 
 ????????user_moid??????TableSource??TableSource??????????scan????????

回复