fix: pass series row selector to file range reader (#5054)

This commit is contained in:
Yingwen
2024-11-26 19:13:00 +08:00
committed by GitHub
parent fae141ad0a
commit 6130c70b63

View File

@@ -170,7 +170,7 @@ pub(crate) fn scan_file_ranges(
for range in ranges {
let build_reader_start = Instant::now();
let reader = range.reader(None).await?;
let reader = range.reader(stream_ctx.input.series_row_selector).await?;
let build_cost = build_reader_start.elapsed();
part_metrics.inc_build_reader_cost(build_cost);
let compat_batch = range.compat_batch();