可以使用下面的自定义函数,取消当前节点上的所有共享表的定义: 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
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
可以使用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
可以使用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
针对上述场景,这边给出两种查询方案: 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
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
提供一种解决方案,自定义集群后台作业取消的函数: 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
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
可以使用DolphinDB的cancelJob函数取消后台作业,配合loop就可以实现批量取消后台作业的目的,参考代码如下: def cancelJobBatch(){ loop(cancelJob, exec jobID from pnodeRun(getRecentJobs) where endTime =NULL) } cancelJobBatch()
回答于 2022-04-14 09:44