Skip to content

Commit

Permalink
fix format
Browse files Browse the repository at this point in the history
Signed-off-by: Little-Wallace <[email protected]>
  • Loading branch information
Little-Wallace committed Nov 25, 2023
1 parent 9c6ab96 commit ba49e30
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ impl SstableIterator {
}

fn init_block_prefetch_range(&mut self, start_idx: usize) {
self.preload_end_block_idx = 0;
if let Some(bound) = self.options.must_iterated_end_user_key.as_ref() {
let block_metas = &self.sst.value().meta.block_metas;
let next_to_start_idx = start_idx + 1;
Expand Down
2 changes: 1 addition & 1 deletion src/storage/src/hummock/sstable_store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1242,7 +1242,7 @@ impl BatchBlockStream {
Box::new(block.clone()),
CachePriority::Low,
);
self.blocks.push_back(Box::new(block.clone()));
self.blocks.push_back(Box::new(block));
buff_offset = end;
block_idx += 1;
}
Expand Down
2 changes: 2 additions & 0 deletions src/storage/src/store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -269,6 +269,8 @@ pub trait LocalStateStore: StaticSendSync {

/// If `prefetch` is true, prefetch will be enabled. Prefetching may increase the memory
/// footprint of the CN process because the prefetched blocks cannot be evicted.
/// If `for_large_query` is true, hummock will prefetch the whole object inside the range of this query by a streaming connection.
/// If `for_large_query` is false, hummock will only read at most 16 blocks in once IO.
#[derive(Default, Clone, Copy)]
pub struct PrefetchOptions {
pub prefetch: bool,
Expand Down

0 comments on commit ba49e30

Please sign in to comment.