feat: assert precision

This commit is contained in:
evenyag
2024-11-05 15:24:07 +08:00
parent 3e5bbdf71e
commit f59e28006a

View File

@@ -341,6 +341,17 @@ impl PartSortStream {
)?,
);
match sort_column.data_type() {
arrow_schema::DataType::Timestamp(unit, _) => {
assert_eq!(cur_range.start.unit().as_arrow_time_unit(), *unit);
assert_eq!(cur_range.end.unit().as_arrow_time_unit(), *unit);
}
_ => panic!(
"Unsupported data type for sort column: {:?}",
sort_column.data_type()
),
}
for (idx, val) in sort_column_iter {
// ignore vacant time index data
if let Some(val) = val {