Skip to content

Commit e58ae7c

Browse files
committed
Minor tidy ups and test fix
1 parent 07ad9dd commit e58ae7c

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

parquet/src/arrow/async_reader/mod.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -216,8 +216,7 @@ impl<T: AsyncRead + AsyncSeek + Unpin + Send> AsyncFileReader for T {
216216
let mut buf = Vec::with_capacity(metadata_len);
217217
self.take(metadata_len as _).read_to_end(&mut buf).await?;
218218

219-
let parquet_metadata_reader = ParquetMetaDataReader::decode_metadata(&buf)?;
220-
Ok(Arc::new(parquet_metadata_reader))
219+
Ok(Arc::new(ParquetMetaDataReader::decode_metadata(&buf)?))
221220
}
222221
.boxed()
223222
}

parquet/src/file/metadata/reader.rs

+5-3
Original file line numberDiff line numberDiff line change
@@ -679,8 +679,8 @@ impl ParquetMetaDataReader {
679679
/// file. The format of `buf` is the Thrift compact binary protocol, as specified
680680
/// by the [Parquet Spec].
681681
///
682-
/// This method handles using either decode_footer of
683-
/// decode_metadata_with_encryption depending on whether the encryption
682+
/// This method handles using either `decode_metadata` or
683+
/// `decode_metadata_with_encryption` depending on whether the encryption
684684
/// feature is enabled.
685685
///
686686
/// [Parquet Spec]: https://github.com/apache/parquet-format#metadata
@@ -698,7 +698,9 @@ impl ParquetMetaDataReader {
698698
#[cfg(not(feature = "encryption"))]
699699
let result = {
700700
if footer_tail.is_encrypted_footer() {
701-
Err(general_err!("Parquet error: Parquet file has an encrypted footer but the encryption feature is disabled"))
701+
Err(general_err!(
702+
"Parquet file has an encrypted footer but the encryption feature is disabled"
703+
))
702704
} else {
703705
Self::decode_metadata(buf)
704706
}

0 commit comments

Comments
 (0)