Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
HammadB committed Mar 9, 2024
1 parent 0845cb9 commit 7690de3
Showing 1 changed file with 0 additions and 19 deletions.
19 changes: 0 additions & 19 deletions rust/worker/src/blockstore/arrow_blockfile/block/delta.rs
Original file line number Diff line number Diff line change
Expand Up @@ -145,16 +145,7 @@ impl BlockDeltaInner {
let key_offset_bytes = self.offset_size_for_key_type(item_count, key_type);

let value_total_bytes = bit_util::round_upto_multiple_of_64(value_size);
<<<<<<< HEAD
let value_offset_bytes = self.offset_size_for_value_type(item_count, value_type);
=======
let value_offset_bytes = match value_type {
ValueType::Int32Array | ValueType::String | ValueType::RoaringBitmap => {
bit_util::round_upto_multiple_of_64((item_count + 1) * 4)
}
_ => unimplemented!("Value type not implemented"),
};
>>>>>>> 14c977d3 (split commits wip)

prefix_total_bytes
+ prefix_offset_bytes
Expand Down Expand Up @@ -338,15 +329,6 @@ impl From<Arc<Block>> for BlockDelta {

#[cfg(test)]
mod test {
<<<<<<< HEAD
=======
use arrow::array::{Array, Int32Array};
use figment::value;
use rand::{random, Rng};

use crate::blockstore::types::{Key, KeyType, ValueType};

>>>>>>> 14c977d3 (split commits wip)
use super::*;
use crate::blockstore::types::{Key, KeyType, ValueType};
use arrow::array::Int32Array;
Expand Down Expand Up @@ -429,6 +411,5 @@ mod test {
assert_eq!(size, block_data.get_size());

let (split_key, delta) = delta.split(&block_provider);
println!("Split key: {:?}", split_key);
}
}

0 comments on commit 7690de3

Please sign in to comment.