diff --git a/cpp/core/shuffle/Partitioner.cc b/cpp/core/shuffle/Partitioner.cc index 1b98f7a6702a..3e2781ae8b43 100644 --- a/cpp/core/shuffle/Partitioner.cc +++ b/cpp/core/shuffle/Partitioner.cc @@ -23,7 +23,8 @@ namespace gluten { -arrow::Result> Partitioner::make(Partitioning partitioning, int32_t numPartitions, int32_t partitionKeySeed) { +arrow::Result> +Partitioner::make(Partitioning partitioning, int32_t numPartitions, int32_t partitionKeySeed) { switch (partitioning) { case Partitioning::kHash: return std::make_shared(numPartitions); diff --git a/cpp/core/shuffle/Partitioner.h b/cpp/core/shuffle/Partitioner.h index e9576b36388f..817c4bb3bc57 100644 --- a/cpp/core/shuffle/Partitioner.h +++ b/cpp/core/shuffle/Partitioner.h @@ -26,7 +26,8 @@ namespace gluten { class Partitioner { public: - static arrow::Result> make(Partitioning partitioning, int32_t numPartitions, int32_t partitionKeySeed); + static arrow::Result> + make(Partitioning partitioning, int32_t numPartitions, int32_t partitionKeySeed); // Whether the first column is partition key. bool hasPid() const { diff --git a/cpp/velox/shuffle/VeloxShuffleWriter.cc b/cpp/velox/shuffle/VeloxShuffleWriter.cc index 82574513f2e7..fe33a20180a4 100644 --- a/cpp/velox/shuffle/VeloxShuffleWriter.cc +++ b/cpp/velox/shuffle/VeloxShuffleWriter.cc @@ -411,7 +411,8 @@ arrow::Status VeloxShuffleWriter::init() { VELOX_CHECK_NOT_NULL(options_.memory_pool); ARROW_ASSIGN_OR_RAISE(partitionWriter_, partitionWriterCreator_->make(this)); - ARROW_ASSIGN_OR_RAISE(partitioner_, Partitioner::make(options_.partitioning, numPartitions_, options_.partition_key_seed)); + ARROW_ASSIGN_OR_RAISE( + partitioner_, Partitioner::make(options_.partitioning, numPartitions_, options_.partition_key_seed)); // pre-allocated buffer size for each partition, unit is row count // when partitioner is SinglePart, partial variables don`t need init