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

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

2.00分支的TSDB的默认值是DolphinDB系统可使用（maxMemSize设置）的5%，最小值是0.1GB. 查询索引已经占用内存大小的语句： select capacity\1024\1024\1024 as capacityGB, round(usage\1024\1024\1024,2) as usageGB from pnodeRun(getLevelFileIndexCacheStats)

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

可以通过函数getTabletsMeta()查看数据节点chunk的元数据信息，包含了chunk所在数据节点信息。 基于上述函数，封装一个该场景的查询函数： def chunkDistribution(dbName, tbName){ return select count(*) from pnodeRun(getTabletsMeta{"/"+substr(dbName,6)+"/%",tbName,true,-1}) group by node } dbName = "dfs://testD

2022-03-17 19:00 回答问题

可以执行查询函数： getCpuAffinity() 返回如下信息： 说明该节点的DolphinDB进程绑定在序列号为0~15的CPU核心上