digraph G {
id="graph_69325";
subgraph graph_stage_69325 {
id="graph_stage_69325";
isCluster="true";
label="Stage 69325";
subgraph cluster_514744 {
id="cluster_514744";
isCluster="true";
label="Exchange";
195376 [id="node_195376" labelType="html" label="ShuffledRowRDD [195376] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514738 {
id="cluster_514738";
isCluster="true";
label="WholeStageCodegen (5)";
195377 [id="node_195377" labelType="html" label="MapPartitionsRDD [195377] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514737 {
id="cluster_514737";
isCluster="true";
label="SortAggregate";
195378 [id="node_195378" labelType="html" label="MapPartitionsRDD [195378] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514736 {
id="cluster_514736";
isCluster="true";
label="InMemoryTableScan";
195379 [id="node_195379" labelType="html" label="MapPartitionsRDD [195379] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195380 [id="node_195380" labelType="html" label="SortAggregate(key=[demandChannel#3458573, shardId#3371037, qty#3458593, worklistShardItemId#3371038L, demandStream#3458574], functions=[first(kpis#3458602, false)], output=[shardId#3371037, worklistShardItemId#3371038L, qty#3458593, demandChannel#3458573, demandStream#3458574, kpis#3458715])\n+- *(5) Sort [demandChannel#3458573 ASC NULLS FIRST, shardId#3371037 ASC NULLS FIRST, qty#3458593 ASC NULLS FIRST, worklistShardItemId#3371038L ASC NULLS FIRST, demandStream#3458574 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#3458573, shardId#3371037, qty#3458593, worklistShardItemId#3371038L, demandStream#3458574, 30), ENSURE_REQUIREMENTS, [plan_id=5495851]\n +- SortAggregate(key=[demandChannel#3458573, shardId#3371037, knownfloatingpointnormalized(normalizenanandzero(qty#3458593)) AS qty#3458593, worklistShardItemId#3371038L, demandStream#3458574], functions=[partial_first(kpis#3458602, false)], output=[demandChannel#3458573, shardId#3371037, qty#3458593, worklistShardItemId#3371038L,... [195380] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514848 {
id="cluster_514848";
isCluster="true";
label="InMemoryTableScan";
195395 [id="node_195395" labelType="html" label="MapPartitionsRDD [195395] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195396 [id="node_195396" labelType="html" label="MapPartitionsRDD [195396] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195397 [id="node_195397" labelType="html" label="MapPartitionsRDD [195397] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514823 {
id="cluster_514823";
isCluster="true";
label="WholeStageCodegen (3)";
195398 [id="node_195398" labelType="html" label="MapPartitionsRDD [195398] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514822 {
id="cluster_514822";
isCluster="true";
label="InMemoryTableScan";
195399 [id="node_195399" labelType="html" label="MapPartitionsRDD [195399] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195400 [id="node_195400" labelType="html" label="*(3) Project [shardId#3371037, worklistShardItemId#3371038L, version#3459064, qty#3458593, demandChannel#3458573, demandStream#3458574, kpis#3458602]\n+- *(3) BroadcastHashJoin [shardId#3371037, worklistShardItemId#3371038L], [shardId#3459069, worklistShardItemId#3459070L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#3371037) AND isnotnull(worklistShardItemId#3371038L))\n : +- InMemoryTableScan [shardId#3371037, worklistShardItemId#3371038L, qty#3458593, demandChannel#3458573, demandStream#3458574, kpis#3458602], [isnotnull(shardId#3371037), isnotnull(worklistShardItemId#3371038L)]\n : +- InMemoryRelation [shardId#3371037, worklistShardItemId#3371038L, qty#3458593, demandChannel#3458573, demandStream#3458574, kpis#3458602], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#3458573, shardId#3371037, qty#3458593, worklistShardItemId#3371038L, demandStream#3458574], functions=[first(kpis#3458602, false)], output=[shardId#3371037, worklistSh... [195400] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195401 [id="node_195401" labelType="html" label="MapPartitionsRDD [195401] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195402 [id="node_195402" labelType="html" label="MapPartitionsRDD [195402] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195403 [id="node_195403" labelType="html" label="MapPartitionsRDD [195403] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_514821 {
id="cluster_514821";
isCluster="true";
label="CollectLimit";
195404 [id="node_195404" labelType="html" label="MapPartitionsRDD [195404] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195405 [id="node_195405" labelType="html" label="MapPartitionsRDD [195405] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
195376->195377;
195377->195378;
195378->195379;
195379->195380;
195380->195395;
195395->195396;
195396->195397;
195397->195398;
195398->195399;
195399->195400;
195400->195401;
195401->195402;
195402->195403;
195403->195404;
195404->195405;
}
195375,195376
195380
195400