Hao Jia
Hao Jia

性别: 注册于 2022-03-05

向TA求助
20金币数
340 经验值
0个粉丝
主页被访问 1628 次

16 个回答

0 赞同

持久化共享流表服务器重启后不知道schema无法读取元数据,且无法...

这种情况需要去服务器目录下删除对应的数据文件,可以在cfg文件中查看持久化目录,并进行删除对应名字的持久化共享流表目录。

回答于 2022-06-24 18:04

1 赞同

如何实现pandas中group by agg对多列调用多个函数计算指标

可以配合DolphinDB元编程实现: https://www.dolphindb.cn/cn/help/200/FunctionsandCommands/FunctionReferences/s/sql.html data = table(take(1 2, 10) as `id, 1..10 as `col1, 2..11 as `col2, 1..10 as `col3, 2..11 as `col4, 1..10 as `col5) def createAggMetaCode(aggDict){ metaCode = [] for(colName in ag...

回答于 2022-06-08 14:47

0 赞同

如何清理TSDB引擎的Level File Index缓存?

invalidateLevelIndexCache()

回答于 2022-05-18 18:26

0 赞同

使用TSDB引擎,如何查看level index cache占用多少内存?

可以使用getLevelFileIndexCacheStatus()函数,单位是字节

回答于 2022-05-18 16:39

0 赞同

dynamic GroubyCumcount函数,计算结果与预期不符

给您详细介绍一下这个函数。dynamicGroupCumcount输出的是每个组中元素的数量。他的实际计算原理是根据membership和prevmembership的变化来计算的。如果membership=b  prevmembership=a 表示这个元素从a组变成b组,那么a组的累计数就要-1,b组的累计数就要+1。如果membership=a prevmembership=a 表示这个元素保持a组不变,...

回答于 2022-05-11 15:52

0 赞同

如何按照某一列的数值进行分组聚合,实现pandas中qcut相同的操作...

testData = table(1 2 3 4 5 6 7 8 9 10 as `id,1 2 3 4 5 6 7 8 9 10 as `val) groupby(sum,testData.val,asof(cutPoints(testData.val,2),testData.val))

回答于 2022-04-26 16:38

0 赞同

table中arrayVector列如何进行单点修改?

k=1 2 3a=arrayVector(3 6 9, 1 2 3 4 5 6 7 8 9)arrayVector(3 6, 1 2 3 4 5 6)b=arrayVector(3 6 9, 1 2 3 4 5 6 7 8 9) + 10c=arrayVector(3 6 9, 1 2 3 4 5 6 7 8 9) + 100tb = table(k,a,b,c);print(tb)update tb set c = array(INT[], 0, 3).append!([1 2 3])  where k=3print(tb) 结合实际场景,通常会有一列key,...

回答于 2022-04-22 09:20

0 赞同

如何累加统计连续出现的true/false的个数

cumPositiveStreak(not(false false false false true false true false false false false)) cumPositiveStreak:累积计算 X 中连续的正数之和

回答于 2022-04-21 13:47

0 赞同

使用DolphinDB进行最小二乘法计算时速度较慢,CPU一直是单核运行...

新版本的DolphinDB在配置文件中可以设置 openblasThreads=32 参数来开启并行度。 开启后许多矩阵运算都可以进行并行计算。 在DolphinDB中并不推荐直接使用内存矩阵进行计算,结合实际问题使用分布式表,使用olsEx方法进行最小二乘计算可以得到性能的极大提升。

回答于 2022-04-20 14:02

0 赞同

The aggregate function in column aggrTopN doesn't have a map...

从代码上看,期望是能在单个交易日期内对股票代码分组计算,在组内还要按照CLOSE进行筛选。由于分布式表的分区规则与group by需求相同,理论上可以对单个分区内的数据进行股票分组聚合计算,可以使用mr方法进行自定义的map-reduce任务计算。 def myMap(table){ result_temp = select SecurityID,date(first(TradeTime)...

回答于 2022-04-11 10:21