使用createReactiveStateEngine时报错A metric shouldn't be a constant.如何在metrics中传入一个常量

下面的写法报错A metric shouldn't be a constant.,请问怎么可以实现在metrics中传入一个常量

share streamTable(1:0, `date`time`sym`market`price`qty, [DATE, TIME, SYMBOL, CHAR, DOUBLE, INT]) as trade
outputTable = table(100:0, `date`sym`factor1`flag, [DATE, STRING, DOUBLE, INT])
engine = createReactiveStateEngine(name="test", metrics=[<mavg(price, 3)>, <1>], dummyTable=trade, outputTable=outputTable, keyColumn=["date","sym"], filter=<date between 2012.01.01 : 2012.01.03>, keepOrder=true)
请先 登录 后评论

1 个回答

Yating Xie

在metrics中不支持常量,但是可以用下面的办法实现

engine = createReactiveStateEngine(name="test", metrics=[<mavg(price, 3)>, <price-price+1>], dummyTable=trade, outputTable=outputTable, keyColumn=["date","sym"], filter=<date between 2012.01.01 : 2012.01.03>, keepOrder=true)
请先 登录 后评论