digraph G {
id="graph_446162";
subgraph graph_stage_446162 {
id="graph_stage_446162";
isCluster="true";
label="Stage 446162";
subgraph cluster_3151183 {
id="cluster_3151183";
isCluster="true";
label="Exchange";
1243031 [id="node_1243031" labelType="html" label="ShuffledRowRDD [1243031] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151178 {
id="cluster_3151178";
isCluster="true";
label="WholeStageCodegen (5)";
1243032 [id="node_1243032" labelType="html" label="MapPartitionsRDD [1243032] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151177 {
id="cluster_3151177";
isCluster="true";
label="SortAggregate";
1243033 [id="node_1243033" labelType="html" label="MapPartitionsRDD [1243033] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151176 {
id="cluster_3151176";
isCluster="true";
label="InMemoryTableScan";
1243034 [id="node_1243034" labelType="html" label="MapPartitionsRDD [1243034] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243035 [id="node_1243035" labelType="html" label="SortAggregate(key=[demandChannel#21548535, shardId#21517301, qty#21548555, worklistShardItemId#21517302L, demandStream#21548536], functions=[first(kpis#21548564, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21548555, demandChannel#21548535, demandStream#21548536, kpis#21548677])\n+- *(5) Sort [demandChannel#21548535 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21548555 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21548536 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21548535, shardId#21517301, qty#21548555, worklistShardItemId#21517302L, demandStream#21548536, 20), ENSURE_REQUIREMENTS, [plan_id=21357144]\n +- SortAggregate(key=[demandChannel#21548535, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21548555)) AS qty#21548555, worklistShardItemId#21517302L, demandStream#21548536], functions=[partial_first(kpis#21548564, false)], output=[demandChannel#21548535, shardId#21517301, qty#215485... [1243035] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151288 {
id="cluster_3151288";
isCluster="true";
label="InMemoryTableScan";
1243050 [id="node_1243050" labelType="html" label="MapPartitionsRDD [1243050] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243051 [id="node_1243051" labelType="html" label="MapPartitionsRDD [1243051] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243052 [id="node_1243052" labelType="html" label="MapPartitionsRDD [1243052] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151263 {
id="cluster_3151263";
isCluster="true";
label="WholeStageCodegen (3)";
1243053 [id="node_1243053" labelType="html" label="MapPartitionsRDD [1243053] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151262 {
id="cluster_3151262";
isCluster="true";
label="InMemoryTableScan";
1243054 [id="node_1243054" labelType="html" label="MapPartitionsRDD [1243054] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243055 [id="node_1243055" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21549026, qty#21548555, demandChannel#21548535, demandStream#21548536, kpis#21548564]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21549031, worklistShardItemId#21549032L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21548555, demandChannel#21548535, demandStream#21548536, kpis#21548564], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21548555, demandChannel#21548535, demandStream#21548536, kpis#21548564], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21548535, shardId#21517301, qty#21548555, worklistShardItemId#21517302L, demandStream#21548536], functions=[first(kpis#21548564, false)], ou... [1243055] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3151306 {
id="cluster_3151306";
isCluster="true";
label="InMemoryTableScan";
1243064 [id="node_1243064" labelType="html" label="MapPartitionsRDD [1243064] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243065 [id="node_1243065" labelType="html" label="MapPartitionsRDD [1243065] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243066 [id="node_1243066" labelType="html" label="MapPartitionsRDD [1243066] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1243031->1243032;
1243032->1243033;
1243033->1243034;
1243034->1243035;
1243035->1243050;
1243050->1243051;
1243051->1243052;
1243052->1243053;
1243053->1243054;
1243054->1243055;
1243055->1243064;
1243064->1243065;
1243065->1243066;
}
1243030,1243031
1243035
1243055