65 个回答
多个流表的级联处理的代码是怎么写的呢？ 这个在文档中没有找到
https://gitee.com/dolphindb/Tutorials_CN/blob/master/stream_aggregator.md 这个教程中【3. 多个引擎串联使用】有个代码示范 ，供参考。 简单来说，outputTable参数除了可以是表之外还可以是其他流数据计算引擎。 share streamTable(1000:0, `time`sym`price`volume, [TIMESTAMP, SYMBOL, DOUBLE, INT]) as trades sh...
回答于 2022-02-09 13:02
Reactive State Engine calculation problem
I tried to solve this problem by using user-defined functions. share streamTable(100:0, `time`sym`volume`inc, [TIMESTAMP, SYMBOL, INT, INT]) as trades; share table(100:0, `sym`time`msum_volume`inc`upd, [SYMBOL, TIMESTAMP, INT, INT, TIMESTAMP]) as output; share streamTable(100:0, `time`sym`volume`...
回答于 2022-01-28 12:28
How to select last 4 OHLCV values from each timeframe ?
solution1：Calculating the results for each timeframe separately select symbol , ts_m1, om1, hm1,lm1,cm1,vm1 from t where isDuplicated([symbol, ts_m1], LAST)=false context by symbol limit -4 then, using "join" to concat two or more result tables t1 = select symbol , ts_m1, om1, hm1,lm1,cm1,vm1...
回答于 2022-01-25 17:05
Feature request for ReactiveStateEngine
Hi Vishvesh, we would like to know your usage scenarios so that we can help you find a solution or further evaluate your requirements.
回答于 2022-01-25 14:11
DolphinDB更换license.lic之后需要重启控制节点或数据节点吗？
1.30.11及以上版本，支持替换license支持不停机在线更新。用updateLicense函数 。 //用于在线更新license. 先手动替换license文件，然后执行该函数在线更新license，而无需重启节点。 updateLicense() //用于查看当前节点的license过期时间。可用于更新license之后，验证新的license是否生效。 getLicenseExpiration() l...
回答于 2021-12-27 12:51
如何释放流引擎占用的内存？StreamEngine的内存如何释放
首先，getStreamEngineStat().AsofJoinEngine 返回的是实时的内存占用情况。 其次，取消订阅和engine没有关系的。您这种情况，要释放引擎的话，需要以下两步：1、dropStreamEngine 2、createEngine的返回的变量=NULL。具体示例如下： 假设你定义的引擎如下： ajEngine=createAsofJoinEngine(name="aj1", leftTable=trade...
回答于 2021-12-27 09:52
订阅流表时报错exception=Only a table can append to another t...
subscribeTable加上参数 msgAsTable=true。 默认值是false，表示订阅的数据是由列组成的元组。你的两个报错都是这个原因 subscribeTable(tableName="trades1", actionName="tradesStats22", offset=0, handler=func, msgAsTable=true)
回答于 2021-12-17 13:02
想要实现如下的功能： 3个变量, 分别从 表中的 3列中得到
v = exec exch, product, templateID from t where templateID = "IBM"exch, product, templateID = v[0], v[1], v[2]
回答于 2021-12-17 12:17
升级版本后，定时任务在log中出现此错误信息Failed to decrypt t...
删除定时任务后再重新执行schedule job把原先的定时任务重新定义下就可以了。 https://gitee.com/dolphindb/Tutorials_CN/blob/master/scheduledJob.md#%E5%B8%B8%E8%A7%81%E6%95%85%E9%9A%9C%E5%8F%8A%E6%8E%92%E9%99%A4，这个问题在上述教程中有提及： 在某些罕见的情况下，可能出现在系统重启时，发生定时作业加载失败...
回答于 2021-12-12 18:53
请教下，求向量中最长连续的大于0的子串的长度，有现成的函数吗...
maxPositiveStreak(X)， 返回X中连续的正数之和的最大值。 示例如下，1 2 3 1 是最长的正数子串， 所以返回子串长度4 v = 10 -1 0 0 1 2 3 1 0 0 -1 -1 maxPositiveStreak(iif(v>0, 1, 0))
回答于 2021-12-12 18:21