File tree Expand file tree Collapse file tree
datafusion/physical-plan/src/aggregates Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -244,7 +244,7 @@ impl OrderedPartialAggregateStream {
244244 /// Consumes one ordered input batch, then immediately emits completed groups
245245 /// if the ordering proves any group is ready.
246246 ///
247- /// See comments at `poll_next()` for details.
247+ /// See comments at [`Self::create_stream`] for details.
248248 async fn handle_reading_input (
249249 & mut self ,
250250 table : & mut OrderedAggregateTable < PartialMarker > ,
@@ -327,7 +327,7 @@ impl OrderedPartialAggregateStream {
327327 /// Returns the last batch to emit so we can free all the state and memory before emitting,
328328 /// and we won't need to hold while waiting for the next poll.
329329 ///
330- /// See comments at `poll_next()` for details.
330+ /// See comments at [`Self::create_stream`] for details.
331331 ///
332332 async fn handle_draining_final (
333333 & mut self ,
You can’t perform that action at this time.
0 commit comments