Skip to content

Commit

Permalink
resolve comment
Browse files Browse the repository at this point in the history
  • Loading branch information
mapleFU committed Apr 4, 2024
1 parent 43d0ea7 commit df15e10
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion cpp/src/parquet/encoding.cc
Original file line number Diff line number Diff line change
Expand Up @@ -3161,7 +3161,8 @@ class RleBooleanDecoder : public DecoderImpl, virtual public BooleanDecoder {
DCHECK_EQ(current_index_in_batch, current_batch_size);
current_batch_size = std::min(num_remain_non_null_values, kBatchSize);
int decoded_count = decoder_->GetBatch(values.data(), current_batch_size);
if (decoded_count != current_batch_size) {
if (ARROW_PREDICT_FALSE(decoded_count != current_batch_size)) {
// required values is more than values in decoder.
ParquetException::EofException();
}
num_remain_non_null_values -= current_batch_size;
Expand Down

0 comments on commit df15e10

Please sign in to comment.