digraph G {
id="graph_1450";
subgraph graph_stage_1450 {
id="graph_stage_1450";
isCluster="true";
label="Stage 1450";
subgraph cluster_11748 {
id="cluster_11748";
isCluster="true";
label="Exchange";
3766 [id="node_3766" labelType="html" label="ShuffledRowRDD [3766] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11742 {
id="cluster_11742";
isCluster="true";
label="WholeStageCodegen (5)";
3767 [id="node_3767" labelType="html" label="MapPartitionsRDD [3767] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11741 {
id="cluster_11741";
isCluster="true";
label="SortAggregate";
3768 [id="node_3768" labelType="html" label="MapPartitionsRDD [3768] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11740 {
id="cluster_11740";
isCluster="true";
label="InMemoryTableScan";
3769 [id="node_3769" labelType="html" label="MapPartitionsRDD [3769] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3770 [id="node_3770" labelType="html" label="SortAggregate(key=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[first(kpis#73141, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73254])\n+- *(5) Sort [demandChannel#73112 ASC NULLS FIRST, shardId#49871 ASC NULLS FIRST, qty#73132 ASC NULLS FIRST, worklistShardItemId#49872L ASC NULLS FIRST, demandStream#73113 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113, 8), ENSURE_REQUIREMENTS, [plan_id=332016]\n +- SortAggregate(key=[demandChannel#73112, shardId#49871, knownfloatingpointnormalized(normalizenanandzero(qty#73132)) AS qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[partial_first(kpis#73141, false)], output=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113, first#73320, valueSet#73321])\n +- *(4) ... [3770] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11852 {
id="cluster_11852";
isCluster="true";
label="InMemoryTableScan";
3785 [id="node_3785" labelType="html" label="MapPartitionsRDD [3785] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3786 [id="node_3786" labelType="html" label="MapPartitionsRDD [3786] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3787 [id="node_3787" labelType="html" label="MapPartitionsRDD [3787] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11827 {
id="cluster_11827";
isCluster="true";
label="WholeStageCodegen (3)";
3788 [id="node_3788" labelType="html" label="MapPartitionsRDD [3788] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11826 {
id="cluster_11826";
isCluster="true";
label="InMemoryTableScan";
3789 [id="node_3789" labelType="html" label="MapPartitionsRDD [3789] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3790 [id="node_3790" labelType="html" label="*(3) Project [shardId#49871, worklistShardItemId#49872L, version#73603, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141]\n+- *(3) BroadcastHashJoin [shardId#49871, worklistShardItemId#49872L], [shardId#73608, worklistShardItemId#73609L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#49871) AND isnotnull(worklistShardItemId#49872L))\n : +- InMemoryTableScan [shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141], [isnotnull(shardId#49871), isnotnull(worklistShardItemId#49872L)]\n : +- InMemoryRelation [shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[first(kpis#73141, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113... [3790] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3791 [id="node_3791" labelType="html" label="MapPartitionsRDD [3791] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3792 [id="node_3792" labelType="html" label="MapPartitionsRDD [3792] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3793 [id="node_3793" labelType="html" label="MapPartitionsRDD [3793] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11825 {
id="cluster_11825";
isCluster="true";
label="CollectLimit";
3794 [id="node_3794" labelType="html" label="MapPartitionsRDD [3794] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3795 [id="node_3795" labelType="html" label="MapPartitionsRDD [3795] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
3766->3767;
3767->3768;
3768->3769;
3769->3770;
3770->3785;
3785->3786;
3786->3787;
3787->3788;
3788->3789;
3789->3790;
3790->3791;
3791->3792;
3792->3793;
3793->3794;
3794->3795;
}
3765,3766
3770
3790