digraph G {
id="graph_172221";
subgraph graph_stage_172221 {
id="graph_stage_172221";
isCluster="true";
label="Stage 172221";
subgraph cluster_1236393 {
id="cluster_1236393";
isCluster="true";
label="Exchange";
480856 [id="node_480856" labelType="html" label="ShuffledRowRDD [480856] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236387 {
id="cluster_1236387";
isCluster="true";
label="WholeStageCodegen (5)";
480857 [id="node_480857" labelType="html" label="MapPartitionsRDD [480857] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236386 {
id="cluster_1236386";
isCluster="true";
label="SortAggregate";
480858 [id="node_480858" labelType="html" label="MapPartitionsRDD [480858] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236385 {
id="cluster_1236385";
isCluster="true";
label="InMemoryTableScan";
480859 [id="node_480859" labelType="html" label="MapPartitionsRDD [480859] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480860 [id="node_480860" labelType="html" label="SortAggregate(key=[demandChannel#8512528, shardId#7905118, qty#8512548, worklistShardItemId#7905119L, demandStream#8512529], functions=[first(kpis#8512557, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8512548, demandChannel#8512528, demandStream#8512529, kpis#8512670])\n+- *(5) Sort [demandChannel#8512528 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8512548 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8512529 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8512528, shardId#7905118, qty#8512548, worklistShardItemId#7905119L, demandStream#8512529, 30), ENSURE_REQUIREMENTS, [plan_id=11172210]\n +- SortAggregate(key=[demandChannel#8512528, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8512548)) AS qty#8512548, worklistShardItemId#7905119L, demandStream#8512529], functions=[partial_first(kpis#8512557, false)], output=[demandChannel#8512528, shardId#7905118, qty#8512548, worklistShardItemId#7905119L... [480860] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236497 {
id="cluster_1236497";
isCluster="true";
label="InMemoryTableScan";
480875 [id="node_480875" labelType="html" label="MapPartitionsRDD [480875] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480876 [id="node_480876" labelType="html" label="MapPartitionsRDD [480876] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480877 [id="node_480877" labelType="html" label="MapPartitionsRDD [480877] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236472 {
id="cluster_1236472";
isCluster="true";
label="WholeStageCodegen (3)";
480878 [id="node_480878" labelType="html" label="MapPartitionsRDD [480878] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236471 {
id="cluster_1236471";
isCluster="true";
label="InMemoryTableScan";
480879 [id="node_480879" labelType="html" label="MapPartitionsRDD [480879] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480880 [id="node_480880" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8513019, qty#8512548, demandChannel#8512528, demandStream#8512529, kpis#8512557]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8513024, worklistShardItemId#8513025L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8512548, demandChannel#8512528, demandStream#8512529, kpis#8512557], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8512548, demandChannel#8512528, demandStream#8512529, kpis#8512557], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8512528, shardId#7905118, qty#8512548, worklistShardItemId#7905119L, demandStream#8512529], functions=[first(kpis#8512557, false)], output=[shardId#7905118, worklistSh... [480880] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480881 [id="node_480881" labelType="html" label="MapPartitionsRDD [480881] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480882 [id="node_480882" labelType="html" label="MapPartitionsRDD [480882] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480883 [id="node_480883" labelType="html" label="MapPartitionsRDD [480883] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1236470 {
id="cluster_1236470";
isCluster="true";
label="CollectLimit";
480884 [id="node_480884" labelType="html" label="MapPartitionsRDD [480884] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
480885 [id="node_480885" labelType="html" label="MapPartitionsRDD [480885] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
480856->480857;
480857->480858;
480858->480859;
480859->480860;
480860->480875;
480875->480876;
480876->480877;
480877->480878;
480878->480879;
480879->480880;
480880->480881;
480881->480882;
480882->480883;
480883->480884;
480884->480885;
}
480855,480856
480860
480880