这个 asof join 可能无法完成,可能自定义 handler 或者 createReactiveEngine 可以完成
目前这样写的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应该设为多少?