Skip to content

Commit 098b4b5

Browse files
committed
compress
Signed-off-by: Robert Kruszewski <github@robertk.io>
1 parent ab5601f commit 098b4b5

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

  • vortex-btrblocks/src/compressor/integer

vortex-btrblocks/src/compressor/integer/mod.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1090,7 +1090,7 @@ mod scheme_selection_tests {
10901090
use vortex_sequence::Sequence;
10911091
use vortex_sparse::Sparse;
10921092

1093-
use crate::BtrBlocksCompressor;
1093+
use crate::{BtrBlocksCompressor, IntCode};
10941094
use crate::CompressorContext;
10951095
use crate::CompressorExt;
10961096

@@ -1205,14 +1205,14 @@ mod scheme_selection_tests {
12051205
#[test]
12061206
fn test_rle_compressed() -> VortexResult<()> {
12071207
let mut values: Vec<i32> = Vec::new();
1208-
for i in 0..10 {
1209-
values.extend(iter::repeat_n(i, 100));
1208+
for i in 0..1024 {
1209+
values.extend(iter::repeat_n(i, 10));
12101210
}
12111211
let array = PrimitiveArray::new(Buffer::copy_from(&values), Validity::NonNullable);
12121212
let btr = BtrBlocksCompressor::default();
12131213
let compressed =
12141214
btr.integer_compressor()
1215-
.compress(&btr, &array, CompressorContext::default(), &[])?;
1215+
.compress(&btr, &array, CompressorContext::default(), &[IntCode::RunEnd])?;
12161216
assert!(compressed.is::<RLE>());
12171217
Ok(())
12181218
}

0 commit comments

Comments
 (0)