用nanosecond函数获取纳秒数: iif(nanosecond(nt)>500000000, nt - nanosecond(nt) +500000000, nt - nanosecond(nt) )
回答于 1天前
用 sqlDS(<select * from loadTable("dfs://Lev2","order") where date=2022.04.01 and security_id="000001.SZ">) 和sqlDS(<select * from loadTable("dfs://Lev2","order") where date=2022.04.01 and security_id in ("000001.SZ")>) 看一下分别涉及到了多少分区,两者有什么不一样?
回答于 6天前
error code 99 是套接字错误码,表示EADDRNOTAVAIL,可参考类似问题 linux - Socket bind failed errno = 99 - Stack Overflow 。可能是端口不够用了
回答于 2024-03-08 15:29
这个跟订阅设置有关,subscribeTable有batchSize 和throttle这2个参数设置触发方式: batchSize 是一个整数。若为正数,表示未处理消息的数量达到 batchSize 时,handler 才会处理消息。若未指定或为非正数,每一批次的消息到达之后,handler 就会马上处理。 throttle 是一个浮点数,单位为秒,默认值为1。表示继上次 han...
回答于 2024-03-08 14:22
用响应式状态引擎和deltas函数,示例如下: share streamTable(1:0, `date`time`sym`market`price`qty, [DATE, TIME, SYMBOL, CHAR, DOUBLE, INT]) as trades outputTable = table(100:0, `date`sym`factor1, [DATE, STRING, DOUBLE]) engine = createReactiveStateEngine(name="test", metrics=<deltas(price)>, du...
回答于 2024-03-06 16:01
用响应式状态引擎和deltas函数,示例如下: share streamTable(1:0, `date`time`sym`market`price`qty, [DATE, TIME, SYMBOL, CHAR, DOUBLE, INT]) as trades outputTable = table(100:0, `date`sym`factor1, [DATE, STRING, DOUBLE]) engine = createReactiveStateEngine(name="test", metrics=<deltas(price)>, du...
回答于 2024-03-06 09:58
在 DolphinDB 中,Python 的 pass 占位语句并没有直接的对应实现。在 DolphinDB 中,您可以使用其他方式来实现类似的功能,例如使用空语句或注释来作为占位符。 例如,您可以在 DolphinDB 中使用空语句作为占位符,类似于 Python 中的 pass 语句。示例代码如下: if (condition, , ) // 使用空语句作为占位符{ // 这里...
回答于 2024-03-01 11:44