以下是流水线处理,目前只是写法有区别 dummy = table(1:0, `sym`time`maxIndex, [SYMBOL, TIMESTAMP, DOUBLE])resultTable = streamTable(10000:0, `time`sym`factor1, [TIMESTAMP, SYMBOL, DOUBLE])ccsRank = createCrossSectionalAggregator(name="alpha1CCS", metrics=<[sym, rank(maxIndex)\count(maxIndex) - 0.5...
回答于 2022-02-09 09:39
这个 asof join 可能无法完成,可能自定义 handler 或者 createReactiveEngine 可以完成
回答于 2022-02-09 09:34
因为在 响应式引擎与其它引擎不同, result 每一列都要有一个metrics中的元代码来输出, 比如有3列 ,就要有3段元代码分别计算(即 [<a>,<b>,<c>]), <[a,b,c]> 只是1段源代码
回答于 2022-02-08 16:35
Hi:1. Sorry, sequence sensitive function isn't supported in reactive engine yet 2. Yes, the params to move must be positive, for now. We will inform you if these features are available in the future. Regards
回答于 2022-01-28 10:09
不知道这是不是想要的 假设 ANY DICTIONARY 是 string -> int d = {a: 1, b: 2} tbl = table(d.keys() as k ,d.values()$INT as v) edit : 如果要用 ANY DICT 的 key 做 column name 的话: tbl = table(0:2, d.keys() , `INT`INT) 参考:https://www.dolphindb.cn/cn/help/130/FunctionsandCommands/Functi...
回答于 2022-01-27 17:26
你好 关于问题2, 方便贴一下 dolphindb.cfg 吗? 另外能运行一下 netstat -nlp |grep dolphin 确认一下 dolphindb 是否运行在 8848 端口 附: 如果还有问题,可以添加我的企业微信
回答于 2022-01-27 12:06