digraph G {
subgraph cluster0 {
isCluster="true";
id="cluster0";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n36 ms (0 ms, 1 ms, 5 ms (stage 1573812.0: task 2942672))";
tooltip="WholeStageCodegen (2)";
1 [id="node1" labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>15 ms (0 ms, 0 ms, 4 ms (stage 1573812.0: task 2942672))<br>peak memory total (min, med, max (stageId: taskId))<br>9.5 MiB (256.0 KiB, 256.0 KiB, 2.3 MiB (stage 1573812.0: task 2942671))<br>number of output rows: 1<br>number of sort fallback tasks: 0<br>avg hash probes per key: 1" tooltip="HashAggregate(keys=[shardId#6420877], functions=[max(version#6420879)])"];
}
2 [id="node2" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 95.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: 40.0 B<br>local merged bytes read: 0.0 B<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>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>number of partitions: 30<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 95.0 B" tooltip="Exchange hashpartitioning(shardId#6420877, 30), ENSURE_REQUIREMENTS, [plan_id=3472056]"];
subgraph cluster3 {
isCluster="true";
id="cluster3";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n927 ms (0 ms, 28 ms, 124 ms (stage 1573811.0: task 2942649))";
tooltip="WholeStageCodegen (1)";
4 [id="node4" labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>12 ms (0 ms, 0 ms, 3 ms (stage 1573811.0: task 2942649))<br>peak memory total (min, med, max (stageId: taskId))<br>7.5 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 1573811.0: task 2942653))<br>number of output rows: 1<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0" tooltip="HashAggregate(keys=[shardId#6420877], functions=[partial_max(version#6420879)])"];
}
5 [id="node5" labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 4" tooltip="InMemoryTableScan [shardId#6420877, version#6420879]"];
6 [id="node6" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 4<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 4<br>local bytes read: 443.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 2<br>data size total (min, med, max (stageId: taskId))<br>2.1 KiB (544.0 B, 544.0 B, 1088.0 B (stage 1573810.0: task 2942611))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>1 ms (0 ms, 0 ms, 0 ms (stage 1573810.0: task 2942611))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time: 6 ms<br>remote bytes read: 866.0 B<br>number of partitions: 30<br>remote reqs duration: 7 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1309.0 B (433.0 B, 433.0 B, 443.0 B (stage 1573810.0: task 2942611))" tooltip="Exchange hashpartitioning(worklistShardItemId#6420878L, 30), REPARTITION_BY_NUM, [plan_id=3472027]"];
subgraph cluster7 {
isCluster="true";
id="cluster7";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n239 ms (0 ms, 5 ms, 23 ms (stage 1573810.0: task 2942611))";
tooltip="WholeStageCodegen (2)";
8 [id="node8" labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>12 ms (0 ms, 0 ms, 4 ms (stage 1573810.0: task 2942612))<br>peak memory total (min, med, max (stageId: taskId))<br>13.5 MiB (256.0 KiB, 256.0 KiB, 2.3 MiB (stage 1573810.0: task 2942613))<br>number of output rows: 4<br>number of sort fallback tasks: 0<br>avg hash probes per key (min, med, max (stageId: taskId)):<br>(1, 1, 1 (stage 1573810.0: task 2942613))" tooltip="HashAggregate(keys=[demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882], functions=[])"];
}
9 [id="node9" labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 4<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 4<br>local bytes read total (min, med, max (stageId: taskId))<br>1281.0 B (427.0 B, 427.0 B, 427.0 B (stage 1573810.0: task 2942613))<br>merged fetch fallback count: 0<br>local blocks read: 3<br>remote merged chunks fetched: 0<br>remote blocks read: 1<br>data size total (min, med, max (stageId: taskId))<br>2.1 KiB (544.0 B, 544.0 B, 544.0 B (stage 1573809.0: task 2942607))<br>local merged bytes read: 0.0 B<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>1 ms (0 ms, 0 ms, 0 ms (stage 1573809.0: task 2942609))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 1573810.0: task 2942613))<br>remote bytes read: 427.0 B<br>number of partitions: 30<br>remote reqs duration: 1 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1708.0 B (427.0 B, 427.0 B, 427.0 B (stage 1573809.0: task 2942607))" tooltip="Exchange hashpartitioning(demandChannel#6420881, shardId#6420877, kpis#6420883, version#6420879, qty#6420880, worklistShardItemId#6420878L, demandStream#6420882, 30), ENSURE_REQUIREMENTS, [plan_id=3472023]"];
10 [id="node10" labelType="html" label="<b>HashAggregate</b><br><br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 1573809.0: task 2942607))<br>time in aggregation build total (min, med, max (stageId: taskId))<br>676 ms (161 ms, 176 ms, 178 ms (stage 1573809.0: task 2942608))<br>peak memory total (min, med, max (stageId: taskId))<br>9.0 MiB (2.3 MiB, 2.3 MiB, 2.3 MiB (stage 1573809.0: task 2942607))<br>number of output rows: 4<br>number of sort fallback tasks: 0<br>avg hash probes per key (min, med, max (stageId: taskId)):<br>(1, 1, 1 (stage 1573809.0: task 2942607))" tooltip="HashAggregate(keys=[demandChannel#6420881, shardId#6420877, knownfloatingpointnormalized(transform(kpis#6420883, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#6606992)) null else named_struct(label, lambda arg#6606992.label, dateTime, lambda arg#6606992.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#6606992.value)))), lambda arg#6606992, false))) AS kpis#6420883, version#6420879, knownfloatingpointnormalized(normalizenanandzero(qty#6420880)) AS qty#6420880, worklistShardItemId#6420878L, demandStream#6420882], functions=[])"];
subgraph cluster11 {
isCluster="true";
id="cluster11";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n676 ms (161 ms, 176 ms, 178 ms (stage 1573809.0: task 2942608))";
tooltip="WholeStageCodegen (1)";
12 [id="node12" labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 4" tooltip="Scan ExistingRDD[shardId#6420877,worklistShardItemId#6420878L,version#6420879,qty#6420880,demandChannel#6420881,demandStream#6420882,kpis#6420883]"];
}
2->1;
4->2;
5->4;
6->5;
8->6;
9->8;
10->9;
12->10;
}