digraph G {
id="graph_69486";
subgraph graph_stage_69486 {
id="graph_stage_69486";
isCluster="true";
label="Stage 69486";
subgraph cluster_515840 {
id="cluster_515840";
isCluster="true";
label="Exchange";
195825 [id="node_195825" labelType="html" label="ShuffledRowRDD [195825] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515835 {
id="cluster_515835";
isCluster="true";
label="WholeStageCodegen (5)";
195826 [id="node_195826" labelType="html" label="MapPartitionsRDD [195826] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515834 {
id="cluster_515834";
isCluster="true";
label="SortAggregate";
195827 [id="node_195827" labelType="html" label="MapPartitionsRDD [195827] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515833 {
id="cluster_515833";
isCluster="true";
label="InMemoryTableScan";
195828 [id="node_195828" labelType="html" label="MapPartitionsRDD [195828] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195829 [id="node_195829" labelType="html" label="SortAggregate(key=[demandChannel#3466316, shardId#3371037, qty#3466336, worklistShardItemId#3371038L, demandStream#3466317], functions=[first(kpis#3466345, false)], output=[shardId#3371037, worklistShardItemId#3371038L, qty#3466336, demandChannel#3466316, demandStream#3466317, kpis#3466458])\n+- *(5) Sort [demandChannel#3466316 ASC NULLS FIRST, shardId#3371037 ASC NULLS FIRST, qty#3466336 ASC NULLS FIRST, worklistShardItemId#3371038L ASC NULLS FIRST, demandStream#3466317 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#3466316, shardId#3371037, qty#3466336, worklistShardItemId#3371038L, demandStream#3466317, 30), ENSURE_REQUIREMENTS, [plan_id=5498850]\n +- SortAggregate(key=[demandChannel#3466316, shardId#3371037, knownfloatingpointnormalized(normalizenanandzero(qty#3466336)) AS qty#3466336, worklistShardItemId#3371038L, demandStream#3466317], functions=[partial_first(kpis#3466345, false)], output=[demandChannel#3466316, shardId#3371037, qty#3466336, worklistShardItemId#3371038L,... [195829] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515945 {
id="cluster_515945";
isCluster="true";
label="InMemoryTableScan";
195844 [id="node_195844" labelType="html" label="MapPartitionsRDD [195844] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195845 [id="node_195845" labelType="html" label="MapPartitionsRDD [195845] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195846 [id="node_195846" labelType="html" label="MapPartitionsRDD [195846] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515920 {
id="cluster_515920";
isCluster="true";
label="WholeStageCodegen (3)";
195847 [id="node_195847" labelType="html" label="MapPartitionsRDD [195847] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515919 {
id="cluster_515919";
isCluster="true";
label="InMemoryTableScan";
195848 [id="node_195848" labelType="html" label="MapPartitionsRDD [195848] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195849 [id="node_195849" labelType="html" label="*(3) Project [shardId#3371037, worklistShardItemId#3371038L, version#3466807, qty#3466336, demandChannel#3466316, demandStream#3466317, kpis#3466345]\n+- *(3) BroadcastHashJoin [shardId#3371037, worklistShardItemId#3371038L], [shardId#3466812, worklistShardItemId#3466813L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#3371037) AND isnotnull(worklistShardItemId#3371038L))\n : +- InMemoryTableScan [shardId#3371037, worklistShardItemId#3371038L, qty#3466336, demandChannel#3466316, demandStream#3466317, kpis#3466345], [isnotnull(shardId#3371037), isnotnull(worklistShardItemId#3371038L)]\n : +- InMemoryRelation [shardId#3371037, worklistShardItemId#3371038L, qty#3466336, demandChannel#3466316, demandStream#3466317, kpis#3466345], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#3466316, shardId#3371037, qty#3466336, worklistShardItemId#3371038L, demandStream#3466317], functions=[first(kpis#3466345, false)], output=[shardId#3371037, worklistSh... [195849] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515963 {
id="cluster_515963";
isCluster="true";
label="InMemoryTableScan";
195858 [id="node_195858" labelType="html" label="MapPartitionsRDD [195858] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195859 [id="node_195859" labelType="html" label="MapPartitionsRDD [195859] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195860 [id="node_195860" labelType="html" label="MapPartitionsRDD [195860] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
195825->195826;
195826->195827;
195827->195828;
195828->195829;
195829->195844;
195844->195845;
195845->195846;
195846->195847;
195847->195848;
195848->195849;
195849->195858;
195858->195859;
195859->195860;
}
195824,195825
195829
195849