184 个回答
如何提高DolphinDB的写入性能？
你是否启用了cacheEngine功能？CacheEngine是DolphinDB database中的一种数据写入缓存机制，它是为了解决数据表列数过多的情况下写入性能急剧下降的问题而引入的。 DolphinDB采用的是列式存储，一个分区内的每一列数据单独存放在一个文件中。如果表的列数过多（比如物联网场景下同时记录几千个指标）， 每进行一次数据写入...
回答于 2021-05-11 12:04
The key type can't be BOOL, ANY or DICTIONARY
要用中括号，圆括号是tuple x=[int128("2e8ca9773da3a99f2c87a623ac34f242"),int128("2e8ca9773da3a99f2c87a623ac34f243")] y=1..2 dict(x, y);
回答于 2021-05-11 12:02
在Orca中怎么应用自定义函数？
现在要实现的话，需要在Orca所在的那个会话定义函数： orca.default_session().run(definition) definition就是函数的定义，比如def func(x) { return x+1 }。然后apply中的字符串两边要加上括号，比如'(x->(func(x, 1))'
回答于 2021-05-11 12:01
dolphindb中如何在查询表时移除重复数据?
distinct函数返回单个列的唯一元素。如果要根据多列筛选重复行，请用isDuplicated函数 select * from table where isDuplicated([col1, col2], FIRST)=0
回答于 2021-05-11 11:59
如何在DolphinDB database中更快地获取最新状态数据
DolphinDB 提供了快照引擎（Snapshot Engine）以快速获取任意设备任意指标的最新状态。尽管数据库会对最新或最频繁使用的数据进行缓存，但这不是百分之百保证的。快照引擎则会把所有设备采集的实时数据更新到哈希表，查询时可以快速返回结果。一旦客户为数据表设置了快照引擎，写入和查询对用户都是透明的，无需额外的工作...
回答于 2021-05-11 11:58
如何查询流表中已经持久化到磁盘上的历史数据？
通过subscribeTable的方式获取。subscribeTable的参数offset是订阅任务开始后的第一条消息所在的位置。消息是流数据表中的行。offset与流数据表创建时的第一行对应。如果某些行因为内存限制被删除，在决定订阅开始的位置时，这些行仍然考虑在内。
回答于 2021-05-11 11:57
是否有DolphinDB函数来查找向量中元素的索引？
可以用find函数，代码如下： vowels = ['a', 'e', 'i', 'o', 'i', 'u'] index = vowels.find('e')
回答于 2021-05-11 11:56
loadText可以读取csv增量行吗
可以写个job在后台跑，job内部可以做循环，sleep 1秒后，读文件size，如果有变化，可以把变化的部分复制到一个小文件中，然后loadText处理。文件操作的函数请参阅https://www.dolphindb.cn/cn/h... 注意loadText的skipRows不能用，skipRows的效率很低，需要从头开始扫描一遍。所以skipRows最多能跳过1024行。
回答于 2021-05-11 11:55
DolphinDB表schema写法的问题
可以参考下面例子： def createMarketStreamTable(tableName,capacity){ st=streamTable( array(SYMBOL,0) as Permission, array(SYMBOL,0) as DataModel, array(STRING,0) as IC, array(SYMBOL,0) as DsplyNameLoc, array(SYMBOL,0) as DsplyNameEn, array(STRING,0) as DisplayTemplateID, array(SYMBOL,0) as Curr...
回答于 2021-05-11 11:48