JavaAPI端高可用代码实例 String[] sites = new String[] {"115.239.209.122:8711","115.239.209.123:8811","115.239.209.124:8911"}; conn.connect(HOST, PORT, sites); C++API客户端高可用代码实例 string site1 = "115.239.209.122:8711";string site2 = "115.239.209.123:8811";string site4 = "115.239.209.124:891...
回答于 2022-04-22 13:51
分布式表目前不支持。如果是内存表。可以这样来解决: delete from t where date = conextby(min, date, symbol)
回答于 2022-04-22 13:48
您上述写法查询1h的数据没做到分区剪枝,即时全表扫描,所有查询速度很慢 可以尝试下述写法: select * from machines where datehour(ts) =datehour(2022.02.07T06:00:00.000) limit 5
回答于 2022-04-20 10:19
小表,可以以加载到DolphinDB内存的大小为例,假设小于100M可以都设计成一个分区的分布式表 假设是有股票字段,可以设计成只有1个Hash的分区方式 db=database(directory="dfs://hashdb", partitionType=HASH, partitionScheme=[INT, 1])
回答于 2022-03-24 11:20
1 在线更新license step1:用新的dolphindb.lic文件替换对应节点所在服务器上老的dolphindb.lic文件 step2:对节点进行全量更新license a) 普通集群 //普通集群def connctNode(host, port, name){ conn = xdb(host, port, "admin", "123456") try { result = conn(updateLicense()) updateDa...
回答于 2022-01-04 10:26
参考代码如下 根据context by,rank的组合去实现 n = 40 date = take(2019.11.07, n) time = (09:30:00.000 + rand(int(6.5*60*60*1000), n)).sort!() timestamp = concatDateTime(date, time) price = 100+cumsum(rand(0.02, n)-0.01) volume = rand(1000, n) symbol = rand(`AAPL`FB`AMZN`MSFT, n) trade = table(symbo...
回答于 2021-12-20 09:40
请参考以下代码 f= "603998.csv"symCode = substr(f, 0, strpos(f,"."));
回答于 2021-08-27 17:40
请参考 select distinct(id) from loadTable("库名", "表名") where date(时间字段) = 2021.08.24
回答于 2021-08-27 17:21
需要添加这个参数newValuePartitionPolicy=add 您的分区是2019.08.01..2019.08.10,检查下您写入数据的时间范围,以及可以查询运行日志相关信息
回答于 2021-08-19 10:23