digraph G {
id="graph_1397";
subgraph graph_stage_1397 {
id="graph_stage_1397";
isCluster="true";
label="Stage 1397";
subgraph cluster_11326 {
id="cluster_11326";
isCluster="true";
label="Exchange";
3589 [id="node_3589" labelType="html" label="ShuffledRowRDD [3589] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11321 {
id="cluster_11321";
isCluster="true";
label="WholeStageCodegen (5)";
3590 [id="node_3590" labelType="html" label="MapPartitionsRDD [3590] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11320 {
id="cluster_11320";
isCluster="true";
label="SortAggregate";
3591 [id="node_3591" labelType="html" label="MapPartitionsRDD [3591] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11319 {
id="cluster_11319";
isCluster="true";
label="InMemoryTableScan";
3592 [id="node_3592" labelType="html" label="MapPartitionsRDD [3592] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3593 [id="node_3593" labelType="html" label="SortAggregate(key=[demandChannel#69814, shardId#49871, qty#69834, worklistShardItemId#49872L, demandStream#69815], functions=[first(kpis#69843, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#69834, demandChannel#69814, demandStream#69815, kpis#69956])\n+- *(5) Sort [demandChannel#69814 ASC NULLS FIRST, shardId#49871 ASC NULLS FIRST, qty#69834 ASC NULLS FIRST, worklistShardItemId#49872L ASC NULLS FIRST, demandStream#69815 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#69814, shardId#49871, qty#69834, worklistShardItemId#49872L, demandStream#69815, 8), ENSURE_REQUIREMENTS, [plan_id=330846]\n +- SortAggregate(key=[demandChannel#69814, shardId#49871, knownfloatingpointnormalized(normalizenanandzero(qty#69834)) AS qty#69834, worklistShardItemId#49872L, demandStream#69815], functions=[partial_first(kpis#69843, false)], output=[demandChannel#69814, shardId#49871, qty#69834, worklistShardItemId#49872L, demandStream#69815, first#70022, valueSet#70023])\n +- *(4) ... [3593] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11431 {
id="cluster_11431";
isCluster="true";
label="InMemoryTableScan";
3608 [id="node_3608" labelType="html" label="MapPartitionsRDD [3608] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3609 [id="node_3609" labelType="html" label="MapPartitionsRDD [3609] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3610 [id="node_3610" labelType="html" label="MapPartitionsRDD [3610] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11406 {
id="cluster_11406";
isCluster="true";
label="WholeStageCodegen (3)";
3611 [id="node_3611" labelType="html" label="MapPartitionsRDD [3611] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11405 {
id="cluster_11405";
isCluster="true";
label="InMemoryTableScan";
3612 [id="node_3612" labelType="html" label="MapPartitionsRDD [3612] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3613 [id="node_3613" labelType="html" label="*(3) Project [shardId#49871, worklistShardItemId#49872L, version#70305, qty#69834, demandChannel#69814, demandStream#69815, kpis#69843]\n+- *(3) BroadcastHashJoin [shardId#49871, worklistShardItemId#49872L], [shardId#70310, worklistShardItemId#70311L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#49871) AND isnotnull(worklistShardItemId#49872L))\n : +- InMemoryTableScan [shardId#49871, worklistShardItemId#49872L, qty#69834, demandChannel#69814, demandStream#69815, kpis#69843], [isnotnull(shardId#49871), isnotnull(worklistShardItemId#49872L)]\n : +- InMemoryRelation [shardId#49871, worklistShardItemId#49872L, qty#69834, demandChannel#69814, demandStream#69815, kpis#69843], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#69814, shardId#49871, qty#69834, worklistShardItemId#49872L, demandStream#69815], functions=[first(kpis#69843, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#69834, demandChannel#69814, demandStream#69815... [3613] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11449 {
id="cluster_11449";
isCluster="true";
label="InMemoryTableScan";
3622 [id="node_3622" labelType="html" label="MapPartitionsRDD [3622] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3623 [id="node_3623" labelType="html" label="MapPartitionsRDD [3623] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3624 [id="node_3624" labelType="html" label="MapPartitionsRDD [3624] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
3589->3590;
3590->3591;
3591->3592;
3592->3593;
3593->3608;
3608->3609;
3609->3610;
3610->3611;
3611->3612;
3612->3613;
3613->3622;
3622->3623;
3623->3624;
}
3588,3589
3593
3613