digraph G {
id="graph_69400";
subgraph graph_stage_69400 {
id="graph_stage_69400";
isCluster="true";
label="Stage 69400";
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}"];
195615 [id="node_195615" labelType="html" label="MapPartitionsRDD [195615] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195616 [id="node_195616" labelType="html" label="MapPartitionsRDD [195616] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195617 [id="node_195617" labelType="html" label="MapPartitionsRDD [195617] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_515345 {
id="cluster_515345";
isCluster="true";
label="CollectLimit";
195618 [id="node_195618" labelType="html" label="MapPartitionsRDD [195618] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
195619 [id="node_195619" labelType="html" label="MapPartitionsRDD [195619] [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->195615;
195615->195616;
195616->195617;
195617->195618;
195618->195619;
}
195589,195590
195594
195614