在分区时有个问题,date(1990.01M + (0..600))是表示从1990年1月到2040年1月的每个月的1号。因此VALUE值分区后,就只有每个月的1号了。按月VALUE分区,需要改成: valuep = database(, VALUE,1990.01M + (0..600)) 或者 valuep = database("",VALUE,1990.01M..2040.12M) 按日VALUE分区,可以改成如下: valuep = data...
回答于 2021-06-15 15:42
DolphinDB的loadTextEx函数允许输入一个可选参数tranform,用于在写入数据库之前对加载的文本数据进行预处理。可以通过transform函数将日期字段写入数据表。 参考下面的教程https://github.com/dolphindb/...
回答于 2021-06-15 15:38
DolphinDB的数据库存储在分布式文件系统上。即便的是single mode也是采用分布式存储。分布式存储的数据包括两个部分,元数据和数据文件。 将一个DolphinDB实例的所有数据复制到新的数据节点上,必须确保新旧节点的磁盘路径是完全一致的。否则元数据和数据文件会不一致。 数据迁移最好的办法是使用DolphinDB的备份和恢复...
回答于 2021-06-15 15:07
getStreamingStat().subWorkers 体现的是某一个订阅端(客户端)的使用情况。clearTablePersistence 体现是的发布端(服务端)的使用情况。 错误提示的意思是:这个流数据表已经注册了持久化,如果要清除持久化,必须使用table object而是表的名称。可以将代码改成 clearTablePersistence(objByName(`StreamMKT))
回答于 2021-06-15 15:06
last是聚合函数,context by返回的记录数跟组的长度一样,所以会重复产生多条记录。context by可以用top 1来取最后一条记录,代码如下: select top 1 last(date(EndDate)) as date,last(ShortTermLoan) as v from tbFactor where EndDate >= 2015.06.30,EndDate <= 2020.03.31,IfAdjusted == 2 and IfMerged == 1...
回答于 2021-06-15 15:05
这个可以在mysql查询时,将int转成date和time,代码如下所示: db=database("dfs://minute_price") query="select date(trade_date) as date ,time(trade_time) as time, secu_code,int_code,code_type,open,close,high,low,volume,turnover from trades" mysql::loadEx(conn, db, "price_data", `trade_date`secu_code,...
回答于 2021-06-15 15:04
这个问题可以用atImax函数可以解决 select atImax(datestamp,value) as value from svgtable group ty tag
回答于 2021-06-15 15:02
client.subscribe返回值是一个智能指针ThreadSP,若不赋值给一个变量,会立即释放。 int main(int argc, char* argv[]) { std::string host, table, action; int client_listen_port, pub_port; host = "192.168.1.130"; table = "trades"; action = "test"; client_listen_port = 900...
回答于 2021-06-15 14:52
peach是一个高阶函数,并行执行多个任务。以第一个任务的结果来决定整个函数的运行结果。如果单个任务返回的是一个scalar,那么peach返回一个vector,单个任务返回vector,那么peach返回matrix,单个任务返回字典,peach返回table。 该问题中的parse_signals函数没有任何返回值(也就是返回一个NOTHING标量),所以pea...
回答于 2021-06-15 14:51
在GUI左栏顶上点击Database,如下图红色圆圈所示位置,在这里可看到当前有哪些分布式数据库,比如上图中有一个库dfs://FuturesContract,其中有个表tb。要察看具体表的数据,请在编辑器中输入t= loadTable(dbPath, tableName),比如要看图中所示tb的数据,代码如下: tb = loadTable("dfs://FuturesContract","tb") 执行...
回答于 2021-06-15 14:50