如何在metrics参数里 表示出流表的所有列,而不是逐个字段列出,或者将整个流表传递给自定义状态函数


del_engine = createReactiveStateEngine(name="del_engine", metrics=<multiFactors(replay_streamtb)>, dummyTable=replay_streamtb,outputTable =del_Table, keyColumn=["symbol"], keepOrder=true)

请先 登录 后评论

1 个回答

Polly

metrics 部分的元代码可以用元编程的方式实现拼接,例如:

t=streamTable(100:0,`date`time`sym`qty`price`exch,[DATE,TIME,SYMBOL,INT,DOUBLE,SYMBOL])
share t as trades
opt=streamTable(100:0,`sym`fac,[SYMBOL,DOUBLE])
def f(date,time,sym,qty,price,exch){
    return qty * price
}
createReactiveStateEngine(name="del_engine", metrics=makeUnifiedCall(f, sqlCol(trades.columnNames())), dummyTable=trades,outputTable =opt, keyColumn=["sym"])
请先 登录 后评论
  • 1 关注
  • 0 收藏,146 浏览
  • yiar 提出于 2024-03-18 13:06

相似问题