digraph G {
id="graph_446084";
subgraph graph_stage_446084 {
id="graph_stage_446084";
isCluster="true";
label="Stage 446084";
subgraph cluster_3150611 {
id="cluster_3150611";
isCluster="true";
label="Exchange";
1242796 [id="node_1242796" labelType="html" label="ShuffledRowRDD [1242796] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150605 {
id="cluster_3150605";
isCluster="true";
label="WholeStageCodegen (5)";
1242797 [id="node_1242797" labelType="html" label="MapPartitionsRDD [1242797] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150604 {
id="cluster_3150604";
isCluster="true";
label="SortAggregate";
1242798 [id="node_1242798" labelType="html" label="MapPartitionsRDD [1242798] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150603 {
id="cluster_3150603";
isCluster="true";
label="InMemoryTableScan";
1242799 [id="node_1242799" labelType="html" label="MapPartitionsRDD [1242799] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242800 [id="node_1242800" labelType="html" label="SortAggregate(key=[demandChannel#21544527, shardId#21517301, qty#21544547, worklistShardItemId#21517302L, demandStream#21544528], functions=[first(kpis#21544556, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21544547, demandChannel#21544527, demandStream#21544528, kpis#21544669])\n+- *(5) Sort [demandChannel#21544527 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21544547 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21544528 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21544527, shardId#21517301, qty#21544547, worklistShardItemId#21517302L, demandStream#21544528, 20), ENSURE_REQUIREMENTS, [plan_id=21355579]\n +- SortAggregate(key=[demandChannel#21544527, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21544547)) AS qty#21544547, worklistShardItemId#21517302L, demandStream#21544528], functions=[partial_first(kpis#21544556, false)], output=[demandChannel#21544527, shardId#21517301, qty#215445... [1242800] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150715 {
id="cluster_3150715";
isCluster="true";
label="InMemoryTableScan";
1242815 [id="node_1242815" labelType="html" label="MapPartitionsRDD [1242815] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242816 [id="node_1242816" labelType="html" label="MapPartitionsRDD [1242816] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242817 [id="node_1242817" labelType="html" label="MapPartitionsRDD [1242817] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150690 {
id="cluster_3150690";
isCluster="true";
label="WholeStageCodegen (3)";
1242818 [id="node_1242818" labelType="html" label="MapPartitionsRDD [1242818] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150689 {
id="cluster_3150689";
isCluster="true";
label="InMemoryTableScan";
1242819 [id="node_1242819" labelType="html" label="MapPartitionsRDD [1242819] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242820 [id="node_1242820" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21545018, qty#21544547, demandChannel#21544527, demandStream#21544528, kpis#21544556]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21545023, worklistShardItemId#21545024L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21544547, demandChannel#21544527, demandStream#21544528, kpis#21544556], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21544547, demandChannel#21544527, demandStream#21544528, kpis#21544556], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21544527, shardId#21517301, qty#21544547, worklistShardItemId#21517302L, demandStream#21544528], functions=[first(kpis#21544556, false)], ou... [1242820] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150733 {
id="cluster_3150733";
isCluster="true";
label="InMemoryTableScan";
1242829 [id="node_1242829" labelType="html" label="MapPartitionsRDD [1242829] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242830 [id="node_1242830" labelType="html" label="MapPartitionsRDD [1242830] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242831 [id="node_1242831" labelType="html" label="MapPartitionsRDD [1242831] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1242796->1242797;
1242797->1242798;
1242798->1242799;
1242799->1242800;
1242800->1242815;
1242815->1242816;
1242816->1242817;
1242817->1242818;
1242818->1242819;
1242819->1242820;
1242820->1242829;
1242829->1242830;
1242830->1242831;
}
1242795,1242796
1242800
1242820