I have the following CQ:
CREATE CONTINUOUS QUERY MyContinuousQuery ON MyDatabase
RESAMPLE EVERY 30s FOR 120s
BEGIN
SELECT
sum("non_negative_difference")
INTO
MyDatabase2..:MEASUREMENT
FROM (
SELECT
non_negative_difference(sum("count"))
FROM
/.*/
GROUP BY
subtask_index,
time(30s)
)
GROUP BY
time(30s)
END
Each time a new measurement is created in MyDatabase
, after a while a corresponding measurement is created by the CQ in MyDatabase2
. However, the first entry in the measurement in MyDatabase
seems to be not taken into account in the corresponding measurement in MyDatabase2
.
Original measurement:
"values": [
["2017-10-09T09:20:04.741Z", 4],
["2017-10-09T09:20:34.796Z", 4],
["2017-10-09T09:21:04.834Z", 6],
["2017-10-09T09:21:34.849Z", 7]
]
CQ output:
"values": [
["2017-10-09T09:20:30Z", 0],
["2017-10-09T09:21:00Z", 2],
["2017-10-09T09:21:30Z", 1]
]
I expected to have ["2017-10-09T09:20:00Z", 4]
in CQ output. Do I misuse or misunderstand how continuous query works? How can I achieve it?