你看一下[mskew](https://www.dolphindb.cn/cn/help/FunctionsandCommands/FunctionReferences/m/mskew.html)是否满足你的需求?
回答于 2021-10-13 09:00
Please post your relevant code here to facilitate the recurrence of the problem.
回答于 2021-10-12 08:29
filter 参数需要配合setStreamTableFilterColumn函数一起使用。使用setStreamTableFilterColumn指定流数据表的过滤列,流数据表过滤列在filter中的数据才会发布到订阅端,不在filter中的数据不会发布。filter不支持过滤BOOL类型数据。 filter 参数可以使用以下三种方法指定。其中范围过滤与哈希过滤于1.30.3版本发布。 值...
回答于 2021-10-08 08:50
下面写了个demo,你看是否满足你的需求: x=7 4 6 0 -5 32;ploop(mavg{x, 20,},1..10 join 20) ;
回答于 2021-09-30 13:58
你的聚合频率多少,若不高,取最大时间范围是否可以满足需求? 或者在流表侧设置按品种名称过滤,然后每个交易所不同交易时间各自创建订阅和计算引擎,订阅各自的品种进行计算。
回答于 2021-09-30 13:48
你这个createTimeSeriesAggregator代码中的dummyTable参数值不对,该表的唯一作用是为时间序列引擎提供流数据中每一列的数据类型,可以含有数据,亦可为空表。该表的schema必须与订阅的流数据表相同。
回答于 2021-09-28 09:20
已经持久化的表数据不能直接用sql查询。 可以通过指定offset的方式subscribeTable,可以订阅到已经持久化的内容。通常的用法是,把流表订阅到分布式表,数据分析查询分布式表。 offset可通过getPersistenceMeta函数获取,其中diskOffset记录了当前磁盘上数据相对总记录数的偏移量。
回答于 2021-09-26 09:23
我这里有个数据库,schema如下: partitionSchema->([2021.01.31,2021.01.30,2021.01.29,2021.01.28,2021.01.27,2021.01.26,2021.01.25,2021.01.24,2021.01.23,2021.01.22,...],10) databaseDir->dfs://StockTick engineType->OLAP partitionSites-> partitionTypeName->[VALUE,HASH] partitionType->[1...
回答于 2021-09-26 09:14
lanCluster=1表示节点间心跳使用UDP广播传输。 UDP广播有个广播域的概念。广播域内的其中一台主机发出一个广播帧,只有同一广播域内的其它主机才可以收到该广播帧。不同网段的主机一般广播域不同,所以收不到UDP广播帧。
回答于 2021-09-24 15:37
需要去掉引号,斜杠用/或\\ persisitenceDir=C:/DevTools/DolphinDB/Data/Streaming
回答于 2021-09-24 10:56