digraph G {
id="graph_899";
subgraph graph_stage_899 {
id="graph_stage_899";
isCluster="true";
label="Stage 899";
subgraph cluster_7346 {
id="cluster_7346";
isCluster="true";
label="Exchange";
2314 [id="node_2314" labelType="html" label="ShuffledRowRDD [2314] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7341 {
id="cluster_7341";
isCluster="true";
label="WholeStageCodegen (5)";
2315 [id="node_2315" labelType="html" label="MapPartitionsRDD [2315] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7340 {
id="cluster_7340";
isCluster="true";
label="SortAggregate";
2316 [id="node_2316" labelType="html" label="MapPartitionsRDD [2316] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7339 {
id="cluster_7339";
isCluster="true";
label="InMemoryTableScan";
2317 [id="node_2317" labelType="html" label="MapPartitionsRDD [2317] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2318 [id="node_2318" labelType="html" label="SortAggregate(key=[demandChannel#44861, shardId#25237, qty#44881, worklistShardItemId#25238L, demandStream#44862], functions=[first(kpis#44890, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#44881, demandChannel#44861, demandStream#44862, kpis#45003])\n+- *(5) Sort [demandChannel#44861 ASC NULLS FIRST, shardId#25237 ASC NULLS FIRST, qty#44881 ASC NULLS FIRST, worklistShardItemId#25238L ASC NULLS FIRST, demandStream#44862 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#44861, shardId#25237, qty#44881, worklistShardItemId#25238L, demandStream#44862, 8), ENSURE_REQUIREMENTS, [plan_id=215891]\n +- SortAggregate(key=[demandChannel#44861, shardId#25237, knownfloatingpointnormalized(normalizenanandzero(qty#44881)) AS qty#44881, worklistShardItemId#25238L, demandStream#44862], functions=[partial_first(kpis#44890, false)], output=[demandChannel#44861, shardId#25237, qty#44881, worklistShardItemId#25238L, demandStream#44862, first#45069, valueSet#45070])\n +- *(4) ... [2318] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7451 {
id="cluster_7451";
isCluster="true";
label="InMemoryTableScan";
2333 [id="node_2333" labelType="html" label="MapPartitionsRDD [2333] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2334 [id="node_2334" labelType="html" label="MapPartitionsRDD [2334] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2335 [id="node_2335" labelType="html" label="MapPartitionsRDD [2335] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7426 {
id="cluster_7426";
isCluster="true";
label="WholeStageCodegen (3)";
2336 [id="node_2336" labelType="html" label="MapPartitionsRDD [2336] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7425 {
id="cluster_7425";
isCluster="true";
label="InMemoryTableScan";
2337 [id="node_2337" labelType="html" label="MapPartitionsRDD [2337] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2338 [id="node_2338" labelType="html" label="*(3) Project [shardId#25237, worklistShardItemId#25238L, version#45352, qty#44881, demandChannel#44861, demandStream#44862, kpis#44890]\n+- *(3) BroadcastHashJoin [shardId#25237, worklistShardItemId#25238L], [shardId#45357, worklistShardItemId#45358L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#25237) AND isnotnull(worklistShardItemId#25238L))\n : +- InMemoryTableScan [shardId#25237, worklistShardItemId#25238L, qty#44881, demandChannel#44861, demandStream#44862, kpis#44890], [isnotnull(shardId#25237), isnotnull(worklistShardItemId#25238L)]\n : +- InMemoryRelation [shardId#25237, worklistShardItemId#25238L, qty#44881, demandChannel#44861, demandStream#44862, kpis#44890], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#44861, shardId#25237, qty#44881, worklistShardItemId#25238L, demandStream#44862], functions=[first(kpis#44890, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#44881, demandChannel#44861, demandStream#44862... [2338] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2339 [id="node_2339" labelType="html" label="MapPartitionsRDD [2339] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2340 [id="node_2340" labelType="html" label="MapPartitionsRDD [2340] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2341 [id="node_2341" labelType="html" label="MapPartitionsRDD [2341] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7424 {
id="cluster_7424";
isCluster="true";
label="CollectLimit";
2342 [id="node_2342" labelType="html" label="MapPartitionsRDD [2342] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2343 [id="node_2343" labelType="html" label="MapPartitionsRDD [2343] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
2314->2315;
2315->2316;
2316->2317;
2317->2318;
2318->2333;
2333->2334;
2334->2335;
2335->2336;
2336->2337;
2337->2338;
2338->2339;
2339->2340;
2340->2341;
2341->2342;
2342->2343;
}
2313,2314
2318
2338