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

feat: enable batch checker

Browse Source
This commit is contained in:
evenyag
2024-11-05 15:16:53 +08:00
parent b8ac19c480
commit 3e5bbdf71e
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/mito2/src/read.rs
View File

@@ -572,7 +572,7 @@ impl Batch {
}
/// A struct to check the batch is monotonic.
#[cfg(debug_assertions)]
// #[cfg(debug_assertions)]
#[derive(Default)]
pub(crate) struct BatchChecker {
last_batch: Option<Batch>,
@@ -580,7 +580,7 @@ pub(crate) struct BatchChecker {
end: Option<Timestamp>,
}
#[cfg(debug_assertions)]
// #[cfg(debug_assertions)]
impl BatchChecker {
/// Attaches the given start timestamp to the checker.
pub(crate) fn with_start(mut self, start: Option<Timestamp>) -> Self {

4
src/mito2/src/read/unordered_scan.rs
View File

@@ -145,7 +145,7 @@ impl UnorderedScan {
partition,
part_range,
);
#[cfg(debug_assertions)]
// #[cfg(debug_assertions)]
let mut checker = crate::read::BatchChecker::default()
.with_start(Some(part_range.start))
.with_end(Some(part_range.end));
@@ -168,7 +168,7 @@ impl UnorderedScan {
continue;
}
#[cfg(debug_assertions)]
// #[cfg(debug_assertions)]
checker.ensure_part_range_batch(
"UnorderedScan",
stream_ctx.input.mapper.metadata().region_id,