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

refactor: make compaction schema flag explicit in flat reader setup

Browse Source 
Agent-Logs-Url: https://github.com/GreptimeTeam/greptimedb/sessions/d0dc5df7-0d37-4ed0-bfb9-a796fc8025af

Co-authored-by: MichaelScofield <990479+MichaelScofield@users.noreply.github.com>
This commit is contained in:
copilot-swe-agent[bot]
2026-05-20 04:46:35 +00:00
committed by GitHub
parent 8c90f2e800
commit 6d2ec3411f
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/mito2/src/compaction.rs
View File

@@ -1005,10 +1005,11 @@ impl CompactionSstReaderBuilder<'_> {
/// Build a [FlatSource] that yields Arrow `RecordBatch`s from reading all the input SST files,
/// for compaction. The schema of the [FlatSource] is unified.
async fn build_flat_sst_reader(self) -> Result<FlatSource> {
let scan_input = self.build_scan_input().await?.with_compaction(true);
let compaction = true;
let scan_input = self.build_scan_input().await?.with_compaction(compaction);
// Compaction reads/writes flat SST batches (with internal columns), so this must use
// the flat input schema instead of the logical output schema.
let schema = scan_input.mapper.input_arrow_schema(scan_input.compaction);
let schema = scan_input.mapper.input_arrow_schema(compaction);
let stream = SeqScan::new(scan_input)
.build_flat_reader_for_compaction()