digraph G {
id="graph_278701";
subgraph graph_stage_278701 {
id="graph_stage_278701";
isCluster="true";
label="Stage 278701";
subgraph cluster_1999463 {
id="cluster_1999463";
isCluster="true";
label="Exchange";
789787 [id="node_789787" labelType="html" label="ShuffledRowRDD [789787] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999457 {
id="cluster_1999457";
isCluster="true";
label="WholeStageCodegen (5)";
789788 [id="node_789788" labelType="html" label="MapPartitionsRDD [789788] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999456 {
id="cluster_1999456";
isCluster="true";
label="SortAggregate";
789789 [id="node_789789" labelType="html" label="MapPartitionsRDD [789789] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999455 {
id="cluster_1999455";
isCluster="true";
label="InMemoryTableScan";
789790 [id="node_789790" labelType="html" label="MapPartitionsRDD [789790] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789791 [id="node_789791" labelType="html" label="SortAggregate(key=[demandChannel#13804319, shardId#13791298, qty#13804339, worklistShardItemId#13791299L, demandStream#13804320], functions=[first(kpis#13804348, false)], output=[shardId#13791298, worklistShardItemId#13791299L, qty#13804339, demandChannel#13804319, demandStream#13804320, kpis#13804461])\n+- *(5) Sort [demandChannel#13804319 ASC NULLS FIRST, shardId#13791298 ASC NULLS FIRST, qty#13804339 ASC NULLS FIRST, worklistShardItemId#13791299L ASC NULLS FIRST, demandStream#13804320 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#13804319, shardId#13791298, qty#13804339, worklistShardItemId#13791299L, demandStream#13804320, 30), ENSURE_REQUIREMENTS, [plan_id=13568092]\n +- SortAggregate(key=[demandChannel#13804319, shardId#13791298, knownfloatingpointnormalized(normalizenanandzero(qty#13804339)) AS qty#13804339, worklistShardItemId#13791299L, demandStream#13804320], functions=[partial_first(kpis#13804348, false)], output=[demandChannel#13804319, shardId#13791298, qty#138043... [789791] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999567 {
id="cluster_1999567";
isCluster="true";
label="InMemoryTableScan";
789806 [id="node_789806" labelType="html" label="MapPartitionsRDD [789806] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789807 [id="node_789807" labelType="html" label="MapPartitionsRDD [789807] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789808 [id="node_789808" labelType="html" label="MapPartitionsRDD [789808] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999542 {
id="cluster_1999542";
isCluster="true";
label="WholeStageCodegen (3)";
789809 [id="node_789809" labelType="html" label="MapPartitionsRDD [789809] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999541 {
id="cluster_1999541";
isCluster="true";
label="InMemoryTableScan";
789810 [id="node_789810" labelType="html" label="MapPartitionsRDD [789810] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789811 [id="node_789811" labelType="html" label="*(3) Project [shardId#13791298, worklistShardItemId#13791299L, version#13804810, qty#13804339, demandChannel#13804319, demandStream#13804320, kpis#13804348]\n+- *(3) BroadcastHashJoin [shardId#13791298, worklistShardItemId#13791299L], [shardId#13804815, worklistShardItemId#13804816L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#13791298) AND isnotnull(worklistShardItemId#13791299L))\n : +- InMemoryTableScan [shardId#13791298, worklistShardItemId#13791299L, qty#13804339, demandChannel#13804319, demandStream#13804320, kpis#13804348], [isnotnull(shardId#13791298), isnotnull(worklistShardItemId#13791299L)]\n : +- InMemoryRelation [shardId#13791298, worklistShardItemId#13791299L, qty#13804339, demandChannel#13804319, demandStream#13804320, kpis#13804348], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#13804319, shardId#13791298, qty#13804339, worklistShardItemId#13791299L, demandStream#13804320], functions=[first(kpis#13804348, false)], ou... [789811] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999585 {
id="cluster_1999585";
isCluster="true";
label="InMemoryTableScan";
789820 [id="node_789820" labelType="html" label="MapPartitionsRDD [789820] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789821 [id="node_789821" labelType="html" label="MapPartitionsRDD [789821] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789822 [id="node_789822" labelType="html" label="MapPartitionsRDD [789822] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
789787->789788;
789788->789789;
789789->789790;
789790->789791;
789791->789806;
789806->789807;
789807->789808;
789808->789809;
789809->789810;
789810->789811;
789811->789820;
789820->789821;
789821->789822;
}
789786,789787
789791
789811