Juntao Wang
Juntao Wang

性别: 注册于 2021-05-07

向TA求助
0金币数
2550 经验值
0个粉丝
主页被访问 395 次

最近动态

2022-06-20 15:52 回答问题

示例代码如下: A = ["a", "b", "c", "d"] B = ["a", "b"] A[at(not A in B)]

2022-06-17 16:47 回答问题

无法建立连接,常见的原因:连接数满了。连接数查看方法参考:https://ask.dolphindb.net/question/1850

2022-06-17 16:45 回答问题

示例如下: DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyyMMdd"); DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("HHmmssSSS"); Utils.countDays(LocalDate.parse(currentDate, dateFormatter)) Utils.countMilliseconds(LocalTime.pa

2022-06-17 16:44 回答问题

更改为: // 方式1 select * from getTabletsMeta() where chunkId = uuid("92cc1df2-f748-6186-454a-43f33fd6c84f") // 方式2 select * from getTabletsMeta() where string(chunkId) = "92cc1df2-f748-6186-454a-43f33fd6c84f"

2022-06-17 16:42 回答问题

分析了下,是大小写问题,更新语句改为 update loadTable("dfs://test", "test") set deviceId = 'MIX1', value = 55 where value = 44 可以成功,即deviceid 改为 deviceId 。 目前版本中,分布式更新时,严格区分大小写。后面我们会向开发建议支持不区分大小写,这样对用户更友好。

2022-06-17 16:34 回答问题

我们推荐这样一种方式: 每个因子算完之后是个单值模型,类似下面截图数据格式: 所以因子append!到一张表,然后根据TradingTime、SecurityID、Factorname 字段做个pivot by, select Factorvalue from t pivot by TradingTime, SecurityID, Factorname 参考链接:DolphinDB 因子计算最佳实践白皮书

2022-06-11 22:06 回答问题

可以使用writeRecord 函数,示例代码如下: n = 10000 t = table(rand(1..100, n) as id, rand(100.0, n) as value) f = file("/hdd/hdd0/jtwang/data/xinfei/test_export.bin", "w") writeRecord(f, t) 这个函数目前有些限制,对于字符串类型不支持,可以使用API 规避一下,Python API示例代码如下: binFile = open("D:/Work/t

2022-06-11 22:01 回答问题

示例代码如下: t = table(0 0 0 1 1 1 0 0 as value, 2022.01.01 12:00:00 + 1..8 as time, take(1, 8) as id) select * from t where id = 1, (value != prev(value) and isValid(prev(value))) or (value != next(value) and isValid(next(value))) context by id

2022-06-11 21:59 回答问题

测试代码如下: /* 创建三个分布式表: dfs://test_1/test_1 dfs://test_2/test_2 dfs://test_3/test_3 */ def createDBAndTable(dbName, tbName) { db = database(dbName, VALUE, 0..1) model = table(1:0, `id`value, [INT, FLOAT]) createPartitionedTable(db, model, tbName, `id) ap

2022-06-11 21:55 回答问题

查看当前节点连接: getConnections() 查看当前集群中所有数据节点连接: // 方式1 pnodeRun(getConnections) // 方式2 rpc(getControllerAlias(), getClusterPerf).connectionNum