diff --git a/parquet/src/encodings/rle.rs b/parquet/src/encodings/rle.rs index 02a6034d714..f61215f0a5b 100644 --- a/parquet/src/encodings/rle.rs +++ b/parquet/src/encodings/rle.rs @@ -310,6 +310,9 @@ impl RleEncoder { } } +/// Size, in number of `i32s` of buffer to use for RLE batch reading +const RLE_DECODER_INDEX_BUFFER_SIZE: usize = 1024; + /// A RLE/Bit-Packing hybrid decoder. pub struct RleDecoder { // Number of bits used to encode the value. Must be between [0, 64]. @@ -319,7 +322,7 @@ pub struct RleDecoder { bit_reader: Option, // Buffer used when `bit_reader` is not `None`, for batch reading. - index_buf: Option>, + index_buf: Option>, // The remaining number of values in RLE for this run rle_left: u32,