File tree Expand file tree Collapse file tree
quickwit/quickwit-parquet-engine/src/merge/policy Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -58,8 +58,7 @@ impl ParquetMergeOperation {
5858 /// - **MP-3**: all splits share the same compaction scope (sort_fields + window)
5959 pub fn new ( splits : Vec < ParquetSplitMetadata > ) -> Self {
6060 use quickwit_dst:: check_invariant;
61- use quickwit_dst:: invariants:: InvariantId ;
62- use quickwit_dst:: invariants:: merge_policy;
61+ use quickwit_dst:: invariants:: { InvariantId , merge_policy} ;
6362
6463 // MP-2: minimum split count.
6564 check_invariant ! (
@@ -79,8 +78,7 @@ impl ParquetMergeOperation {
7978 ) ;
8079
8180 // MP-3: scope homogeneity (sort_fields + window).
82- let sort_fields_vec: Vec < & str > =
83- splits. iter ( ) . map ( |s| s. sort_fields . as_str ( ) ) . collect ( ) ;
81+ let sort_fields_vec: Vec < & str > = splits. iter ( ) . map ( |s| s. sort_fields . as_str ( ) ) . collect ( ) ;
8482 let windows: Vec < ( i64 , i64 ) > = splits
8583 . iter ( )
8684 . map ( |s| match & s. window {
@@ -254,4 +252,3 @@ mod tests {
254252 assert_eq ! ( op. splits. len( ) , 2 ) ;
255253 }
256254}
257-
You can’t perform that action at this time.
0 commit comments