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 {
122
122
/// when evaluating the expression.
123
123
///
124
124
/// [`collect_columns`]: crate::utils::collect_columns
125
- #[ allow( dead_code) ] // Only used in tests for now
126
125
pub fn new (
127
126
children : Vec < Arc < dyn PhysicalExpr > > ,
128
127
inner : Arc < dyn PhysicalExpr > ,
@@ -191,7 +190,6 @@ impl DynamicFilterPhysicalExpr {
191
190
/// This should be called e.g.:
192
191
/// - When we've computed the probe side's hash table in a HashJoinExec
193
192
/// - 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
195
193
pub fn update ( & self , new_expr : Arc < dyn PhysicalExpr > ) -> Result < ( ) > {
196
194
let mut current = self . inner . write ( ) . map_err ( |_| {
197
195
datafusion_common:: DataFusionError :: Execution (
You can’t perform that action at this time.
0 commit comments