|
 |
b48d46 |
--- ceph-17.2.3/src/s3select/include/s3select_parquet_intrf.h.orig 2022-08-03 18:31:07.578235502 -0400
|
|
|
b48d46 |
+++ ceph-17.2.3/src/s3select/include/s3select_parquet_intrf.h 2022-08-05 11:14:16.114933605 -0400
|
|
|
b48d46 |
@@ -196,8 +196,8 @@
|
|
|
b48d46 |
bool write_only) override {
|
|
|
b48d46 |
RETURN_NOT_OK(SetFileName(path));
|
|
|
b48d46 |
|
|
|
b48d46 |
- ARROW_ASSIGN_OR_RAISE(fd_, ::arrow::internal::FileOpenWritable(file_name_, write_only,
|
|
|
b48d46 |
- truncate, append));
|
|
|
b48d46 |
+ fd_ = ::arrow::internal::FileOpenWritable(file_name_, write_only,
|
|
|
b48d46 |
+ truncate, append)->fd();
|
|
|
b48d46 |
is_open_ = true;
|
|
|
b48d46 |
mode_ = write_only ? FileMode::WRITE : FileMode::READWRITE;
|
|
|
b48d46 |
|
|
|
b48d46 |
@@ -229,7 +229,7 @@
|
|
|
b48d46 |
Status OpenReadable(const std::string& path) override {
|
|
|
b48d46 |
RETURN_NOT_OK(SetFileName(path));
|
|
|
b48d46 |
|
|
|
b48d46 |
- ARROW_ASSIGN_OR_RAISE(fd_, ::arrow::internal::FileOpenReadable(file_name_));
|
|
|
b48d46 |
+ fd_ = ::arrow::internal::FileOpenReadable(file_name_)->fd();
|
|
|
b48d46 |
ARROW_ASSIGN_OR_RAISE(size_, ::arrow::internal::FileGetSize(fd_));
|
|
|
b48d46 |
|
|
|
b48d46 |
is_open_ = true;
|
|
|
b48d46 |
@@ -970,7 +970,7 @@
|
|
|
b48d46 |
CryptoContext ctx(col->has_dictionary_page(), row_group_ordinal_,
|
|
|
b48d46 |
static_cast<int16_t>(i), meta_decryptor, data_decryptor);
|
|
|
b48d46 |
return PageReader::Open(stream, col->num_values(), col->compression(),
|
|
|
b48d46 |
- properties_.memory_pool(), &ctx;;
|
|
|
b48d46 |
+ false, properties_.memory_pool(), &ctx;;
|
|
|
b48d46 |
}
|
|
|
b48d46 |
|
|
|
b48d46 |
// The column is encrypted with its own key
|
|
|
b48d46 |
@@ -985,7 +985,7 @@
|
|
|
b48d46 |
CryptoContext ctx(col->has_dictionary_page(), row_group_ordinal_,
|
|
|
b48d46 |
static_cast<int16_t>(i), meta_decryptor, data_decryptor);
|
|
|
b48d46 |
return PageReader::Open(stream, col->num_values(), col->compression(),
|
|
|
b48d46 |
- properties_.memory_pool(), &ctx;;
|
|
|
b48d46 |
+ false, properties_.memory_pool(), &ctx;;
|
|
|
b48d46 |
}
|
|
|
b48d46 |
|
|
|
b48d46 |
private:
|