diff --git a/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.cc b/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.cc index 365002388754b..41f9823a903ec 100644 --- a/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.cc +++ b/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.cc @@ -123,8 +123,8 @@ arrow::Result> VeloxSortBasedShuffl ShuffleWriterOptions options, std::shared_ptr veloxPool, arrow::MemoryPool* arrowPool) { - std::shared_ptr res( - new VeloxSortBasedShuffleWriter(numPartitions, std::move(partitionWriter), std::move(options), veloxPool, arrowPool)); + std::shared_ptr res(new VeloxSortBasedShuffleWriter( + numPartitions, std::move(partitionWriter), std::move(options), veloxPool, arrowPool)); RETURN_NOT_OK(res->init()); return res; } // namespace gluten @@ -307,9 +307,7 @@ arrow::Status VeloxSortBasedShuffleWriter::initFromRowVector(const facebook::vel false, facebook::velox::common::stringToCompressionKind(partitionWriter_->options().compressionTypeStr)}; batch_ = std::make_unique(veloxPool_.get()); batch_->createStreamTree( - std::static_pointer_cast(rowType_.value()), - options_.bufferSize, - &serdeOptions_); + std::static_pointer_cast(rowType_.value()), options_.bufferSize, &serdeOptions_); return arrow::Status::OK(); } diff --git a/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.h b/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.h index 1df2dda6dbc4f..6306a63c241fd 100644 --- a/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.h +++ b/cpp/velox/shuffle/VeloxSortBasedShuffleWriter.h @@ -101,7 +101,6 @@ struct BinaryArrayResizeState { }; class VeloxSortBasedShuffleWriter : public ShuffleWriter { - public: static arrow::Result> create( uint32_t numPartitions,