digraph G {
id="graph_846";
subgraph graph_stage_846 {
id="graph_stage_846";
isCluster="true";
label="Stage 846";
subgraph cluster_6925 {
id="cluster_6925";
isCluster="true";
label="Exchange";
2137 [id="node_2137" labelType="html" label="ShuffledRowRDD [2137] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_6920 {
id="cluster_6920";
isCluster="true";
label="WholeStageCodegen (5)";
2138 [id="node_2138" labelType="html" label="MapPartitionsRDD [2138] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_6919 {
id="cluster_6919";
isCluster="true";
label="SortAggregate";
2139 [id="node_2139" labelType="html" label="MapPartitionsRDD [2139] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_6918 {
id="cluster_6918";
isCluster="true";
label="InMemoryTableScan";
2140 [id="node_2140" labelType="html" label="MapPartitionsRDD [2140] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2141 [id="node_2141" labelType="html" label="SortAggregate(key=[demandChannel#41563, shardId#25237, qty#41583, worklistShardItemId#25238L, demandStream#41564], functions=[first(kpis#41592, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#41583, demandChannel#41563, demandStream#41564, kpis#41705])\n+- *(5) Sort [demandChannel#41563 ASC NULLS FIRST, shardId#25237 ASC NULLS FIRST, qty#41583 ASC NULLS FIRST, worklistShardItemId#25238L ASC NULLS FIRST, demandStream#41564 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#41563, shardId#25237, qty#41583, worklistShardItemId#25238L, demandStream#41564, 8), ENSURE_REQUIREMENTS, [plan_id=214721]\n +- SortAggregate(key=[demandChannel#41563, shardId#25237, knownfloatingpointnormalized(normalizenanandzero(qty#41583)) AS qty#41583, worklistShardItemId#25238L, demandStream#41564], functions=[partial_first(kpis#41592, false)], output=[demandChannel#41563, shardId#25237, qty#41583, worklistShardItemId#25238L, demandStream#41564, first#41771, valueSet#41772])\n +- *(4) ... [2141] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7030 {
id="cluster_7030";
isCluster="true";
label="InMemoryTableScan";
2156 [id="node_2156" labelType="html" label="MapPartitionsRDD [2156] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2157 [id="node_2157" labelType="html" label="MapPartitionsRDD [2157] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2158 [id="node_2158" labelType="html" label="MapPartitionsRDD [2158] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7005 {
id="cluster_7005";
isCluster="true";
label="WholeStageCodegen (3)";
2159 [id="node_2159" labelType="html" label="MapPartitionsRDD [2159] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7004 {
id="cluster_7004";
isCluster="true";
label="InMemoryTableScan";
2160 [id="node_2160" labelType="html" label="MapPartitionsRDD [2160] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2161 [id="node_2161" labelType="html" label="*(3) Project [shardId#25237, worklistShardItemId#25238L, version#42054, qty#41583, demandChannel#41563, demandStream#41564, kpis#41592]\n+- *(3) BroadcastHashJoin [shardId#25237, worklistShardItemId#25238L], [shardId#42059, worklistShardItemId#42060L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#25237) AND isnotnull(worklistShardItemId#25238L))\n : +- InMemoryTableScan [shardId#25237, worklistShardItemId#25238L, qty#41583, demandChannel#41563, demandStream#41564, kpis#41592], [isnotnull(shardId#25237), isnotnull(worklistShardItemId#25238L)]\n : +- InMemoryRelation [shardId#25237, worklistShardItemId#25238L, qty#41583, demandChannel#41563, demandStream#41564, kpis#41592], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#41563, shardId#25237, qty#41583, worklistShardItemId#25238L, demandStream#41564], functions=[first(kpis#41592, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#41583, demandChannel#41563, demandStream#41564... [2161] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7048 {
id="cluster_7048";
isCluster="true";
label="InMemoryTableScan";
2170 [id="node_2170" labelType="html" label="MapPartitionsRDD [2170] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2171 [id="node_2171" labelType="html" label="MapPartitionsRDD [2171] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2172 [id="node_2172" labelType="html" label="MapPartitionsRDD [2172] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
2137->2138;
2138->2139;
2139->2140;
2140->2141;
2141->2156;
2156->2157;
2157->2158;
2158->2159;
2159->2160;
2160->2161;
2161->2170;
2170->2171;
2171->2172;
}
2136,2137
2141
2161