digraph G {
id="graph_445854";
subgraph graph_stage_445854 {
id="graph_stage_445854";
isCluster="true";
label="Stage 445854";
subgraph cluster_3149028 {
id="cluster_3149028";
isCluster="true";
label="Exchange";
1242145 [id="node_1242145" labelType="html" label="ShuffledRowRDD [1242145] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149022 {
id="cluster_3149022";
isCluster="true";
label="WholeStageCodegen (5)";
1242146 [id="node_1242146" labelType="html" label="MapPartitionsRDD [1242146] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149021 {
id="cluster_3149021";
isCluster="true";
label="SortAggregate";
1242147 [id="node_1242147" labelType="html" label="MapPartitionsRDD [1242147] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149020 {
id="cluster_3149020";
isCluster="true";
label="InMemoryTableScan";
1242148 [id="node_1242148" labelType="html" label="MapPartitionsRDD [1242148] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242149 [id="node_1242149" labelType="html" label="SortAggregate(key=[demandChannel#21533202, shardId#21517301, qty#21533222, worklistShardItemId#21517302L, demandStream#21533203], functions=[first(kpis#21533231, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21533222, demandChannel#21533202, demandStream#21533203, kpis#21533344])\n+- *(5) Sort [demandChannel#21533202 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21533222 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21533203 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21533202, shardId#21517301, qty#21533222, worklistShardItemId#21517302L, demandStream#21533203, 20), ENSURE_REQUIREMENTS, [plan_id=21351252]\n +- SortAggregate(key=[demandChannel#21533202, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21533222)) AS qty#21533222, worklistShardItemId#21517302L, demandStream#21533203], functions=[partial_first(kpis#21533231, false)], output=[demandChannel#21533202, shardId#21517301, qty#215332... [1242149] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149132 {
id="cluster_3149132";
isCluster="true";
label="InMemoryTableScan";
1242164 [id="node_1242164" labelType="html" label="MapPartitionsRDD [1242164] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242165 [id="node_1242165" labelType="html" label="MapPartitionsRDD [1242165] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242166 [id="node_1242166" labelType="html" label="MapPartitionsRDD [1242166] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149107 {
id="cluster_3149107";
isCluster="true";
label="WholeStageCodegen (3)";
1242167 [id="node_1242167" labelType="html" label="MapPartitionsRDD [1242167] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149106 {
id="cluster_3149106";
isCluster="true";
label="InMemoryTableScan";
1242168 [id="node_1242168" labelType="html" label="MapPartitionsRDD [1242168] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242169 [id="node_1242169" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21533693, qty#21533222, demandChannel#21533202, demandStream#21533203, kpis#21533231]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21533698, worklistShardItemId#21533699L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21533222, demandChannel#21533202, demandStream#21533203, kpis#21533231], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21533222, demandChannel#21533202, demandStream#21533203, kpis#21533231], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21533202, shardId#21517301, qty#21533222, worklistShardItemId#21517302L, demandStream#21533203], functions=[first(kpis#21533231, false)], ou... [1242169] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242170 [id="node_1242170" labelType="html" label="MapPartitionsRDD [1242170] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242171 [id="node_1242171" labelType="html" label="MapPartitionsRDD [1242171] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242172 [id="node_1242172" labelType="html" label="MapPartitionsRDD [1242172] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149105 {
id="cluster_3149105";
isCluster="true";
label="CollectLimit";
1242173 [id="node_1242173" labelType="html" label="MapPartitionsRDD [1242173] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242174 [id="node_1242174" labelType="html" label="MapPartitionsRDD [1242174] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1242145->1242146;
1242146->1242147;
1242147->1242148;
1242148->1242149;
1242149->1242164;
1242164->1242165;
1242165->1242166;
1242166->1242167;
1242167->1242168;
1242168->1242169;
1242169->1242170;
1242170->1242171;
1242171->1242172;
1242172->1242173;
1242173->1242174;
}
1242144,1242145
1242149
1242169