digraph G {
id="graph_446543";
subgraph graph_stage_446543 {
id="graph_stage_446543";
isCluster="true";
label="Stage 446543";
subgraph cluster_3153902 {
id="cluster_3153902";
isCluster="true";
label="Exchange";
1244143 [id="node_1244143" labelType="html" label="ShuffledRowRDD [1244143] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153896 {
id="cluster_3153896";
isCluster="true";
label="WholeStageCodegen (5)";
1244144 [id="node_1244144" labelType="html" label="MapPartitionsRDD [1244144] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153895 {
id="cluster_3153895";
isCluster="true";
label="SortAggregate";
1244145 [id="node_1244145" labelType="html" label="MapPartitionsRDD [1244145] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153894 {
id="cluster_3153894";
isCluster="true";
label="InMemoryTableScan";
1244146 [id="node_1244146" labelType="html" label="MapPartitionsRDD [1244146] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244147 [id="node_1244147" labelType="html" label="SortAggregate(key=[demandChannel#21567756, shardId#21517301, qty#21567776, worklistShardItemId#21517302L, demandStream#21567757], functions=[first(kpis#21567785, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21567776, demandChannel#21567756, demandStream#21567757, kpis#21567898])\n+- *(5) Sort [demandChannel#21567756 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21567776 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21567757 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21567756, shardId#21517301, qty#21567776, worklistShardItemId#21517302L, demandStream#21567757, 20), ENSURE_REQUIREMENTS, [plan_id=21364684]\n +- SortAggregate(key=[demandChannel#21567756, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21567776)) AS qty#21567776, worklistShardItemId#21517302L, demandStream#21567757], functions=[partial_first(kpis#21567785, false)], output=[demandChannel#21567756, shardId#21517301, qty#215677... [1244147] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3154006 {
id="cluster_3154006";
isCluster="true";
label="InMemoryTableScan";
1244162 [id="node_1244162" labelType="html" label="MapPartitionsRDD [1244162] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244163 [id="node_1244163" labelType="html" label="MapPartitionsRDD [1244163] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244164 [id="node_1244164" labelType="html" label="MapPartitionsRDD [1244164] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153981 {
id="cluster_3153981";
isCluster="true";
label="WholeStageCodegen (3)";
1244165 [id="node_1244165" labelType="html" label="MapPartitionsRDD [1244165] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153980 {
id="cluster_3153980";
isCluster="true";
label="InMemoryTableScan";
1244166 [id="node_1244166" labelType="html" label="MapPartitionsRDD [1244166] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244167 [id="node_1244167" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21568247, qty#21567776, demandChannel#21567756, demandStream#21567757, kpis#21567785]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21568252, worklistShardItemId#21568253L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21567776, demandChannel#21567756, demandStream#21567757, kpis#21567785], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21567776, demandChannel#21567756, demandStream#21567757, kpis#21567785], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21567756, shardId#21517301, qty#21567776, worklistShardItemId#21517302L, demandStream#21567757], functions=[first(kpis#21567785, false)], ou... [1244167] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3154024 {
id="cluster_3154024";
isCluster="true";
label="InMemoryTableScan";
1244176 [id="node_1244176" labelType="html" label="MapPartitionsRDD [1244176] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244177 [id="node_1244177" labelType="html" label="MapPartitionsRDD [1244177] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1244178 [id="node_1244178" labelType="html" label="MapPartitionsRDD [1244178] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1244143->1244144;
1244144->1244145;
1244145->1244146;
1244146->1244147;
1244147->1244162;
1244162->1244163;
1244163->1244164;
1244164->1244165;
1244165->1244166;
1244166->1244167;
1244167->1244176;
1244176->1244177;
1244177->1244178;
}
1244142,1244143
1244147
1244167