流数据引擎的metrics如果有很多计算列,能否在引擎外面定义并赋值给变量后传参?

目前的流数据引擎创建语句是这样的:

createTimeSeriesEngine(name="IndexTsAggr", windowSize=60000, step=60000, metrics=<[first(LastPrice), last(LastPrice),max(LastPrice),min(LastPrice),last(TotalVolumeTrade)-first(TotalVolumeTrade),last(TotalValueTrade)-first(TotalValueTrade),avg(time(UpdateTime1)-MDTime)]>, dummyTable=IndexStream, outputTable=IndexAggrTable, useSystemTime=true, keyColumn="HTSCSecurityID", fill=["ffill", "ffill", "ffill", "ffill", 0, 0, "null"])

假设metrics有很多计算列,能否在引擎外面定义并赋值给变量后传参?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

可以尝试这样写:

metrics =<[
first(LastPrice), 
last(LastPrice),
max(LastPrice),
min(LastPrice),
last(TotalVolumeTrade)-first(TotalVolumeTrade),
last(TotalValueTrade)-first(TotalValueTrade),
avg(time(UpdateTime1)-MDTime)
]>
createTimeSeriesEngine(name="IndexTsAggr", windowSize=60000, step=60000, metrics=metrics, dummyTable=IndexStream, outputTable=IndexAggrTable, useSystemTime=true, keyColumn="HTSCSecurityID", fill=["ffill", "ffill", "ffill", "ffill", 0, 0, "null"])
请先 登录 后评论