Format

Author: Rafał Hibner

cpp/src/arrow/acero/options.h

@@ -200,20 +200,20 @@ class ARROW_ACERO_EXPORT RecordBatchReaderSourceNodeOptions : public ExecNodeOpt
   /// Create an instance from values
   RecordBatchReaderSourceNodeOptions(std::shared_ptr<RecordBatchReader> reader,
                                      arrow::internal::Executor* io_executor = NULLPTR,
-                                     bool implicit_ordering=false)
-      : reader(std::move(reader)), io_executor(io_executor),implicit_ordering(implicit_ordering) {}
+                                     bool implicit_ordering = false)
+      : reader(std::move(reader)),
+        io_executor(io_executor),
+        implicit_ordering(implicit_ordering) {}
 
   /// \brief The RecordBatchReader which acts as the data source
   std::shared_ptr<RecordBatchReader> reader;
 
-
   /// \brief The executor to use for the reader
   ///
   /// Defaults to the default I/O executor.
   arrow::internal::Executor* io_executor;
 
-  
-  bool implicit_ordering{false}; 
+  bool implicit_ordering{false};
 };
 
 /// a source node that reads from an iterator of array vectors

cpp/src/arrow/acero/source_node.cc

@@ -416,7 +416,8 @@ struct RecordBatchReaderSourceNode : public SourceNode {
     const auto& cast_options =
         checked_cast<const RecordBatchReaderSourceNodeOptions&>(options);
     auto& reader = cast_options.reader;
-    Ordering ordering = cast_options.implicit_ordering?Ordering::Implicit():Ordering::Unordered();
+    Ordering ordering =
+        cast_options.implicit_ordering ? Ordering::Implicit() : Ordering::Unordered();
     auto io_executor = cast_options.io_executor;
 
     if (reader == nullptr) {

cpp/src/arrow/dataset/file_base.cc

@@ -556,8 +556,8 @@ Result<acero::ExecNode*> MakeWriteNode(acero::ExecPlan* plan,
 
   std::shared_ptr<DatasetWritingSinkNodeConsumer> consumer =
       std::make_shared<DatasetWritingSinkNodeConsumer>(
-          custom_schema,
-                                                       write_node_options.write_options, write_node_options.max_rows_queued);
+          custom_schema, write_node_options.write_options,
+          write_node_options.max_rows_queued);
   ARROW_ASSIGN_OR_RAISE(
       auto node,
       // to preserve order explicitly sequence the exec batches