2024-02-01 12:01 回答问题

在计算SMA的时候，您只想要5分钟K线的最后一条数据来计算，但是第二个时序聚合引擎会每分钟计算一次结果且输出到下游，那么在SMA的时候每组都会有四条无用的数据。您在计算完5分钟K线之后与计算SMA之间再加一个响应式状态引擎，对5分钟K线的结果进行一个过滤处理。并且修改计算SMA的响应式状态引擎的输入即可。 重点修改代码如下： // 添加中间过滤的响应式状态引擎 share(streamTable(25000:0,ohlc_colNames,ohlc_colTypes), `sm5_t); rse5m_t

2024-01-29 13:53 回答问题

可以按照以下demo实现 // 1、模拟数据 tmp_table = table( concatDateTime(take(2023.12.12, 4802000), (rand((09:30:00.000+0..2400*3*1000) join (13:00:00.000+0..2400*3*1000), 4802000).sort())) as dt, rand(string(1001..1200), 4802000) as symbol, rand(100.0, 4802

2024-01-29 13:52 回答问题

x=1..1000 res= peach(mavg{x,}, 2..21)

2024-01-29 13:51 回答问题

//1、模拟数据 tmp_table = table( concatDateTime(take(2023.12.12, 4802000), (rand((09:30:00.000+0..2400*3*1000) join (13:00:00.000+0..2400*3*1000), 4802000).sort())) as dt, rand(string(1001..1200), 4802000) as symbol, rand(100.0, 4802000) as price,

2024-01-26 18:34 回答问题

假设有一个表如下： 可以用以下方式实现

2024-01-26 18:32 回答问题

假设有如下两个向量： 可以用以下方式实现 测试数据：模拟数据数据量：v1有100万，v2有102条实现方案耗时（s） 原始方案4.4s新方案 121ms

2024-01-26 18:29 回答问题

假设有一个表如下： t=table(1..10 join [12, 14,16] as index) ; 表中有一列index，是从1开始按顺序编号，现在有数据缺失导致序号不连续，查找连续数找到缺失。 解决： 可以用以下方式实现 select id from table(min(ids)..max(ids) as id) where id not in (select id from t);

2024-01-26 18:27 回答问题

select *, fixedLengthArrayVector(rowCumsum(matrix(t))) as cav from t;

2024-01-26 18:24 回答问题

假设有一个表如下： sym = `C`MS`MS`MS`IBM`IBM`C`C`C$SYMBOL price= 49.6 29.46 29.52 30.02 174.97 175.23 50.76 50.32 51.29 qty = 2200 1900 2100 3200 6800 5400 1300 2500 8800 timestamp = [09:34:07,09:36:42,09:36:51,09:36:59,09:32:47,09:35:26,09:34:16,09:34:26,09:38:12

2024-01-26 18:20 回答问题

n = 10 sql(sqlColAlias(unifiedExpr(binaryExpr(sqlCol("wd_nBidPrice"+ string(1..n)), (1..n\10)$ANY, *), take(+, n-1)), "weightedSum"), t).eval()