diff --git a/cpp/src/arrow/dataset/file_parquet.cc b/cpp/src/arrow/dataset/file_parquet.cc index 9d2a28a821e7b..9d0e8a6515878 100644 --- a/cpp/src/arrow/dataset/file_parquet.cc +++ b/cpp/src/arrow/dataset/file_parquet.cc @@ -89,7 +89,8 @@ parquet::ArrowReaderProperties MakeArrowReaderProperties( } parquet::ArrowReaderProperties MakeArrowReaderProperties( - const ParquetFileFormat& format, const parquet::FileMetaData& metadata, const ScanOptions& options, const ParquetFragmentScanOptions& parquet_scan_options) { + const ParquetFileFormat& format, const parquet::FileMetaData& metadata, + const ScanOptions& options, const ParquetFragmentScanOptions& parquet_scan_options) { auto arrow_properties = MakeArrowReaderProperties(format, metadata); arrow_properties.set_batch_size(options.batch_size); // Must be set here since the sync ScanTask handles pre-buffering itself @@ -455,7 +456,8 @@ Result> ParquetFileFormat::GetReader auto reader = std::move(reader_opt).ValueOrDie(); std::shared_ptr reader_metadata = reader->metadata(); - auto arrow_properties = MakeArrowReaderProperties(*this, *reader_metadata, *options, *parquet_scan_options); + auto arrow_properties = + MakeArrowReaderProperties(*this, *reader_metadata, *options, *parquet_scan_options); std::unique_ptr arrow_reader; RETURN_NOT_OK(parquet::arrow::FileReader::Make( options->pool, std::move(reader), std::move(arrow_properties), &arrow_reader)); @@ -488,7 +490,8 @@ Future> ParquetFileFormat::GetReader ARROW_ASSIGN_OR_RAISE(std::unique_ptr reader, reader_fut.MoveResult()); std::shared_ptr metadata = reader->metadata(); - auto arrow_properties = MakeArrowReaderProperties(*this, *metadata, *options, *parquet_scan_options); + auto arrow_properties = + MakeArrowReaderProperties(*this, *metadata, *options, *parquet_scan_options); std::unique_ptr arrow_reader; RETURN_NOT_OK(parquet::arrow::FileReader::Make(options->pool, std::move(reader), std::move(arrow_properties), diff --git a/cpp/src/arrow/dataset/file_parquet_test.cc b/cpp/src/arrow/dataset/file_parquet_test.cc index 4621023b4df7c..8527c3af64c83 100644 --- a/cpp/src/arrow/dataset/file_parquet_test.cc +++ b/cpp/src/arrow/dataset/file_parquet_test.cc @@ -373,9 +373,7 @@ TEST_F(TestParquetFileFormat, SingleThreadExecutor) { // Reset capacity for io executor struct PoolResetGuard { int original_capacity = io::GetIOThreadPoolCapacity(); - ~PoolResetGuard() { - DCHECK_OK(io::SetIOThreadPoolCapacity(original_capacity)); - } + ~PoolResetGuard() { DCHECK_OK(io::SetIOThreadPoolCapacity(original_capacity)); } } guard; ASSERT_OK(io::SetIOThreadPoolCapacity(1)); @@ -383,8 +381,7 @@ TEST_F(TestParquetFileFormat, SingleThreadExecutor) { ASSERT_OK_AND_ASSIGN(auto buffer, ParquetFormatHelper::Write(reader.get())); auto buffer_reader = std::make_shared<::arrow::io::BufferReader>(buffer); - auto source = - std::make_shared(std::move(buffer_reader), buffer->size()); + auto source = std::make_shared(std::move(buffer_reader), buffer->size()); auto options = std::make_shared(); {