clang-format

apache · Apr 12, 2022 · 1ab0bab · 1ab0bab
1 parent 9b10e06
commit 1ab0bab
Show file tree

Hide file tree

Showing 12 changed files with 511 additions and 644 deletions.
diff --git a/cpp/src/arrow/compute/exec/bloom_filter.cc b/cpp/src/arrow/compute/exec/bloom_filter.cc
@@ -301,7 +301,7 @@ int64_t BlockedBloomFilter::NumBitsSet() const {
 Status BloomFilterBuilder_SingleThreaded::Begin(size_t /*num_threads*/,
                                                 int64_t hardware_flags, MemoryPool* pool,
                                                 int64_t num_rows, int64_t /*num_batches*/,
-                                                BlockedBloomFilter *build_target) {
+                                                BlockedBloomFilter* build_target) {
   hardware_flags_ = hardware_flags;
   build_target_ = build_target;
 
@@ -332,7 +332,7 @@ void BloomFilterBuilder_SingleThreaded::PushNextBatchImp(int num_rows, const T*
 Status BloomFilterBuilder_Parallel::Begin(size_t num_threads, int64_t hardware_flags,
                                           MemoryPool* pool, int64_t num_rows,
                                           int64_t /*num_batches*/,
-                                          BlockedBloomFilter *build_target) {
+                                          BlockedBloomFilter* build_target) {
   hardware_flags_ = hardware_flags;
   build_target_ = build_target;
 

diff --git a/cpp/src/arrow/compute/exec/bloom_filter.h b/cpp/src/arrow/compute/exec/bloom_filter.h
@@ -259,7 +259,7 @@ class ARROW_EXPORT BloomFilterBuilder {
   virtual ~BloomFilterBuilder() = default;
   virtual Status Begin(size_t num_threads, int64_t hardware_flags, MemoryPool* pool,
                        int64_t num_rows, int64_t num_batches,
-                       BlockedBloomFilter *build_target) = 0;
+                       BlockedBloomFilter* build_target) = 0;
   virtual int64_t num_tasks() const { return 0; }
   virtual Status PushNextBatch(size_t thread_index, int num_rows,
                                const uint32_t* hashes) = 0;
@@ -273,7 +273,7 @@ class BloomFilterBuilder_SingleThreaded : public BloomFilterBuilder {
  public:
   Status Begin(size_t num_threads, int64_t hardware_flags, MemoryPool* pool,
                int64_t num_rows, int64_t num_batches,
-               BlockedBloomFilter *build_target) override;
+               BlockedBloomFilter* build_target) override;
 
   Status PushNextBatch(size_t /*thread_index*/, int num_rows,
                        const uint32_t* hashes) override;
@@ -286,14 +286,14 @@ class BloomFilterBuilder_SingleThreaded : public BloomFilterBuilder {
   void PushNextBatchImp(int num_rows, const T* hashes);
 
   int64_t hardware_flags_;
-  BlockedBloomFilter *build_target_;
+  BlockedBloomFilter* build_target_;
 };
 
 class BloomFilterBuilder_Parallel : public BloomFilterBuilder {
  public:
   Status Begin(size_t num_threads, int64_t hardware_flags, MemoryPool* pool,
                int64_t num_rows, int64_t num_batches,
-               BlockedBloomFilter *build_target) override;
+               BlockedBloomFilter* build_target) override;
 
   Status PushNextBatch(size_t thread_id, int num_rows, const uint32_t* hashes) override;
 
@@ -306,7 +306,7 @@ class BloomFilterBuilder_Parallel : public BloomFilterBuilder {
   void PushNextBatchImp(size_t thread_id, int num_rows, const T* hashes);
 
   int64_t hardware_flags_;
-  BlockedBloomFilter *build_target_;
+  BlockedBloomFilter* build_target_;
   int log_num_prtns_;
   struct ThreadLocalState {
     std::vector<uint32_t> partitioned_hashes_32;

diff --git a/cpp/src/arrow/compute/exec/exec_plan.cc b/cpp/src/arrow/compute/exec/exec_plan.cc
@@ -98,9 +98,8 @@ struct ExecPlanImpl : public ExecPlan {
 
     // producers precede consumers
     sorted_nodes_ = TopoSort();
-    for(ExecNode *node : sorted_nodes_)
-    {
-        RETURN_NOT_OK(node->PrepareToProduce());
+    for (ExecNode* node : sorted_nodes_) {
+      RETURN_NOT_OK(node->PrepareToProduce());
     }
 
     std::vector<Future<>> futures;