From bfcde2c458670c07388949b4d7fa08c3a94b0750 Mon Sep 17 00:00:00 2001 From: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com> Date: Wed, 20 Jul 2022 21:11:29 +0600 Subject: [PATCH] Test alignTimestamp --- .../jedis/modules/timeseries/TimeSeriesTest.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/src/test/java/redis/clients/jedis/modules/timeseries/TimeSeriesTest.java b/src/test/java/redis/clients/jedis/modules/timeseries/TimeSeriesTest.java index 8ad2d61ce8..73bc360908 100644 --- a/src/test/java/redis/clients/jedis/modules/timeseries/TimeSeriesTest.java +++ b/src/test/java/redis/clients/jedis/modules/timeseries/TimeSeriesTest.java @@ -937,4 +937,18 @@ public void bucketTimestamp() { assertEquals(5, client.tsMRange(TSMRangeParams.multiRangeParams().aggregation(AggregationType.VAR_S, 10) .bucketTimestamp("~").filter("l=v")).get(0).getValue().get(0).getTimestamp()); } + + @Test + public void alignTimestamp() { + client.tsCreate("ts1"); + client.tsCreate("ts2"); + client.tsCreate("ts3"); + client.tsCreateRule("ts1", "ts2", AggregationType.COUNT, 10, 0); + client.tsCreateRule("ts1", "ts3", AggregationType.COUNT, 10, 1); + client.tsAdd("ts1", 1, 1); + client.tsAdd("ts1", 10, 3); + client.tsAdd("ts1", 21, 7); + assertEquals(2, client.tsRange("ts2", TSRangeParams.rangeParams().aggregation(AggregationType.COUNT, 10)).size()); + assertEquals(1, client.tsRange("ts3", TSRangeParams.rangeParams().aggregation(AggregationType.COUNT, 10)).size()); + } }