digraph G {
id="graph_172755";
subgraph graph_stage_172755 {
id="graph_stage_172755";
isCluster="true";
label="Stage 172755";
subgraph cluster_1240178 {
id="cluster_1240178";
isCluster="true";
label="Exchange";
482401 [id="node_482401" labelType="html" label="ShuffledRowRDD [482401] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240171 {
id="cluster_1240171";
isCluster="true";
label="WholeStageCodegen (5)";
482402 [id="node_482402" labelType="html" label="MapPartitionsRDD [482402] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240170 {
id="cluster_1240170";
isCluster="true";
label="SortAggregate";
482403 [id="node_482403" labelType="html" label="MapPartitionsRDD [482403] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240169 {
id="cluster_1240169";
isCluster="true";
label="InMemoryTableScan";
482404 [id="node_482404" labelType="html" label="MapPartitionsRDD [482404] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482405 [id="node_482405" labelType="html" label="SortAggregate(key=[demandChannel#8539268, shardId#7905118, qty#8539288, worklistShardItemId#7905119L, demandStream#8539269], functions=[first(kpis#8539297, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8539288, demandChannel#8539268, demandStream#8539269, kpis#8539410])\n+- *(5) Sort [demandChannel#8539268 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8539288 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8539269 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8539268, shardId#7905118, qty#8539288, worklistShardItemId#7905119L, demandStream#8539269, 30), ENSURE_REQUIREMENTS, [plan_id=11182753]\n +- SortAggregate(key=[demandChannel#8539268, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8539288)) AS qty#8539288, worklistShardItemId#7905119L, demandStream#8539269], functions=[partial_first(kpis#8539297, false)], output=[demandChannel#8539268, shardId#7905118, qty#8539288, worklistShardItemId#7905119L... [482405] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240281 {
id="cluster_1240281";
isCluster="true";
label="InMemoryTableScan";
482420 [id="node_482420" labelType="html" label="MapPartitionsRDD [482420] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482421 [id="node_482421" labelType="html" label="MapPartitionsRDD [482421] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482422 [id="node_482422" labelType="html" label="MapPartitionsRDD [482422] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240256 {
id="cluster_1240256";
isCluster="true";
label="WholeStageCodegen (3)";
482423 [id="node_482423" labelType="html" label="MapPartitionsRDD [482423] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240255 {
id="cluster_1240255";
isCluster="true";
label="InMemoryTableScan";
482424 [id="node_482424" labelType="html" label="MapPartitionsRDD [482424] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482425 [id="node_482425" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8539759, qty#8539288, demandChannel#8539268, demandStream#8539269, kpis#8539297]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8539764, worklistShardItemId#8539765L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8539288, demandChannel#8539268, demandStream#8539269, kpis#8539297], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8539288, demandChannel#8539268, demandStream#8539269, kpis#8539297], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8539268, shardId#7905118, qty#8539288, worklistShardItemId#7905119L, demandStream#8539269], functions=[first(kpis#8539297, false)], output=[shardId#7905118, worklistSh... [482425] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482426 [id="node_482426" labelType="html" label="MapPartitionsRDD [482426] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482427 [id="node_482427" labelType="html" label="MapPartitionsRDD [482427] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482428 [id="node_482428" labelType="html" label="MapPartitionsRDD [482428] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1240254 {
id="cluster_1240254";
isCluster="true";
label="CollectLimit";
482429 [id="node_482429" labelType="html" label="MapPartitionsRDD [482429] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482430 [id="node_482430" labelType="html" label="MapPartitionsRDD [482430] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
482401->482402;
482402->482403;
482403->482404;
482404->482405;
482405->482420;
482420->482421;
482421->482422;
482422->482423;
482423->482424;
482424->482425;
482425->482426;
482426->482427;
482427->482428;
482428->482429;
482429->482430;
}
482400,482401
482405
482425