分区列您这边的数据有null值,dolphindb分布式表的分区列不允许有空值 您确认一下是怎么产生的,目前可以通过自定义函数筛选掉空值数据.
回答于 2021-08-10 16:06
详细可以参照链接 DolphinDB与Spark的性能对比测试报告 - 知乎 (zhihu.com)
回答于 2021-08-04 18:01
参考loadTextEx函数可以转换读取到数据的数据类型 def d2m(mutable t){ return t.replaceColumn!(`point_code,symbol(t.point_code))}tmpTB=loadTextEx(dbHandle=database("dfs://table_join"),tableName=`dkh_point_summary_daily,partitionColumns=`point_code,filename="/home/jwu/data/hailan/dkh_point_summary_da...
回答于 2021-08-04 17:54
rpc(getControllerAlias(),getNodeHost) rpc(getControllerAlias(),getNodePort) 这两个函数即可
回答于 2021-07-19 16:47
1.看scheduleJob如何定义 2.查看运行完成的scheduleJob select * from getRecentJobs() where jobDesc like "%Hour compose Test%" order by startTime desc 3.getJobMessage和getJobReturn来查看每个作业的运行日志和返回值 运行日志保存在jodId.msg 文件中,定时作业的返回值保存在jobId.object文件中。这些文件都...
回答于 2021-07-02 16:46
loadText加载文本生成的字段数据类型,是一个sample操作,随机取的数据生成对应数据类型,第二次加载CSV时也是这样,这个机制导致了,您追加了数据,重新加载文件生成的数据类型有变化。想要100%保证数据类型没有变化,只能指定schemaschema=extractTextSchema("/home/wujin/data/sh50_2012-2020_1h.csv");t1 = loadText("/...
回答于 2021-06-24 10:24
/*---------------------------------------------场景需求--------------------------------------------------- 过去5天股价日涨幅与板块内所有股票的平均日涨幅两者相关性过去10天股价日涨幅与板块内所有股票的平均日涨幅两者相关性所有股票的平均日涨幅:按所有股票等权重平均涨幅计算单只股票的日涨幅 = 今日股价/昨...
回答于 2021-06-24 10:23