Skip to content

Commit 88ad15f

Browse files
committed
Fix parquet rustdoc links
1 parent bb417e1 commit 88ad15f

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

datafusion/datasource-parquet/src/opener.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ pub(super) struct ParquetMorselizer {
104104
/// Factory for instantiating parquet reader
105105
pub parquet_file_reader_factory: Arc<dyn ParquetFileReaderFactory>,
106106
/// Should the filters be evaluated during the parquet scan using
107-
/// [`DataFusionArrowPredicate`](row_filter::DatafusionArrowPredicate)?
107+
/// [`DatafusionArrowPredicate`](crate::row_filter::DatafusionArrowPredicate)?
108108
pub pushdown_filters: bool,
109109
/// Should the filters be reordered to optimize the scan?
110110
pub reorder_filters: bool,

datafusion/datasource-parquet/src/push_decoder.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ pub(crate) struct PushDecoderStreamState {
123123
}
124124

125125
impl PushDecoderStreamState {
126-
/// Drive the state machine to completion as a [`Stream`] of record batches.
126+
/// Drive the state machine to completion as a [`futures::Stream`] of record batches.
127127
///
128128
/// The returned stream is fused and boxed so the caller can wrap it (for
129129
/// example, with an early-stopping adapter) without naming the unfold type.

0 commit comments

Comments
 (0)