digraph G {
id="graph_446237";
subgraph graph_stage_446237 {
id="graph_stage_446237";
isCluster="true";
label="Stage 446237";
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}"];
}
subgraph cluster_3151830 {
id="cluster_3151830";
isCluster="true";
label="InMemoryTableScan";
1243278 [id="node_1243278" labelType="html" label="MapPartitionsRDD [1243278] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243279 [id="node_1243279" labelType="html" label="MapPartitionsRDD [1243279] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243280 [id="node_1243280" labelType="html" label="MapPartitionsRDD [1243280] [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->1243278;
1243278->1243279;
1243279->1243280;
}
1243244,1243245
1243249
1243269