功能 DolphinDB JIT版本相比非JIT版本提供了实时编译的功能,主要功能差异参考:DolphinDB JIT教程 安装 JIT版本的安装包略大于非JIT的安装包,所以如果不需要JIT的功能,可以选择安装非JIT版本对c库版本要求不同。比如linux jit对c库的要求是GLIBC_2.18及其以上(例如centos7自带c库是GLIBC_2.17版本,不支持,需要升级...
回答于 2022-04-14 09:35
在上面的例子中,整个SQL表达式的执行过程 表达式要先分解,分解成转置,fill,和reduce三个步骤。 last(price)是转置前每个单元格的值fill的输入是转置后的一个列reduce的输入是转置以及fill后的所有列 所以last(price)不是fill的直接输入
回答于 2022-04-14 09:30
以提取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:41
可以用 replaceColumn! 函数实现: syms = symbol(exec sym from t) replaceColumn!(t, `sym, syms); schema(t).colDefs;
回答于 2022-04-01 12:30
配置项有一个关于流数据发布过程中限制一个消息块中最多的记录条数,默认值为1024。该配置参数的名字是maxMsgNumPerBlock=1024 single单节点在dolphindb.cfg配置文件配置,集群在cluster.cfg配置文件配置。
回答于 2022-04-01 09:55
这个是上交所所有证券快照数据存储的一个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(dbName)){ dropDatab...
回答于 2022-03-24 12:25
2.00分支的TSDB的默认值是DolphinDB系统可使用(maxMemSize设置)的5%,最小值是0.1GB。 也可以通过配置参数TSDBLevelFileIndexCacheSize设置,单位为GB。 查询索引已经占用内存大小的语句: select capacity\1024\1024\1024 as capacityGB, round(usage\1024\1024\1024,2) as usageGB from pnodeRun(getLevelFileIndexC...
回答于 2022-03-24 12:12
可以通过函数getTabletsMeta()查看数据节点chunk的元数据信息,包含了chunk所在数据节点信息。 基于上述函数,封装一个该场景的查询函数: def chunkDistribution(dbName, tbName){ return select count(*) from pnodeRun(getTabletsMeta{"/"+substr(dbName,6)+"/%",tbName,true,-1}) group by node } dbName = "dfs:...
回答于 2022-03-24 12:04
可以执行查询函数: getCpuAffinity() 返回如下信息: 说明该节点的DolphinDB进程绑定在序列号为0~15的CPU核心上
回答于 2022-03-17 19:00
DolphinDB提供了常用的流计算监控函数 节点的消费队列、消费情况等信息 getStreamingStat().subWorkers 节点的发布队列情况 getStreamingStat().pubConns 节点的订阅关系查询 getStreamingStat().pubTables 已经定义的所以计算引擎信息查询 getStreamEngineStat() 具体某种引擎的查询,参考: getStreamEngineSta...
回答于 2022-03-17 18:49