File tree Expand file tree Collapse file tree 2 files changed +18
-0
lines changed
rust/cubestore/cubestore/src Expand file tree Collapse file tree 2 files changed +18
-0
lines changed Original file line number Diff line number Diff line change @@ -53,6 +53,13 @@ impl Chunk {
5353 self . partition_id
5454 }
5555
56+ pub fn unset_min_max ( & self ) -> Self {
57+ let mut to_update = self . clone ( ) ;
58+ to_update. min = None ;
59+ to_update. max = None ;
60+ to_update
61+ }
62+
5663 pub fn set_partition_id ( & self , partition_id : u64 ) -> Self {
5764 let mut to_update = self . clone ( ) ;
5865 to_update. partition_id = partition_id;
Original file line number Diff line number Diff line change @@ -1300,6 +1300,17 @@ fn pick_partitions(
13001300 continue ;
13011301 }
13021302
1303+ //FIXME !!!!! emergency fix for APM, might break the limit pushdown, need to be solved on
1304+ //another way
1305+ let chunks = chunks
1306+ . into_iter ( )
1307+ . map ( |c| {
1308+ let id = c. id ;
1309+ let chunk = c. into_row ( ) . unset_min_max ( ) ;
1310+ IdRow :: new ( id, chunk)
1311+ } )
1312+ . collect :: < Vec < _ > > ( ) ;
1313+
13031314 partition_snapshots. push ( PartitionSnapshot { chunks, partition } ) ;
13041315 }
13051316 log:: trace!(
You can’t perform that action at this time.
0 commit comments