26 个回答
做分布式集群的话，各台机器的 cpu 和核数可以不一样吗？
可以在配置里以前缀的形式配置，像这样： node1.maxMemSize = 4 node2.maxMemSize = 2
回答于 2022-03-14 10:17
往DFS表插入一行数据时报错：The input argument must be a vect...
这个应该和 DFS 表无关，是创建 table 报的错， repay_enabled = 1b 这样 repay_enabled 还是标量 应该写成 repay_enabled = [1b] 其他列同理
回答于 2022-03-05 20:01
how to get previous value of output column ?
currently, this can only be done by handler: login("admin","123456");share streamTable(100:0, `id`val1`val2, [INT,DOUBLE,DOUBLE]) as input;output = table(100:0, `id`f1`f2 , [INT,DOUBLE,DOUBLE]);pre_v1v2f1f2_count = (double(0),double(0),double(0),double(0), int(0));def handler(mutable data, mutable...
回答于 2022-02-21 00:19
多线程写入一个库的多个分布式表
最简单粗暴的办法，可以起多个GUI客户端; 如果是测性能的话，也可以用你偏好的语言的 Dolphindb API 比如 python 多进程或者 Java 多线程进行 append
回答于 2022-02-16 16:42
求助 ，怎么在一个特定的策略程序结构中使用Event.wait()接收服...
试试把 Event().wait() 去掉，因为教程里 Event().wait() 的作用只是为了避免退出主线程，在 subscribeTable 后面程序已经 while True 了，所以 Event.wait() 会阻塞程序逻辑 （可能教程里的写法容易让人误解成插入一条数据就会触发 Event().wait()）
回答于 2022-02-14 15:51
如何写一个函数内执行清除变量，表，订阅关系等等
订阅 可以 unsubscribeTable 共享表可以 undef(表名, SHARED) 引擎 可以 dropStreamEngine 其它 可以 undef all Edit: 获取所有共享表 ： objs(true) getStreamingStat 返回流数据发布和订阅的状态
回答于 2022-02-11 15:34
asof join engine中结果表的一列想取now()失败
可以增加一个 handler def addRecvTimestamp(mutable msg) { msg[`recvTimestamp] = take(now(), size(msg)) tbl.append!(msg) } subscribeTable(tableName="tbl", actionName="addRecvTimestamp", offset=-1, handler=addRecvTimestamp, msgAsTable=true)
回答于 2022-02-10 10:33
多个流表的级联处理的代码是怎么写的呢？ 这个在文档中没有找到
像这种：def h0(){ tableInsert(t1}subscribeTable(tableName="t0", handler=h0, ) subscribeTable(tableName="t1", handler=....) 不过也有各种引擎无法表达想要的逻辑的时候，所以有时这样写也无法避免
回答于 2022-02-09 10:19