digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 4 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
}
3 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 24 ms";
5 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 64.1 MiB<br>spill size: 0.0 B"];
}
6 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 762.0 B<br>number of coalesced partitions: 1"];
7 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 17<br>local merged chunks fetched: 0<br>shuffle write time: 1 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 17<br>local bytes read: 748.0 B<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 1224.0 B<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 748.0 B"];
subgraph cluster8 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 10 ms";
9 [labelType="html" label="<br><b>Project</b><br><br>"];
}
10 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 17<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 613.0 B"];
2->0;
3->2;
5->3;
6->5;
7->6;
9->7;
10->9;
}
11
AdaptiveSparkPlan isFinalPlan=true
Project [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#6887, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808, date_if_with_rule(isnull(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771), str_to_datez(01/01/2100, dd/MM/yyyy, Europe/Paris, fr_FR), COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771) AS COL_E03084D9_2C2F_49CC_9C75_BE8C0662503E#6889]
WholeStageCodegen (3)
Window [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST]
Sort [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST], false, 0
WholeStageCodegen (2)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, 10), ENSURE_REQUIREMENTS, [plan_id=1610]
Project [No ligne#6656 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, MMAT#6657 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, ETP#6658 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, str_to_datez(DDEB#6659, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, str_to_datez(DFIN#6660, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
WholeStageCodegen (1)
FileScan csv [No ligne#6656,MMAT#6657,ETP#6658,DDEB#6659,DFIN#6660] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/IFPEN_23381/current/AVW_DB_TEMPS_..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<No ligne:string,MMAT:string,ETP:string,DDEB:string,DFIN:string>
== Physical Plan ==
AdaptiveSparkPlan (15)
+- == Final Plan ==
* Project (8)
+- Window (7)
+- * Sort (6)
+- AQEShuffleRead (5)
+- ShuffleQueryStage (4), Statistics(sizeInBytes=1224.0 B, rowCount=17)
+- Exchange (3)
+- * Project (2)
+- Scan csv (1)
+- == Initial Plan ==
CollectLimit (14)
+- Project (13)
+- Window (12)
+- Sort (11)
+- Exchange (10)
+- Project (9)
+- Scan csv (1)
(1) Scan csv
Output [5]: [No ligne#6656, MMAT#6657, ETP#6658, DDEB#6659, DFIN#6660]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/IFPEN_23381/current/AVW_DB_TEMPS_TRAVAIL.csv]
ReadSchema: struct<No ligne:string,MMAT:string,ETP:string,DDEB:string,DFIN:string>
(2) Project [codegen id : 1]
Output [5]: [No ligne#6656 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, MMAT#6657 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, ETP#6658 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, str_to_datez(DDEB#6659, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, str_to_datez(DFIN#6660, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Input [5]: [No ligne#6656, MMAT#6657, ETP#6658, DDEB#6659, DFIN#6660]
(3) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, 10), ENSURE_REQUIREMENTS, [plan_id=1610]
(4) ShuffleQueryStage
Output [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: 0
(5) AQEShuffleRead
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: coalesced
(6) Sort [codegen id : 2]
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST], false, 0
(7) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST]
(8) Project [codegen id : 3]
Output [8]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#6887, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808, date_if_with_rule(isnull(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771), str_to_datez(01/01/2100, dd/MM/yyyy, Europe/Paris, fr_FR), COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771) AS COL_E03084D9_2C2F_49CC_9C75_BE8C0662503E#6889]
Input [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808]
(9) Project
Output [5]: [No ligne#6656 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, MMAT#6657 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, ETP#6658 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, str_to_datez(DDEB#6659, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, str_to_datez(DFIN#6660, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Input [5]: [No ligne#6656, MMAT#6657, ETP#6658, DDEB#6659, DFIN#6660]
(10) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, 10), ENSURE_REQUIREMENTS, [plan_id=1597]
(11) Sort
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST], false, 0
(12) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770 ASC NULLS LAST]
(13) Project
Output [8]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#6887, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808, date_if_with_rule(isnull(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771), str_to_datez(01/01/2100, dd/MM/yyyy, Europe/Paris, fr_FR), COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771) AS COL_E03084D9_2C2F_49CC_9C75_BE8C0662503E#6889]
Input [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6771, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808]
(14) CollectLimit
Input [8]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#6887, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808, COL_E03084D9_2C2F_49CC_9C75_BE8C0662503E#6889]
Arguments: 1500
(15) AdaptiveSparkPlan
Output [8]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6767, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6768, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6769, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6770, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6785, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#6887, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6808, COL_E03084D9_2C2F_49CC_9C75_BE8C0662503E#6889]
Arguments: isFinalPlan=true