关于asof join的delayedTime参数和触发时机的疑问?

目前这样写的asofengine: createAsofJoinEngine(name="aje",leftTable=res_quotes,rightTable=res_ohlc,outputTable=result,metrics=[<spread>,<bidasknum>,<posneg>,<ma3>],matchingColumn=`symbol,timeColumn=`datetime,delayedTime=1)

我的result表定义为share streamTable(70000:0,`datetime`symbol`spread`bidasknum`posneg`ma3,[NANOTIMESTAMP,SYMBOL,LONG,LONG,STRING,LONG]) as result

文档里说“当 useSystemTime = false(缺省值)时,按照数据中的时间列进行计算。请注意,触发计算的数据并不会参与该次计算。”,按照这个意思,那么它就不能满足我需要了,我预想的是 左表resquotes表每插入一条记录就触发与右表的asofjoin, 能否通过设置delayedTime参数满足我的需求? 另外我的datetime列为NANOTIMESTAMP类型,所以delayedTime应该设为多少?

请先 登录 后评论

1 个回答

alex

这个 asof join 可能无法完成,可能自定义 handler 或者 createReactiveEngine 可以完成

请先 登录 后评论
  • 1 关注
  • 0 收藏,886 浏览
  • ddbuserex 提出于 2022-02-08 15:58

相似问题