digraph G {
id="graph_69561";
subgraph graph_stage_69561 {
id="graph_stage_69561";
isCluster="true";
label="Stage 69561";
subgraph cluster_516365 {
id="cluster_516365";
isCluster="true";
label="Exchange";
196039 [id="node_196039" labelType="html" label="ShuffledRowRDD [196039] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516359 {
id="cluster_516359";
isCluster="true";
label="WholeStageCodegen (5)";
196040 [id="node_196040" labelType="html" label="MapPartitionsRDD [196040] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516358 {
id="cluster_516358";
isCluster="true";
label="SortAggregate";
196041 [id="node_196041" labelType="html" label="MapPartitionsRDD [196041] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516357 {
id="cluster_516357";
isCluster="true";
label="InMemoryTableScan";
196042 [id="node_196042" labelType="html" label="MapPartitionsRDD [196042] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196043 [id="node_196043" labelType="html" label="SortAggregate(key=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[first(kpis#3470080, false)], output=[shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470193])\n+- *(5) Sort [demandChannel#3470051 ASC NULLS FIRST, shardId#3371037 ASC NULLS FIRST, qty#3470071 ASC NULLS FIRST, worklistShardItemId#3371038L ASC NULLS FIRST, demandStream#3470052 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052, 30), ENSURE_REQUIREMENTS, [plan_id=5500325]\n +- SortAggregate(key=[demandChannel#3470051, shardId#3371037, knownfloatingpointnormalized(normalizenanandzero(qty#3470071)) AS qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[partial_first(kpis#3470080, false)], output=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L,... [196043] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516469 {
id="cluster_516469";
isCluster="true";
label="InMemoryTableScan";
196058 [id="node_196058" labelType="html" label="MapPartitionsRDD [196058] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196059 [id="node_196059" labelType="html" label="MapPartitionsRDD [196059] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196060 [id="node_196060" labelType="html" label="MapPartitionsRDD [196060] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516444 {
id="cluster_516444";
isCluster="true";
label="WholeStageCodegen (3)";
196061 [id="node_196061" labelType="html" label="MapPartitionsRDD [196061] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516443 {
id="cluster_516443";
isCluster="true";
label="InMemoryTableScan";
196062 [id="node_196062" labelType="html" label="MapPartitionsRDD [196062] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196063 [id="node_196063" labelType="html" label="*(3) Project [shardId#3371037, worklistShardItemId#3371038L, version#3470542, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080]\n+- *(3) BroadcastHashJoin [shardId#3371037, worklistShardItemId#3371038L], [shardId#3470547, worklistShardItemId#3470548L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#3371037) AND isnotnull(worklistShardItemId#3371038L))\n : +- InMemoryTableScan [shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080], [isnotnull(shardId#3371037), isnotnull(worklistShardItemId#3371038L)]\n : +- InMemoryRelation [shardId#3371037, worklistShardItemId#3371038L, qty#3470071, demandChannel#3470051, demandStream#3470052, kpis#3470080], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#3470051, shardId#3371037, qty#3470071, worklistShardItemId#3371038L, demandStream#3470052], functions=[first(kpis#3470080, false)], output=[shardId#3371037, worklistSh... [196063] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_516487 {
id="cluster_516487";
isCluster="true";
label="InMemoryTableScan";
196072 [id="node_196072" labelType="html" label="MapPartitionsRDD [196072] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196073 [id="node_196073" labelType="html" label="MapPartitionsRDD [196073] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
196074 [id="node_196074" labelType="html" label="MapPartitionsRDD [196074] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
196039->196040;
196040->196041;
196041->196042;
196042->196043;
196043->196058;
196058->196059;
196059->196060;
196060->196061;
196061->196062;
196062->196063;
196063->196072;
196072->196073;
196073->196074;
}
196038,196039
196043
196063