@@ -209,12 +209,12 @@ impl ExecutorExt for BoxedExecutor {
209
209
210
210
impl PlanVisitor < BoxedExecutor > for ExecutorBuilder {
211
211
fn visit_dummy ( & mut self , _plan : & Dummy , root : & Span ) -> Option < BoxedExecutor > {
212
- let _child_span = Span :: enter_with_parent ( "DummyScanExecutor" , & root) ;
212
+ let _child_span = Span :: enter_with_parent ( "DummyScanExecutor" , root) ;
213
213
Some ( DummyScanExecutor . execute ( ) )
214
214
}
215
215
216
216
fn visit_internal ( & mut self , plan : & Internal , root : & Span ) -> Option < BoxedExecutor > {
217
- let _child_span = Span :: enter_with_parent ( "InternalTableExecutor" , & root) ;
217
+ let _child_span = Span :: enter_with_parent ( "InternalTableExecutor" , root) ;
218
218
Some (
219
219
InternalTableExecutor {
220
220
table_name : plan. table_name ( ) ,
@@ -228,7 +228,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
228
228
plan : & PhysicalCreateTable ,
229
229
root : & Span ,
230
230
) -> Option < BoxedExecutor > {
231
- let _child_span = Span :: enter_with_parent ( "CreateTableExecutor" , & root) ;
231
+ let _child_span = Span :: enter_with_parent ( "CreateTableExecutor" , root) ;
232
232
Some ( match & self . storage {
233
233
StorageImpl :: InMemoryStorage ( storage) => CreateTableExecutor {
234
234
plan : plan. clone ( ) ,
@@ -244,7 +244,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
244
244
}
245
245
246
246
fn visit_physical_drop ( & mut self , plan : & PhysicalDrop , root : & Span ) -> Option < BoxedExecutor > {
247
- let _child_span = Span :: enter_with_parent ( "DropExecutor" , & root) ;
247
+ let _child_span = Span :: enter_with_parent ( "DropExecutor" , root) ;
248
248
Some ( match & self . storage {
249
249
StorageImpl :: InMemoryStorage ( storage) => DropExecutor {
250
250
plan : plan. clone ( ) ,
@@ -264,7 +264,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
264
264
plan : & PhysicalInsert ,
265
265
root : & Span ,
266
266
) -> Option < BoxedExecutor > {
267
- let _child_span = Span :: enter_with_parent ( "InsertExecutor" , & root) ;
267
+ let _child_span = Span :: enter_with_parent ( "InsertExecutor" , root) ;
268
268
Some ( match & self . storage {
269
269
StorageImpl :: InMemoryStorage ( storage) => InsertExecutor {
270
270
context : self . context . clone ( ) ,
@@ -292,7 +292,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
292
292
plan : & PhysicalNestedLoopJoin ,
293
293
root : & Span ,
294
294
) -> Option < BoxedExecutor > {
295
- let _child_span = Span :: enter_with_parent ( "NestedLoopJoinExecutor" , & root) ;
295
+ let _child_span = Span :: enter_with_parent ( "NestedLoopJoinExecutor" , root) ;
296
296
let left_child = self . visit ( plan. left ( ) , & _child_span) . unwrap ( ) ;
297
297
let right_child = self . visit ( plan. right ( ) , & _child_span) . unwrap ( ) ;
298
298
Some (
@@ -313,7 +313,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
313
313
plan : & PhysicalTableScan ,
314
314
root : & Span ,
315
315
) -> Option < BoxedExecutor > {
316
- let _child_span = Span :: enter_with_parent ( "TableScanExecutor" , & root) ;
316
+ let _child_span = Span :: enter_with_parent ( "TableScanExecutor" , root) ;
317
317
Some ( match & self . storage {
318
318
StorageImpl :: InMemoryStorage ( storage) => TableScanExecutor {
319
319
context : self . context . clone ( ) ,
@@ -339,7 +339,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
339
339
plan : & PhysicalProjection ,
340
340
root : & Span ,
341
341
) -> Option < BoxedExecutor > {
342
- let _child_span = Span :: enter_with_parent ( "ProjectionExecutor" , & root) ;
342
+ let _child_span = Span :: enter_with_parent ( "ProjectionExecutor" , root) ;
343
343
Some (
344
344
ProjectionExecutor {
345
345
project_expressions : plan. logical ( ) . project_expressions ( ) . to_vec ( ) ,
@@ -354,7 +354,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
354
354
plan : & PhysicalFilter ,
355
355
root : & Span ,
356
356
) -> Option < BoxedExecutor > {
357
- let _child_span = Span :: enter_with_parent ( "FilterExecutor" , & root) ;
357
+ let _child_span = Span :: enter_with_parent ( "FilterExecutor" , root) ;
358
358
Some (
359
359
FilterExecutor {
360
360
expr : plan. logical ( ) . expr ( ) . clone ( ) ,
@@ -365,7 +365,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
365
365
}
366
366
367
367
fn visit_physical_order ( & mut self , plan : & PhysicalOrder , root : & Span ) -> Option < BoxedExecutor > {
368
- let _child_span = Span :: enter_with_parent ( "OrderExecutor" , & root) ;
368
+ let _child_span = Span :: enter_with_parent ( "OrderExecutor" , root) ;
369
369
Some (
370
370
OrderExecutor {
371
371
comparators : plan. logical ( ) . comparators ( ) . to_vec ( ) ,
@@ -376,7 +376,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
376
376
}
377
377
378
378
fn visit_physical_limit ( & mut self , plan : & PhysicalLimit , root : & Span ) -> Option < BoxedExecutor > {
379
- let _child_span = Span :: enter_with_parent ( "a child span" , & root) ;
379
+ let _child_span = Span :: enter_with_parent ( "a child span" , root) ;
380
380
Some (
381
381
LimitExecutor {
382
382
child : self . visit ( plan. child ( ) , & _child_span) . unwrap ( ) ,
@@ -388,7 +388,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
388
388
}
389
389
390
390
fn visit_physical_top_n ( & mut self , plan : & PhysicalTopN , root : & Span ) -> Option < BoxedExecutor > {
391
- let _child_span = Span :: enter_with_parent ( "TopNExecutor" , & root) ;
391
+ let _child_span = Span :: enter_with_parent ( "TopNExecutor" , root) ;
392
392
Some (
393
393
TopNExecutor {
394
394
child : self . visit ( plan. child ( ) , & _child_span) . unwrap ( ) ,
@@ -405,7 +405,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
405
405
plan : & PhysicalExplain ,
406
406
root : & Span ,
407
407
) -> Option < BoxedExecutor > {
408
- let _child_span = Span :: enter_with_parent ( "ExplainExecutor" , & root) ;
408
+ let _child_span = Span :: enter_with_parent ( "ExplainExecutor" , root) ;
409
409
Some ( ExplainExecutor { plan : plan. clone ( ) } . execute ( ) )
410
410
}
411
411
@@ -414,7 +414,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
414
414
plan : & PhysicalHashAgg ,
415
415
root : & Span ,
416
416
) -> Option < BoxedExecutor > {
417
- let _child_span = Span :: enter_with_parent ( "HashAggExecutor" , & root) ;
417
+ let _child_span = Span :: enter_with_parent ( "HashAggExecutor" , root) ;
418
418
Some (
419
419
HashAggExecutor {
420
420
agg_calls : plan. logical ( ) . agg_calls ( ) . to_vec ( ) ,
@@ -430,7 +430,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
430
430
plan : & PhysicalHashJoin ,
431
431
root : & Span ,
432
432
) -> Option < BoxedExecutor > {
433
- let _child_span = Span :: enter_with_parent ( "HashJoinExecutor" , & root) ;
433
+ let _child_span = Span :: enter_with_parent ( "HashJoinExecutor" , root) ;
434
434
let left_child = self . visit ( plan. left ( ) , & _child_span) . unwrap ( ) ;
435
435
let right_child = self . visit ( plan. right ( ) , & _child_span) . unwrap ( ) ;
436
436
@@ -462,7 +462,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
462
462
plan : & PhysicalSimpleAgg ,
463
463
root : & Span ,
464
464
) -> Option < BoxedExecutor > {
465
- let _child_span = Span :: enter_with_parent ( "SimpleAggExecutor" , & root) ;
465
+ let _child_span = Span :: enter_with_parent ( "SimpleAggExecutor" , root) ;
466
466
Some (
467
467
SimpleAggExecutor {
468
468
agg_calls : plan. agg_calls ( ) . to_vec ( ) ,
@@ -477,7 +477,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
477
477
plan : & PhysicalDelete ,
478
478
root : & Span ,
479
479
) -> Option < BoxedExecutor > {
480
- let _child_span = Span :: enter_with_parent ( "DeleteExecutor" , & root) ;
480
+ let _child_span = Span :: enter_with_parent ( "DeleteExecutor" , root) ;
481
481
let child = self . visit ( plan. child ( ) , & _child_span) . unwrap ( ) ;
482
482
Some ( match & self . storage {
483
483
StorageImpl :: InMemoryStorage ( storage) => DeleteExecutor {
@@ -504,7 +504,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
504
504
plan : & PhysicalValues ,
505
505
root : & Span ,
506
506
) -> Option < BoxedExecutor > {
507
- let _child_span = Span :: enter_with_parent ( "ValuesExecutor" , & root) ;
507
+ let _child_span = Span :: enter_with_parent ( "ValuesExecutor" , root) ;
508
508
Some (
509
509
ValuesExecutor {
510
510
column_types : plan. logical ( ) . column_types ( ) . to_vec ( ) ,
@@ -519,7 +519,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
519
519
plan : & PhysicalCopyFromFile ,
520
520
root : & Span ,
521
521
) -> Option < BoxedExecutor > {
522
- let _child_span = Span :: enter_with_parent ( "CopyFromFileExecutor" , & root) ;
522
+ let _child_span = Span :: enter_with_parent ( "CopyFromFileExecutor" , root) ;
523
523
Some (
524
524
CopyFromFileExecutor {
525
525
context : self . context . clone ( ) ,
@@ -535,7 +535,7 @@ impl PlanVisitor<BoxedExecutor> for ExecutorBuilder {
535
535
plan : & PhysicalCopyToFile ,
536
536
root : & Span ,
537
537
) -> Option < BoxedExecutor > {
538
- let _child_span = Span :: enter_with_parent ( "CopyToFileExecutor" , & root) ;
538
+ let _child_span = Span :: enter_with_parent ( "CopyToFileExecutor" , root) ;
539
539
Some (
540
540
CopyToFileExecutor {
541
541
context : self . context . clone ( ) ,
0 commit comments