关于createAsofJoinEngine引擎

请教一下如果我想实现:左表中只要加入新数据(时间大于或者等于之前的数据,以秒为精度),就触发与右表的join,并且结果能够尽快进入输出表,可以怎么设置参数?

请先 登录 后评论

1 个回答

Qing Li

如果需求是一收到数据就和右表join的话可以设useSystemTime =true, 然后把左表的数据时间加在metrics,这样做目的是outputTable可以对应输出左表的数据时间,而且默认输出join数据的时间,保证输出表既有数据时间,也有引擎处理数据时间。但是通过这样设置的话比如10:00:00.000的时候,左表和右表都有数据,左表的数据先收到了,那就会和右表的上一条记录join。保证了最快匹配数据,但是会导致不是最优匹配数据.

请先 登录 后评论