digraph G {
id="graph_173131";
subgraph graph_stage_173131 {
id="graph_stage_173131";
isCluster="true";
label="Stage 173131";
subgraph cluster_1242819 {
id="cluster_1242819";
isCluster="true";
label="Exchange";
483479 [id="node_483479" labelType="html" label="ShuffledRowRDD [483479] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242813 {
id="cluster_1242813";
isCluster="true";
label="WholeStageCodegen (5)";
483480 [id="node_483480" labelType="html" label="MapPartitionsRDD [483480] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242812 {
id="cluster_1242812";
isCluster="true";
label="SortAggregate";
483481 [id="node_483481" labelType="html" label="MapPartitionsRDD [483481] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242811 {
id="cluster_1242811";
isCluster="true";
label="InMemoryTableScan";
483482 [id="node_483482" labelType="html" label="MapPartitionsRDD [483482] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483483 [id="node_483483" labelType="html" label="SortAggregate(key=[demandChannel#8557975, shardId#7905118, qty#8557995, worklistShardItemId#7905119L, demandStream#8557976], functions=[first(kpis#8558004, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8557995, demandChannel#8557975, demandStream#8557976, kpis#8558117])\n+- *(5) Sort [demandChannel#8557975 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8557995 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8557976 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8557975, shardId#7905118, qty#8557995, worklistShardItemId#7905119L, demandStream#8557976, 30), ENSURE_REQUIREMENTS, [plan_id=11190146]\n +- SortAggregate(key=[demandChannel#8557975, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8557995)) AS qty#8557995, worklistShardItemId#7905119L, demandStream#8557976], functions=[partial_first(kpis#8558004, false)], output=[demandChannel#8557975, shardId#7905118, qty#8557995, worklistShardItemId#7905119L... [483483] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242923 {
id="cluster_1242923";
isCluster="true";
label="InMemoryTableScan";
483498 [id="node_483498" labelType="html" label="MapPartitionsRDD [483498] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483499 [id="node_483499" labelType="html" label="MapPartitionsRDD [483499] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483500 [id="node_483500" labelType="html" label="MapPartitionsRDD [483500] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242898 {
id="cluster_1242898";
isCluster="true";
label="WholeStageCodegen (3)";
483501 [id="node_483501" labelType="html" label="MapPartitionsRDD [483501] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242897 {
id="cluster_1242897";
isCluster="true";
label="InMemoryTableScan";
483502 [id="node_483502" labelType="html" label="MapPartitionsRDD [483502] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483503 [id="node_483503" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8558466, qty#8557995, demandChannel#8557975, demandStream#8557976, kpis#8558004]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8558471, worklistShardItemId#8558472L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8557995, demandChannel#8557975, demandStream#8557976, kpis#8558004], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8557995, demandChannel#8557975, demandStream#8557976, kpis#8558004], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8557975, shardId#7905118, qty#8557995, worklistShardItemId#7905119L, demandStream#8557976], functions=[first(kpis#8558004, false)], output=[shardId#7905118, worklistSh... [483503] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483504 [id="node_483504" labelType="html" label="MapPartitionsRDD [483504] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483505 [id="node_483505" labelType="html" label="MapPartitionsRDD [483505] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483506 [id="node_483506" labelType="html" label="MapPartitionsRDD [483506] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1242896 {
id="cluster_1242896";
isCluster="true";
label="CollectLimit";
483507 [id="node_483507" labelType="html" label="MapPartitionsRDD [483507] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
483508 [id="node_483508" labelType="html" label="MapPartitionsRDD [483508] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
483479->483480;
483480->483481;
483481->483482;
483482->483483;
483483->483498;
483498->483499;
483499->483500;
483500->483501;
483501->483502;
483502->483503;
483503->483504;
483504->483505;
483505->483506;
483506->483507;
483507->483508;
}
483478,483479
483483
483503