diff --git a/cpp/velox/shuffle/VeloxShuffleReader.cc b/cpp/velox/shuffle/VeloxShuffleReader.cc index a352e63fb09..bfe11ef3e9f 100644 --- a/cpp/velox/shuffle/VeloxShuffleReader.cc +++ b/cpp/velox/shuffle/VeloxShuffleReader.cc @@ -444,22 +444,16 @@ VeloxHashShuffleReaderDeserializer::VeloxHashShuffleReaderDeserializer( const std::shared_ptr& schema, const std::shared_ptr& codec, const facebook::velox::RowTypePtr& rowType, - int32_t batchSize, int64_t readerBufferSize, VeloxMemoryManager* memoryManager, - std::vector* isValidityBuffer, - bool hasComplexType, int64_t& deserializeTime, int64_t& decompressTime) : streamReader_(streamReader), schema_(schema), codec_(codec), rowType_(rowType), - batchSize_(batchSize), readerBufferSize_(readerBufferSize), memoryManager_(memoryManager), - isValidityBuffer_(isValidityBuffer), - hasComplexType_(hasComplexType), deserializeTime_(deserializeTime), decompressTime_(decompressTime) {} @@ -838,11 +832,8 @@ std::unique_ptr VeloxShuffleReaderDeserializerFactory::cr schema_, codec_, rowType_, - batchSize_, readerBufferSize_, memoryManager_, - &isValidityBuffer_, - hasComplexType_, deserializeTime_, decompressTime_); case ShuffleWriterType::kSortShuffle: diff --git a/cpp/velox/shuffle/VeloxShuffleReader.h b/cpp/velox/shuffle/VeloxShuffleReader.h index 26a1634f4d6..f30595dde45 100644 --- a/cpp/velox/shuffle/VeloxShuffleReader.h +++ b/cpp/velox/shuffle/VeloxShuffleReader.h @@ -34,11 +34,8 @@ class VeloxHashShuffleReaderDeserializer final : public ColumnarBatchIterator { const std::shared_ptr& schema, const std::shared_ptr& codec, const facebook::velox::RowTypePtr& rowType, - int32_t batchSize, int64_t readerBufferSize, VeloxMemoryManager* memoryManager, - std::vector* isValidityBuffer, - bool hasComplexType, int64_t& deserializeTime, int64_t& decompressTime); @@ -53,20 +50,15 @@ class VeloxHashShuffleReaderDeserializer final : public ColumnarBatchIterator { std::shared_ptr schema_; std::shared_ptr codec_; facebook::velox::RowTypePtr rowType_; - int32_t batchSize_; int64_t readerBufferSize_; VeloxMemoryManager* memoryManager_; - std::vector* isValidityBuffer_; - bool hasComplexType_; - int64_t& deserializeTime_; int64_t& decompressTime_; std::shared_ptr in_{nullptr}; bool reachedEos_{false}; - bool blockTypeResolved_{false}; std::vector dictionaryFields_{}; std::vector dictionaries_{};