Yating Xie
Yating Xie

性别: 注册于 2021-11-05

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

50 个回答

1 赞同

使用insert into时报错To form a pair, both operands must be a...

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

回答于 2022-08-17 18:11

0 赞同

使用sliceByKey函数时报错Please use sql query to manipulate a...

这个报错的意思是对共享表只能用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", "M...

回答于 2022-08-17 18:02

0 赞同

一边replay回放到流数据表,一边订阅这张流数据表。在回放执行中...

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

回答于 2022-08-05 18:01

0 赞同

如何统计每一行非空字段的个数?

用 rowCount 函数,逐行进行非空值的统计操作,返回一个长度与输入参数行数相同的向量。 select sym,rowCount(price1,price2) as count from t; DolphinDB 提供了丰富的行计算函数,可以参考以下链接 https://www.dolphindb.cn/cn/help/FunctionsandCommands/SeriesOfFunctions/rowFunctions.html?highlight=row

回答于 2022-08-05 17:46

0 赞同

replay函数多对多回放时replayRate=200000, absoluteRate=true时...

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

回答于 2022-07-18 18:07

0 赞同

针对某列,希望该列的值变化时,返回变化相应的两条记录,SQL如...

如果需要按分组实现的话,建议用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 (value != next(value) and...

回答于 2022-07-11 10:36

0 赞同

使用c++API的threadedClient.subscribe订阅流数据,为什么订阅程...

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

回答于 2022-05-09 18:20

1 赞同

使用createReactiveStateEngine时报错A metric shouldn't be a c...

在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)

回答于 2022-04-21 22:05

0 赞同

在使用join引擎时左右两表有相同的字段名在metric中如何区分?

用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, SYMBOL, DOUBLE, DOUBLE]) ajEngine=createAso...

回答于 2022-04-21 21:54

0 赞同

dropStreamTable时报错All subscriptions to the shared stream...

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

回答于 2022-04-21 21:34