digraph G {
id="graph_446229";
subgraph graph_stage_446229 {
id="graph_stage_446229";
isCluster="true";
label="Stage 446229";
subgraph cluster_3151707 {
id="cluster_3151707";
isCluster="true";
label="Exchange";
1243245 [id="node_1243245" labelType="html" label="ShuffledRowRDD [1243245] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151702 {
id="cluster_3151702";
isCluster="true";
label="WholeStageCodegen (5)";
1243246 [id="node_1243246" labelType="html" label="MapPartitionsRDD [1243246] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151701 {
id="cluster_3151701";
isCluster="true";
label="SortAggregate";
1243247 [id="node_1243247" labelType="html" label="MapPartitionsRDD [1243247] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151700 {
id="cluster_3151700";
isCluster="true";
label="InMemoryTableScan";
1243248 [id="node_1243248" labelType="html" label="MapPartitionsRDD [1243248] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243249 [id="node_1243249" labelType="html" label="SortAggregate(key=[demandChannel#21552270, shardId#21517301, qty#21552290, worklistShardItemId#21517302L, demandStream#21552271], functions=[first(kpis#21552299, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21552290, demandChannel#21552270, demandStream#21552271, kpis#21552412])\n+- *(5) Sort [demandChannel#21552270 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21552290 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21552271 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21552270, shardId#21517301, qty#21552290, worklistShardItemId#21517302L, demandStream#21552271, 20), ENSURE_REQUIREMENTS, [plan_id=21358619]\n +- SortAggregate(key=[demandChannel#21552270, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21552290)) AS qty#21552290, worklistShardItemId#21517302L, demandStream#21552271], functions=[partial_first(kpis#21552299, false)], output=[demandChannel#21552270, shardId#21517301, qty#215522... [1243249] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151812 {
id="cluster_3151812";
isCluster="true";
label="InMemoryTableScan";
1243264 [id="node_1243264" labelType="html" label="MapPartitionsRDD [1243264] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243265 [id="node_1243265" labelType="html" label="MapPartitionsRDD [1243265] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243266 [id="node_1243266" labelType="html" label="MapPartitionsRDD [1243266] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151787 {
id="cluster_3151787";
isCluster="true";
label="WholeStageCodegen (3)";
1243267 [id="node_1243267" labelType="html" label="MapPartitionsRDD [1243267] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151786 {
id="cluster_3151786";
isCluster="true";
label="InMemoryTableScan";
1243268 [id="node_1243268" labelType="html" label="MapPartitionsRDD [1243268] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243269 [id="node_1243269" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21552761, qty#21552290, demandChannel#21552270, demandStream#21552271, kpis#21552299]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21552766, worklistShardItemId#21552767L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21552290, demandChannel#21552270, demandStream#21552271, kpis#21552299], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21552290, demandChannel#21552270, demandStream#21552271, kpis#21552299], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21552270, shardId#21517301, qty#21552290, worklistShardItemId#21517302L, demandStream#21552271], functions=[first(kpis#21552299, false)], ou... [1243269] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243270 [id="node_1243270" labelType="html" label="MapPartitionsRDD [1243270] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243271 [id="node_1243271" labelType="html" label="MapPartitionsRDD [1243271] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243272 [id="node_1243272" labelType="html" label="MapPartitionsRDD [1243272] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151785 {
id="cluster_3151785";
isCluster="true";
label="CollectLimit";
1243273 [id="node_1243273" labelType="html" label="MapPartitionsRDD [1243273] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243274 [id="node_1243274" labelType="html" label="MapPartitionsRDD [1243274] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1243245->1243246;
1243246->1243247;
1243247->1243248;
1243248->1243249;
1243249->1243264;
1243264->1243265;
1243265->1243266;
1243266->1243267;
1243267->1243268;
1243268->1243269;
1243269->1243270;
1243270->1243271;
1243271->1243272;
1243272->1243273;
1243273->1243274;
}
1243244,1243245
1243249
1243269