Yating Xie
Yating Xie

性别: 注册于 2021-11-05

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

最近动态

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

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

报错解释:创建持久化流表时报错,需要指定配置参数 persistenceDir,即保存持久化流数据表的文件夹路径解决方法:在配置文件中指定persistenceDir,修改节点配置信息后,重启数据节点/计算节点

2022-04-21 20:55 回答问题

报错解释:在subscribeTable时通过tableName参数指定订阅的数据表名,该表必须为共享的流数据表,否则报错解决方法:将需要订阅的流表创建为共享流数据表,检查一下您的tableName参数对应的表是否可能是普通流表用share创建共享流表t1= streamTable(1 2 3 as id, 4 5 6 as value); share t1 as table1; 用enableTableShareAndPersistence创建持久化共享流表

2022-04-11 14:51 回答问题

1、看下当前所有数据节点内存使用情况 select site, maxMemSize, memoryUsed, memoryAlloc from rpc(getControllerAlias(),getClusterPerf)

2022-04-10 16:54 回答问题

getPerf() 函数以字典的形式返回本地节点上的多个性能监控度量值,其中cpuUsage 为CPU使用率。也可以在服务器上从系统层面直接查看DolphinDB进程的cpu使用情况。 DolphinDB提供了内置函数、web界面、通过第三方系统的API这三种性能监控方式。详细可参阅用户手册 性能监控这一节。

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

1、暂时没有这方面的比较。您可以对自己的脚本运行起来观察一下,使用timer 可以方便地返回一条命令的执行时间。 2、如果sql的计算结果过大,那么sql语句确实是需要优化的,比如按日期拆成多次sql来做,遍历日期并且每次把结果写入到数据库里。如果只是sql的中间过程内存消耗大、sql的结果并不大的话,也可以在遍历日期的过程中直接在内存里拼接最终结果

2022-04-04 18:25 回答问题

不能用table=NULL来释放共享流表。如果是普通的共享流表建议用undef(`table, SHARED)或者dropStreamTable(table) 来删除;如果是持久化共享流表,只能用dropStreamTable来删除,并且会将磁盘上持久化的数据删除。