digraph G {
id="graph_172913";
subgraph graph_stage_172913 {
id="graph_stage_172913";
isCluster="true";
label="Stage 172913";
subgraph cluster_1241226 {
id="cluster_1241226";
isCluster="true";
label="Exchange";
482829 [id="node_482829" labelType="html" label="ShuffledRowRDD [482829] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241219 {
id="cluster_1241219";
isCluster="true";
label="WholeStageCodegen (5)";
482830 [id="node_482830" labelType="html" label="MapPartitionsRDD [482830] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241218 {
id="cluster_1241218";
isCluster="true";
label="SortAggregate";
482831 [id="node_482831" labelType="html" label="MapPartitionsRDD [482831] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241217 {
id="cluster_1241217";
isCluster="true";
label="InMemoryTableScan";
482832 [id="node_482832" labelType="html" label="MapPartitionsRDD [482832] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482833 [id="node_482833" labelType="html" label="SortAggregate(key=[demandChannel#8546738, shardId#7905118, qty#8546758, worklistShardItemId#7905119L, demandStream#8546739], functions=[first(kpis#8546767, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8546758, demandChannel#8546738, demandStream#8546739, kpis#8546880])\n+- *(5) Sort [demandChannel#8546738 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8546758 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8546739 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8546738, shardId#7905118, qty#8546758, worklistShardItemId#7905119L, demandStream#8546739, 30), ENSURE_REQUIREMENTS, [plan_id=11185688]\n +- SortAggregate(key=[demandChannel#8546738, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8546758)) AS qty#8546758, worklistShardItemId#7905119L, demandStream#8546739], functions=[partial_first(kpis#8546767, false)], output=[demandChannel#8546738, shardId#7905118, qty#8546758, worklistShardItemId#7905119L... [482833] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241329 {
id="cluster_1241329";
isCluster="true";
label="InMemoryTableScan";
482848 [id="node_482848" labelType="html" label="MapPartitionsRDD [482848] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482849 [id="node_482849" labelType="html" label="MapPartitionsRDD [482849] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482850 [id="node_482850" labelType="html" label="MapPartitionsRDD [482850] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241304 {
id="cluster_1241304";
isCluster="true";
label="WholeStageCodegen (3)";
482851 [id="node_482851" labelType="html" label="MapPartitionsRDD [482851] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241303 {
id="cluster_1241303";
isCluster="true";
label="InMemoryTableScan";
482852 [id="node_482852" labelType="html" label="MapPartitionsRDD [482852] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482853 [id="node_482853" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8547229, qty#8546758, demandChannel#8546738, demandStream#8546739, kpis#8546767]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8547234, worklistShardItemId#8547235L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8546758, demandChannel#8546738, demandStream#8546739, kpis#8546767], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8546758, demandChannel#8546738, demandStream#8546739, kpis#8546767], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8546738, shardId#7905118, qty#8546758, worklistShardItemId#7905119L, demandStream#8546739], functions=[first(kpis#8546767, false)], output=[shardId#7905118, worklistSh... [482853] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1241347 {
id="cluster_1241347";
isCluster="true";
label="InMemoryTableScan";
482862 [id="node_482862" labelType="html" label="MapPartitionsRDD [482862] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482863 [id="node_482863" labelType="html" label="MapPartitionsRDD [482863] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482864 [id="node_482864" labelType="html" label="MapPartitionsRDD [482864] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
482829->482830;
482830->482831;
482831->482832;
482832->482833;
482833->482848;
482848->482849;
482849->482850;
482850->482851;
482851->482852;
482852->482853;
482853->482862;
482862->482863;
482863->482864;
}
482828,482829
482833
482853