Skip to content

Commit 7ef530c

Browse files
committed
Status version FileReader::Make set to deprecated
1 parent bbfda8e commit 7ef530c

File tree

4 files changed

+41
-37
lines changed

4 files changed

+41
-37
lines changed

cpp/src/arrow/dataset/file_parquet.cc

Lines changed: 28 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -509,9 +509,9 @@ Result<std::shared_ptr<parquet::arrow::FileReader>> ParquetFileFormat::GetReader
509509
std::shared_ptr<parquet::FileMetaData> reader_metadata = reader->metadata();
510510
auto arrow_properties =
511511
MakeArrowReaderProperties(*this, *reader_metadata, *options, *parquet_scan_options);
512-
std::unique_ptr<parquet::arrow::FileReader> arrow_reader;
513-
RETURN_NOT_OK(parquet::arrow::FileReader::Make(
514-
options->pool, std::move(reader), std::move(arrow_properties), &arrow_reader));
512+
ARROW_ASSIGN_OR_RAISE(auto arrow_reader,
513+
parquet::arrow::FileReader::Make(options->pool, std::move(reader),
514+
std::move(arrow_properties)));
515515
// R build with openSUSE155 requires an explicit shared_ptr construction
516516
return std::shared_ptr<parquet::arrow::FileReader>(std::move(arrow_reader));
517517
}
@@ -532,37 +532,37 @@ Future<std::shared_ptr<parquet::arrow::FileReader>> ParquetFileFormat::GetReader
532532
source.filesystem(), options->pool);
533533
auto self = checked_pointer_cast<const ParquetFileFormat>(shared_from_this());
534534

535-
return source.OpenAsync().Then(
536-
[self = self, properties = std::move(properties), source = source,
537-
options = options, metadata = metadata,
538-
parquet_scan_options = parquet_scan_options](
539-
const std::shared_ptr<io::RandomAccessFile>& input) mutable {
540-
return parquet::ParquetFileReader::OpenAsync(input, properties, metadata)
541-
.Then(
542-
[=](const std::unique_ptr<parquet::ParquetFileReader>& reader) mutable
543-
-> Result<std::shared_ptr<parquet::arrow::FileReader>> {
544-
auto arrow_properties = MakeArrowReaderProperties(
545-
*self, *reader->metadata(), *options, *parquet_scan_options);
546-
547-
std::unique_ptr<parquet::arrow::FileReader> arrow_reader;
548-
RETURN_NOT_OK(parquet::arrow::FileReader::Make(
535+
return source.OpenAsync().Then([self = self, properties = std::move(properties),
536+
source = source, options = options, metadata = metadata,
537+
parquet_scan_options = parquet_scan_options](
538+
const std::shared_ptr<io::RandomAccessFile>&
539+
input) mutable {
540+
return parquet::ParquetFileReader::OpenAsync(input, properties, metadata)
541+
.Then(
542+
[=](const std::unique_ptr<parquet::ParquetFileReader>& reader) mutable
543+
-> Result<std::shared_ptr<parquet::arrow::FileReader>> {
544+
auto arrow_properties = MakeArrowReaderProperties(
545+
*self, *reader->metadata(), *options, *parquet_scan_options);
546+
547+
ARROW_ASSIGN_OR_RAISE(
548+
auto arrow_reader,
549+
parquet::arrow::FileReader::Make(
549550
options->pool,
550551
// TODO(ARROW-12259): workaround since we have Future<(move-only
551552
// type)> It *wouldn't* be safe to const_cast reader except that
552553
// here we know there are no other waiters on the reader.
553554
std::move(const_cast<std::unique_ptr<parquet::ParquetFileReader>&>(
554555
reader)),
555-
arrow_properties, &arrow_reader));
556-
557-
// R build with openSUSE155 requires an explicit shared_ptr construction
558-
return std::shared_ptr<parquet::arrow::FileReader>(
559-
std::move(arrow_reader));
560-
},
561-
[path = source.path()](const Status& status)
562-
-> Result<std::shared_ptr<parquet::arrow::FileReader>> {
563-
return WrapSourceError(status, path);
564-
});
565-
});
556+
arrow_properties));
557+
558+
// R build with openSUSE155 requires an explicit shared_ptr construction
559+
return std::shared_ptr<parquet::arrow::FileReader>(std::move(arrow_reader));
560+
},
561+
[path = source.path()](const Status& status)
562+
-> Result<std::shared_ptr<parquet::arrow::FileReader>> {
563+
return WrapSourceError(status, path);
564+
});
565+
});
566566
}
567567

568568
struct SlicingGenerator {

cpp/src/parquet/arrow/arrow_statistics_test.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -202,9 +202,9 @@ ::arrow::Result<std::shared_ptr<::arrow::Array>> StatisticsReadArray(
202202

203203
auto reader =
204204
ParquetFileReader::Open(std::make_shared<::arrow::io::BufferReader>(buffer));
205-
std::unique_ptr<FileReader> file_reader;
206-
ARROW_RETURN_NOT_OK(FileReader::Make(::arrow::default_memory_pool(), std::move(reader),
207-
reader_properties, &file_reader));
205+
ARROW_ASSIGN_OR_RAISE(auto file_reader,
206+
FileReader::Make(::arrow::default_memory_pool(),
207+
std::move(reader), reader_properties));
208208
std::shared_ptr<::arrow::ChunkedArray> chunked_array;
209209
ARROW_RETURN_NOT_OK(file_reader->ReadColumn(0, &chunked_array));
210210
return chunked_array->chunk(0);

cpp/src/parquet/arrow/reader.cc

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1404,13 +1404,13 @@ FileReaderBuilder* FileReaderBuilder::properties(
14041404
}
14051405

14061406
Status FileReaderBuilder::Build(std::unique_ptr<FileReader>* out) {
1407-
return FileReader::Make(pool_, std::move(raw_reader_), properties_, out);
1407+
ARROW_ASSIGN_OR_RAISE(*out,
1408+
FileReader::Make(pool_, std::move(raw_reader_), properties_));
1409+
return Status::OK();
14081410
}
14091411

14101412
Result<std::unique_ptr<FileReader>> FileReaderBuilder::Build() {
1411-
std::unique_ptr<FileReader> out;
1412-
RETURN_NOT_OK(FileReader::Make(pool_, std::move(raw_reader_), properties_, &out));
1413-
return out;
1413+
return FileReader::Make(pool_, std::move(raw_reader_), properties_);
14141414
}
14151415

14161416
Result<std::unique_ptr<FileReader>> OpenFile(
@@ -1581,8 +1581,8 @@ Status FuzzReader(const uint8_t* data, int64_t size) {
15811581
pq_file_reader = ParquetFileReader::Open(file, reader_properties, pq_md);
15821582
END_PARQUET_CATCH_EXCEPTIONS
15831583

1584-
std::unique_ptr<FileReader> reader;
1585-
RETURN_NOT_OK(FileReader::Make(pool, std::move(pq_file_reader), properties, &reader));
1584+
ARROW_ASSIGN_OR_RAISE(auto reader,
1585+
FileReader::Make(pool, std::move(pq_file_reader), properties));
15861586
st &= FuzzReadData(std::move(reader));
15871587
}
15881588
return st;

cpp/src/parquet/arrow/reader.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,12 +116,16 @@ class RowGroupReader;
116116
class PARQUET_EXPORT FileReader {
117117
public:
118118
/// Factory function to create a FileReader from a ParquetFileReader and properties
119+
/// \deprecated Deprecated in 23.0.0. Use arrow::Result version instead.
120+
ARROW_DEPRECATED("Deprecated in 23.0.0. Use arrow::Result version instead.")
119121
static ::arrow::Status Make(::arrow::MemoryPool* pool,
120122
std::unique_ptr<ParquetFileReader> reader,
121123
const ArrowReaderProperties& properties,
122124
std::unique_ptr<FileReader>* out);
123125

124126
/// Factory function to create a FileReader from a ParquetFileReader
127+
/// \deprecated Deprecated in 23.0.0. Use arrow::Result version instead.
128+
ARROW_DEPRECATED("Deprecated in 23.0.0. Use arrow::Result version instead.")
125129
static ::arrow::Status Make(::arrow::MemoryPool* pool,
126130
std::unique_ptr<ParquetFileReader> reader,
127131
std::unique_ptr<FileReader>* out);

0 commit comments

Comments
 (0)