Yating Xie
Yating Xie

性别: 注册于 2021-11-05

向TA求助
20金币数
640 经验值
0个粉丝
主页被访问 1541 次

最近动态

2022-08-17 18:11 回答问题

2022-08-17T18:07:04.047 不符合DolphinDB中TIMESTAMP类型的数据格式,需要改为2022.08.17T18:07:04.047 如果您的原始数据文件里就是2022-08-17T18:07:04.047的话,可以用temporalParse 转换一下格式 temporalParse("2022-08-17T18:07:04.047","y-M-d H:m:s.SSS")

2022-08-17 18:02 回答问题

这个报错的意思是对共享表只能用sql查询,目前这里你的keyedTable不share才可以用sliceByKey t1 = keyedTable(`sym`side, 10000:0, `sym`side`price`qty, [SYMBOL,CHAR,DOUBLE,INT]) insert into t1 values(`IBM`MSFT`IBM, ['B','S','S'], 125.27 208.9 125.29, 1000 800 200) sliceByKey(t1, [["IBM", "MS

2022-08-05 18:01 回答问题

通过submitjob后台作业提交replay任务,不阻塞当前GUI,或者重开一个GUI。 以下脚本用submitjob提交后台作业进行回放,后两个函数是作业的运维函数。 submitJob("jobName", "jobDesc",  replay,  yourInputTable,  yourOutputTable, `date, `time, 100000, true, 4) //用submitJob提交后台回放作业getRecentJobs() //查看作业状态、作业idcancelJob(

2022-08-05 17:46 回答问题

select sym,rowCount(price1,price2) as count from t;

2022-07-18 18:07 回答问题

replay(inputTables=[ds1,ds2],outputTables=[st1,st2],dateColumn=`date,timeColumn=`time, replayRate =200000, absoluteRate =true) 是的,这样设置的话是每秒两张表一共回放200000条数据。每秒每张表分别回放多少条数据取决于原始数据的分布,并不是一个固定的值。

2022-07-11 10:36 回答问题

如果需要按分组实现的话,建议用context by和having,示例代码如下: t = table(0 0 0 1 1 1 0 0 1 1 0 0 1 2 as value, 2022.01.01 12:00:00 + 1..14 as time, take(1, 8) join take(2, 6) as id) select * from t context by id having (value != prev(value) and isValid(prev(value))) or (valu

2022-05-09 18:20 回答问题

主线程需要阻塞一下,您的情况是线程创建后又立刻结束、线程崩溃了。 可以加thread->join()让程序一直运行不要退出  ThreadedClient threadedClient(listenport); auto thread = threadedClient.subscribe(hostName, port, onehandler, "replayStreamTB", "printStreamTB", -1, true, nullptr, false, false,

2022-04-21 22:05 回答问题

目前在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>,

2022-04-21 21:54 回答问题

用table1.factor 这样的写法 share streamTable(1:0, `time`sym`factor, [TIMESTAMP, SYMBOL, DOUBLE]) as table1 share streamTable(1:0, `time`sym`factor, [TIMESTAMP, SYMBOL, DOUBLE]) as table2 prevailingQuotes=table(100:0, `time`sym`factor1`factor2, [TIMESTAMP, SYMBO

2022-04-21 21:34 回答问题

报错解释:dropStreamTable时该表还有通过subscribeTable提交的订阅解决方法:需要先用unsubscribeTable取消相关的订阅后再dropStreamTable。1、如何查看流表所有的订阅? getStreamingStat().pubTables可以查询所有的流数据表订阅关系 2、如何取消订阅? 使用unsubscribeTable函数,在信息订阅端的节点执行,以停止向信息发布者订阅数据。 3、可以一键取消所有的订阅吗? 可以的。getStreamingStat().pu