digraph G {
id="graph_446315";
subgraph graph_stage_446315 {
id="graph_stage_446315";
isCluster="true";
label="Stage 446315";
subgraph cluster_3152280 {
id="cluster_3152280";
isCluster="true";
label="Exchange";
1243480 [id="node_1243480" labelType="html" label="ShuffledRowRDD [1243480] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152275 {
id="cluster_3152275";
isCluster="true";
label="WholeStageCodegen (5)";
1243481 [id="node_1243481" labelType="html" label="MapPartitionsRDD [1243481] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152274 {
id="cluster_3152274";
isCluster="true";
label="SortAggregate";
1243482 [id="node_1243482" labelType="html" label="MapPartitionsRDD [1243482] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152273 {
id="cluster_3152273";
isCluster="true";
label="InMemoryTableScan";
1243483 [id="node_1243483" labelType="html" label="MapPartitionsRDD [1243483] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243484 [id="node_1243484" labelType="html" label="SortAggregate(key=[demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[first(kpis#21556307, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556420])\n+- *(5) Sort [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, 20), ENSURE_REQUIREMENTS, [plan_id=21360184]\n +- SortAggregate(key=[demandChannel#21556278, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[partial_first(kpis#21556307, false)], output=[demandChannel#21556278, shardId#21517301, qty#215562... [1243484] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152385 {
id="cluster_3152385";
isCluster="true";
label="InMemoryTableScan";
1243499 [id="node_1243499" labelType="html" label="MapPartitionsRDD [1243499] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243500 [id="node_1243500" labelType="html" label="MapPartitionsRDD [1243500] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243501 [id="node_1243501" labelType="html" label="MapPartitionsRDD [1243501] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152360 {
id="cluster_3152360";
isCluster="true";
label="WholeStageCodegen (3)";
1243502 [id="node_1243502" labelType="html" label="MapPartitionsRDD [1243502] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152359 {
id="cluster_3152359";
isCluster="true";
label="InMemoryTableScan";
1243503 [id="node_1243503" labelType="html" label="MapPartitionsRDD [1243503] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243504 [id="node_1243504" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21556769, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21556774, worklistShardItemId#21556775L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556307], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[first(kpis#21556307, false)], ou... [1243504] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3152403 {
id="cluster_3152403";
isCluster="true";
label="InMemoryTableScan";
1243513 [id="node_1243513" labelType="html" label="MapPartitionsRDD [1243513] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243514 [id="node_1243514" labelType="html" label="MapPartitionsRDD [1243514] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243515 [id="node_1243515" labelType="html" label="MapPartitionsRDD [1243515] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1243480->1243481;
1243481->1243482;
1243482->1243483;
1243483->1243484;
1243484->1243499;
1243499->1243500;
1243500->1243501;
1243501->1243502;
1243502->1243503;
1243503->1243504;
1243504->1243513;
1243513->1243514;
1243514->1243515;
}
1243479,1243480
1243484
1243504