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

chore: more log

Browse Source
This commit is contained in:
evenyag
2024-11-04 20:06:20 +08:00
parent 6e590da412
commit e003eaab36
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/mito2/src/read/scan_util.rs
View File

@@ -163,7 +163,11 @@ pub(crate) fn scan_file_ranges(
for range in ranges {
let build_reader_start = Instant::now();
let reader = range.reader(None).await?;
part_metrics.inc_build_reader_cost(build_reader_start.elapsed());
let build_cost = build_reader_start.elapsed();
part_metrics.inc_build_reader_cost(build_cost);
if read_type == "unordered_scan_files" {
common_telemetry::debug!("Scan file range, region_id: {}, file_id: {}, build_cost: {:?}", stream_ctx.input.mapper.metadata().region_id, range.file_handle().file_id(), build_cost);
}
let compat_batch = range.compat_batch();
let mut source = Source::PruneReader(reader);
while let Some(mut batch) = source.next_batch().await? {

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

@@ -188,7 +188,9 @@ impl UnorderedScan {
metrics.yield_cost += yield_start.elapsed();
}
metrics.scan_cost += fetch_start.elapsed();
let scan_cost = fetch_start.elapsed();
common_telemetry::debug!("Unordered scan range, region_id: {}, scan_cost: {:?}", stream_ctx.input.mapper.metadata().region_id, scan_cost);
metrics.scan_cost += scan_cost;
part_metrics.merge_metrics(&metrics);
}