context by分组后实现动态长度窗口计算

需求:通过context by根据symbol分组后,统计每个时间点最近一段时间的Volume之和(比如symboA,6月1日那个点要算5月20日至6月1日的总和,6月2日那个点要算5月25日至6月2日的总和),请问如何实现?目前通过下面方式报如下错误:

def DynamicSum(vol,indexEnd){

        indexBegin=xx......此处代码算出滑动窗口起点序列号

        //return sum(vol[indexBegin:indexEnd])    //此种方式报错: To form a pair, both operands must be a scalar.

//return sum(cells(matrix(vol),indexBegin..indexEnd,take(0,(indexEnd-indexBegin+1))))    //此种方式报错:Both starting value and ending value of 'seq' must be an integer or a temporal object'

//用parseExpr.eval()也报和上面一样的错误

}

select DateTime,Symbol,Volume,DynamicSum(Volume,cumcount(Volume)) from tbDx where Category=`ddb_stock context by Symbol csort DateTime


请先 登录 后评论

1 个回答

peter

能提供下更为具体的业务场景么

请先 登录 后评论
  • 1 关注
  • 0 收藏,521 浏览
  • 迈拓将 提出于 2023-07-31 22:07

相似问题