能提供下更为具体的业务场景么
需求:通过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