Skip to content

Commit e56c877

Browse files
committed
File rename
1 parent 0908342 commit e56c877

File tree

2 files changed

+9
-12
lines changed

2 files changed

+9
-12
lines changed

cpp/src/parquet/decoder.cc

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,9 @@
4141
#include "arrow/util/bit_util.h"
4242
#include "arrow/util/bitmap_ops.h"
4343
#include "arrow/util/byte_stream_split_internal.h"
44-
#include "arrow/util/alp/Alp.h"
45-
#include "arrow/util/alp/AlpConstants.h"
46-
#include "arrow/util/alp/AlpWrapper.h"
44+
#include "arrow/util/alp/alp.h"
45+
#include "arrow/util/alp/alp_constants.h"
46+
#include "arrow/util/alp/alp_wrapper.h"
4747
#include "arrow/util/checked_cast.h"
4848
#include "arrow/util/int_util_overflow.h"
4949
#include "arrow/util/logging_internal.h"
@@ -2352,9 +2352,8 @@ class AlpDecoder : public TypedDecoderImpl<DType> {
23522352
int Decode(T* buffer, int max_values) override {
23532353
// Fast path: decode directly into output buffer if requesting all values
23542354
if (needs_decode_ && max_values >= this->num_values_) {
2355-
size_t decompSize = this->num_values_ * sizeof(T);
23562355
::arrow::util::alp::AlpWrapper<T>::Decode(
2357-
buffer, &decompSize,
2356+
buffer, static_cast<uint64_t>(this->num_values_),
23582357
reinterpret_cast<const char*>(this->data_), this->len_);
23592358

23602359
const int decoded = this->num_values_;
@@ -2367,9 +2366,8 @@ class AlpDecoder : public TypedDecoderImpl<DType> {
23672366
// ALP Bit unpacker needs batches of 64
23682367
if (needs_decode_) {
23692368
decoded_buffer_.resize(this->num_values_);
2370-
size_t decompSize = this->num_values_ * sizeof(T);
23712369
::arrow::util::alp::AlpWrapper<T>::Decode(
2372-
decoded_buffer_.data(), &decompSize,
2370+
decoded_buffer_.data(), static_cast<uint64_t>(this->num_values_),
23732371
reinterpret_cast<const char*>(this->data_), this->len_);
23742372
needs_decode_ = false;
23752373
}
@@ -2402,9 +2400,8 @@ class AlpDecoder : public TypedDecoderImpl<DType> {
24022400
// Decode if needed (DecodeArrow always needs intermediate buffer for nulls)
24032401
if (needs_decode_) {
24042402
decoded_buffer_.resize(this->num_values_);
2405-
size_t decompSize = this->num_values_ * sizeof(T);
24062403
::arrow::util::alp::AlpWrapper<T>::Decode(
2407-
decoded_buffer_.data(), &decompSize,
2404+
decoded_buffer_.data(), static_cast<uint64_t>(this->num_values_),
24082405
reinterpret_cast<const char*>(this->data_), this->len_);
24092406
needs_decode_ = false;
24102407
}

cpp/src/parquet/encoder.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,9 @@
3636
#include "arrow/util/bit_util.h"
3737
#include "arrow/util/bitmap_ops.h"
3838
#include "arrow/util/byte_stream_split_internal.h"
39-
#include "arrow/util/alp/Alp.h"
40-
#include "arrow/util/alp/AlpConstants.h"
41-
#include "arrow/util/alp/AlpWrapper.h"
39+
#include "arrow/util/alp/alp.h"
40+
#include "arrow/util/alp/alp_constants.h"
41+
#include "arrow/util/alp/alp_wrapper.h"
4242
#include "arrow/util/checked_cast.h"
4343
#include "arrow/util/hashing.h"
4444
#include "arrow/util/int_util_overflow.h"

0 commit comments

Comments
 (0)