digraph G {
id="graph_69408";
subgraph graph_stage_69408 {
id="graph_stage_69408";
isCluster="true";
label="Stage 69408";
subgraph cluster_515268 {
id="cluster_515268";
isCluster="true";
label="Exchange";
195590 [id="node_195590" labelType="html" label="ShuffledRowRDD [195590] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515262 {
id="cluster_515262";
isCluster="true";
label="WholeStageCodegen (5)";
195591 [id="node_195591" labelType="html" label="MapPartitionsRDD [195591] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515261 {
id="cluster_515261";
isCluster="true";
label="SortAggregate";
195592 [id="node_195592" labelType="html" label="MapPartitionsRDD [195592] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515260 {
id="cluster_515260";
isCluster="true";
label="InMemoryTableScan";
195593 [id="node_195593" labelType="html" label="MapPartitionsRDD [195593] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195594 [id="node_195594" labelType="html" label="SortAggregate(key=[demandChannel#3462308, shardId#3371037, qty#3462328, worklistShardItemId#3371038L, demandStream#3462309], functions=[first(kpis#3462337, false)], output=[shardId#3371037, worklistShardItemId#3371038L, qty#3462328, demandChannel#3462308, demandStream#3462309, kpis#3462450])\n+- *(5) Sort [demandChannel#3462308 ASC NULLS FIRST, shardId#3371037 ASC NULLS FIRST, qty#3462328 ASC NULLS FIRST, worklistShardItemId#3371038L ASC NULLS FIRST, demandStream#3462309 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#3462308, shardId#3371037, qty#3462328, worklistShardItemId#3371038L, demandStream#3462309, 30), ENSURE_REQUIREMENTS, [plan_id=5497326]\n +- SortAggregate(key=[demandChannel#3462308, shardId#3371037, knownfloatingpointnormalized(normalizenanandzero(qty#3462328)) AS qty#3462328, worklistShardItemId#3371038L, demandStream#3462309], functions=[partial_first(kpis#3462337, false)], output=[demandChannel#3462308, shardId#3371037, qty#3462328, worklistShardItemId#3371038L,... [195594] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515372 {
id="cluster_515372";
isCluster="true";
label="InMemoryTableScan";
195609 [id="node_195609" labelType="html" label="MapPartitionsRDD [195609] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195610 [id="node_195610" labelType="html" label="MapPartitionsRDD [195610] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195611 [id="node_195611" labelType="html" label="MapPartitionsRDD [195611] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515347 {
id="cluster_515347";
isCluster="true";
label="WholeStageCodegen (3)";
195612 [id="node_195612" labelType="html" label="MapPartitionsRDD [195612] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515346 {
id="cluster_515346";
isCluster="true";
label="InMemoryTableScan";
195613 [id="node_195613" labelType="html" label="MapPartitionsRDD [195613] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195614 [id="node_195614" labelType="html" label="*(3) Project [shardId#3371037, worklistShardItemId#3371038L, version#3462799, qty#3462328, demandChannel#3462308, demandStream#3462309, kpis#3462337]\n+- *(3) BroadcastHashJoin [shardId#3371037, worklistShardItemId#3371038L], [shardId#3462804, worklistShardItemId#3462805L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#3371037) AND isnotnull(worklistShardItemId#3371038L))\n : +- InMemoryTableScan [shardId#3371037, worklistShardItemId#3371038L, qty#3462328, demandChannel#3462308, demandStream#3462309, kpis#3462337], [isnotnull(shardId#3371037), isnotnull(worklistShardItemId#3371038L)]\n : +- InMemoryRelation [shardId#3371037, worklistShardItemId#3371038L, qty#3462328, demandChannel#3462308, demandStream#3462309, kpis#3462337], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#3462308, shardId#3371037, qty#3462328, worklistShardItemId#3371038L, demandStream#3462309], functions=[first(kpis#3462337, false)], output=[shardId#3371037, worklistSh... [195614] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515390 {
id="cluster_515390";
isCluster="true";
label="InMemoryTableScan";
195623 [id="node_195623" labelType="html" label="MapPartitionsRDD [195623] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195624 [id="node_195624" labelType="html" label="MapPartitionsRDD [195624] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195625 [id="node_195625" labelType="html" label="MapPartitionsRDD [195625] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
195590->195591;
195591->195592;
195592->195593;
195593->195594;
195594->195609;
195609->195610;
195610->195611;
195611->195612;
195612->195613;
195613->195614;
195614->195623;
195623->195624;
195624->195625;
}
195589,195590
195594
195614