digraph G {
id="graph_278762";
subgraph graph_stage_278762 {
id="graph_stage_278762";
isCluster="true";
label="Stage 278762";
subgraph cluster_1999884 {
id="cluster_1999884";
isCluster="true";
label="Exchange";
789964 [id="node_789964" labelType="html" label="ShuffledRowRDD [789964] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999878 {
id="cluster_1999878";
isCluster="true";
label="WholeStageCodegen (5)";
789965 [id="node_789965" labelType="html" label="MapPartitionsRDD [789965] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999877 {
id="cluster_1999877";
isCluster="true";
label="SortAggregate";
789966 [id="node_789966" labelType="html" label="MapPartitionsRDD [789966] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999876 {
id="cluster_1999876";
isCluster="true";
label="InMemoryTableScan";
789967 [id="node_789967" labelType="html" label="MapPartitionsRDD [789967] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789968 [id="node_789968" labelType="html" label="SortAggregate(key=[demandChannel#13807617, shardId#13791298, qty#13807637, worklistShardItemId#13791299L, demandStream#13807618], functions=[first(kpis#13807646, false)], output=[shardId#13791298, worklistShardItemId#13791299L, qty#13807637, demandChannel#13807617, demandStream#13807618, kpis#13807759])\n+- *(5) Sort [demandChannel#13807617 ASC NULLS FIRST, shardId#13791298 ASC NULLS FIRST, qty#13807637 ASC NULLS FIRST, worklistShardItemId#13791299L ASC NULLS FIRST, demandStream#13807618 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#13807617, shardId#13791298, qty#13807637, worklistShardItemId#13791299L, demandStream#13807618, 30), ENSURE_REQUIREMENTS, [plan_id=13569262]\n +- SortAggregate(key=[demandChannel#13807617, shardId#13791298, knownfloatingpointnormalized(normalizenanandzero(qty#13807637)) AS qty#13807637, worklistShardItemId#13791299L, demandStream#13807618], functions=[partial_first(kpis#13807646, false)], output=[demandChannel#13807617, shardId#13791298, qty#138076... [789968] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999988 {
id="cluster_1999988";
isCluster="true";
label="InMemoryTableScan";
789983 [id="node_789983" labelType="html" label="MapPartitionsRDD [789983] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789984 [id="node_789984" labelType="html" label="MapPartitionsRDD [789984] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789985 [id="node_789985" labelType="html" label="MapPartitionsRDD [789985] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999963 {
id="cluster_1999963";
isCluster="true";
label="WholeStageCodegen (3)";
789986 [id="node_789986" labelType="html" label="MapPartitionsRDD [789986] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_1999962 {
id="cluster_1999962";
isCluster="true";
label="InMemoryTableScan";
789987 [id="node_789987" labelType="html" label="MapPartitionsRDD [789987] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789988 [id="node_789988" labelType="html" label="*(3) Project [shardId#13791298, worklistShardItemId#13791299L, version#13808108, qty#13807637, demandChannel#13807617, demandStream#13807618, kpis#13807646]\n+- *(3) BroadcastHashJoin [shardId#13791298, worklistShardItemId#13791299L], [shardId#13808113, worklistShardItemId#13808114L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#13791298) AND isnotnull(worklistShardItemId#13791299L))\n : +- InMemoryTableScan [shardId#13791298, worklistShardItemId#13791299L, qty#13807637, demandChannel#13807617, demandStream#13807618, kpis#13807646], [isnotnull(shardId#13791298), isnotnull(worklistShardItemId#13791299L)]\n : +- InMemoryRelation [shardId#13791298, worklistShardItemId#13791299L, qty#13807637, demandChannel#13807617, demandStream#13807618, kpis#13807646], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#13807617, shardId#13791298, qty#13807637, worklistShardItemId#13791299L, demandStream#13807618], functions=[first(kpis#13807646, false)], ou... [789988] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_2000006 {
id="cluster_2000006";
isCluster="true";
label="InMemoryTableScan";
789997 [id="node_789997" labelType="html" label="MapPartitionsRDD [789997] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789998 [id="node_789998" labelType="html" label="MapPartitionsRDD [789998] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
789999 [id="node_789999" labelType="html" label="MapPartitionsRDD [789999] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
789964->789965;
789965->789966;
789966->789967;
789967->789968;
789968->789983;
789983->789984;
789984->789985;
789985->789986;
789986->789987;
789987->789988;
789988->789997;
789997->789998;
789998->789999;
}
789963,789964
789968
789988