2022-07-22 13:15 回答问题

查询当前节点的连接数： getConnections() 查询集群内所有节点的： pnodeRun(getConnections)

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

提供一种解决方案： def cancelAllJobs(){ 2 nodes = exec node from pnodeRun(getRecentJobs) where endTime=NULL 3 jobIds = exec jobId from pnodeRun(getRecentJobs) where endTime=NULL 4 print("All running jobs number is: "+size(nodes)) 5 if(size(nodes)>0){ 6 for(i i

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

DolphinDB数据库存储时间信息是无时区的，1656898205942是unix时间戳，表示0时区的2022/7/4 1:30:5.942，但是DolphinDB存储无时区概念，存入1656898205942时间戳，代表的时间就是2022/7/4 1:30:5.942，所以查询出来也是2022/7/4 1:30:5.942。所以存入的时候，加上一个时区的转换就可以了，DolphinDB提供了localtime函数将0时区的转成服务器本地时区。或者就是在1656898205942加上8个小时的偏移量，变成

2022-04-14 09:44 回答问题

可以使用DolphinDB的cancelJob函数取消后台作业，配合loop就可以实现批量取消后台作业的目的，参考代码如下： def cancelJobBatch(){ loop(cancelJob, exec jobID from pnodeRun(getRecentJobs) where endTime =NULL) } cancelJobBatch()

2022-04-14 09:35 回答问题

功能 DolphinDB JIT版本相比非JIT版本提供了实时编译的功能，主要功能差异参考：DolphinDB JIT教程 安装 JIT版本的安装包略大于非JIT的安装包，所以如果不需要JIT的功能，可以选择安装非JIT版本对c库版本要求不同。比如linux jit对c库的要求是GLIBC_2.18及其以上（例如centos7自带c库是GLIBC_2.17版本，不支持，需要升级），但是非jit版本没有这个限制

2022-04-14 09:30 回答问题

在上面的例子中，整个SQL表达式的执行过程 表达式要先分解，分解成转置，fill，和reduce三个步骤。 last(price)是转置前每个单元格的值fill的输入是转置后的一个列reduce的输入是转置以及fill后的所有列 所以last(price)不是fill的直接输入

2022-04-01 12:41 回答问题

以提取2020.01.02这天，SecurityID分区内HASH为1的分区的数据： select count(*) from loadTable("dfs://trade", "trade") where date(TradeTime)=2020.01.02, partition(SecurityID, 1)

2022-04-01 12:30 回答问题

可以用 replaceColumn! 函数实现： syms = symbol(exec sym from t) replaceColumn!(t, `sym, syms); schema(t).colDefs;

2022-04-01 09:55 回答问题

配置项有一个关于流数据发布过程中限制一个消息块中最多的记录条数，默认值为1024。该配置参数的名字是maxMsgNumPerBlock=1024 single单节点在dolphindb.cfg配置文件配置，集群在cluster.cfg配置文件配置。

2022-03-24 12:25 回答问题

这个是上交所所有证券快照数据存储的一个demo脚本，仅供参考 login("admin", "123456") //create snapshot_SH_L2_OLAP dbName = "dfs://snapshot_SH_L2_TSDB" tbName = "snapshot" dbTime = database(, VALUE, 2021.01.01..2021.12.31) dbSymbol = database(, HASH, [SYMBOL, 30]) if(existsDatabase(db