SP1 - Details for Query 792

Submitted Time: 2026/02/24 09:34:32
Duration: 0.7 s
Succeeded Jobs: 1007 1008 1011 1012 1014

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: 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: 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))\n16 ms (3 ms, 13 ms, 13 ms (stage 1310.0: task 1866))"; 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 1310.0: task 1866)) peak memory total (min, med, max (stageId: taskId)) 32.5 MiB (16.3 MiB, 16.3 MiB, 16.3 MiB (stage 1310.0: task 1866)) 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 1310.0: task 1866))"]; } 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)) 16 ms (1 ms, 2 ms, 6 ms (stage 1308.0: task 1860)) 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 1310.0: task 1866)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 1310.0: task 1866)) 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 1308.0: task 1862)) 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 1308.0: task 1862))"]; subgraph cluster16 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n460 ms (50 ms, 83 ms, 88 ms (stage 1308.0: task 1863))"; 17 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 382 ms (38 ms, 69 ms, 74 ms (stage 1308.0: task 1863)) peak memory total (min, med, max (stageId: taskId)) 97.5 MiB (16.3 MiB, 16.3 MiB, 16.3 MiB (stage 1308.0: task 1861)) 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 1308.0: task 1861))"]; 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)) 248 ms (22 ms, 47 ms, 53 ms (stage 1308.0: task 1863)) 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#233309 ASC NULLS FIRST], output=[COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310,COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L,COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309,COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L,COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233505])

Window [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309], [1 DESC NULLS LAST]

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

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 10), ENSURE_REQUIREMENTS, [plan_id=22057]

Project [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]

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

WholeStageCodegen (3)

AQEShuffleRead coalesced

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

HashAggregate(keys=[COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169], functions=[count(1)])

WholeStageCodegen (2)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, 10), ENSURE_REQUIREMENTS, [plan_id=21840]

HashAggregate(keys=[COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169], functions=[partial_count(1)])

Project [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172]

ColumnarToRow

WholeStageCodegen (1)

FileScan parquet [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143,COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146] 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#232143, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146]
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#232143, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146]

(3) Project [codegen id : 1]
Output [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172]
Input [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146]

(4) HashAggregate [codegen id : 1]
Input [2]: [COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#233514L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]

(5) Exchange
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Arguments: hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, 10), ENSURE_REQUIREMENTS, [plan_id=21840]

(6) ShuffleQueryStage
Output [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Arguments: 0

(7) AQEShuffleRead
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Arguments: coalesced

(8) HashAggregate [codegen id : 2]
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#233378L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172 AS COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169 AS COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, count(1)#233378L AS COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]

(9) Exchange
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: rangepartitioning(COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310 ASC NULLS FIRST, 10), ENSURE_REQUIREMENTS, [plan_id=21946]

(10) ShuffleQueryStage
Output [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: 1

(11) AQEShuffleRead
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: coalesced

(12) Sort [codegen id : 3]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310 ASC NULLS FIRST], true, 0

(13) Project [codegen id : 3]
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]

(14) Exchange
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 10), ENSURE_REQUIREMENTS, [plan_id=22057]

(15) ShuffleQueryStage
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: 2

(16) AQEShuffleRead
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: coalesced

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

(18) Window
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309], [1 DESC NULLS LAST]

(19) TakeOrderedAndProject
Input [4]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L]
Arguments: 500000, [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309 ASC NULLS FIRST], [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L, dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L)), 100.0)), 2) AS COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233505]

(20) Project
Output [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143 AS COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146 AS COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172]
Input [2]: [COL_F39B11B8_702A_4D04_905D_8CF5B339E153#232143, COL_AEC76732_ACB3_4AC1_8391_5254B5238C36#232146]

(21) HashAggregate
Input [2]: [COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169]
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#233514L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]

(22) Exchange
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Arguments: hashpartitioning(COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, 10), ENSURE_REQUIREMENTS, [plan_id=21786]

(23) HashAggregate
Input [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169, count#233515L]
Keys [2]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169]
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#233378L]
Results [3]: [COL_C8C8D9AA_5E3C_46B3_BEC8_5EA06C069BCC#233172 AS COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_3DCBE7EF_EB88_484C_94A1_303061CC7EEE#233169 AS COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, count(1)#233378L AS COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]

(24) Exchange
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: rangepartitioning(COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310 ASC NULLS FIRST, 10), ENSURE_REQUIREMENTS, [plan_id=21798]

(25) Sort
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]
Arguments: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310 ASC NULLS FIRST], true, 0

(26) Project
Output [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Input [3]: [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L]

(27) Exchange
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: hashpartitioning(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 10), ENSURE_REQUIREMENTS, [plan_id=21810]

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

(29) Window
Input [3]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309]
Arguments: [sum(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L) windowspecdefinition(COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, 1 DESC NULLS LAST, specifiedwindowframe(RangeFrame, unboundedpreceding$(), currentrow$())) AS COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L], [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309], [1 DESC NULLS LAST]

(30) TakeOrderedAndProject
Input [4]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L]
Arguments: 500000, [COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309 ASC NULLS FIRST], [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L, dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L)), 100.0)), 2) AS COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233505]

(31) AdaptiveSparkPlan
Output [5]: [COL_FD32BFDB_47E7_4883_B460_C270AD516A5C#233310, COL_EA397FE2_8E57_41A7_B026_07B0BE39C3A1#233380L, COL_A6141562_7FC7_46BC_8B5F_A864A7132006#233309, COL_C0BD3228_B8EF_4D99_9227_0F490091E005#233437L, COL_AC4463DC_93A3_4C74_BFE7_1C492B5D6D68#233505]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

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