关于createAsofJoinEngine引擎

createAsofJoinEngine引擎触发join的机制是什么

请先 登录 后评论

1 个回答

Qing Li

createAsofJoinEngine使用于左表为高频交易数据表,右表低频数据表。
可以设置一下delayedTime参数来决定asofjoin的条件.
delayedTime 只能在useSystemTime = false时指定,有两条规则:一条规则是(如果leftTable中的最新的数据时间t1 - leftTable中未计算的数据时间t2)>delayedTime, 则认为rightTable的最新时间rt到t2这段时间内,rightTable没有数据输入,t2这条记录可以直接触发join。或者另外一条规则是leftTable中的数据在经过 2 *delayedTime(小于2秒按2秒算,按照系统经过的时间)后还没join输出,则直接触发join。

请先 登录 后评论