digraph G {
id="graph_69333";
subgraph graph_stage_69333 {
id="graph_stage_69333";
isCluster="true";
label="Stage 69333";
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}"];
}
subgraph cluster_514866 {
id="cluster_514866";
isCluster="true";
label="InMemoryTableScan";
195409 [id="node_195409" labelType="html" label="MapPartitionsRDD [195409] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195410 [id="node_195410" labelType="html" label="MapPartitionsRDD [195410] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195411 [id="node_195411" labelType="html" label="MapPartitionsRDD [195411] [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->195409;
195409->195410;
195410->195411;
}
195375,195376
195380
195400