commit | 42e80eeac1fef4a7ac38fa3f2e71699751ef099e | [log] [tgz] |
---|---|---|
author | Alex Levenson <alexlevenson@twitter.com> | Fri May 31 01:26:19 2013 -0700 |
committer | Alex Levenson <alexlevenson@twitter.com> | Fri May 31 01:26:19 2013 -0700 |
tree | 68c23f6765e4868b547a901a4a34134bb7118e83 | |
parent | e3fb1336587cf7210a9995214bd06fc20189ec16 [diff] |
change buffer size to match rle threshold
diff --git a/parquet-column/src/main/java/parquet/column/values/rle/RunLengthBitPackingHybridEncoder.java b/parquet-column/src/main/java/parquet/column/values/rle/RunLengthBitPackingHybridEncoder.java index 674efe8..dba1729 100644 --- a/parquet-column/src/main/java/parquet/column/values/rle/RunLengthBitPackingHybridEncoder.java +++ b/parquet-column/src/main/java/parquet/column/values/rle/RunLengthBitPackingHybridEncoder.java
@@ -117,7 +117,7 @@ this.bitWidth = bitWidth; this.baos = new CapacityByteArrayOutputStream(initialCapacity); this.packBuffer = new byte[bitWidth]; - this.bufferedValues = new int[8]; + this.bufferedValues = new int[rleThreshold]; this.packer = ByteBitPacking.getPacker(bitWidth); this.rleThreshold = rleThreshold;