From 34e3474060eb2130ebd59fea691a9bf6ab3b4c56 Mon Sep 17 00:00:00 2001 From: mwish Date: Tue, 3 Sep 2024 20:54:42 +0800 Subject: [PATCH] fix typo --- cpp/src/arrow/compute/row/row_encoder_internal.cc | 6 +++--- cpp/src/arrow/compute/row/row_encoder_internal.h | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/cpp/src/arrow/compute/row/row_encoder_internal.cc b/cpp/src/arrow/compute/row/row_encoder_internal.cc index 43476bd5b1bcc..17747f90948c1 100644 --- a/cpp/src/arrow/compute/row/row_encoder_internal.cc +++ b/cpp/src/arrow/compute/row/row_encoder_internal.cc @@ -331,12 +331,12 @@ void RowEncoder::Init(const std::vector& column_types, ExecContext* void RowEncoder::Clear() { offsets_.clear(); bytes_.clear(); - fixed_with_row_count_ = 0; + fixed_width_row_count_ = 0; } Status RowEncoder::EncodeAndAppendForFixedWidth(const ExecSpan& batch) { size_t length_before = - static_cast(this->fixed_width_length_) * this->fixed_with_row_count_; + static_cast(this->fixed_width_length_) * this->fixed_width_row_count_; ARROW_CHECK_EQ(length_before, bytes_.size()); #ifndef NDEBUG { @@ -356,7 +356,7 @@ Status RowEncoder::EncodeAndAppendForFixedWidth(const ExecSpan& batch) { for (int64_t i = 0; i < batch.length; ++i) { buf_ptrs[i] = bytes_.data() + length_before + i * fixed_width_length_; } - fixed_with_row_count_ += batch.length; + fixed_width_row_count_ += batch.length; for (int i = 0; i < batch.num_values(); ++i) { RETURN_NOT_OK(encoders_[i]->Encode(batch[i], batch.length, buf_ptrs.data())); } diff --git a/cpp/src/arrow/compute/row/row_encoder_internal.h b/cpp/src/arrow/compute/row/row_encoder_internal.h index 565f54d01d5a6..d2d25ef98f35b 100644 --- a/cpp/src/arrow/compute/row/row_encoder_internal.h +++ b/cpp/src/arrow/compute/row/row_encoder_internal.h @@ -388,7 +388,7 @@ class ARROW_EXPORT RowEncoder { int32_t num_rows() const { if (IsFixedWidth()) { - return fixed_with_row_count_; + return fixed_width_row_count_; } return offsets_.empty() ? 0 : static_cast(offsets_.size() - 1); } @@ -407,7 +407,7 @@ class ARROW_EXPORT RowEncoder { // doesn't need to maintain the row offsets. In this case, the // offsets_.size() would be also empty. int32_t fixed_width_length_{kInvalidFixedWidthOffset}; - int32_t fixed_with_row_count_{0}; + int32_t fixed_width_row_count_{0}; // offsets_ vector stores the starting position (offset) of each encoded row // within the bytes_ vector. This allows for quick access to individual rows. //