EVAL1_SPC1 - Details for Query 27

Submitted Time: 2026/06/02 09:24:05
Duration: 1 s
Succeeded Jobs: 28 29 32 34

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 (10)\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 (9)\n \nduration: 42 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 41 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: 4,253 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 92 ms"; 9 [labelType="html" label="Sort sort time: 17 ms peak memory: 65.0 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 99.3 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 24,850 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 17 ms (2 ms, 3 ms, 4 ms (stage 41.0: task 36)) 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: 24,850 local bytes read: 94.3 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 5 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 582.4 KiB (39.1 KiB, 116.7 KiB, 195.0 KiB (stage 41.0: task 33)) 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)) 94.3 KiB (6.8 KiB, 18.8 KiB, 31.2 KiB (stage 41.0: task 33))"]; 12 [labelType="html" label=" Union "]; subgraph cluster13 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 381 ms"; 14 [labelType="html" label=" Project "]; 15 [labelType="html" label="Filter number of output rows: 8,319"]; } 16 [labelType="html" label="Scan csv number of output rows: 8,319 number of files read: 1 metadata time: 0 ms size of files read: 2.1 MiB"]; subgraph cluster17 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 380 ms"; 18 [labelType="html" label=" Project "]; 19 [labelType="html" label="Filter number of output rows: 6,597"]; } 20 [labelType="html" label="Scan csv number of output rows: 6,597 number of files read: 1 metadata time: 0 ms size of files read: 2.1 MiB"]; subgraph cluster21 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 374 ms"; 22 [labelType="html" label=" Project "]; 23 [labelType="html" label="Filter number of output rows: 4,980"]; } 24 [labelType="html" label="Scan csv number of output rows: 4,980 number of files read: 1 metadata time: 0 ms size of files read: 2.1 MiB"]; subgraph cluster25 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 384 ms"; 26 [labelType="html" label=" Project "]; 27 [labelType="html" label="Filter number of output rows: 3,285"]; } 28 [labelType="html" label="Scan csv number of output rows: 3,285 number of files read: 1 metadata time: 0 ms size of files read: 2.1 MiB"]; subgraph cluster29 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 339 ms"; 30 [labelType="html" label=" Project "]; 31 [labelType="html" label="Filter number of output rows: 1,669"]; } 32 [labelType="html" label="Scan csv number of output rows: 1,669 number of files read: 1 metadata time: 0 ms size of files read: 2.1 MiB"]; subgraph cluster33 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; 34 [labelType="html" label="Sort sort time: 0 ms peak memory: 64.1 MiB spill size: 0.0 B"]; } 35 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 15.2 KiB number of coalesced partitions: 1"]; 36 [labelType="html" label="Exchange shuffle records written: 2,022 local merged chunks fetched: 0 shuffle write time: 4 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: 2,022 local bytes read: 14.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: 47.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: 14.5 KiB"]; subgraph cluster37 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 130 ms"; 38 [labelType="html" label=" Project "]; 39 [labelType="html" label="Filter number of output rows: 2,022"]; } 40 [labelType="html" label="Scan csv number of output rows: 2,022 number of files read: 1 metadata time: 0 ms size of files read: 196.4 KiB"]; 2->0; 3->2; 5->3; 6->5; 7->6; 9->7; 10->9; 11->10; 12->11; 14->12; 15->14; 16->15; 18->12; 19->18; 20->19; 22->12; 23->22; 24->23; 26->12; 27->26; 28->27; 30->12; 31->30; 32->31; 34->7; 35->34; 36->35; 38->36; 39->38; 40->39; }

AdaptiveSparkPlan isFinalPlan=true

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

WholeStageCodegen (10)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1429]

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

Project

SortMergeJoin [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755], [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791], Inner

WholeStageCodegen (9)

Sort [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755 ASC NULLS FIRST], false, 0

WholeStageCodegen (7)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755, 10), ENSURE_REQUIREMENTS, [plan_id=1114]

Union

Project [Code_DA1#2018 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]

Filter isnotnull(Code_DA1#2018)

WholeStageCodegen (1)

FileScan csv [Code_DA1#2018] Batched: false, DataFilters: [isnotnull(Code_DA1#2018)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnost..., PartitionFilters: [], PushedFilters: [IsNotNull(Code_DA1)], ReadSchema: struct<Code_DA1:string>

Project [Code_DA2#2531 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3073]

Filter isnotnull(Code_DA2#2531)

WholeStageCodegen (2)

FileScan csv [Code_DA2#2531] Batched: false, DataFilters: [isnotnull(Code_DA2#2531)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnost..., PartitionFilters: [], PushedFilters: [IsNotNull(Code_DA2)], ReadSchema: struct<Code_DA2:string>

Project [Code_DA3#2648 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3081]

Filter isnotnull(Code_DA3#2648)

WholeStageCodegen (3)

FileScan csv [Code_DA3#2648] Batched: false, DataFilters: [isnotnull(Code_DA3#2648)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnost..., PartitionFilters: [], PushedFilters: [IsNotNull(Code_DA3)], ReadSchema: struct<Code_DA3:string>

Project [Code_DA4#2693 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3089]

Filter isnotnull(Code_DA4#2693)

WholeStageCodegen (4)

FileScan csv [Code_DA4#2693] Batched: false, DataFilters: [isnotnull(Code_DA4#2693)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnost..., PartitionFilters: [], PushedFilters: [IsNotNull(Code_DA4)], ReadSchema: struct<Code_DA4:string>

Project [Code_DA5#2738 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3097]

Filter isnotnull(Code_DA5#2738)

WholeStageCodegen (5)

FileScan csv [Code_DA5#2738] Batched: false, DataFilters: [isnotnull(Code_DA5#2738)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnost..., PartitionFilters: [], PushedFilters: [IsNotNull(Code_DA5)], ReadSchema: struct<Code_DA5:string>

Sort [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791 ASC NULLS FIRST], false, 0

WholeStageCodegen (8)

AQEShuffleRead coalesced

Exchange hashpartitioning(REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791, 10), ENSURE_REQUIREMENTS, [plan_id=1154]

Project [Code_CIM10#2187 AS REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]

Filter (isnotnull(CCS_Famille#2190) AND isnotnull(Code_CIM10#2187))

WholeStageCodegen (6)

FileScan csv [Code_CIM10#2187,CCS_Famille#2190] Batched: false, DataFilters: [isnotnull(CCS_Famille#2190), isnotnull(Code_CIM10#2187)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/REGROUPEMENT_CO_14336/current/ccs..., PartitionFilters: [], PushedFilters: [IsNotNull(CCS_Famille), IsNotNull(Code_CIM10)], ReadSchema: struct<Code_CIM10:string,CCS_Famille:string>

Details

== Physical Plan ==
AdaptiveSparkPlan (56)
+- == Final Plan ==
   * HashAggregate (33)
   +- ShuffleQueryStage (32), Statistics(sizeInBytes=16.0 B, rowCount=1)
      +- Exchange (31)
         +- * HashAggregate (30)
            +- * Project (29)
               +- * SortMergeJoin Inner (28)
                  :- * Sort (20)
                  :  +- AQEShuffleRead (19)
                  :     +- ShuffleQueryStage (18), Statistics(sizeInBytes=582.4 KiB, rowCount=2.49E+4)
                  :        +- Exchange (17)
                  :           +- Union (16)
                  :              :- * Project (3)
                  :              :  +- * Filter (2)
                  :              :     +- Scan csv  (1)
                  :              :- * Project (6)
                  :              :  +- * Filter (5)
                  :              :     +- Scan csv  (4)
                  :              :- * Project (9)
                  :              :  +- * Filter (8)
                  :              :     +- Scan csv  (7)
                  :              :- * Project (12)
                  :              :  +- * Filter (11)
                  :              :     +- Scan csv  (10)
                  :              +- * Project (15)
                  :                 +- * Filter (14)
                  :                    +- Scan csv  (13)
                  +- * Sort (27)
                     +- AQEShuffleRead (26)
                        +- ShuffleQueryStage (25), Statistics(sizeInBytes=47.4 KiB, rowCount=2.02E+3)
                           +- Exchange (24)
                              +- * Project (23)
                                 +- * Filter (22)
                                    +- Scan csv  (21)
+- == Initial Plan ==
   HashAggregate (55)
   +- Exchange (54)
      +- HashAggregate (53)
         +- Project (52)
            +- SortMergeJoin Inner (51)
               :- Sort (46)
               :  +- Exchange (45)
               :     +- Union (44)
               :        :- Project (35)
               :        :  +- Filter (34)
               :        :     +- Scan csv  (1)
               :        :- Project (37)
               :        :  +- Filter (36)
               :        :     +- Scan csv  (4)
               :        :- Project (39)
               :        :  +- Filter (38)
               :        :     +- Scan csv  (7)
               :        :- Project (41)
               :        :  +- Filter (40)
               :        :     +- Scan csv  (10)
               :        +- Project (43)
               :           +- Filter (42)
               :              +- Scan csv  (13)
               +- Sort (50)
                  +- Exchange (49)
                     +- Project (48)
                        +- Filter (47)
                           +- Scan csv  (21)


(1) Scan csv 
Output [1]: [Code_DA1#2018]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnostics_cim10.csv]
PushedFilters: [IsNotNull(Code_DA1)]
ReadSchema: struct<Code_DA1:string>

(2) Filter [codegen id : 1]
Input [1]: [Code_DA1#2018]
Condition : isnotnull(Code_DA1#2018)

(3) Project [codegen id : 1]
Output [1]: [Code_DA1#2018 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Input [1]: [Code_DA1#2018]

(4) Scan csv 
Output [1]: [Code_DA2#2531]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnostics_cim10.csv]
PushedFilters: [IsNotNull(Code_DA2)]
ReadSchema: struct<Code_DA2:string>

(5) Filter [codegen id : 2]
Input [1]: [Code_DA2#2531]
Condition : isnotnull(Code_DA2#2531)

(6) Project [codegen id : 2]
Output [1]: [Code_DA2#2531 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3073]
Input [1]: [Code_DA2#2531]

(7) Scan csv 
Output [1]: [Code_DA3#2648]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnostics_cim10.csv]
PushedFilters: [IsNotNull(Code_DA3)]
ReadSchema: struct<Code_DA3:string>

(8) Filter [codegen id : 3]
Input [1]: [Code_DA3#2648]
Condition : isnotnull(Code_DA3#2648)

(9) Project [codegen id : 3]
Output [1]: [Code_DA3#2648 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3081]
Input [1]: [Code_DA3#2648]

(10) Scan csv 
Output [1]: [Code_DA4#2693]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnostics_cim10.csv]
PushedFilters: [IsNotNull(Code_DA4)]
ReadSchema: struct<Code_DA4:string>

(11) Filter [codegen id : 4]
Input [1]: [Code_DA4#2693]
Condition : isnotnull(Code_DA4#2693)

(12) Project [codegen id : 4]
Output [1]: [Code_DA4#2693 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3089]
Input [1]: [Code_DA4#2693]

(13) Scan csv 
Output [1]: [Code_DA5#2738]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/DIAGNOSTIC_14331/current/diagnostics_cim10.csv]
PushedFilters: [IsNotNull(Code_DA5)]
ReadSchema: struct<Code_DA5:string>

(14) Filter [codegen id : 5]
Input [1]: [Code_DA5#2738]
Condition : isnotnull(Code_DA5#2738)

(15) Project [codegen id : 5]
Output [1]: [Code_DA5#2738 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3097]
Input [1]: [Code_DA5#2738]

(16) Union

(17) Exchange
Input [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: hashpartitioning(COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755, 10), ENSURE_REQUIREMENTS, [plan_id=1114]

(18) ShuffleQueryStage
Output [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: 0

(19) AQEShuffleRead
Input [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: coalesced

(20) Sort [codegen id : 7]
Input [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755 ASC NULLS FIRST], false, 0

(21) Scan csv 
Output [2]: [Code_CIM10#2187, CCS_Famille#2190]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/REGROUPEMENT_CO_14336/current/ccs_detail_complet.csv]
PushedFilters: [IsNotNull(CCS_Famille), IsNotNull(Code_CIM10)]
ReadSchema: struct<Code_CIM10:string,CCS_Famille:string>

(22) Filter [codegen id : 6]
Input [2]: [Code_CIM10#2187, CCS_Famille#2190]
Condition : (isnotnull(CCS_Famille#2190) AND isnotnull(Code_CIM10#2187))

(23) Project [codegen id : 6]
Output [1]: [Code_CIM10#2187 AS REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Input [2]: [Code_CIM10#2187, CCS_Famille#2190]

(24) Exchange
Input [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: hashpartitioning(REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791, 10), ENSURE_REQUIREMENTS, [plan_id=1154]

(25) ShuffleQueryStage
Output [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: 1

(26) AQEShuffleRead
Input [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: coalesced

(27) Sort [codegen id : 8]
Input [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791 ASC NULLS FIRST], false, 0

(28) SortMergeJoin [codegen id : 9]
Left keys [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Right keys [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Join type: Inner
Join condition: None

(29) Project [codegen id : 9]
Output: []
Input [2]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755, REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]

(30) HashAggregate [codegen id : 9]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#3211L]
Results [1]: [count#3212L]

(31) Exchange
Input [1]: [count#3212L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1429]

(32) ShuffleQueryStage
Output [1]: [count#3212L]
Arguments: 2

(33) HashAggregate [codegen id : 10]
Input [1]: [count#3212L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#2924L]
Results [1]: [count(1)#2924L AS count#2925L]

(34) Filter
Input [1]: [Code_DA1#2018]
Condition : isnotnull(Code_DA1#2018)

(35) Project
Output [1]: [Code_DA1#2018 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Input [1]: [Code_DA1#2018]

(36) Filter
Input [1]: [Code_DA2#2531]
Condition : isnotnull(Code_DA2#2531)

(37) Project
Output [1]: [Code_DA2#2531 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3073]
Input [1]: [Code_DA2#2531]

(38) Filter
Input [1]: [Code_DA3#2648]
Condition : isnotnull(Code_DA3#2648)

(39) Project
Output [1]: [Code_DA3#2648 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3081]
Input [1]: [Code_DA3#2648]

(40) Filter
Input [1]: [Code_DA4#2693]
Condition : isnotnull(Code_DA4#2693)

(41) Project
Output [1]: [Code_DA4#2693 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3089]
Input [1]: [Code_DA4#2693]

(42) Filter
Input [1]: [Code_DA5#2738]
Condition : isnotnull(Code_DA5#2738)

(43) Project
Output [1]: [Code_DA5#2738 AS COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#3097]
Input [1]: [Code_DA5#2738]

(44) Union

(45) Exchange
Input [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: hashpartitioning(COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755, 10), ENSURE_REQUIREMENTS, [plan_id=1038]

(46) Sort
Input [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Arguments: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755 ASC NULLS FIRST], false, 0

(47) Filter
Input [2]: [Code_CIM10#2187, CCS_Famille#2190]
Condition : (isnotnull(CCS_Famille#2190) AND isnotnull(Code_CIM10#2187))

(48) Project
Output [1]: [Code_CIM10#2187 AS REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Input [2]: [Code_CIM10#2187, CCS_Famille#2190]

(49) Exchange
Input [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: hashpartitioning(REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791, 10), ENSURE_REQUIREMENTS, [plan_id=1039]

(50) Sort
Input [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Arguments: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791 ASC NULLS FIRST], false, 0

(51) SortMergeJoin
Left keys [1]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755]
Right keys [1]: [REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]
Join type: Inner
Join condition: None

(52) Project
Output: []
Input [2]: [COL_983A817F_3EA2_4B94_AD4A_A0B9FE6C2965#2755, REGROUPEMENT_CO_14459_CODE_CIM10_14460#2791]

(53) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#3211L]
Results [1]: [count#3212L]

(54) Exchange
Input [1]: [count#3212L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1046]

(55) HashAggregate
Input [1]: [count#3212L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#2924L]
Results [1]: [count(1)#2924L AS count#2925L]

(56) AdaptiveSparkPlan
Output [1]: [count#2925L]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

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