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

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

向TA求助
340金币数
1980 经验值
1个粉丝
主页被访问 1846 次

最近动态

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