65 个回答
针对某列，希望该列的值变化时，返回变化相应的两条记录，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
使用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
使用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
在使用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
dropStreamTable时报错All subscriptions to the shared stream...
报错解释：dropStreamTable时该表还有通过subscribeTable提交的订阅解决方法：需要先用unsubscribeTable取消相关的订阅后再dropStreamTable。1、如何查看流表所有的订阅？ getStreamingStat().pubTables可以查询所有的流数据表订阅关系2、如何取消订阅？ 使用unsubscribeTable函数，在信息订阅端的节点执行，以停止向信息发...
回答于 2022-04-21 21:34
使用enableTableShareAndPersistence创建持久化流表时报错To ena...
报错解释：创建持久化流表时报错，需要指定配置参数 persistenceDir，即保存持久化流数据表的文件夹路径解决方法：在配置文件中指定persistenceDir，修改节点配置信息后，重启数据节点/计算节点通过3种方式进行配置，请参考 用户手册-流计算
回答于 2022-04-21 21:03
用subscribetable函数时报错The publisher doesn't have the tab...
报错解释：在subscribeTable时通过tableName参数指定订阅的数据表名，该表必须为共享的流数据表，否则报错解决方法：将需要订阅的流表创建为共享流数据表，检查一下您的tableName参数对应的表是否可能是普通流表可以用以下语句创建共享流表：使用share创建共享流表t1= streamTable(1 2 3 as id, 4 5 6 as value); share t1...
回答于 2022-04-21 20:55
流计算场景下DolphinDB发生OOM，如何排查具体的内存使用的情况？...
1、查看当前所有数据节点内存使用情况（maxMemSize 是程序的实际最大内存限制，oom的情况下memoryUsed应该已经基本打满至maxMemSize了） select site, maxMemSize, memoryUsed\1024\1024\1024 as memoryUsed, memoryAlloc\1024\1024\1024 as memoryAlloc from rpc(getControllerAlias(),getClusterPerf) 程序的实际最大...
回答于 2022-04-11 14:51
在ddb服务端持续处理流表进来的数据时，可以查看CPU的占用情况吗
getPerf() 函数以字典的形式返回本地节点上的多个性能监控度量值，其中cpuUsage 为CPU使用率。也可以在服务器上从系统层面直接查看DolphinDB进程的cpu使用情况。 DolphinDB提供了内置函数、web界面、通过第三方系统的API这三种性能监控方式。详细可参阅用户手册 性能监控这一节。
回答于 2022-04-10 16:54
继续咨询SQL引擎和流引擎计算方式的区别
1、暂时没有这方面的比较。您可以对自己的脚本运行起来观察一下，使用timer 可以方便地返回一条命令的执行时间。 2、如果sql的计算结果过大，那么sql语句确实是需要优化的，比如按日期拆成多次sql来做，遍历日期并且每次把结果写入到数据库里。如果只是sql的中间过程内存消耗大、sql的结果并不大的话，也可以在遍历日期的...
回答于 2022-04-07 18:12