SP1 - Details for Query 7699

Submitted Time: 2026/10/27 21:26:05
Duration: 0.8 s
Succeeded Jobs: 11201 11202 11203 11204 11205 11206 11207 11208 11209 11210 11211 11212

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: 25 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 25 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: 44 ms"; 9 [labelType="html" label="Sort sort time: 2 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: 36 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: 39 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: 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: 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: 47 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: 120 ms"; 24 [labelType="html" label="Sort sort time: 3 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: 35 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: 148 ms"; 31 [labelType="html" label="Sort sort time: 7 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, 1 ms, 2 ms (stage 22545.0: task 28212)) 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 22545.0: task 28210)) 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 22545.0: task 28210))"]; subgraph cluster34 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n209 ms (25 ms, 75 ms, 109 ms (stage 22545.0: task 28211))"; 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: 49.3 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: 17 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: 118 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: 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: 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: 14 ms"; 52 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 7 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: 1.2 s"; 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: 8 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: 6 ms"; 64 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 3 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: 3 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: 33.9 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: 8 ms"; 74 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 2 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)) 14 ms (1 ms, 2 ms, 2 ms (stage 22549.0: task 28220)) 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 22549.0: task 28217)) 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 22549.0: task 28220))"]; subgraph cluster77 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n101 ms (12 ms, 17 ms, 21 ms (stage 22549.0: task 28216))"; 78 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 61 ms (7 ms, 10 ms, 13 ms (stage 22549.0: task 28220)) peak memory total (min, med, max (stageId: taskId)) 1536.0 KiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 22549.0: task 28217)) 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)) 45 ms (5 ms, 8 ms, 10 ms (stage 22549.0: task 28216)) 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=1088407]

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

Project

SortMergeJoin [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427], [SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#1966593], LeftOuter

WholeStageCodegen (19)

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

WholeStageCodegen (17)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427, 10), ENSURE_REQUIREMENTS, [plan_id=1088329]

Project [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]

SortMergeJoin [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441], [SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#1966470], LeftOuter

WholeStageCodegen (16)

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

WholeStageCodegen (14)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, 10), ENSURE_REQUIREMENTS, [plan_id=1088184]

Project [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427 AS COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]

Project [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]

SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298], [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1961578], FullOuter

WholeStageCodegen (13)

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

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087874]

Project [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]

SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298], [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1961467], FullOuter

WholeStageCodegen (8)

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

WholeStageCodegen (6)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087603]

Project [NO_ADMIN#1955793 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, str_remove_space(NO_ADMIN#1955793, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]

WholeStageCodegen (1)

FileScan csv [NO_ADMIN#1955793] 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#1961467 ASC NULLS FIRST], false, 0

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

WholeStageCodegen (7)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1958369, 10), ENSURE_REQUIREMENTS, [plan_id=1087616]

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

Project [str_remove_space(str_extract_middle(_c0#1958256, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1958369]

WholeStageCodegen (2)

FileScan csv [_c0#1958256] 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#1961578 ASC NULLS FIRST], false, 0

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

WholeStageCodegen (12)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1957522, 10), ENSURE_REQUIREMENTS, [plan_id=1087636]

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

Project [str_remove_space(str_extract_middle(_c0#1957375, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1957522]

WholeStageCodegen (3)

FileScan csv [_c0#1957375] 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#1966470 ASC NULLS FIRST], false, 0

WholeStageCodegen (15)

AQEShuffleRead coalesced

Exchange hashpartitioning(SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#1966470, 10), ENSURE_REQUIREMENTS, [plan_id=1087909]

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

WholeStageCodegen (9)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#1963872, 10), ENSURE_REQUIREMENTS, [plan_id=1087664]

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

Project [N%C2%B0+SEJOUR#1962326 AS COL_F9F96C8E_88C5_4F50_8E38_8609DC933CEA#1963872]

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

ColumnarToRow

WholeStageCodegen (4)

FileScan parquet [N%C2%B0+SEJOUR#1962326] Batched: true, DataFilters: [isnotnull(N%C2%B0+SEJOUR#1962326), isnotnull(str_remove_space(N%C2%B0+SEJOUR#1962326, 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#1966593 ASC NULLS FIRST], false, 0

WholeStageCodegen (18)

AQEShuffleRead coalesced

Exchange hashpartitioning(SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#1966593, 10), ENSURE_REQUIREMENTS, [plan_id=1088082]

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

WholeStageCodegen (10)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_38C3BE50_A7EE_41B8_BB22_8A6D1B6C1A8A#1966115, 10), ENSURE_REQUIREMENTS, [plan_id=1087695]

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

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

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

ColumnarToRow

WholeStageCodegen (5)

FileScan parquet [N%C2%B0+s%C3%A9jour#1965170] Batched: true, DataFilters: [isnotnull(str_complete(N%C2%B0+s%C3%A9jour#1965170, 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#1955793]
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#1955793 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, str_remove_space(NO_ADMIN#1955793, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Input [1]: [NO_ADMIN#1955793]

(3) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087603]

(4) ShuffleQueryStage
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: 0

(5) AQEShuffleRead
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: coalesced

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

(7) Scan csv 
Output [1]: [_c0#1958256]
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#1958256, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1958369]
Input [1]: [_c0#1958256]

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

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

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

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

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

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

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

(16) Project [codegen id : 8]
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1961467]

(17) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087874]

(18) ShuffleQueryStage
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: 5

(19) AQEShuffleRead
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: coalesced

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

(21) Scan csv 
Output [1]: [_c0#1957375]
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#1957375, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1957522]
Input [1]: [_c0#1957375]

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

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

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

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

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

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

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

(30) Project [codegen id : 13]
Output [1]: [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1961578]

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

(32) Exchange
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Arguments: hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, 10), ENSURE_REQUIREMENTS, [plan_id=1088184]

(33) ShuffleQueryStage
Output [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Arguments: 8

(34) AQEShuffleRead
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Arguments: coalesced

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

(36) Scan parquet 
Output [1]: [N%C2%B0+SEJOUR#1962326]
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#1962326]

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

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

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

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

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

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

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

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

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

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

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

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

(50) Project [codegen id : 16]
Output [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Input [3]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427, SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#1966470]

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

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

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

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

(55) Scan parquet 
Output [1]: [N%C2%B0+s%C3%A9jour#1965170]
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#1965170]

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

(73) HashAggregate [codegen id : 20]
Input [1]: [count#1966788L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#1966750L]
Results [1]: [count(1)#1966750L AS count#1966751L]

(74) Project
Output [2]: [NO_ADMIN#1955793 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, str_remove_space(NO_ADMIN#1955793, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Input [1]: [NO_ADMIN#1955793]

(75) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087466]

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

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

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

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

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

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

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

(83) Project
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1961467]

(84) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 10), ENSURE_REQUIREMENTS, [plan_id=1087475]

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

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

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

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

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

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

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

(92) Project
Output [1]: [str_remove_space(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, ALL) AS COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1959685, COL_7948E047_29EE_472A_BFFC_723098878DAD#1961298, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1961578]

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

(94) Exchange
Input [2]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Arguments: hashpartitioning(COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, 10), ENSURE_REQUIREMENTS, [plan_id=1087487]

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

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

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

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

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

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

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

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

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

(104) Project
Output [1]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427]
Input [3]: [COL_08BB1328_B413_455F_B93A_BA75BC9D58C2#1966441, COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427, SYNTHESE_MO_237830_COL_946985B2_1317_4E0F_8860_BCC73CE1B319#1966470]

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

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

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

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

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

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

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

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

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

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

(115) Project
Output: []
Input [2]: [COL_EEED4DDE_3E30_4DD6_9226_2EB2D5C004D0#1966427, SYNTHESE_DMI_237847_COL_3EFE5338_508A_40B8_A657_9886B74C9033#1966593]

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

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

(118) HashAggregate
Input [1]: [count#1966788L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#1966750L]
Results [1]: [count(1)#1966750L AS count#1966751L]

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

SQL / DataFrame Properties

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