254 个回答
kurtosis对于全0数据返回NAN，如何返回0？
可以做个判断，示例如下： x = matrix(0 0 0 0, 1 2 3 4)iif(sum(x==0) == x.rows(), 0, kurtosis(x))
回答于 2022-03-05 19:52
查询结果中随机选取N条
示例脚本如下： ids = ["024bafec-0adc-4e51-bffe-793085c0559e", "018b8110-ca1b-4f1e-97b2-0363c8ed49ae", "0164480b-11a8-4312-91e0-c96f9faac95c"] result = select * from loadTable('dfs://GZB_TSDB', 'data') where time between 2021.01.01T00:00:00.000 : 2021.01.01T00:10:00.000, id in ids iif(result.size()...
回答于 2022-03-05 19:51
如何对每只股票09:31m volume字段更新为09:31m与09:30m volume之...
示例代码如下： t = table(`A`A`A`A`B`B`B`B as symbol, 09:28m 09:29m 09:30m 09:31m 09:28m 09:29m 09:30m 09:31m as minute, 10 20 30 40 20 15 25 10 as volume)update t set volume = volume+move_volume from (select *,move(volume,1) from t context by symbol) where minute = 09:31m
回答于 2022-02-20 11:24
三个设备分别计算每一分钟均值并求和，SQL能否直接实现？
示例代码如下： ids = ["024bafec-0adc-4e51-bffe-793085c0559e", "018b8110-ca1b-4f1e-97b2-0363c8ed49ae", "0164480b-11a8-4312-91e0-c96f9faac95c"] timePeriod = 2021.01.01T00:00:00.000 : 2021.01.01T00:10:00.000 result = select rowSum(ffill(avg(v))) from loadTable("dfs://GZB_TSDB", "data") where id in ids...
回答于 2022-02-20 11:23
LVM逻辑卷是否会影响DolphinDB性能，或者有什么更好的方案便于扩...
不建议使用逻辑卷。除了性能问题，还会影响系统稳定性。数据库在某些关键操作上需要文件系统API提供原子性的操作，LVM在某些实现上无法保证原子性。 DolphinDB扩盘很方便：可以更改cluster.cfg volumes字段，重启生效，也可以addVolume函数动态添加。DolphinDB集群如何扩展节点和存储：https://gitee.com/dolphindb/Tutori...
回答于 2022-02-20 11:22
如何设置对于不活跃的session，超过一定时间自动清理？
目前没有办法直接设置，因为有些session虽然这段时间不活跃，不能排除后面再次活跃的可能。如果您有这方面需求，可以自定义一个函数，然后定时任务调用。示例如下： def closeNotActiveSessions() { gap = 43200000 // 12:00:00.000 sessionIds = exec sessionId from pnodeRun(getSessionMemoryStat) where...
回答于 2022-01-25 11:40
group by interval(pricetime, 5m, 'none', ,false) 聚合后时间...
可以使用temporalAdd 函数，示例如下： t = table(13:01:00 13:02:00 13:03:00 13:04:00 13:04:59 13:05:00 13:07:00 13:09:00 13:09:59 13:10:00 as pricetime, rand(100, 10) as value) res = select max(value) from t group by interval(pricetime, 5m, "none") as pricetime update res set pricetime = temporalAdd(...
回答于 2021-12-13 10:42
Kafka读取读取数据，延迟较长，怎么优化？
batchSize=1，表示一次处理一条数据。可以尝试将batchSize 改为1000，一次处理1000条数据。throttle=10 表示如果10 s内到达Kafka数据达不到1000条，触发一次消息处理操作。
回答于 2021-12-13 09:52
Kafka读取数据一段时间后报错：Invalid expression
语法错误，报在第一行。既然之前能够正常读取一段时间，怀疑后面其中某一条数据格式存在问题。 如果不希望订阅停止，那么可以加个try catch 语句，catch 后使用writeLog函数向日志中记录下错误信息。
回答于 2021-12-13 09:43
使用context by计算mwavg和使用for loop对于每只股票分别计算mwa...
模拟数据如下： login(`admin, `123456) pnodeRun(clearAllCache) undef all syms = format(1..3000, "SH000000") N = 10000 t = cj(table(syms as symbol), table(rand(100.0, N) as price, rand(10000, N) as volume)) 方法1：context by，耗时约3.3 s。 timer result1 = select mwavg(price, volume, 4) from t cont...
回答于 2021-11-18 14:54