SP1 - Details for Query 7845

Submitted Time: 2026/10/27 21:49:57
Duration: 0.9 s
Succeeded Jobs: 11355 11356 11357 11358 11359 11360 11361 11363 11364 11365 11366 11367

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster1 { isCluster="true"; label="WholeStageCodegen (20)\n \nduration: 0 ms"; 2 [labelType="html" label="HashAggregate time in aggregation build: 0 ms number of output rows: 1"]; } 3 [labelType="html" label="Exchange shuffle records written: 1 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 59.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 16.0 B local merged bytes read: 0.0 B number of partitions: 1 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 59.0 B"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (19)\n \nduration: 27 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 27 ms peak memory: 0.0 B number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 6 [labelType="html" label=" Project "]; 7 [labelType="html" label="SortMergeJoin number of output rows: 21,131 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (17)\n \nduration: 46 ms"; 9 [labelType="html" label="Sort sort time: 3 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 148.0 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 21,131 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 21,131 local bytes read: 141.2 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 660.2 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 141.2 KiB"]; subgraph cluster12 { isCluster="true"; label="WholeStageCodegen (16)\n \nduration: 27 ms"; 13 [labelType="html" label=" Project "]; 14 [labelType="html" label="SortMergeJoin number of output rows: 21,131 spill size: 0.0 B"]; } subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (14)\n \nduration: 30 ms"; 16 [labelType="html" label="Sort sort time: 3 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 17 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 257.5 KiB number of coalesced partitions: 1"]; 18 [labelType="html" label="Exchange shuffle records written: 21,131 local merged chunks fetched: 0 shuffle write time: 2 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 21,131 local bytes read: 241.3 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 1155.3 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 241.3 KiB"]; subgraph cluster19 { isCluster="true"; label="WholeStageCodegen (13)\n \nduration: 58 ms"; 20 [labelType="html" label=" Project "]; 21 [labelType="html" label=" Project "]; 22 [labelType="html" label="SortMergeJoin number of output rows: 21,131 spill size: 0.0 B"]; } subgraph cluster23 { isCluster="true"; label="WholeStageCodegen (11)\n \nduration: 142 ms"; 24 [labelType="html" label="Sort sort time: 2 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 25 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 345.9 KiB number of coalesced partitions: 1"]; 26 [labelType="html" label="Exchange shuffle records written: 21,127 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 21,127 local bytes read: 334.2 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 1320.2 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 334.2 KiB"]; subgraph cluster27 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 38 ms"; 28 [labelType="html" label=" Project "]; 29 [labelType="html" label="SortMergeJoin number of output rows: 21,127 spill size: 0.0 B"]; } subgraph cluster30 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 152 ms"; 31 [labelType="html" label="Sort sort time: 8 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 32 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 449.6 KiB number of coalesced partitions: 1"]; 33 [labelType="html" label="Exchange shuffle records written: 21,121 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 6 ms (1 ms, 2 ms, 2 ms (stage 22951.0: task 28432)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 21,121 local bytes read: 424.2 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 3 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 1320.1 KiB (41.4 KiB, 639.3 KiB, 639.3 KiB (stage 22951.0: task 28430)) local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 424.2 KiB (14.7 KiB, 203.1 KiB, 206.5 KiB (stage 22951.0: task 28430))"]; subgraph cluster34 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n211 ms (18 ms, 87 ms, 106 ms (stage 22951.0: task 28431))"; 35 [labelType="html" label=" Project "]; } 36 [labelType="html" label="Scan csv number of output rows: 21,121 number of files read: 1 metadata time: 0 ms size of files read: 8.3 MiB"]; subgraph cluster37 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 52.8 s"; 38 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; 39 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 256.0 KiB number of output rows: 445 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 40 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 5.0 KiB number of coalesced partitions: 1"]; 41 [labelType="html" label="Exchange shuffle records written: 445 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 445 local bytes read: 4.8 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 13.9 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 4.8 KiB"]; subgraph cluster42 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 14 ms"; 43 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 8 ms peak memory: 256.0 KiB number of output rows: 445 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 44 [labelType="html" label=" Project "]; } 45 [labelType="html" label="Scan csv number of output rows: 1,216 number of files read: 1 metadata time: 0 ms size of files read: 111.6 KiB"]; subgraph cluster46 { isCluster="true"; label="WholeStageCodegen (12)\n \nduration: 140 ms"; 47 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; 48 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 256.0 KiB number of output rows: 464 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 49 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 5.2 KiB number of coalesced partitions: 1"]; 50 [labelType="html" label="Exchange shuffle records written: 464 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 464 local bytes read: 5.0 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 14.5 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 5.0 KiB"]; subgraph cluster51 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 8 ms"; 52 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 5 ms peak memory: 256.0 KiB number of output rows: 464 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 53 [labelType="html" label=" Project "]; } 54 [labelType="html" label="Scan csv number of output rows: 486 number of files read: 1 metadata time: 0 ms size of files read: 50.8 KiB"]; subgraph cluster55 { isCluster="true"; label="WholeStageCodegen (15)\n \nduration: 924 ms"; 56 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 57 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 3.6 KiB number of coalesced partitions: 1"]; 58 [labelType="html" label="Exchange shuffle records written: 268 local merged chunks fetched: 0 shuffle write time: 2 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 268 local bytes read: 3.5 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 8.4 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 3.5 KiB"]; subgraph cluster59 { isCluster="true"; label="WholeStageCodegen (9)\n \nduration: 7 ms"; 60 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 1 ms peak memory: 256.0 KiB number of output rows: 268 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 61 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 3.7 KiB number of coalesced partitions: 1"]; 62 [labelType="html" label="Exchange shuffle records written: 268 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 268 local bytes read: 3.5 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 8.4 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 3.5 KiB"]; subgraph cluster63 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 5 ms"; 64 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 2 ms peak memory: 256.0 KiB number of output rows: 268 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 65 [labelType="html" label=" Project "]; 66 [labelType="html" label="Filter number of output rows: 283"]; 67 [labelType="html" label="ColumnarToRow number of output rows: 295 number of input batches: 1"]; } 68 [labelType="html" label="Scan parquet number of files read: 1 scan time: 2 ms metadata time: 0 ms size of files read: 16.7 KiB number of output rows: 295"]; subgraph cluster69 { isCluster="true"; label="WholeStageCodegen (18)\n \nduration: 35.8 s"; 70 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 71 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 5.1 KiB number of coalesced partitions: 1"]; 72 [labelType="html" label="Exchange shuffle records written: 440 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 440 local bytes read: 4.9 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 13.7 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 4.9 KiB"]; subgraph cluster73 { isCluster="true"; label="WholeStageCodegen (10)\n \nduration: 7 ms"; 74 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 1 ms peak memory: 256.0 KiB number of output rows: 440 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 75 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 8.2 KiB number of coalesced partitions: 1"]; 76 [labelType="html" label="Exchange shuffle records written: 447 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 17 ms (1 ms, 3 ms, 3 ms (stage 22955.0: task 28438)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 447 local bytes read: 7.8 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 6 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 17.5 KiB (2.4 KiB, 3.0 KiB, 3.0 KiB (stage 22955.0: task 28440)) local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 7.8 KiB (1229.0 B, 1351.0 B, 1390.0 B (stage 22955.0: task 28440))"]; subgraph cluster77 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n109 ms (11 ms, 19 ms, 23 ms (stage 22955.0: task 28437))"; 78 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 67 ms (5 ms, 12 ms, 15 ms (stage 22955.0: task 28437)) peak memory total (min, med, max (stageId: taskId)) 1536.0 KiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 22955.0: task 28440)) number of output rows: 447 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 79 [labelType="html" label=" Project "]; 80 [labelType="html" label="Filter number of output rows: 1,189"]; 81 [labelType="html" label="ColumnarToRow number of output rows: 1,201 number of input batches: 12"]; } 82 [labelType="html" label="Scan parquet number of files read: 12 scan time total (min, med, max (stageId: taskId)) 50 ms (3 ms, 9 ms, 12 ms (stage 22955.0: task 28437)) metadata time: 0 ms size of files read: 175.2 KiB number of output rows: 1,201"]; 2->0; 3->2; 5->3; 6->5; 7->6; 9->7; 10->9; 11->10; 13->11; 14->13; 16->14; 17->16; 18->17; 20->18; 21->20; 22->21; 24->22; 25->24; 26->25; 28->26; 29->28; 31->29; 32->31; 33->32; 35->33; 36->35; 38->29; 39->38; 40->39; 41->40; 43->41; 44->43; 45->44; 47->22; 48->47; 49->48; 50->49; 52->50; 53->52; 54->53; 56->14; 57->56; 58->57; 60->58; 61->60; 62->61; 64->62; 65->64; 66->65; 67->66; 68->67; 70->7; 71->70; 72->71; 74->72; 75->74; 76->75; 78->76; 79->78; 80->79; 81->80; 82->81; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[], functions=[count(1)])

WholeStageCodegen (20)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1102592]

HashAggregate(keys=[], functions=[partial_count(1)])

Project

SortMergeJoin [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379], [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545], LeftOuter

WholeStageCodegen (19)

Sort [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 ASC NULLS FIRST], false, 0

WholeStageCodegen (17)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, 10), ENSURE_REQUIREMENTS, [plan_id=1102514]

Project [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]

SortMergeJoin [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393], [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422], LeftOuter

WholeStageCodegen (16)

Sort [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393 ASC NULLS FIRST], false, 0

WholeStageCodegen (14)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, 10), ENSURE_REQUIREMENTS, [plan_id=1102363]

Project [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 AS COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]

Project [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]

SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405], [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530], FullOuter

WholeStageCodegen (13)

Sort [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1102053]

Project [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]

SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405], [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419], FullOuter

WholeStageCodegen (8)

Sort [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

WholeStageCodegen (6)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1101788]

Project [NO_ADMIN#2016745 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, str_remove_space(NO_ADMIN#2016745, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]

WholeStageCodegen (1)

FileScan csv [NO_ADMIN#2016745] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/VISUALVALOSEJOU_237544/420780652.2025.1..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<NO_ADMIN:string>

Sort [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419 ASC NULLS FIRST], false, 0

HashAggregate(keys=[COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881], functions=[])

WholeStageCodegen (7)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881, 10), ENSURE_REQUIREMENTS, [plan_id=1101801]

HashAggregate(keys=[COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881], functions=[])

Project [str_remove_space(str_extract_middle(_c0#2020776, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]

WholeStageCodegen (2)

FileScan csv [_c0#2020776] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/DMI_M12_2025_237543/DMI-M12-2025 - BIS...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<_c0:string>

Sort [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530 ASC NULLS FIRST], false, 0

HashAggregate(keys=[COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123], functions=[])

WholeStageCodegen (12)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123, 10), ENSURE_REQUIREMENTS, [plan_id=1101821]

HashAggregate(keys=[COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123], functions=[])

Project [str_remove_space(str_extract_middle(_c0#2019004, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]

WholeStageCodegen (3)

FileScan csv [_c0#2019004] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/MOLECULES_ONERE_237545/MO-M12-2025.txt], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<_c0:string>

Sort [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422 ASC NULLS FIRST], false, 0

WholeStageCodegen (15)

AQEShuffleRead coalesced

Exchange hashpartitioning(SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422, 10), ENSURE_REQUIREMENTS, [plan_id=1102088]

HashAggregate(keys=[COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290], functions=[])

WholeStageCodegen (9)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290, 10), ENSURE_REQUIREMENTS, [plan_id=1101849]

HashAggregate(keys=[COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290], functions=[])

Project [N%C2%B0+SEJOUR#2023437 AS COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]

Filter (isnotnull(N%C2%B0+SEJOUR#2023437) AND isnotnull(str_remove_space(N%C2%B0+SEJOUR#2023437, ALL)))

ColumnarToRow

WholeStageCodegen (4)

FileScan parquet [N%C2%B0+SEJOUR#2023437] Batched: true, DataFilters: [isnotnull(N%C2%B0+SEJOUR#2023437), isnotnull(str_remove_space(N%C2%B0+SEJOUR#2023437, ALL))], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/SYNTHESE_MO_202_237812_bd57d7746602..., PartitionFilters: [], PushedFilters: [IsNotNull(`N%C2%B0+SEJOUR`)], ReadSchema: struct<N%C2%B0+SEJOUR:string>

Sort [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545 ASC NULLS FIRST], false, 0

WholeStageCodegen (18)

AQEShuffleRead coalesced

Exchange hashpartitioning(SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545, 10), ENSURE_REQUIREMENTS, [plan_id=1102261]

HashAggregate(keys=[COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067], functions=[])

WholeStageCodegen (10)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067, 10), ENSURE_REQUIREMENTS, [plan_id=1101880]

HashAggregate(keys=[COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067], functions=[])

Project [str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT) AS COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]

Filter (isnotnull(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)) AND isnotnull(bigint_to_str(str_to_bigint(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)))))

ColumnarToRow

WholeStageCodegen (5)

FileScan parquet [N%C2%B0+s%C3%A9jour#2026241] Batched: true, DataFilters: [isnotnull(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)), isnotnull(bigint_to_str(str_t..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/SYNTHESE_DMI_20_237789_b7c9fcd90987..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<N%C2%B0+s%C3%A9jour:string>

Details

== Physical Plan ==
AdaptiveSparkPlan (119)
+- == Final Plan ==
   * HashAggregate (73)
   +- ShuffleQueryStage (72), Statistics(sizeInBytes=16.0 B, rowCount=1)
      +- Exchange (71)
         +- * HashAggregate (70)
            +- * Project (69)
               +- * SortMergeJoin LeftOuter (68)
                  :- * Sort (54)
                  :  +- AQEShuffleRead (53)
                  :     +- ShuffleQueryStage (52), Statistics(sizeInBytes=660.2 KiB, rowCount=2.11E+4)
                  :        +- Exchange (51)
                  :           +- * Project (50)
                  :              +- * SortMergeJoin LeftOuter (49)
                  :                 :- * Sort (35)
                  :                 :  +- AQEShuffleRead (34)
                  :                 :     +- ShuffleQueryStage (33), Statistics(sizeInBytes=1155.3 KiB, rowCount=2.11E+4)
                  :                 :        +- Exchange (32)
                  :                 :           +- * Project (31)
                  :                 :              +- * Project (30)
                  :                 :                 +- * SortMergeJoin FullOuter (29)
                  :                 :                    :- * Sort (20)
                  :                 :                    :  +- AQEShuffleRead (19)
                  :                 :                    :     +- ShuffleQueryStage (18), Statistics(sizeInBytes=1320.2 KiB, rowCount=2.11E+4)
                  :                 :                    :        +- Exchange (17)
                  :                 :                    :           +- * Project (16)
                  :                 :                    :              +- * SortMergeJoin FullOuter (15)
                  :                 :                    :                 :- * Sort (6)
                  :                 :                    :                 :  +- AQEShuffleRead (5)
                  :                 :                    :                 :     +- ShuffleQueryStage (4), Statistics(sizeInBytes=1320.1 KiB, rowCount=2.11E+4)
                  :                 :                    :                 :        +- Exchange (3)
                  :                 :                    :                 :           +- * Project (2)
                  :                 :                    :                 :              +- Scan csv  (1)
                  :                 :                    :                 +- * Sort (14)
                  :                 :                    :                    +- * HashAggregate (13)
                  :                 :                    :                       +- AQEShuffleRead (12)
                  :                 :                    :                          +- ShuffleQueryStage (11), Statistics(sizeInBytes=13.9 KiB, rowCount=445)
                  :                 :                    :                             +- Exchange (10)
                  :                 :                    :                                +- * HashAggregate (9)
                  :                 :                    :                                   +- * Project (8)
                  :                 :                    :                                      +- Scan csv  (7)
                  :                 :                    +- * Sort (28)
                  :                 :                       +- * HashAggregate (27)
                  :                 :                          +- AQEShuffleRead (26)
                  :                 :                             +- ShuffleQueryStage (25), Statistics(sizeInBytes=14.5 KiB, rowCount=464)
                  :                 :                                +- Exchange (24)
                  :                 :                                   +- * HashAggregate (23)
                  :                 :                                      +- * Project (22)
                  :                 :                                         +- Scan csv  (21)
                  :                 +- * Sort (48)
                  :                    +- AQEShuffleRead (47)
                  :                       +- ShuffleQueryStage (46), Statistics(sizeInBytes=8.4 KiB, rowCount=268)
                  :                          +- Exchange (45)
                  :                             +- * HashAggregate (44)
                  :                                +- AQEShuffleRead (43)
                  :                                   +- ShuffleQueryStage (42), Statistics(sizeInBytes=8.4 KiB, rowCount=268)
                  :                                      +- Exchange (41)
                  :                                         +- * HashAggregate (40)
                  :                                            +- * Project (39)
                  :                                               +- * Filter (38)
                  :                                                  +- * ColumnarToRow (37)
                  :                                                     +- Scan parquet  (36)
                  +- * Sort (67)
                     +- AQEShuffleRead (66)
                        +- ShuffleQueryStage (65), Statistics(sizeInBytes=13.7 KiB, rowCount=440)
                           +- Exchange (64)
                              +- * HashAggregate (63)
                                 +- AQEShuffleRead (62)
                                    +- ShuffleQueryStage (61), Statistics(sizeInBytes=17.5 KiB, rowCount=447)
                                       +- Exchange (60)
                                          +- * HashAggregate (59)
                                             +- * Project (58)
                                                +- * Filter (57)
                                                   +- * ColumnarToRow (56)
                                                      +- Scan parquet  (55)
+- == Initial Plan ==
   HashAggregate (118)
   +- Exchange (117)
      +- HashAggregate (116)
         +- Project (115)
            +- SortMergeJoin LeftOuter (114)
               :- Sort (106)
               :  +- Exchange (105)
               :     +- Project (104)
               :        +- SortMergeJoin LeftOuter (103)
               :           :- Sort (95)
               :           :  +- Exchange (94)
               :           :     +- Project (93)
               :           :        +- Project (92)
               :           :           +- SortMergeJoin FullOuter (91)
               :           :              :- Sort (85)
               :           :              :  +- Exchange (84)
               :           :              :     +- Project (83)
               :           :              :        +- SortMergeJoin FullOuter (82)
               :           :              :           :- Sort (76)
               :           :              :           :  +- Exchange (75)
               :           :              :           :     +- Project (74)
               :           :              :           :        +- Scan csv  (1)
               :           :              :           +- Sort (81)
               :           :              :              +- HashAggregate (80)
               :           :              :                 +- Exchange (79)
               :           :              :                    +- HashAggregate (78)
               :           :              :                       +- Project (77)
               :           :              :                          +- Scan csv  (7)
               :           :              +- Sort (90)
               :           :                 +- HashAggregate (89)
               :           :                    +- Exchange (88)
               :           :                       +- HashAggregate (87)
               :           :                          +- Project (86)
               :           :                             +- Scan csv  (21)
               :           +- Sort (102)
               :              +- Exchange (101)
               :                 +- HashAggregate (100)
               :                    +- Exchange (99)
               :                       +- HashAggregate (98)
               :                          +- Project (97)
               :                             +- Filter (96)
               :                                +- Scan parquet  (36)
               +- Sort (113)
                  +- Exchange (112)
                     +- HashAggregate (111)
                        +- Exchange (110)
                           +- HashAggregate (109)
                              +- Project (108)
                                 +- Filter (107)
                                    +- Scan parquet  (55)


(1) Scan csv 
Output [1]: [NO_ADMIN#2016745]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/VISUALVALOSEJOU_237544/420780652.2025.12.MCO.VisualValoSejours.csv]
ReadSchema: struct<NO_ADMIN:string>

(2) Project [codegen id : 1]
Output [2]: [NO_ADMIN#2016745 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, str_remove_space(NO_ADMIN#2016745, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Input [1]: [NO_ADMIN#2016745]

(3) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1101788]

(4) ShuffleQueryStage
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: 0

(5) AQEShuffleRead
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: coalesced

(6) Sort [codegen id : 6]
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

(7) Scan csv 
Output [1]: [_c0#2020776]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/DMI_M12_2025_237543/DMI-M12-2025 - BIS.txt]
ReadSchema: struct<_c0:string>

(8) Project [codegen id : 2]
Output [1]: [str_remove_space(str_extract_middle(_c0#2020776, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Input [1]: [_c0#2020776]

(9) HashAggregate [codegen id : 2]
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]

(10) Exchange
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Arguments: hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881, 10), ENSURE_REQUIREMENTS, [plan_id=1101801]

(11) ShuffleQueryStage
Output [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Arguments: 1

(12) AQEShuffleRead
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Arguments: coalesced

(13) HashAggregate [codegen id : 7]
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881 AS 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]

(14) Sort [codegen id : 7]
Input [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]
Arguments: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419 ASC NULLS FIRST], false, 0

(15) SortMergeJoin [codegen id : 8]
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Right keys [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]
Join type: FullOuter
Join condition: None

(16) Project [codegen id : 8]
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]

(17) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1102053]

(18) ShuffleQueryStage
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: 5

(19) AQEShuffleRead
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: coalesced

(20) Sort [codegen id : 11]
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

(21) Scan csv 
Output [1]: [_c0#2019004]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/MOLECULES_ONERE_237545/MO-M12-2025.txt]
ReadSchema: struct<_c0:string>

(22) Project [codegen id : 3]
Output [1]: [str_remove_space(str_extract_middle(_c0#2019004, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Input [1]: [_c0#2019004]

(23) HashAggregate [codegen id : 3]
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]

(24) Exchange
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Arguments: hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123, 10), ENSURE_REQUIREMENTS, [plan_id=1101821]

(25) ShuffleQueryStage
Output [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Arguments: 2

(26) AQEShuffleRead
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Arguments: coalesced

(27) HashAggregate [codegen id : 12]
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123 AS 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]

(28) Sort [codegen id : 12]
Input [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]
Arguments: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530 ASC NULLS FIRST], false, 0

(29) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Right keys [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]
Join type: FullOuter
Join condition: None

(30) Project [codegen id : 13]
Output [1]: [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]

(31) Project [codegen id : 13]
Output [2]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 AS COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]

(32) Exchange
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, 10), ENSURE_REQUIREMENTS, [plan_id=1102363]

(33) ShuffleQueryStage
Output [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: 8

(34) AQEShuffleRead
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: coalesced

(35) Sort [codegen id : 14]
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393 ASC NULLS FIRST], false, 0

(36) Scan parquet 
Output [1]: [N%C2%B0+SEJOUR#2023437]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/SYNTHESE_MO_202_237812_bd57d77466024fccdf18ace5a6e64d03/synthèse-MO-2025.xlsx_6fa2b969a426becf7b2379293a107a75]
PushedFilters: [IsNotNull(`N%C2%B0+SEJOUR`)]
ReadSchema: struct<N%C2%B0+SEJOUR:string>

(37) ColumnarToRow [codegen id : 4]
Input [1]: [N%C2%B0+SEJOUR#2023437]

(38) Filter [codegen id : 4]
Input [1]: [N%C2%B0+SEJOUR#2023437]
Condition : (isnotnull(N%C2%B0+SEJOUR#2023437) AND isnotnull(str_remove_space(N%C2%B0+SEJOUR#2023437, ALL)))

(39) Project [codegen id : 4]
Output [1]: [N%C2%B0+SEJOUR#2023437 AS COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Input [1]: [N%C2%B0+SEJOUR#2023437]

(40) HashAggregate [codegen id : 4]
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Keys [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]

(41) Exchange
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Arguments: hashpartitioning(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290, 10), ENSURE_REQUIREMENTS, [plan_id=1101849]

(42) ShuffleQueryStage
Output [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Arguments: 3

(43) AQEShuffleRead
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Arguments: coalesced

(44) HashAggregate [codegen id : 9]
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Keys [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Functions: []
Aggregate Attributes: []
Results [1]: [str_remove_space(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290, ALL) AS SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]

(45) Exchange
Input [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: hashpartitioning(SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422, 10), ENSURE_REQUIREMENTS, [plan_id=1102088]

(46) ShuffleQueryStage
Output [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: 6

(47) AQEShuffleRead
Input [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: coalesced

(48) Sort [codegen id : 15]
Input [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422 ASC NULLS FIRST], false, 0

(49) SortMergeJoin [codegen id : 16]
Left keys [1]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393]
Right keys [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Join type: LeftOuter
Join condition: None

(50) Project [codegen id : 16]
Output [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [3]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]

(51) Exchange
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: hashpartitioning(COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, 10), ENSURE_REQUIREMENTS, [plan_id=1102514]

(52) ShuffleQueryStage
Output [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: 9

(53) AQEShuffleRead
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: coalesced

(54) Sort [codegen id : 17]
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 ASC NULLS FIRST], false, 0

(55) Scan parquet 
Output [1]: [N%C2%B0+s%C3%A9jour#2026241]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/SYNTHESE_DMI_20_237789_b7c9fcd90987f45e4002171a5d87dfdd/synthèse-DMI-2025.xls_41d136f5d26b76a99c371a1af7fc9e64]
ReadSchema: struct<N%C2%B0+s%C3%A9jour:string>

(56) ColumnarToRow [codegen id : 5]
Input [1]: [N%C2%B0+s%C3%A9jour#2026241]

(57) Filter [codegen id : 5]
Input [1]: [N%C2%B0+s%C3%A9jour#2026241]
Condition : (isnotnull(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)) AND isnotnull(bigint_to_str(str_to_bigint(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)))))

(58) Project [codegen id : 5]
Output [1]: [str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT) AS COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Input [1]: [N%C2%B0+s%C3%A9jour#2026241]

(59) HashAggregate [codegen id : 5]
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Keys [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]

(60) Exchange
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Arguments: hashpartitioning(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067, 10), ENSURE_REQUIREMENTS, [plan_id=1101880]

(61) ShuffleQueryStage
Output [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Arguments: 4

(62) AQEShuffleRead
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Arguments: coalesced

(63) HashAggregate [codegen id : 10]
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Keys [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Functions: []
Aggregate Attributes: []
Results [1]: [bigint_to_str(str_to_bigint(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067)) AS SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]

(64) Exchange
Input [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: hashpartitioning(SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545, 10), ENSURE_REQUIREMENTS, [plan_id=1102261]

(65) ShuffleQueryStage
Output [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: 7

(66) AQEShuffleRead
Input [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: coalesced

(67) Sort [codegen id : 18]
Input [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545 ASC NULLS FIRST], false, 0

(68) SortMergeJoin [codegen id : 19]
Left keys [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Right keys [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Join type: LeftOuter
Join condition: None

(69) Project [codegen id : 19]
Output: []
Input [2]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]

(70) HashAggregate [codegen id : 19]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#2028549L]
Results [1]: [count#2028550L]

(71) Exchange
Input [1]: [count#2028550L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1102592]

(72) ShuffleQueryStage
Output [1]: [count#2028550L]
Arguments: 10

(73) HashAggregate [codegen id : 20]
Input [1]: [count#2028550L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#2028546L]
Results [1]: [count(1)#2028546L AS count#2028547L]

(74) Project
Output [2]: [NO_ADMIN#2016745 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, str_remove_space(NO_ADMIN#2016745, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Input [1]: [NO_ADMIN#2016745]

(75) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1101651]

(76) Sort
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

(77) Project
Output [1]: [str_remove_space(str_extract_middle(_c0#2020776, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Input [1]: [_c0#2020776]

(78) HashAggregate
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]

(79) Exchange
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Arguments: hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881, 10), ENSURE_REQUIREMENTS, [plan_id=1101647]

(80) HashAggregate
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#2020881 AS 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]

(81) Sort
Input [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]
Arguments: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419 ASC NULLS FIRST], false, 0

(82) SortMergeJoin
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Right keys [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]
Join type: FullOuter
Join condition: None

(83) Project
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#2022419]

(84) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 10), ENSURE_REQUIREMENTS, [plan_id=1101660]

(85) Sort
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405 ASC NULLS FIRST], false, 0

(86) Project
Output [1]: [str_remove_space(str_extract_middle(_c0#2019004, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Input [1]: [_c0#2019004]

(87) HashAggregate
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]

(88) Exchange
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Arguments: hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123, 10), ENSURE_REQUIREMENTS, [plan_id=1101656]

(89) HashAggregate
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#2019123 AS 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]

(90) Sort
Input [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]
Arguments: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530 ASC NULLS FIRST], false, 0

(91) SortMergeJoin
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405]
Right keys [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]
Join type: FullOuter
Join condition: None

(92) Project
Output [1]: [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#2021878, COL_7948E047_29EE_472A_BFFC_723098878DAD#2022405, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#2022530]

(93) Project
Output [2]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 AS COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]

(94) Exchange
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, 10), ENSURE_REQUIREMENTS, [plan_id=1101672]

(95) Sort
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393 ASC NULLS FIRST], false, 0

(96) Filter
Input [1]: [N%C2%B0+SEJOUR#2023437]
Condition : (isnotnull(N%C2%B0+SEJOUR#2023437) AND isnotnull(str_remove_space(N%C2%B0+SEJOUR#2023437, ALL)))

(97) Project
Output [1]: [N%C2%B0+SEJOUR#2023437 AS COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Input [1]: [N%C2%B0+SEJOUR#2023437]

(98) HashAggregate
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Keys [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]

(99) Exchange
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Arguments: hashpartitioning(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290, 10), ENSURE_REQUIREMENTS, [plan_id=1101666]

(100) HashAggregate
Input [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Keys [1]: [COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290]
Functions: []
Aggregate Attributes: []
Results [1]: [str_remove_space(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#2025290, ALL) AS SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]

(101) Exchange
Input [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: hashpartitioning(SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422, 10), ENSURE_REQUIREMENTS, [plan_id=1101673]

(102) Sort
Input [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Arguments: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422 ASC NULLS FIRST], false, 0

(103) SortMergeJoin
Left keys [1]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393]
Right keys [1]: [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]
Join type: LeftOuter
Join condition: None

(104) Project
Output [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Input [3]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#2027393, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#2027422]

(105) Exchange
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: hashpartitioning(COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, 10), ENSURE_REQUIREMENTS, [plan_id=1101684]

(106) Sort
Input [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Arguments: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379 ASC NULLS FIRST], false, 0

(107) Filter
Input [1]: [N%C2%B0+s%C3%A9jour#2026241]
Condition : (isnotnull(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)) AND isnotnull(bigint_to_str(str_to_bigint(str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT)))))

(108) Project
Output [1]: [str_complete(N%C2%B0+s%C3%A9jour#2026241, 0, 20, LEFT) AS COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Input [1]: [N%C2%B0+s%C3%A9jour#2026241]

(109) HashAggregate
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Keys [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]

(110) Exchange
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Arguments: hashpartitioning(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067, 10), ENSURE_REQUIREMENTS, [plan_id=1101678]

(111) HashAggregate
Input [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Keys [1]: [COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067]
Functions: []
Aggregate Attributes: []
Results [1]: [bigint_to_str(str_to_bigint(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#2027067)) AS SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]

(112) Exchange
Input [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: hashpartitioning(SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545, 10), ENSURE_REQUIREMENTS, [plan_id=1101685]

(113) Sort
Input [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Arguments: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545 ASC NULLS FIRST], false, 0

(114) SortMergeJoin
Left keys [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379]
Right keys [1]: [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]
Join type: LeftOuter
Join condition: None

(115) Project
Output: []
Input [2]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#2027379, SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#2027545]

(116) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#2028549L]
Results [1]: [count#2028550L]

(117) Exchange
Input [1]: [count#2028550L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1101692]

(118) HashAggregate
Input [1]: [count#2028550L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#2028546L]
Results [1]: [count(1)#2028546L AS count#2028547L]

(119) AdaptiveSparkPlan
Output [1]: [count#2028547L]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

Name	Value
spark.sql.optimizer.nestedPredicatePushdown.supportedFileSources	parquet,orc,geoparquet