Jason Tang
Jason Tang - 时序数据库技术支持

性别: 浙江 - 杭州 注册于 2021-05-07

向TA求助
340金币数
2080 经验值
3个粉丝
主页被访问 2618 次

184 个回答

0 赞同

如何清除当前节点上的所有共享变量?

可以使用下面的自定义函数,取消当前节点上的所有共享表的定义: def existsShareVariable(varName){ return objs(true).name.find(varName)>=0 } def ClearAllSharedTables(){ sharedTables = exec name from objs(true) where form="TABLE", shared=true for(sharedTable in sharedTables){ print("Undef S...

回答于 2022-11-25 09:53

0 赞同

如何遍历一个集合(set)里面的所有元素?

set表示集合,没有重复元素,不能直接遍历其中的元素,可以通过 keys 函数先转换成一个 vector 类型,具体代码如下 t1 = set(1..23) t2 = set(2..34) result = t1^t2 vecResult = result.keys() for(i in vecResult){ print(i) }

回答于 2022-11-25 09:27

0 赞同

如何快速删除分布式表的所有数据,但保留数据表结构?

可以使用DolphinDB的truncate函数,参考文档:https://www.dolphindb.cn/cn/help/200/FunctionsandCommands/CommandsReferences/t/truncate.html 测试方法如下: (1)创建分布式表,并写入100万行数据 n=1000000 ID=rand(150, n) dates=2017.08.07..2017.08.11 date=rand(dates, n) x=rand(10.0, n) t=table(ID, date,...

回答于 2022-11-09 13:09

0 赞同

如何将SQL查询返回的列的列名通过传入字符串变量的方式重命名

可以使用DolphinDB的元编程功能实现上述需求,元编程教程链接:https://gitee.com/dolphindb/Tutorials_CN/blob/master/meta_programming.md 可以参考以下写法: name1 = `avgPrice name2 = `sumVol whereConditions = [<symbol=`MSFT>,<volume>x>] sql(select=(sqlColAlias(<avg(price)>, name1),...

回答于 2022-11-09 13:00

0 赞同

如何高效取某个股票的最后35000行高频行情数据?

针对上述场景,这边给出两种查询方案: def createData(num){ date = take(2022.01.01, num) time = 00:00:00.000 + take(0..num, num) a1 = rand(1000, num) a2 = rand(1000, num) a3 = rand(1000, num) a4= rand(1000, num) a5 = rand(100.0, num) a6 = rand(100.0, num) a7 = rand(100.0, num) a8 = rand(100...

回答于 2022-10-26 20:11

0 赞同

DolphinDB c# api 支持.net core吗?

DolphinDB c# API 已经有nuget包发布的,支持framework和net core。 DolphinDB c# API 教程网站: https://gitee.com/dolphindb/api-csharp/blob/master/README_CN.md

回答于 2022-10-25 09:45

0 赞同

如何查询节点的所有连接数

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

回答于 2022-07-22 13:15

0 赞同

如何取消集群内所有节点的后台作业的办法?

提供一种解决方案,自定义集群后台作业取消的函数: def cancelAllJobs(){ nodes = exec node from pnodeRun(getRecentJobs) where endTime=NULL jobIds = exec jobId from pnodeRun(getRecentJobs) where endTime=NULL print("All running jobs number is: "+size(nodes)) if(size(nodes)>0){ for(i in 0..(size...

回答于 2022-07-11 10:18

0 赞同

关于DolphinDB插入时间戳数据时,DolphinDB显示的数据和预期不一...

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...

回答于 2022-07-11 10:10

0 赞同

DolphinDB中如何把submitJob提交的正在执行的全部后台作业终止掉...

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

回答于 2022-04-14 09:44