From ceac1d753e2cb5bebee2d81b5c87835811259444 Mon Sep 17 00:00:00 2001 From: Vish Ramachandran Date: Sat, 23 Nov 2024 06:15:57 +0530 Subject: [PATCH] bug fix RateAndMinMaxOverTimeH range function --- .../filodb/query/exec/rangefn/AggrOverTimeFunctions.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/query/src/main/scala/filodb/query/exec/rangefn/AggrOverTimeFunctions.scala b/query/src/main/scala/filodb/query/exec/rangefn/AggrOverTimeFunctions.scala index 1dd0ad02bf..9ee5dff507 100644 --- a/query/src/main/scala/filodb/query/exec/rangefn/AggrOverTimeFunctions.scala +++ b/query/src/main/scala/filodb/query/exec/rangefn/AggrOverTimeFunctions.scala @@ -376,11 +376,13 @@ class RateAndMinMaxOverTimeFuncHD(maxColId: Int, minColId: Int) extends ChunkedR maxFunc.reset() minFunc.reset() } - final def apply(endTimestamp: Long, sampleToEmit: TransientHistMaxMinRow): Unit = { - sampleToEmit.setValues(endTimestamp, hFunc.h) + + override def apply(windowStart: Long, windowEnd: Long, sampleToEmit: TransientHistMaxMinRow): Unit = { + hFunc.apply(windowStart, windowEnd, sampleToEmit) sampleToEmit.setDouble(2, maxFunc.max) sampleToEmit.setDouble(3, minFunc.min) } + final def apply(endTimestamp: Long, sampleToEmit: TransientHistMaxMinRow): Unit = ??? // should not be invoked import BinaryVector.BinaryVectorPtr