digraph G {
id="graph_838";
subgraph graph_stage_838 {
id="graph_stage_838";
isCluster="true";
label="Stage 838";
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}"];
2162 [id="node_2162" labelType="html" label="MapPartitionsRDD [2162] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2163 [id="node_2163" labelType="html" label="MapPartitionsRDD [2163] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2164 [id="node_2164" labelType="html" label="MapPartitionsRDD [2164] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7003 {
id="cluster_7003";
isCluster="true";
label="CollectLimit";
2165 [id="node_2165" labelType="html" label="MapPartitionsRDD [2165] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2166 [id="node_2166" labelType="html" label="MapPartitionsRDD [2166] [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->2162;
2162->2163;
2163->2164;
2164->2165;
2165->2166;
}
2136,2137
2141
2161