digraph G {
id="graph_27735";
subgraph graph_stage_27735 {
id="graph_stage_27735";
isCluster="true";
label="Stage 27735";
subgraph cluster_205297 {
id="cluster_205297";
isCluster="true";
label="Exchange";
77882 [id="node_77882" labelType="html" label="ShuffledRowRDD [77882] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205292 {
id="cluster_205292";
isCluster="true";
label="WholeStageCodegen (5)";
77883 [id="node_77883" labelType="html" label="MapPartitionsRDD [77883] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205291 {
id="cluster_205291";
isCluster="true";
label="SortAggregate";
77884 [id="node_77884" labelType="html" label="MapPartitionsRDD [77884] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205290 {
id="cluster_205290";
isCluster="true";
label="InMemoryTableScan";
77885 [id="node_77885" labelType="html" label="MapPartitionsRDD [77885] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77886 [id="node_77886" labelType="html" label="SortAggregate(key=[demandChannel#1359841, shardId#1310127, qty#1359861, worklistShardItemId#1310128L, demandStream#1359842], functions=[first(kpis#1359870, false)], output=[shardId#1310127, worklistShardItemId#1310128L, qty#1359861, demandChannel#1359841, demandStream#1359842, kpis#1359983])\n+- *(5) Sort [demandChannel#1359841 ASC NULLS FIRST, shardId#1310127 ASC NULLS FIRST, qty#1359861 ASC NULLS FIRST, worklistShardItemId#1310128L ASC NULLS FIRST, demandStream#1359842 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1359841, shardId#1310127, qty#1359861, worklistShardItemId#1310128L, demandStream#1359842, 30), ENSURE_REQUIREMENTS, [plan_id=2204512]\n +- SortAggregate(key=[demandChannel#1359841, shardId#1310127, knownfloatingpointnormalized(normalizenanandzero(qty#1359861)) AS qty#1359861, worklistShardItemId#1310128L, demandStream#1359842], functions=[partial_first(kpis#1359870, false)], output=[demandChannel#1359841, shardId#1310127, qty#1359861, worklistShardItemId#1310128L,... [77886] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205402 {
id="cluster_205402";
isCluster="true";
label="InMemoryTableScan";
77901 [id="node_77901" labelType="html" label="MapPartitionsRDD [77901] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77902 [id="node_77902" labelType="html" label="MapPartitionsRDD [77902] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77903 [id="node_77903" labelType="html" label="MapPartitionsRDD [77903] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205377 {
id="cluster_205377";
isCluster="true";
label="WholeStageCodegen (3)";
77904 [id="node_77904" labelType="html" label="MapPartitionsRDD [77904] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205376 {
id="cluster_205376";
isCluster="true";
label="InMemoryTableScan";
77905 [id="node_77905" labelType="html" label="MapPartitionsRDD [77905] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77906 [id="node_77906" labelType="html" label="*(3) Project [shardId#1310127, worklistShardItemId#1310128L, version#1360332, qty#1359861, demandChannel#1359841, demandStream#1359842, kpis#1359870]\n+- *(3) BroadcastHashJoin [shardId#1310127, worklistShardItemId#1310128L], [shardId#1360337, worklistShardItemId#1360338L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#1310127) AND isnotnull(worklistShardItemId#1310128L))\n : +- InMemoryTableScan [shardId#1310127, worklistShardItemId#1310128L, qty#1359861, demandChannel#1359841, demandStream#1359842, kpis#1359870], [isnotnull(shardId#1310127), isnotnull(worklistShardItemId#1310128L)]\n : +- InMemoryRelation [shardId#1310127, worklistShardItemId#1310128L, qty#1359861, demandChannel#1359841, demandStream#1359842, kpis#1359870], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#1359841, shardId#1310127, qty#1359861, worklistShardItemId#1310128L, demandStream#1359842], functions=[first(kpis#1359870, false)], output=[shardId#1310127, worklistSh... [77906] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205420 {
id="cluster_205420";
isCluster="true";
label="InMemoryTableScan";
77915 [id="node_77915" labelType="html" label="MapPartitionsRDD [77915] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77916 [id="node_77916" labelType="html" label="MapPartitionsRDD [77916] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77917 [id="node_77917" labelType="html" label="MapPartitionsRDD [77917] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
77882->77883;
77883->77884;
77884->77885;
77885->77886;
77886->77901;
77901->77902;
77902->77903;
77903->77904;
77904->77905;
77905->77906;
77906->77915;
77915->77916;
77916->77917;
}
77881,77882
77886
77906