digraph G {
id="graph_446000";
subgraph graph_stage_446000 {
id="graph_stage_446000";
isCluster="true";
label="Stage 446000";
subgraph cluster_3150075 {
id="cluster_3150075";
isCluster="true";
label="Exchange";
1242578 [id="node_1242578" labelType="html" label="ShuffledRowRDD [1242578] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150070 {
id="cluster_3150070";
isCluster="true";
label="WholeStageCodegen (5)";
1242579 [id="node_1242579" labelType="html" label="MapPartitionsRDD [1242579] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150069 {
id="cluster_3150069";
isCluster="true";
label="SortAggregate";
1242580 [id="node_1242580" labelType="html" label="MapPartitionsRDD [1242580] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150068 {
id="cluster_3150068";
isCluster="true";
label="InMemoryTableScan";
1242581 [id="node_1242581" labelType="html" label="MapPartitionsRDD [1242581] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242582 [id="node_1242582" labelType="html" label="SortAggregate(key=[demandChannel#21540770, shardId#21517301, qty#21540790, worklistShardItemId#21517302L, demandStream#21540771], functions=[first(kpis#21540799, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21540790, demandChannel#21540770, demandStream#21540771, kpis#21540912])\n+- *(5) Sort [demandChannel#21540770 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21540790 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21540771 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21540770, shardId#21517301, qty#21540790, worklistShardItemId#21517302L, demandStream#21540771, 20), ENSURE_REQUIREMENTS, [plan_id=21354093]\n +- SortAggregate(key=[demandChannel#21540770, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21540790)) AS qty#21540790, worklistShardItemId#21517302L, demandStream#21540771], functions=[partial_first(kpis#21540799, false)], output=[demandChannel#21540770, shardId#21517301, qty#215407... [1242582] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150180 {
id="cluster_3150180";
isCluster="true";
label="InMemoryTableScan";
1242597 [id="node_1242597" labelType="html" label="MapPartitionsRDD [1242597] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242598 [id="node_1242598" labelType="html" label="MapPartitionsRDD [1242598] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242599 [id="node_1242599" labelType="html" label="MapPartitionsRDD [1242599] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150155 {
id="cluster_3150155";
isCluster="true";
label="WholeStageCodegen (3)";
1242600 [id="node_1242600" labelType="html" label="MapPartitionsRDD [1242600] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150154 {
id="cluster_3150154";
isCluster="true";
label="InMemoryTableScan";
1242601 [id="node_1242601" labelType="html" label="MapPartitionsRDD [1242601] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242602 [id="node_1242602" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21541261, qty#21540790, demandChannel#21540770, demandStream#21540771, kpis#21540799]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21541266, worklistShardItemId#21541267L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21540790, demandChannel#21540770, demandStream#21540771, kpis#21540799], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21540790, demandChannel#21540770, demandStream#21540771, kpis#21540799], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21540770, shardId#21517301, qty#21540790, worklistShardItemId#21517302L, demandStream#21540771], functions=[first(kpis#21540799, false)], ou... [1242602] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242603 [id="node_1242603" labelType="html" label="MapPartitionsRDD [1242603] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242604 [id="node_1242604" labelType="html" label="MapPartitionsRDD [1242604] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242605 [id="node_1242605" labelType="html" label="MapPartitionsRDD [1242605] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3150153 {
id="cluster_3150153";
isCluster="true";
label="CollectLimit";
1242606 [id="node_1242606" labelType="html" label="MapPartitionsRDD [1242606] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242607 [id="node_1242607" labelType="html" label="MapPartitionsRDD [1242607] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1242578->1242579;
1242579->1242580;
1242580->1242581;
1242581->1242582;
1242582->1242597;
1242597->1242598;
1242598->1242599;
1242599->1242600;
1242600->1242601;
1242601->1242602;
1242602->1242603;
1242603->1242604;
1242604->1242605;
1242605->1242606;
1242606->1242607;
}
1242577,1242578
1242582
1242602