digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 6 ms";
3 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 64.1 MiB<br>spill size: 0.0 B"];
}
4 [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"];
5 [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 cluster6 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 9 ms";
7 [labelType="html" label="<br><b>Project</b><br><br>"];
}
8 [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"];
1->0;
3->1;
4->3;
5->4;
7->5;
8->7;
}
9
AdaptiveSparkPlan isFinalPlan=true
Window [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6325, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6348], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST]
Sort [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST], false, 0
WholeStageCodegen (2)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, 10), ENSURE_REQUIREMENTS, [plan_id=1520]
Project [No ligne#6191 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, MMAT#6192 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, ETP#6193 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, str_to_datez(DDEB#6194, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, str_to_datez(DFIN#6195, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
WholeStageCodegen (1)
FileScan csv [No ligne#6191,MMAT#6192,ETP#6193,DDEB#6194,DFIN#6195] 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 (13)
+- == Final Plan ==
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 (12)
+- Window (11)
+- Sort (10)
+- Exchange (9)
+- Project (8)
+- Scan csv (1)
(1) Scan csv
Output [5]: [No ligne#6191, MMAT#6192, ETP#6193, DDEB#6194, DFIN#6195]
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#6191 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, MMAT#6192 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, ETP#6193 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, str_to_datez(DDEB#6194, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, str_to_datez(DFIN#6195, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Input [5]: [No ligne#6191, MMAT#6192, ETP#6193, DDEB#6194, DFIN#6195]
(3) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, 10), ENSURE_REQUIREMENTS, [plan_id=1520]
(4) ShuffleQueryStage
Output [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: 0
(5) AQEShuffleRead
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: coalesced
(6) Sort [codegen id : 2]
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST], false, 0
(7) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6325, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6348], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST]
(8) Project
Output [5]: [No ligne#6191 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, MMAT#6192 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, ETP#6193 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, str_to_datez(DDEB#6194, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, str_to_datez(DFIN#6195, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Input [5]: [No ligne#6191, MMAT#6192, ETP#6193, DDEB#6194, DFIN#6195]
(9) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, 10), ENSURE_REQUIREMENTS, [plan_id=1508]
(10) Sort
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST], false, 0
(11) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6325, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6348], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310 ASC NULLS LAST]
(12) CollectLimit
Input [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6325, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6348]
Arguments: 1500
(13) AdaptiveSparkPlan
Output [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#6307, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#6308, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#6309, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#6310, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#6311, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#6325, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#6348]
Arguments: isFinalPlan=true