165 个回答
能够间隔几分钟自动和删除 log 吗
节点日志 1小时左右会自动删除，可以先用find + crontab shell 删除 job log find . -name "*.log" -mmin +720 -exec rm {} \; 另外日志增长过快的情况可以看看是否是设置了日志等级为 debug，可以通过 setLogLevel 在线设置
回答于 2024-04-15 13:55
关于python_api：跑python文件时，session.run结果为空；但是pdb...
您好，您的问题可能是因为 MTW insert 到后台后 python 进程就结束了，数据还未写到 DDB ，所以如果用 waitForCompletion 或者主线程被阻塞住，就能等到后台数据累累积后写入 DDB，这个时候就能查到了。
回答于 2024-04-15 10:17
如何求一个INT向量中的值落在另一个INT向量中哪个区间范围？
可以用 asof 实现，并利用一个字典维护数据范围： v1 = [-5, 5, 10, 15, 20, 25, 100] v2 = [-9999999, 0, 10, 30, 9999999] d = dict(INT, STRING) d[-9999999]="C9999999_0" d[0]="C0_10" d[10]="C10_30" d[30]="C30_9999999" d[v2.at(asof(v2, v1))]
回答于 2024-04-08 14:18
多行代码的语法解析的问题
目前(11.1 版本后)支持换行的有: SQL 语句： select a,b from t where time between 09:00:00 and 15:00:00 context by sym 函数的链式调： v.cumsum() .max() 其他场景换行意味着上一个语句的结束，或者同一行可以加分号表示语句结束: a=1;b=1
回答于 2024-03-20 10:55
如何在metrics参数里 表示出流表的所有列，而不是逐个字段列出，...
metrics 部分的元代码可以用元编程的方式实现拼接，例如： t=streamTable(100:0,`date`time`sym`qty`price`exch,[DATE,TIME,SYMBOL,INT,DOUBLE,SYMBOL])share t as tradesopt=streamTable(100:0,`sym`fac,[SYMBOL,DOUBLE])def f(date,time,sym,qty,price,exch){ return qty * price}createReactiveStateEngine(name="de...
回答于 2024-03-19 10:53
按行筛选表数据
可以使用 rowAnd 函数将多个比较字段的结果取并集，select * from where rowAnd((col1,col2, ... col32)<0.5)。如果列数非常多的场景，也可以借助元编程生成该 SQL 语句。
回答于 2024-03-16 18:08
pythonAPI 获取表的句柄
建表时你指定了别名 “a”，这个 a 实际就是 server 端该表对应的变量名， 那么直接通过 s.run("a") 就能获取 a 的句柄，或者执行 s.run("select * from a") 也可以获取。
回答于 2024-03-16 18:07
byRow 报错：Not allowed to create a matrix with type ANY
linearTimeTrend 返回的是一个 tuple，byRow 的func只能返回等长的向量或者标量。根据你的代码感觉你完全不需要 transpose 转置，使用 loop 函数直接按列遍历计算就可以。 loop(linearTimeTrend{,4}, p[1:10,1:10])
回答于 2024-03-16 18:02
关于moving以及m系列函数的问题
对于 mfunc 如果传入的是索引矩阵实际上会按照索引去滑动，您的索引是时间列，传入的是 3，时间精度是 s，实际就是每 3s 一个窗口，您可以不要 setIndexedMatrix 以实现按行滑动的窗口，或者如果已经是索引矩阵也可以 setIndexedMatrix!(false) 转成普通矩阵
回答于 2024-03-11 13:48