SP1 - Details for Query 791

Submitted Time: 2026/02/24 09:34:32
Duration: 0.7 s
Succeeded Jobs: 1006 1009 1010 1013 1015

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

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; 1 [labelType="html" label="TakeOrderedAndProject shuffle records written: 0 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: 0 local bytes read: 0.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 0 remote merged chunks fetched: 0 remote blocks read: 0 local merged bytes read: 0.0 B remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 0.0 B"]; 2 [labelType="html" label="Window spill size: 0.0 B"]; subgraph cluster3 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 77 ms"; 4 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 5 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 3.0 KiB number of coalesced partitions: 1"]; 6 [labelType="html" label="Exchange shuffle records written: 86 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: 86 local bytes read: 2.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: 5.6 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: 2.9 KiB"]; subgraph cluster7 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 54 ms"; 8 [labelType="html" label=" Project "]; 9 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 3.2 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 86 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: 86 local bytes read: 3.1 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: 5.6 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.1 KiB"]; subgraph cluster12 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n13 ms (3 ms, 10 ms, 10 ms (stage 1312.0: task 1867))"; 13 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 2 ms (1 ms, 1 ms, 1 ms (stage 1312.0: task 1867)) peak memory total (min, med, max (stageId: taskId)) 32.5 MiB (16.3 MiB, 16.3 MiB, 16.3 MiB (stage 1312.0: task 1867)) number of output rows: 172 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 1312.0: task 1867))"]; } 14 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 17.5 KiB number of coalesced partitions: 1"]; 15 [labelType="html" label="Exchange shuffle records written: 370 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 24 ms (1 ms, 5 ms, 6 ms (stage 1307.0: task 1859)) 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: 740 local bytes read total (min, med, max (stageId: taskId)) 33.6 KiB (16.8 KiB, 16.8 KiB, 16.8 KiB (stage 1312.0: task 1867)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1312.0: task 1867)) remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 12 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 23.7 KiB (2.0 KiB, 4.4 KiB, 4.8 KiB (stage 1307.0: task 1856)) 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)) 16.8 KiB (1825.0 B, 3.0 KiB, 3.3 KiB (stage 1307.0: task 1856))"]; subgraph cluster16 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n450 ms (49 ms, 83 ms, 83 ms (stage 1307.0: task 1856))"; 17 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 381 ms (39 ms, 68 ms, 73 ms (stage 1307.0: task 1859)) peak memory total (min, med, max (stageId: taskId)) 97.5 MiB (16.3 MiB, 16.3 MiB, 16.3 MiB (stage 1307.0: task 1855)) number of output rows: 370 number of sort fallback tasks: 0 avg hash probes per key (min, med, max (stageId: taskId)): (1, 1, 1 (stage 1307.0: task 1855))"]; 18 [labelType="html" label=" Project "]; 19 [labelType="html" label="ColumnarToRow number of output rows: 79,304 number of input batches: 24"]; } 20 [labelType="html" label="Scan parquet number of files read: 12 scan time total (min, med, max (stageId: taskId)) 244 ms (25 ms, 40 ms, 60 ms (stage 1307.0: task 1857)) metadata time: 0 ms size of files read: 3.0 MiB number of output rows: 79,304"]; 1->0; 2->1; 4->2; 5->4; 6->5; 8->6; 9->8; 10->9; 11->10; 13->11; 14->13; 15->14; 17->15; 18->17; 19->18; 20->19; }

AdaptiveSparkPlan isFinalPlan=true

TakeOrderedAndProject(limit=500000, orderBy=[COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST], output=[COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108,COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L,COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107,COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L,COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233485])

Window [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107], [1 DESC NULLS LAST]

Sort [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 10), ENSURE_REQUIREMENTS, [plan_id=22044]

Project [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]

Sort [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST], true, 0

WholeStageCodegen (3)

AQEShuffleRead coalesced

Exchange rangepartitioning(COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST, 10), ENSURE_REQUIREMENTS, [plan_id=21945]

HashAggregate(keys=[COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911], functions=[count(1)])

WholeStageCodegen (2)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, 10), ENSURE_REQUIREMENTS, [plan_id=21784]

HashAggregate(keys=[COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911], functions=[partial_count(1)])

Project [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914]

ColumnarToRow

WholeStageCodegen (1)

FileScan parquet [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015,COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/RPU_FICHIER_FIC_253692], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<COL_F39B11B8_702A_4D04_905D_8CF5B339E153:string,COL_AEC76732_ACB3_4AC1_8391_5254B5238C36:s...

Details

== Physical Plan ==
AdaptiveSparkPlan (31)
+- == Final Plan ==
   TakeOrderedAndProject (19)
   +- Window (18)
      +- * Sort (17)
         +- AQEShuffleRead (16)
            +- ShuffleQueryStage (15), Statistics(sizeInBytes=5.6 KiB, rowCount=86)
               +- Exchange (14)
                  +- * Project (13)
                     +- * Sort (12)
                        +- AQEShuffleRead (11)
                           +- ShuffleQueryStage (10), Statistics(sizeInBytes=5.6 KiB, rowCount=86)
                              +- Exchange (9)
                                 +- * HashAggregate (8)
                                    +- AQEShuffleRead (7)
                                       +- ShuffleQueryStage (6), Statistics(sizeInBytes=23.7 KiB, rowCount=370)
                                          +- Exchange (5)
                                             +- * HashAggregate (4)
                                                +- * Project (3)
                                                   +- * ColumnarToRow (2)
                                                      +- Scan parquet  (1)
+- == Initial Plan ==
   TakeOrderedAndProject (30)
   +- Window (29)
      +- Sort (28)
         +- Exchange (27)
            +- Project (26)
               +- Sort (25)
                  +- Exchange (24)
                     +- HashAggregate (23)
                        +- Exchange (22)
                           +- HashAggregate (21)
                              +- Project (20)
                                 +- Scan parquet  (1)


(1) Scan parquet 
Output [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/RPU_FICHIER_FIC_253692]
ReadSchema: struct<COL_F39B11B8_702A_4D04_905D_8CF5B339E153:string,COL_AEC76732_ACB3_4AC1_8391_5254B5238C36:string>

(2) ColumnarToRow [codegen id : 1]
Input [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018]

(3) Project [codegen id : 1]
Output [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914]
Input [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018]

(4) HashAggregate [codegen id : 1]
Input [2]: [COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#233511L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]

(5) Exchange
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Arguments: hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, 10), ENSURE_REQUIREMENTS, [plan_id=21784]

(6) ShuffleQueryStage
Output [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Arguments: 0

(7) AQEShuffleRead
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Arguments: coalesced

(8) HashAggregate [codegen id : 2]
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#233237L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914 AS COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911 AS COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, count(1)#233237L AS COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]

(9) Exchange
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: rangepartitioning(COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST, 10), ENSURE_REQUIREMENTS, [plan_id=21945]

(10) ShuffleQueryStage
Output [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: 1

(11) AQEShuffleRead
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: coalesced

(12) Sort [codegen id : 3]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST], true, 0

(13) Project [codegen id : 3]
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]

(14) Exchange
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 10), ENSURE_REQUIREMENTS, [plan_id=22044]

(15) ShuffleQueryStage
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: 2

(16) AQEShuffleRead
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: coalesced

(17) Sort [codegen id : 4]
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

(18) Window
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107], [1 DESC NULLS LAST]

(19) TakeOrderedAndProject
Input [4]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L]
Arguments: 500000, [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST], [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L, dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L)), 100.0)), 2) AS COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233485]

(20) Project
Output [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914]
Input [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232015, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232018]

(21) HashAggregate
Input [2]: [COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#233511L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]

(22) Exchange
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Arguments: hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, 10), ENSURE_REQUIREMENTS, [plan_id=21719]

(23) HashAggregate
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911, count#233512L]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#233237L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#232914 AS COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#232911 AS COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, count(1)#233237L AS COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]

(24) Exchange
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: rangepartitioning(COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST, 10), ENSURE_REQUIREMENTS, [plan_id=21722]

(25) Sort
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]
Arguments: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108 ASC NULLS FIRST], true, 0

(26) Project
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L]

(27) Exchange
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 10), ENSURE_REQUIREMENTS, [plan_id=21726]

(28) Sort
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

(29) Window
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107]
Arguments: [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107], [1 DESC NULLS LAST]

(30) TakeOrderedAndProject
Input [4]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L]
Arguments: 500000, [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107 ASC NULLS FIRST], [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L, dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L)), 100.0)), 2) AS COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233485]

(31) AdaptiveSparkPlan
Output [5]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233108, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233239L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233107, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233411L, COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233485]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

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