Skip to content

Commit 83b8e22

Browse files
committed
compress
Signed-off-by: Robert Kruszewski <github@robertk.io>
1 parent 20eabb5 commit 83b8e22

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
@@ -1087,7 +1087,7 @@ mod scheme_selection_tests {
10871087
use vortex_sequence::Sequence;
10881088
use vortex_sparse::Sparse;
10891089

1090-
use crate::BtrBlocksCompressor;
1090+
use crate::{BtrBlocksCompressor, IntCode};
10911091
use crate::CompressorContext;
10921092
use crate::CompressorExt;
10931093

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

0 commit comments

Comments
 (0)