博文

目前显示的是 三月, 2018的博文

Fink:使用Table api和SQL

这几天在学习和使用flink中的table api和SQL部分,准备使用之前的数据做一个查询的小实验,简而言之,就是在接收到一条车辆流水数据之后,判断他是否是一条出站数据,如果是的话,就查询到之前与它对应的如站数据。然后,也可以使用table做一些其他的事情。