SP1 - Details for Query 571

Submitted Time: 2026/02/24 09:27:30
Duration: 1.0 s
Succeeded Jobs: 730 731 734 736 740

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 (8)\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: 88.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: 104.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: 88.0 B"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 22 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 22 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: 503 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 46 ms"; 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: 10.7 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 741 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: 741 local bytes read: 10.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: 23.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: 10.3 KiB"]; 12 [labelType="html" label=" Project "]; 13 [labelType="html" label=" Project "]; 14 [labelType="html" label="Filter number of output rows: 741"]; subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 430 ms"; 16 [labelType="html" label="Generate number of output rows: 1,002"]; } 17 [labelType="html" label=" Project "]; 18 [labelType="html" label="Filter number of output rows: 1"]; 19 [labelType="html" label="Scan text number of output rows: 1 number of files read: 1 metadata time: 0 ms size of files read: 599.6 KiB"]; subgraph cluster20 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 0 ms"; 21 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 22 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 18.3 KiB number of coalesced partitions: 1"]; 23 [labelType="html" label="Exchange shuffle records written: 1,505 local merged chunks fetched: 0 shuffle write time: 8 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,505 local bytes read: 17.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: 47.0 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: 17.3 KiB"]; subgraph cluster24 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 16 ms"; 25 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 6 ms peak memory: 256.0 KiB number of output rows: 1,505 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 26 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 128.6 KiB number of coalesced partitions: 1"]; 27 [labelType="html" label="Exchange shuffle records written: 1,505 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 43 ms (1 ms, 1 ms, 34 ms (stage 968.0: task 1315)) 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,505 local bytes read: 123.2 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)) 184.0 KiB (880.0 B, 36.6 KiB, 37.1 KiB (stage 968.0: task 1314)) 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)) 123.2 KiB (1008.0 B, 24.4 KiB, 24.7 KiB (stage 968.0: task 1314))"]; subgraph cluster28 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n199 ms (6 ms, 19 ms, 72 ms (stage 968.0: task 1317))"; 29 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 159 ms (3 ms, 15 ms, 66 ms (stage 968.0: task 1317)) peak memory total (min, med, max (stageId: taskId)) 2.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 968.0: task 1322)) number of output rows: 1,505 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 30 [labelType="html" label=" Project "]; subgraph cluster31 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n204 ms (10 ms, 19 ms, 72 ms (stage 968.0: task 1317))"; 32 [labelType="html" label="Filter number of output rows: 1,505"]; 33 [labelType="html" label="Generate number of output rows: 1,507"]; } 34 [labelType="html" label=" Project "]; 35 [labelType="html" label="Filter number of output rows: 16"]; 36 [labelType="html" label="Scan text number of output rows: 30 number of files read: 30 metadata time: 0 ms size of files read: 266.0 KiB"]; 2->0; 3->2; 5->3; 6->5; 7->6; 9->7; 10->9; 11->10; 12->11; 13->12; 14->13; 16->14; 17->16; 18->17; 19->18; 21->7; 22->21; 23->22; 25->23; 26->25; 27->26; 29->27; 30->29; 32->30; 33->32; 34->33; 35->34; 36->35; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[], functions=[avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)])

WholeStageCodegen (8)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=16887]

HashAggregate(keys=[], functions=[partial_avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), partial_avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), partial_avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), partial_avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), partial_avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), partial_avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)])

Project [dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) AS COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158, str_to_integer(str_create(0)) AS COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388, str_to_integer(str_create(100)) AS COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470, str_to_integer(str_create(25)) AS COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549, str_to_integer(str_create(50)) AS COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654, str_to_integer(str_create(75)) AS COL_CA890354_B95E_461B_87B4_7F83650C3820#154719]

SortMergeJoin [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899], [INFORMATION_STA_119303_STATIONCODE_119307#152944], Inner, CASE WHEN isnull(dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2))) THEN false ELSE (dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) > 20) END

WholeStageCodegen (7)

Sort [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899 ASC NULLS FIRST], false, 0

WholeStageCodegen (5)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, 10), ENSURE_REQUIREMENTS, [plan_id=16443]

Project [get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.stationcode) AS COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, str_to_integer(get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.numbikesavailable)) AS COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]

Project [to_json(root#152370, Some(Etc/UTC)) AS COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648]

Filter ((str_remove_accent(upper(str_if_with_rule((CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END AND CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END), Mécaniques + Electriques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END, Mécaniques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END, Electriques, Pas de disponibilité))))) <=> MECANIQUES + ELECTRIQUES) AND isnotnull(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.stationcode)))

Generate explode(_extract_fields#155859), false, [root#152370]

WholeStageCodegen (1)

Project [from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields AS _extract_fields#155859]

Filter ((size(from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields, true) > 0) AND isnotnull(from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields))

FileScan text [value#152337] Batched: false, DataFilters: [(size(from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType..., Format: Text, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/json/tmp/VLIB_JSON_119256168/HTTP_FILE_0.json], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<value:string>

Sort [INFORMATION_STA_119303_STATIONCODE_119307#152944 ASC NULLS FIRST], false, 0

WholeStageCodegen (6)

AQEShuffleRead coalesced

Exchange hashpartitioning(INFORMATION_STA_119303_STATIONCODE_119307#152944, 10), ENSURE_REQUIREMENTS, [plan_id=16710]

HashAggregate(keys=[CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592], functions=[])

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592, 10), ENSURE_REQUIREMENTS, [plan_id=16466]

HashAggregate(keys=[CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592], functions=[])

WholeStageCodegen (3)

Project [root#152556.capacity AS CAPACITY_119304#152589L, to_json(root#152556.coordonnees_geo, Some(Etc/UTC)) AS COORDONNEES_GEO_119305#152590, root#152556.name AS NAME_119306#152591, root#152556.stationcode AS STATIONCODE_119307#152592]

Filter (CASE WHEN isnull(bigint_to_int(root#152556.capacity)) THEN false ELSE (bigint_to_int(root#152556.capacity) > 0) END AND isnotnull(root#152556.stationcode))

Generate explode(root#152553), false, [root#152556]

WholeStageCodegen (2)

Project [from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC)) AS root#152553]

Filter ((size(from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC)), true) > 0) AND isnotnull(from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC))))

FileScan text [value#152538] Batched: false, DataFilters: [(size(from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees..., Format: Text, Location: InMemoryFileIndex(30 paths)[file:/data/input/depot/json/tmp/INFORMATION_STA_119302168/HTTP_FILE_0..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<value:string>

Details

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


(1) Scan text 
Output [1]: [value#152337]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/json/tmp/VLIB_JSON_119256168/HTTP_FILE_0.json]
ReadSchema: struct<value:string>

(2) Filter
Input [1]: [value#152337]
Condition : ((size(from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields, true) > 0) AND isnotnull(from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields))

(3) Project
Output [1]: [from_json(ArrayType(StructType(StructField(fields,StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,ArrayType(DoubleType,true),true),StructField(duedate,StringType,true),StructField(ebike,LongType,true),StructField(is_installed,StringType,true),StructField(is_renting,StringType,true),StructField(is_returning,StringType,true),StructField(mechanical,LongType,true),StructField(name,StringType,true),StructField(nom_arrondissement_communes,StringType,true),StructField(numbikesavailable,LongType,true),StructField(numdocksavailable,LongType,true),StructField(stationcode,StringType,true)),true)),true), get_json_object(value#152337, $.records), Some(Etc/UTC)).fields AS _extract_fields#155859]
Input [1]: [value#152337]

(4) Generate [codegen id : 1]
Input [1]: [_extract_fields#155859]
Arguments: explode(_extract_fields#155859), false, [root#152370]

(5) Filter
Input [1]: [root#152370]
Condition : ((str_remove_accent(upper(str_if_with_rule((CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END AND CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END), Mécaniques + Electriques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END, Mécaniques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END, Electriques, Pas de disponibilité))))) <=> MECANIQUES + ELECTRIQUES) AND isnotnull(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.stationcode)))

(6) Project
Output [1]: [to_json(root#152370, Some(Etc/UTC)) AS COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648]
Input [1]: [root#152370]

(7) Project
Output [2]: [get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.stationcode) AS COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, str_to_integer(get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.numbikesavailable)) AS COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Input [1]: [COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648]

(8) Exchange
Input [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: hashpartitioning(COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, 10), ENSURE_REQUIREMENTS, [plan_id=16443]

(9) ShuffleQueryStage
Output [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: 0

(10) AQEShuffleRead
Input [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: coalesced

(11) Sort [codegen id : 5]
Input [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899 ASC NULLS FIRST], false, 0

(12) Scan text 
Output [1]: [value#152538]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/json/tmp/INFORMATION_STA_119302168/HTTP_FILE_0.json, ... 29 entries]
ReadSchema: struct<value:string>

(13) Filter
Input [1]: [value#152538]
Condition : ((size(from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC)), true) > 0) AND isnotnull(from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC))))

(14) Project
Output [1]: [from_json(ArrayType(StructType(StructField(capacity,LongType,true),StructField(coordonnees_geo,StructType(StructField(lat,DoubleType,true),StructField(lon,DoubleType,true)),true),StructField(name,StringType,true),StructField(station_opening_hours,StringType,true),StructField(stationcode,StringType,true)),true), get_json_object(value#152538, $.results), Some(Etc/UTC)) AS root#152553]
Input [1]: [value#152538]

(15) Generate [codegen id : 2]
Input [1]: [root#152553]
Arguments: explode(root#152553), false, [root#152556]

(16) Filter [codegen id : 2]
Input [1]: [root#152556]
Condition : (CASE WHEN isnull(bigint_to_int(root#152556.capacity)) THEN false ELSE (bigint_to_int(root#152556.capacity) > 0) END AND isnotnull(root#152556.stationcode))

(17) Project
Output [4]: [root#152556.capacity AS CAPACITY_119304#152589L, to_json(root#152556.coordonnees_geo, Some(Etc/UTC)) AS COORDONNEES_GEO_119305#152590, root#152556.name AS NAME_119306#152591, root#152556.stationcode AS STATIONCODE_119307#152592]
Input [1]: [root#152556]

(18) HashAggregate [codegen id : 3]
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Keys [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Functions: []
Aggregate Attributes: []
Results [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]

(19) Exchange
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Arguments: hashpartitioning(CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592, 10), ENSURE_REQUIREMENTS, [plan_id=16466]

(20) ShuffleQueryStage
Output [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Arguments: 1

(21) AQEShuffleRead
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Arguments: coalesced

(22) HashAggregate [codegen id : 4]
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Keys [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Functions: []
Aggregate Attributes: []
Results [2]: [CAPACITY_119304#152589L AS INFORMATION_STA_119303_CAPACITY_119304#152941L, STATIONCODE_119307#152592 AS INFORMATION_STA_119303_STATIONCODE_119307#152944]

(23) Exchange
Input [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: hashpartitioning(INFORMATION_STA_119303_STATIONCODE_119307#152944, 10), ENSURE_REQUIREMENTS, [plan_id=16710]

(24) ShuffleQueryStage
Output [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: 2

(25) AQEShuffleRead
Input [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: coalesced

(26) Sort [codegen id : 6]
Input [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: [INFORMATION_STA_119303_STATIONCODE_119307#152944 ASC NULLS FIRST], false, 0

(27) SortMergeJoin [codegen id : 7]
Left keys [1]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899]
Right keys [1]: [INFORMATION_STA_119303_STATIONCODE_119307#152944]
Join type: Inner
Join condition: CASE WHEN isnull(dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2))) THEN false ELSE (dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) > 20) END

(28) Project [codegen id : 7]
Output [6]: [dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) AS COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158, str_to_integer(str_create(0)) AS COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388, str_to_integer(str_create(100)) AS COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470, str_to_integer(str_create(25)) AS COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549, str_to_integer(str_create(50)) AS COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654, str_to_integer(str_create(75)) AS COL_CA890354_B95E_461B_87B4_7F83650C3820#154719]
Input [4]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]

(29) HashAggregate [codegen id : 7]
Input [6]: [COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158, COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388, COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470, COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549, COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654, COL_CA890354_B95E_461B_87B4_7F83650C3820#154719]
Keys: []
Functions [6]: [partial_avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), partial_avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), partial_avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), partial_avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), partial_avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), partial_avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)]
Aggregate Attributes [12]: [sum#155883, count#155884L, sum#155885, count#155886L, sum#155887, count#155888L, sum#155889, count#155890L, sum#155891, count#155892L, sum#155893, count#155894L]
Results [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]

(30) Exchange
Input [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=16887]

(31) ShuffleQueryStage
Output [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]
Arguments: 3

(32) HashAggregate [codegen id : 8]
Input [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]
Keys: []
Functions [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)]
Aggregate Attributes [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388)#154931, avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158)#154933, avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470)#154935, avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549)#154937, avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654)#154939, avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)#154941]
Results [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388)#154931 AS COL_AF54A9F5_CBB6_427F_8667_E83447A8F563#154932, avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158)#154933 AS COL_E6BCD687_4596_4D15_AC59_90CC70C1343C#154934, avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470)#154935 AS COL_87C3F2BB_CE4E_4CDA_AF24_91837AEFBAEE#154936, avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549)#154937 AS COL_0EAD41C8_A8B9_4F0A_B4DC_674252979444#154938, avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654)#154939 AS COL_F0B1090B_BD84_43C1_B441_5177DBAEEEAF#154940, avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)#154941 AS COL_A41EC495_BE1A_414F_B81F_12D4C98892DE#154942]

(33) Generate
Input [1]: [_extract_fields#155859]
Arguments: explode(_extract_fields#155859), false, [root#152370]

(34) Filter
Input [1]: [root#152370]
Condition : ((str_remove_accent(upper(str_if_with_rule((CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END AND CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END), Mécaniques + Electriques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.mechanical)) > 0) END, Mécaniques, str_if_with_rule(CASE WHEN isnull(str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike))) THEN false ELSE (str_to_integer(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.ebike)) > 0) END, Electriques, Pas de disponibilité))))) <=> MECANIQUES + ELECTRIQUES) AND isnotnull(get_json_object(to_json(root#152370, Some(Etc/UTC)), $.stationcode)))

(35) Project
Output [1]: [to_json(root#152370, Some(Etc/UTC)) AS COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648]
Input [1]: [root#152370]

(36) Project
Output [2]: [get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.stationcode) AS COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, str_to_integer(get_json_object(COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648, $.numbikesavailable)) AS COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Input [1]: [COL_9091B58C_8072_40BA_9B1C_4828078CF13A#152648]

(37) Exchange
Input [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: hashpartitioning(COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, 10), ENSURE_REQUIREMENTS, [plan_id=16382]

(38) Sort
Input [2]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912]
Arguments: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899 ASC NULLS FIRST], false, 0

(39) Generate
Input [1]: [root#152553]
Arguments: explode(root#152553), false, [root#152556]

(40) Filter
Input [1]: [root#152556]
Condition : (CASE WHEN isnull(bigint_to_int(root#152556.capacity)) THEN false ELSE (bigint_to_int(root#152556.capacity) > 0) END AND isnotnull(root#152556.stationcode))

(41) Project
Output [4]: [root#152556.capacity AS CAPACITY_119304#152589L, to_json(root#152556.coordonnees_geo, Some(Etc/UTC)) AS COORDONNEES_GEO_119305#152590, root#152556.name AS NAME_119306#152591, root#152556.stationcode AS STATIONCODE_119307#152592]
Input [1]: [root#152556]

(42) HashAggregate
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Keys [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Functions: []
Aggregate Attributes: []
Results [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]

(43) Exchange
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Arguments: hashpartitioning(CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592, 10), ENSURE_REQUIREMENTS, [plan_id=16376]

(44) HashAggregate
Input [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Keys [4]: [CAPACITY_119304#152589L, COORDONNEES_GEO_119305#152590, NAME_119306#152591, STATIONCODE_119307#152592]
Functions: []
Aggregate Attributes: []
Results [2]: [CAPACITY_119304#152589L AS INFORMATION_STA_119303_CAPACITY_119304#152941L, STATIONCODE_119307#152592 AS INFORMATION_STA_119303_STATIONCODE_119307#152944]

(45) Exchange
Input [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: hashpartitioning(INFORMATION_STA_119303_STATIONCODE_119307#152944, 10), ENSURE_REQUIREMENTS, [plan_id=16383]

(46) Sort
Input [2]: [INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]
Arguments: [INFORMATION_STA_119303_STATIONCODE_119307#152944 ASC NULLS FIRST], false, 0

(47) SortMergeJoin
Left keys [1]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899]
Right keys [1]: [INFORMATION_STA_119303_STATIONCODE_119307#152944]
Join type: Inner
Join condition: CASE WHEN isnull(dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2))) THEN false ELSE (dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) > 20) END

(48) Project
Output [6]: [dec_to_int(dec_round(dec_operator(PRODUIT, array(dec_operator(DIVISION, array(COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, int_sum(array(bigint_to_int(INFORMATION_STA_119303_CAPACITY_119304#152941L), COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912)))), 100.0)), 2)) AS COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158, str_to_integer(str_create(0)) AS COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388, str_to_integer(str_create(100)) AS COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470, str_to_integer(str_create(25)) AS COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549, str_to_integer(str_create(50)) AS COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654, str_to_integer(str_create(75)) AS COL_CA890354_B95E_461B_87B4_7F83650C3820#154719]
Input [4]: [COL_613DB6B3_74E6_4C99_93FD_E5777B617C86#152899, COL_222816E0_1771_4A96_9C59_DB1900C311FE#152912, INFORMATION_STA_119303_CAPACITY_119304#152941L, INFORMATION_STA_119303_STATIONCODE_119307#152944]

(49) HashAggregate
Input [6]: [COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158, COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388, COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470, COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549, COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654, COL_CA890354_B95E_461B_87B4_7F83650C3820#154719]
Keys: []
Functions [6]: [partial_avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), partial_avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), partial_avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), partial_avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), partial_avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), partial_avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)]
Aggregate Attributes [12]: [sum#155883, count#155884L, sum#155885, count#155886L, sum#155887, count#155888L, sum#155889, count#155890L, sum#155891, count#155892L, sum#155893, count#155894L]
Results [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]

(50) Exchange
Input [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=16390]

(51) HashAggregate
Input [12]: [sum#155895, count#155896L, sum#155897, count#155898L, sum#155899, count#155900L, sum#155901, count#155902L, sum#155903, count#155904L, sum#155905, count#155906L]
Keys: []
Functions [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388), avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158), avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470), avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549), avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654), avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)]
Aggregate Attributes [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388)#154931, avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158)#154933, avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470)#154935, avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549)#154937, avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654)#154939, avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)#154941]
Results [6]: [avg(COL_60710BBB_84E6_4D82_BF64_43AD7277D805#154388)#154931 AS COL_AF54A9F5_CBB6_427F_8667_E83447A8F563#154932, avg(COL_72171A9C_F337_4AD3_8511_8797B9778C04#154158)#154933 AS COL_E6BCD687_4596_4D15_AC59_90CC70C1343C#154934, avg(COL_CED3F36A_E724_46B8_A288_EEE4FE1ED252#154470)#154935 AS COL_87C3F2BB_CE4E_4CDA_AF24_91837AEFBAEE#154936, avg(COL_51C8BEA6_620D_446F_8AB6_19853E93FD0E#154549)#154937 AS COL_0EAD41C8_A8B9_4F0A_B4DC_674252979444#154938, avg(COL_97F2AE14_003B_420E_B9D6_E6D0C34DCE18#154654)#154939 AS COL_F0B1090B_BD84_43C1_B441_5177DBAEEEAF#154940, avg(COL_CA890354_B95E_461B_87B4_7F83650C3820#154719)#154941 AS COL_A41EC495_BE1A_414F_B81F_12D4C98892DE#154942]

(52) AdaptiveSparkPlan
Output [6]: [COL_AF54A9F5_CBB6_427F_8667_E83447A8F563#154932, COL_E6BCD687_4596_4D15_AC59_90CC70C1343C#154934, COL_87C3F2BB_CE4E_4CDA_AF24_91837AEFBAEE#154936, COL_0EAD41C8_A8B9_4F0A_B4DC_674252979444#154938, COL_F0B1090B_BD84_43C1_B441_5177DBAEEEAF#154940, COL_A41EC495_BE1A_414F_B81F_12D4C98892DE#154942]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

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