File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed
datafusion/physical-expr/src/expressions Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -122,7 +122,6 @@ impl DynamicFilterPhysicalExpr {
122122 /// when evaluating the expression.
123123 ///
124124 /// [`collect_columns`]: crate::utils::collect_columns
125- #[ allow( dead_code) ] // Only used in tests for now
126125 pub fn new (
127126 children : Vec < Arc < dyn PhysicalExpr > > ,
128127 inner : Arc < dyn PhysicalExpr > ,
@@ -191,7 +190,6 @@ impl DynamicFilterPhysicalExpr {
191190 /// This should be called e.g.:
192191 /// - When we've computed the probe side's hash table in a HashJoinExec
193192 /// - After every batch is processed if we update the TopK heap in a SortExec using a TopK approach.
194- #[ allow( dead_code) ] // Only used in tests for now
195193 pub fn update ( & self , new_expr : Arc < dyn PhysicalExpr > ) -> Result < ( ) > {
196194 let mut current = self . inner . write ( ) . map_err ( |_| {
197195 datafusion_common:: DataFusionError :: Execution (
You can’t perform that action at this time.
0 commit comments