若节点内存接近 warningMemSize,通过函数 clearAllCache() 来手动释放节点的缓存数据。如果内存占用仍然未显著降低,请依次排查下述问题: 通过函数 getSessionMemoryStat() 结合 objs() 和 objs(true) 排查是否某个用户忘记 undef 了变量 ;通过函数 getRecentJobs() 和 getConsoleJobs() 查看是否还有超过预期运行时长的...
回答于 2023-01-11 11:08
一点数据比对经验分享如下:异构数据库迁移数据比对,这个比对方法的数据数据量最大的表是9亿条,30多个字段吧。数据比对必须要有主键追求的是数据一点不能差,对于比对耗时要求不是太高。计算逻辑1 两个不同数据库都要计算这张表的最终md5 值,然后比对,全表对比 1.1 首先把每一行的字段拼成一个长字符串,然后计算md5...
回答于 2023-01-10 23:19
方法一:利用 [pandas.DataFrame.count](https://pandas.pydata.org/docs/reference/api/pandas.DataFrame.count.html) 函数获取。 trade.select("*").toDF().count()["col"] # 其中 col 为 SQL 查询返回的 DataFrame 任意一列的名字 # toDF() 前可以替换为任意 SQL 语句 方法二: 在 DolphinDB 中,上述 t2=t1.selec...
回答于 2023-01-10 23:15
用defs函数,例如查ops模块用下列语句: select * from defs() where name like "ops::%" 返回结果: name isCommand userDefined minParamCount maxParamCount syntax ops::cancelJobEx false true 0 1 (id) ops::checkChunkReplicas false true 3 3 (dbPath,tableName,targetChunkId) ops::checkOLAPChunkReplicas fal...
回答于 2023-01-05 11:39
用files函数得到表名,并share: login(`admin,`123456) tables=select * from files("/home/xjqian/mvcctables") where isDir=true for (tableName in tables.filename){ share( loadMvccTable("/home/xjqian/mvcctables",tableName) , "share_"+tableName) } 把上述代码加入startup.dos,在系统启动时执行即可。...
回答于 2023-01-04 17:14
先用dbUpload把R的数据上传上去,再追加,示例如下: > conn <- dbConnect(DolphinDB(), "localhost", 8848, "admin", "123456")> ID=c(1L,2L)> x=c(1,2)> df=data.frame(ID,x)> df ID x1 1 12 2 2> rs<-dbUpload(conn, c("t1"), list(df))> rs_rt<-dbRun(conn, "t1")> rs_rt ID x1 ...
回答于 2023-01-03 23:00
版本不匹配引起,请重新下载release200.8分支(kafka/bin/linux · dolphindb/DolphinDBPlugin - 码云 - 开源中国 (gitee.com))再试用。
回答于 2022-12-29 23:04
用ifirstHit,例如下列代码 data = 0 0 0 0 0 0 1 1 1 ifirstHit(ne, data, 0) 执行后返回6
回答于 2022-12-27 10:21