diff --git a/cpp/velox/shuffle/VeloxShuffleReader.cc b/cpp/velox/shuffle/VeloxShuffleReader.cc index a39566a9b6e5..00e2225744ec 100644 --- a/cpp/velox/shuffle/VeloxShuffleReader.cc +++ b/cpp/velox/shuffle/VeloxShuffleReader.cc @@ -296,23 +296,6 @@ std::shared_ptr makeColumnarBatch( return std::make_shared(std::move(rowVector)); } -std::shared_ptr makeColumnarBatch( - RowTypePtr type, - std::unique_ptr payload, - memory::MemoryPool* pool, - int64_t& deserializeTime) { - ScopedTimer timer(&deserializeTime); - std::vector veloxBuffers; - auto numBuffers = payload->numBuffers(); - veloxBuffers.reserve(numBuffers); - for (size_t i = 0; i < numBuffers; ++i) { - GLUTEN_ASSIGN_OR_THROW(auto buffer, payload->readBufferAt(i)); - veloxBuffers.push_back(convertToVeloxBuffer(std::move(buffer))); - } - auto rowVector = deserialize(type, payload->numRows(), veloxBuffers, {}, {}, pool); - return std::make_shared(std::move(rowVector)); -} - arrow::Result readDictionaryBuffer(arrow::io::InputStream* in, facebook::velox::memory::MemoryPool* pool, arrow::util::Codec* codec) { size_t bufferSize;