MCPcopy Create free account
hub / github.com/apache/arrow / DecryptPageIndex

Method DecryptPageIndex

cpp/src/parquet/encryption/test_encryption_util.cc:521–539  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

519}
520
521void FileDecryptor::DecryptPageIndex(
522 const std::string& file,
523 const std::shared_ptr<FileDecryptionProperties>& file_decryption_properties) {
524 std::string exception_msg;
525 parquet::ReaderProperties reader_properties = parquet::default_reader_properties();
526 if (file_decryption_properties) {
527 reader_properties.file_decryption_properties(file_decryption_properties);
528 }
529
530 std::shared_ptr<::arrow::io::RandomAccessFile> source;
531 PARQUET_ASSIGN_OR_THROW(
532 source, ::arrow::io::ReadableFile::Open(file, reader_properties.memory_pool()));
533
534 auto file_reader = parquet::ParquetFileReader::Open(source, reader_properties);
535 CheckPageIndex(file_reader.get(), file_decryption_properties);
536
537 ASSERT_NO_FATAL_FAILURE(file_reader->Close());
538 PARQUET_THROW_NOT_OK(source->Close());
539}
540
541template <typename DType, typename c_type = typename DType::c_type>
542void AssertColumnIndex(const std::shared_ptr<ColumnIndex>& column_index,

Callers

nothing calls this directly

Calls 4

memory_poolMethod · 0.45
getMethod · 0.45
CloseMethod · 0.45

Tested by

no test coverage detected