File tree Expand file tree Collapse file tree
datafusion/physical-expr/src/expressions Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -276,12 +276,6 @@ impl DynamicFilterPhysicalExpr {
276276 ///
277277 /// This method will return when [`Self::update`] is called and the generation increases.
278278 /// It does not guarantee that the filter is complete.
279- ///
280- /// # Note
281- ///
282- /// This method should only be called on filters that have consumers. If you don't
283- /// know whether the filter is being used, call [`Self::is_used`] first to avoid
284- /// waiting indefinitely.
285279 pub async fn wait_update ( & self ) {
286280 let mut rx = self . state_watch . subscribe ( ) ;
287281 // Get the current generation
@@ -298,12 +292,6 @@ impl DynamicFilterPhysicalExpr {
298292 ///
299293 /// Unlike [`Self::wait_update`], this method guarantees that when it returns,
300294 /// the filter is fully complete with no more updates expected.
301- ///
302- /// # Note
303- ///
304- /// This method should only be called on filters that have consumers. If you don't
305- /// know whether the filter is being used, call [`Self::is_used`] first to avoid
306- /// waiting indefinitely.
307295 pub async fn wait_complete ( & self ) {
308296 if self . inner . read ( ) . is_complete {
309297 return ;
You can’t perform that action at this time.
0 commit comments