cumulativeSum() 函数
cumulativeSum()
计算表中非空记录的累积总和。
输出表模式将与输入表相同。
函数类型签名
(<-tables: stream[A], ?columns: [string]) => stream[B] where A: Record, B: Record
有关更多信息,请参阅 函数类型签名。
参数
columns
要操作的列列表。默认为 ["_value"]
。
tables
输入数据。默认为管道转发数据 (<-
)。
示例
返回每个表中值的运行总计
import "sampledata"
sampledata.int()
|> cumulativeSum()
此页是否对您有帮助?
感谢您的反馈!