2022-11-25 09:57 回答问题

可以参考下面的自定义函数，作用是删除当前节点上的所有流计算引擎： def DropAllEngines(){ if(getStreamEngineStat().rows() > 0){ engineTypes = getStreamEngineStat().keys() for(engineType in engineTypes){ engineNum = size(getStreamEngineStat()[engineType]) i = 0 do{ pri

2022-11-25 09:55 回答问题

可以参考下面的自定义函数，作用是清除当前节点的所有流计算相关的订阅： def ClearAllSubscriptions(){ if(getStreamingStat().pubTables.rows() > 0){ do{ try{ tableName = getStreamingStat().pubTables[0,0] actionName = getStreamingStat().pubTables[0,3] actionName = strReplac

2022-11-25 09:53 回答问题

可以使用下面的自定义函数，取消当前节点上的所有共享表的定义： 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){

2022-11-25 09:27 回答问题

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-09 13:09 回答问题

可以使用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

2022-11-09 13:00 回答问题

可以参考以下写法： name1 = `avgPrice name2 = `sumVol whereConditions = [<symbol=`MSFT>,<volume>x>] sql(select=(sqlColAlias(<avg(price)>, name1), sqlColAlias(<sum(volume)>, name2)), from=t1, groupBy=sqlCol(`date)).eval() 返回结果如下

2022-10-26 20:11 回答问题

针对上述场景，这边给出两种查询方案： 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(

2022-10-25 09:45 回答问题

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

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