Function RateCall

aggregation/function/rate.go:27–38

RateCall represents rate function call.

(interval int64, params ...*collections.FloatArray)

// RateCall represents rate function call.
func RateCall(interval int64, params ...*collections.FloatArray) *collections.FloatArray {
	if len(params) == 0 {
		return nil
	}
	result := collections.NewFloatArray(params[0].Capacity())
	itr := params[0].NewIterator()
	for itr.HasNext() {
		idx, val := itr.Next()
		result.SetValue(idx, val/float64(interval/timeutil.OneSecond))
	}
	return result
}