asof join engine中结果表的一列想取now()失败

share streamTable(70000:0,`datetime`symbol`inserttime`spread`bidasksum`posneg`ma3,[NANOTIMESTAMP,SYMBOL,NANOTIMESTAMP,LONG,LONG,STRING,LONG]) as result

result_aje=createAsofJoinEngine(name="aje",leftTable=res_quotes,rightTable=res_ohlc,outputTable=result,metrics=<[now(),spread,bidasksum,posneg,ma3]>,matchingColumn=`symbol,timeColumn=`datetime,delayedTime=1)

subscribeTable(tableName="res_quotes", actionName="joinLeft", offset=0, handler=appendForJoin{result_aje, true}, msgAsTable=true)

subscribeTable(tableName="res_ohlc", actionName="joinRight", offset=0, handler=appendForJoin{result_aje, false}, msgAsTable=true)

=> Usage: createAsofJoinEngine(name, leftTable, rightTable, outputTable, metrics, matchingColumn, [timeColumn], [useSystemTime=false], [delayedTime], [garbageSize]). aggregate metric is not supported

0 条评论

默认排序时间排序

1 个回答

alex 2022-02-10 10:33

可以增加一个 handler

def addRecvTimestamp(mutable msg)

{

msg[`recvTimestamp] = take(now(), size(msg))

tbl.append!(msg)

}

subscribeTable(tableName="tbl", actionName="addRecvTimestamp", offset=-1, handler=addRecvTimestamp, msgAsTable=true)

asof join engine中结果表的一列想取now()失败

1 个回答

相似问题