能backup并上传这一天这只股票的数据么 backup("/home/DolphinDB/backup",<select * from loadTable("dfs://compoDB","pt") where ...>,true);
回答于 5天前
语法和一般语言的fmt函数类似。 stringFormat("This is %W format %W", "a", "string")
回答于 2024-05-06 16:44
与 shift 相对应的函数是next,move v=1..10next(v) move(v, -1) #output [2,3,4,5,6,7,8,9,10,]
回答于 2024-05-06 16:13
v.copy().fill!({x->x[0<=sub:P(x)<5] join x[sub:O(x)>-5]}(at(v != 0)), 0)
回答于 2024-05-06 13:58
更新的话,SQL 可以用 update upsert!。如果待更新的数据量很大,更推荐的方式是 dropPartition 然后重新写入。
回答于 2024-05-06 13:41
可以直接对表求平均sym = `C`MS`MS`MS`IBM`IBM`C`C`Cprice= 49.6 29.46 29.52 30.02 174.97 175.23 50.76 50.32 51.29qty = 2200 1900 2100 3200 6800 5400 1300 2500 8800timestamp = [09:34:07,09:35:42,09:36:51,09:36:59,09:35:47,09:36:26,09:34:16,09:35:26,09:36:12]t1 = table(timestamp, sym, qty, price);mean(se...
回答于 2024-05-06 13:38
先使用 listRemotePlugins() 查找适配当前版本的插件 然后使用installPlugin()进行安装 installPlugin("feather", "2.00.11.3.1")目前parquet插件尚未支持,后续会陆续增加windows版本支持的插件。
回答于 2024-05-06 11:37
最简单直接的方式是通过run方法执行脚本。 defAlpha101=""" def WQAlpha100(vol, high, low, close, indclass){ tmprank = rowRank(((close - low - (high - close)) / (high - low) * vol), percent=true) ind1 = byRow(contextby{demean, , indclass.row(0)}, tmprank) ind2 = byRow(contextby{demean,...
回答于 2024-04-07 18:10
可以使用rpc或者remoteRun 1. B与A是同一个集群 使用RPC更方便 def readShareTab(tabName, size){ return select * from objByName(tabName) limit size}rpc(`A, readShareTab, "tg", 10) 2. B位于另外的集群 使用remoteRun def readShareTab(tabName, size){ return select * from objByName(tabName) limit...
回答于 2024-04-07 17:38
方法一:分页查询 n = 100SecurityID = rand(`st0001`st0002`st0003`st0004`st0005, n)sym = rand(`A`B, n)TradeDate = 2022.01.01 + rand(100,n)TotalVolumeTrade = rand(1000..3000, n)TotalValueTrade = rand(100.0, n)schemaTable_snap = table(SecurityID, TradeDate, TotalVolumeTrade, TotalValueTrade) .sortBy...
回答于 2024-04-07 17:23