digraph G {
id="graph_446076";
subgraph graph_stage_446076 {
id="graph_stage_446076";
isCluster="true";
label="Stage 446076";
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}"];
1242821 [id="node_1242821" labelType="html" label="MapPartitionsRDD [1242821] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242822 [id="node_1242822" labelType="html" label="MapPartitionsRDD [1242822] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242823 [id="node_1242823" labelType="html" label="MapPartitionsRDD [1242823] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150688 {
id="cluster_3150688";
isCluster="true";
label="CollectLimit";
1242824 [id="node_1242824" labelType="html" label="MapPartitionsRDD [1242824] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242825 [id="node_1242825" labelType="html" label="MapPartitionsRDD [1242825] [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->1242821;
1242821->1242822;
1242822->1242823;
1242823->1242824;
1242824->1242825;
}
1242795,1242796
1242800
1242820