rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-28 19:00:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix zero timestamp

Browse Source 
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2026-04-08 07:11:38 +08:00
parent 4545b691b4
commit 7117cefe44
1 changed files with 37 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/query/src/optimizer/const_normalization.rs
View File

@@ -554,7 +554,7 @@ fn lower_bound_for_ge(
) -> Option<i64> {
let ratio = finer_to_coarser_ratio(source_unit, target_unit)?;
let base = target_value.checked_mul(ratio)?;
if target_value < 0 {
if target_value <= 0 {
base.checked_sub(ratio - 1)
} else {
Some(base)
@@ -833,6 +833,42 @@ mod tests {
);
}
#[test]
fn test_normalize_zero_boundary_timestamp_filter() {
let fields = vec![Field::new(
"ts",
DataType::Timestamp(ArrowTimeUnit::Nanosecond, None),
false,
)];
assert_timestamp_pushdown(
fields.clone(),
ts_cast_to_ms().gt_eq(ts_ms_literal(0)),
"Filter: t.ts >= TimestampNanosecond(-999999, None)\n TableScan: t",
"TableScan: t, full_filters=[t.ts >= TimestampNanosecond(-999999, None)]",
TimestampRange::from_start(Timestamp::new_nanosecond(-999_999)),
);
assert_timestamp_pushdown(
fields.clone(),
ts_cast_to_ms().lt(ts_ms_literal(0)),
"Filter: t.ts < TimestampNanosecond(-999999, None)\n TableScan: t",
"TableScan: t, full_filters=[t.ts < TimestampNanosecond(-999999, None)]",
TimestampRange::until_end(Timestamp::new_nanosecond(-999_999), false),
);
assert_timestamp_pushdown(
fields,
ts_cast_to_ms().between(ts_ms_literal(0), ts_ms_literal(0)),
"Filter: t.ts >= TimestampNanosecond(-999999, None) AND t.ts < TimestampNanosecond(1000000, None)\n TableScan: t",
"TableScan: t, full_filters=[t.ts >= TimestampNanosecond(-999999, None), t.ts < TimestampNanosecond(1000000, None)]",
TimestampRange::new_inclusive(
Some(Timestamp::new_nanosecond(-999_999)),
Some(Timestamp::new_nanosecond(999_999)),
),
);
}
#[test]
fn test_normalize_plain_timestamp_literals() {
assert_timestamp_pushdown(