digraph G {
id="graph_446382";
subgraph graph_stage_446382 {
id="graph_stage_446382";
isCluster="true";
label="Stage 446382";
subgraph cluster_3152805 {
id="cluster_3152805";
isCluster="true";
label="Exchange";
1243694 [id="node_1243694" labelType="html" label="ShuffledRowRDD [1243694] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152799 {
id="cluster_3152799";
isCluster="true";
label="WholeStageCodegen (5)";
1243695 [id="node_1243695" labelType="html" label="MapPartitionsRDD [1243695] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152798 {
id="cluster_3152798";
isCluster="true";
label="SortAggregate";
1243696 [id="node_1243696" labelType="html" label="MapPartitionsRDD [1243696] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152797 {
id="cluster_3152797";
isCluster="true";
label="InMemoryTableScan";
1243697 [id="node_1243697" labelType="html" label="MapPartitionsRDD [1243697] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243698 [id="node_1243698" labelType="html" label="SortAggregate(key=[demandChannel#21560013, shardId#21517301, qty#21560033, worklistShardItemId#21517302L, demandStream#21560014], functions=[first(kpis#21560042, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21560033, demandChannel#21560013, demandStream#21560014, kpis#21560155])\n+- *(5) Sort [demandChannel#21560013 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21560033 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21560014 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21560013, shardId#21517301, qty#21560033, worklistShardItemId#21517302L, demandStream#21560014, 20), ENSURE_REQUIREMENTS, [plan_id=21361659]\n +- SortAggregate(key=[demandChannel#21560013, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21560033)) AS qty#21560033, worklistShardItemId#21517302L, demandStream#21560014], functions=[partial_first(kpis#21560042, false)], output=[demandChannel#21560013, shardId#21517301, qty#215600... [1243698] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152909 {
id="cluster_3152909";
isCluster="true";
label="InMemoryTableScan";
1243713 [id="node_1243713" labelType="html" label="MapPartitionsRDD [1243713] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243714 [id="node_1243714" labelType="html" label="MapPartitionsRDD [1243714] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243715 [id="node_1243715" labelType="html" label="MapPartitionsRDD [1243715] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152884 {
id="cluster_3152884";
isCluster="true";
label="WholeStageCodegen (3)";
1243716 [id="node_1243716" labelType="html" label="MapPartitionsRDD [1243716] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152883 {
id="cluster_3152883";
isCluster="true";
label="InMemoryTableScan";
1243717 [id="node_1243717" labelType="html" label="MapPartitionsRDD [1243717] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243718 [id="node_1243718" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21560504, qty#21560033, demandChannel#21560013, demandStream#21560014, kpis#21560042]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21560509, worklistShardItemId#21560510L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21560033, demandChannel#21560013, demandStream#21560014, kpis#21560042], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21560033, demandChannel#21560013, demandStream#21560014, kpis#21560042], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21560013, shardId#21517301, qty#21560033, worklistShardItemId#21517302L, demandStream#21560014], functions=[first(kpis#21560042, false)], ou... [1243718] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243719 [id="node_1243719" labelType="html" label="MapPartitionsRDD [1243719] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243720 [id="node_1243720" labelType="html" label="MapPartitionsRDD [1243720] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243721 [id="node_1243721" labelType="html" label="MapPartitionsRDD [1243721] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152882 {
id="cluster_3152882";
isCluster="true";
label="CollectLimit";
1243722 [id="node_1243722" labelType="html" label="MapPartitionsRDD [1243722] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243723 [id="node_1243723" labelType="html" label="MapPartitionsRDD [1243723] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1243694->1243695;
1243695->1243696;
1243696->1243697;
1243697->1243698;
1243698->1243713;
1243713->1243714;
1243714->1243715;
1243715->1243716;
1243716->1243717;
1243717->1243718;
1243718->1243719;
1243719->1243720;
1243720->1243721;
1243721->1243722;
1243722->1243723;
}
1243693,1243694
1243698
1243718