参照以上代码 t=table((2018.01.01T01:00:00+rand(1000,25)) join (2018.01.01T02:00:00 + rand(100,5)) as time, rand(1.0, 30) as x)select temporalAdd(t.intervaltime,5,"m"),last_x from (select last(x) from t group by interval(time, 300, 1) as intervaltime) as t
回答于 2021-08-03 10:17
两个方案 第一种 dbName="/stocks_orderbook" fileCond=dbName + "%" t=exec substr(file,strlen(dbName)) from rpc(getControllerAlias(),getClusterChunksStatus) where file like fileCond, state != "COMPLETE" dropPartition(database("dfs:/"+dbName),t,,true) 第二种 deleteChunkMetaOnMaster("dfs://compoDB...
回答于 2021-08-02 17:08
参考下面脚本 a = 17 15 a = string(a) + "0000" temporalParse(a,"HHmmss");
回答于 2021-08-02 10:05
https://www.dolphindb.cn/cn/help/FunctionsandCommands/CommandsReferences/setRetentionPolicy.html?highlight=setr 参考setRetentionPolicy()函数
回答于 2021-07-29 17:32
sym = take(1, 110) id = 1..100 join take(int(),10) id2 = take(int(1),10) join 1..100 t = table(sym, id,id2) each(x->x.deltas(), t.values()) 参考一下以上写法
回答于 2021-07-27 15:17
可以用这个写法 loadTable("dfs://testDB", "testTable").schema().partitionSchema
回答于 2021-07-26 15:18