digraph G {
id="graph_27810";
subgraph graph_stage_27810 {
id="graph_stage_27810";
isCluster="true";
label="Stage 27810";
subgraph cluster_205823 {
id="cluster_205823";
isCluster="true";
label="Exchange";
78096 [id="node_78096" labelType="html" label="ShuffledRowRDD [78096] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205816 {
id="cluster_205816";
isCluster="true";
label="WholeStageCodegen (5)";
78097 [id="node_78097" labelType="html" label="MapPartitionsRDD [78097] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205815 {
id="cluster_205815";
isCluster="true";
label="SortAggregate";
78098 [id="node_78098" labelType="html" label="MapPartitionsRDD [78098] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205814 {
id="cluster_205814";
isCluster="true";
label="InMemoryTableScan";
78099 [id="node_78099" labelType="html" label="MapPartitionsRDD [78099] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78100 [id="node_78100" labelType="html" label="SortAggregate(key=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[first(kpis#1363605, false)], output=[shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363718])\n+- *(5) Sort [demandChannel#1363576 ASC NULLS FIRST, shardId#1310127 ASC NULLS FIRST, qty#1363596 ASC NULLS FIRST, worklistShardItemId#1310128L ASC NULLS FIRST, demandStream#1363577 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577, 30), ENSURE_REQUIREMENTS, [plan_id=2205987]\n +- SortAggregate(key=[demandChannel#1363576, shardId#1310127, knownfloatingpointnormalized(normalizenanandzero(qty#1363596)) AS qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[partial_first(kpis#1363605, false)], output=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L,... [78100] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205926 {
id="cluster_205926";
isCluster="true";
label="InMemoryTableScan";
78115 [id="node_78115" labelType="html" label="MapPartitionsRDD [78115] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78116 [id="node_78116" labelType="html" label="MapPartitionsRDD [78116] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78117 [id="node_78117" labelType="html" label="MapPartitionsRDD [78117] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205901 {
id="cluster_205901";
isCluster="true";
label="WholeStageCodegen (3)";
78118 [id="node_78118" labelType="html" label="MapPartitionsRDD [78118] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205900 {
id="cluster_205900";
isCluster="true";
label="InMemoryTableScan";
78119 [id="node_78119" labelType="html" label="MapPartitionsRDD [78119] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78120 [id="node_78120" labelType="html" label="*(3) Project [shardId#1310127, worklistShardItemId#1310128L, version#1364067, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605]\n+- *(3) BroadcastHashJoin [shardId#1310127, worklistShardItemId#1310128L], [shardId#1364072, worklistShardItemId#1364073L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#1310127) AND isnotnull(worklistShardItemId#1310128L))\n : +- InMemoryTableScan [shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605], [isnotnull(shardId#1310127), isnotnull(worklistShardItemId#1310128L)]\n : +- InMemoryRelation [shardId#1310127, worklistShardItemId#1310128L, qty#1363596, demandChannel#1363576, demandStream#1363577, kpis#1363605], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#1363576, shardId#1310127, qty#1363596, worklistShardItemId#1310128L, demandStream#1363577], functions=[first(kpis#1363605, false)], output=[shardId#1310127, worklistSh... [78120] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_205944 {
id="cluster_205944";
isCluster="true";
label="InMemoryTableScan";
78129 [id="node_78129" labelType="html" label="MapPartitionsRDD [78129] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78130 [id="node_78130" labelType="html" label="MapPartitionsRDD [78130] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
78131 [id="node_78131" labelType="html" label="MapPartitionsRDD [78131] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
78096->78097;
78097->78098;
78098->78099;
78099->78100;
78100->78115;
78115->78116;
78116->78117;
78117->78118;
78118->78119;
78119->78120;
78120->78129;
78129->78130;
78130->78131;
}
78095,78096
78100
78120