经过沟通 了解了您的具体需求是,将多个参数传参后,一起采用链式调用,对于自定义函数,可以通过元组的形式传参,如: def info(config){print(config[0])print(config[1])}config1=("日志", "任务类别")config1.info()
回答于 2023-07-10 09:39
可以通过 parseExpr 将类型字符串解析为类型: s = extractTextSchema("/hdd/data/finance/2021tick/20211130tick.csv")t = table(10:0, s.name, each(x->parseExpr(x).eval(), s.type))schema(t) // output chunkPath-> partitionColumnIndex->-1 colDefs-> name typeString typeInt extra comment...
回答于 2023-07-10 09:26
sql(select=sqlColAlias(makeUnifiedCall(funcByName("corr"), [sqlCol("a"), sqlCol("b")])), from="t")
回答于 2023-07-07 17:26
t = loadText("/home/ffliu/data/rNum.txt") select sum(sum_count) as sum, toArray(sID) from t group by volumeBar(t.sum_count, 0.2)
回答于 2023-06-16 11:50
目前没有原生接口,可以用 s.run("select * from objs(true) where shared=true")
回答于 2023-06-16 10:36
目前在响应式引擎中某些函数暂不支持 array vector。一个解决方案是:先单独写再合成一列,比如这样: fixedLengthArrayVector(prev(bid[0]), prev(bid[1]), prev(bid[2]), prev(bid[3]), prev(bid[4]))
回答于 2023-06-16 09:47
报错信息: To create a new database, the directory [F:/DolphinDB/Data] must be empty.' db_path = "F:/DolphinDB/Data" 是本地磁盘路径,因此创建的是磁盘数据库,磁盘数据库会要求这个目录必须是个空文件夹,现在我们也不怎么推荐用磁盘数据库,建议改成 "dfs://" 开头的路径,创建分布式数据库替代。
回答于 2023-06-09 15:50
此处导入数据的时候 schema 无需进行类型变更,loadTextEx 的过程中,数据先根据给定的 schema 导入内存,然后再基于该内存表进行 transform。由于您的数据时间列不包含日期列,因此不能指定为 TIMESTAMP。
回答于 2023-06-08 18:09