digraph G {
id="graph_1328";
subgraph graph_stage_1328 {
id="graph_stage_1328";
isCluster="true";
label="Stage 1328";
subgraph cluster_10905 {
id="cluster_10905";
isCluster="true";
label="Exchange";
3412 [id="node_3412" labelType="html" label="ShuffledRowRDD [3412] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10900 {
id="cluster_10900";
isCluster="true";
label="WholeStageCodegen (5)";
3413 [id="node_3413" labelType="html" label="MapPartitionsRDD [3413] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10899 {
id="cluster_10899";
isCluster="true";
label="SortAggregate";
3414 [id="node_3414" labelType="html" label="MapPartitionsRDD [3414] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10898 {
id="cluster_10898";
isCluster="true";
label="InMemoryTableScan";
3415 [id="node_3415" labelType="html" label="MapPartitionsRDD [3415] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3416 [id="node_3416" labelType="html" label="SortAggregate(key=[demandChannel#66516, shardId#49871, qty#66536, worklistShardItemId#49872L, demandStream#66517], functions=[first(kpis#66545, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#66536, demandChannel#66516, demandStream#66517, kpis#66658])\n+- *(5) Sort [demandChannel#66516 ASC NULLS FIRST, shardId#49871 ASC NULLS FIRST, qty#66536 ASC NULLS FIRST, worklistShardItemId#49872L ASC NULLS FIRST, demandStream#66517 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#66516, shardId#49871, qty#66536, worklistShardItemId#49872L, demandStream#66517, 8), ENSURE_REQUIREMENTS, [plan_id=329676]\n +- SortAggregate(key=[demandChannel#66516, shardId#49871, knownfloatingpointnormalized(normalizenanandzero(qty#66536)) AS qty#66536, worklistShardItemId#49872L, demandStream#66517], functions=[partial_first(kpis#66545, false)], output=[demandChannel#66516, shardId#49871, qty#66536, worklistShardItemId#49872L, demandStream#66517, first#66724, valueSet#66725])\n +- *(4) ... [3416] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_11010 {
id="cluster_11010";
isCluster="true";
label="InMemoryTableScan";
3431 [id="node_3431" labelType="html" label="MapPartitionsRDD [3431] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3432 [id="node_3432" labelType="html" label="MapPartitionsRDD [3432] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3433 [id="node_3433" labelType="html" label="MapPartitionsRDD [3433] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10985 {
id="cluster_10985";
isCluster="true";
label="WholeStageCodegen (3)";
3434 [id="node_3434" labelType="html" label="MapPartitionsRDD [3434] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10984 {
id="cluster_10984";
isCluster="true";
label="InMemoryTableScan";
3435 [id="node_3435" labelType="html" label="MapPartitionsRDD [3435] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3436 [id="node_3436" labelType="html" label="*(3) Project [shardId#49871, worklistShardItemId#49872L, version#67007, qty#66536, demandChannel#66516, demandStream#66517, kpis#66545]\n+- *(3) BroadcastHashJoin [shardId#49871, worklistShardItemId#49872L], [shardId#67012, worklistShardItemId#67013L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#49871) AND isnotnull(worklistShardItemId#49872L))\n : +- InMemoryTableScan [shardId#49871, worklistShardItemId#49872L, qty#66536, demandChannel#66516, demandStream#66517, kpis#66545], [isnotnull(shardId#49871), isnotnull(worklistShardItemId#49872L)]\n : +- InMemoryRelation [shardId#49871, worklistShardItemId#49872L, qty#66536, demandChannel#66516, demandStream#66517, kpis#66545], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#66516, shardId#49871, qty#66536, worklistShardItemId#49872L, demandStream#66517], functions=[first(kpis#66545, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#66536, demandChannel#66516, demandStream#66517... [3436] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3437 [id="node_3437" labelType="html" label="MapPartitionsRDD [3437] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3438 [id="node_3438" labelType="html" label="MapPartitionsRDD [3438] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3439 [id="node_3439" labelType="html" label="MapPartitionsRDD [3439] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_10983 {
id="cluster_10983";
isCluster="true";
label="CollectLimit";
3440 [id="node_3440" labelType="html" label="MapPartitionsRDD [3440] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
3441 [id="node_3441" labelType="html" label="MapPartitionsRDD [3441] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
3412->3413;
3413->3414;
3414->3415;
3415->3416;
3416->3431;
3431->3432;
3432->3433;
3433->3434;
3434->3435;
3435->3436;
3436->3437;
3437->3438;
3438->3439;
3439->3440;
3440->3441;
}
3411,3412
3416
3436