digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (6)\n \nduration: 0 ms";
2 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
}
3 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1<br>local merged chunks fetched: 0<br>shuffle write time: 0 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: 1<br>local bytes read: 59.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: 16.0 B<br>local merged bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 59.0 B"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 0 ms";
5 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
6 [labelType="html" label="<br><b>Project</b><br><br>"];
7 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 9"];
}
8 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster9 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 36 ms";
10 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 64.1 MiB<br>spill size: 0.0 B"];
11 [labelType="html" label="<br><b>Project</b><br><br>"];
}
12 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster13 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 46 ms";
14 [labelType="html" label="<br><b>Project</b><br><br>"];
}
15 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster16 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 88 ms";
17 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 64.1 MiB<br>spill size: 0.0 B"];
}
18 [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"];
19 [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 cluster20 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 10 ms";
21 [labelType="html" label="<br><b>Project</b><br><br>"];
}
22 [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;
8->7;
10->8;
11->10;
12->11;
14->12;
15->14;
17->15;
18->17;
19->18;
21->19;
22->21;
}
23
AdaptiveSparkPlan isFinalPlan=true
HashAggregate(keys=[], functions=[count(1)])
WholeStageCodegen (6)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2174]
HashAggregate(keys=[], functions=[partial_count(1)])
Project
Filter (COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979 <=> 1)
WholeStageCodegen (5)
Window [row_number() windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [1 DESC NULLS LAST]
Sort [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
Project [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
WholeStageCodegen (4)
Window [last(COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804, true) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
Project [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804]
WholeStageCodegen (3)
Window [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
Sort [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST], false, 0
WholeStageCodegen (2)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, 10), ENSURE_REQUIREMENTS, [plan_id=2016]
Project [No ligne#8557 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, MMAT#8558 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, ETP#8559 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, str_to_datez(DDEB#8560, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_to_datez(DFIN#8561, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
WholeStageCodegen (1)
FileScan csv [No ligne#8557,MMAT#8558,ETP#8559,DDEB#8560,DFIN#8561] 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 (33)
+- == Final Plan ==
* HashAggregate (18)
+- ShuffleQueryStage (17), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (16)
+- * HashAggregate (15)
+- * Project (14)
+- * Filter (13)
+- Window (12)
+- * Sort (11)
+- * Project (10)
+- Window (9)
+- * 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 ==
HashAggregate (32)
+- Exchange (31)
+- HashAggregate (30)
+- Project (29)
+- Filter (28)
+- Window (27)
+- Sort (26)
+- Project (25)
+- Window (24)
+- Project (23)
+- Window (22)
+- Sort (21)
+- Exchange (20)
+- Project (19)
+- Scan csv (1)
(1) Scan csv
Output [5]: [No ligne#8557, MMAT#8558, ETP#8559, DDEB#8560, DFIN#8561]
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#8557 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, MMAT#8558 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, ETP#8559 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, str_to_datez(DDEB#8560, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_to_datez(DFIN#8561, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Input [5]: [No ligne#8557, MMAT#8558, ETP#8559, DDEB#8560, DFIN#8561]
(3) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, 10), ENSURE_REQUIREMENTS, [plan_id=2016]
(4) ShuffleQueryStage
Output [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: 0
(5) AQEShuffleRead
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: coalesced
(6) Sort [codegen id : 2]
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST], false, 0
(7) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
(8) Project [codegen id : 3]
Output [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804]
Input [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709]
(9) Window
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804]
Arguments: [last(COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804, true) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
(10) Project [codegen id : 4]
Output [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Input [4]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
(11) Sort [codegen id : 4]
Input [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(12) Window
Input [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Arguments: [row_number() windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [1 DESC NULLS LAST]
(13) Filter [codegen id : 5]
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979]
Condition : (COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979 <=> 1)
(14) Project [codegen id : 5]
Output: []
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979]
(15) HashAggregate [codegen id : 5]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#9361L]
Results [1]: [count#9362L]
(16) Exchange
Input [1]: [count#9362L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2174]
(17) ShuffleQueryStage
Output [1]: [count#9362L]
Arguments: 1
(18) HashAggregate [codegen id : 6]
Input [1]: [count#9362L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#9222L]
Results [1]: [count(1)#9222L AS count#9223L]
(19) Project
Output [5]: [No ligne#8557 AS COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, MMAT#8558 AS COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, ETP#8559 AS COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, str_to_datez(DDEB#8560, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_to_datez(DFIN#8561, dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Input [5]: [No ligne#8557, MMAT#8558, ETP#8559, DDEB#8560, DFIN#8561]
(20) Exchange
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: hashpartitioning(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, 10), ENSURE_REQUIREMENTS, [plan_id=1973]
(21) Sort
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST], false, 0
(22) Window
Input [5]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650]
Arguments: [lag(COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686, lag(COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650, -1, null) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
(23) Project
Output [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, str_if_with_rule((NOT (COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686 <=> COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635) OR NOT (date_diff(DAY, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709) <=> 1)), COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, null) AS COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804]
Input [7]: [COL_21421409_025C_4C9D_808E_1BBDEE4BEB7A#8633, COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_584464CD_E9B5_43FD_9EFF_A6F25F111E1E#8635, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_E98066C8_DC97_4A1F_8313_F49AB9504593#8650, COL_BD2B8E9B_E291_4122_9583_89B55048E0F6#8686, COL_BFB362C1_6BA9_4A52_8F3F_E9A1CD765546#8709]
(24) Window
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804]
Arguments: [last(COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804, true) windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634], [COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643 ASC NULLS LAST]
(25) Project
Output [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Input [4]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_6C94855E_C159_4F6C_84D9_BDE0A104240F#8643, COL_5E6DC374_E37E_4131_8AE6_4BA6BDE04FEB#8804, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
(26) Sort
Input [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Arguments: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634 ASC NULLS FIRST, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(27) Window
Input [2]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827]
Arguments: [row_number() windowspecdefinition(COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979], [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827], [1 DESC NULLS LAST]
(28) Filter
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979]
Condition : (COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979 <=> 1)
(29) Project
Output: []
Input [3]: [COL_8200F68A_19E7_411E_8D8B_739E2C5CE4A1#8634, COL_7268252A_B026_4498_AA4C_F471A4DA150D#8827, COL_194CC6F8_DE65_4416_9E61_6B057D1D15C7#8979]
(30) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#9361L]
Results [1]: [count#9362L]
(31) Exchange
Input [1]: [count#9362L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1986]
(32) HashAggregate
Input [1]: [count#9362L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#9222L]
Results [1]: [count(1)#9222L AS count#9223L]
(33) AdaptiveSparkPlan
Output [1]: [count#9223L]
Arguments: isFinalPlan=true