digraph G {
id="graph_968";
subgraph graph_stage_968 {
id="graph_stage_968";
isCluster="true";
label="Stage 968";
subgraph cluster_7767 {
id="cluster_7767";
isCluster="true";
label="Exchange";
2491 [id="node_2491" labelType="html" label="ShuffledRowRDD [2491] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7762 {
id="cluster_7762";
isCluster="true";
label="WholeStageCodegen (5)";
2492 [id="node_2492" labelType="html" label="MapPartitionsRDD [2492] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7761 {
id="cluster_7761";
isCluster="true";
label="SortAggregate";
2493 [id="node_2493" labelType="html" label="MapPartitionsRDD [2493] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7760 {
id="cluster_7760";
isCluster="true";
label="InMemoryTableScan";
2494 [id="node_2494" labelType="html" label="MapPartitionsRDD [2494] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2495 [id="node_2495" labelType="html" label="SortAggregate(key=[demandChannel#48159, shardId#25237, qty#48179, worklistShardItemId#25238L, demandStream#48160], functions=[first(kpis#48188, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#48179, demandChannel#48159, demandStream#48160, kpis#48301])\n+- *(5) Sort [demandChannel#48159 ASC NULLS FIRST, shardId#25237 ASC NULLS FIRST, qty#48179 ASC NULLS FIRST, worklistShardItemId#25238L ASC NULLS FIRST, demandStream#48160 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#48159, shardId#25237, qty#48179, worklistShardItemId#25238L, demandStream#48160, 8), ENSURE_REQUIREMENTS, [plan_id=217061]\n +- SortAggregate(key=[demandChannel#48159, shardId#25237, knownfloatingpointnormalized(normalizenanandzero(qty#48179)) AS qty#48179, worklistShardItemId#25238L, demandStream#48160], functions=[partial_first(kpis#48188, false)], output=[demandChannel#48159, shardId#25237, qty#48179, worklistShardItemId#25238L, demandStream#48160, first#48367, valueSet#48368])\n +- *(4) ... [2495] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7872 {
id="cluster_7872";
isCluster="true";
label="InMemoryTableScan";
2510 [id="node_2510" labelType="html" label="MapPartitionsRDD [2510] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2511 [id="node_2511" labelType="html" label="MapPartitionsRDD [2511] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2512 [id="node_2512" labelType="html" label="MapPartitionsRDD [2512] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7847 {
id="cluster_7847";
isCluster="true";
label="WholeStageCodegen (3)";
2513 [id="node_2513" labelType="html" label="MapPartitionsRDD [2513] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7846 {
id="cluster_7846";
isCluster="true";
label="InMemoryTableScan";
2514 [id="node_2514" labelType="html" label="MapPartitionsRDD [2514] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2515 [id="node_2515" labelType="html" label="*(3) Project [shardId#25237, worklistShardItemId#25238L, version#48650, qty#48179, demandChannel#48159, demandStream#48160, kpis#48188]\n+- *(3) BroadcastHashJoin [shardId#25237, worklistShardItemId#25238L], [shardId#48655, worklistShardItemId#48656L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#25237) AND isnotnull(worklistShardItemId#25238L))\n : +- InMemoryTableScan [shardId#25237, worklistShardItemId#25238L, qty#48179, demandChannel#48159, demandStream#48160, kpis#48188], [isnotnull(shardId#25237), isnotnull(worklistShardItemId#25238L)]\n : +- InMemoryRelation [shardId#25237, worklistShardItemId#25238L, qty#48179, demandChannel#48159, demandStream#48160, kpis#48188], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#48159, shardId#25237, qty#48179, worklistShardItemId#25238L, demandStream#48160], functions=[first(kpis#48188, false)], output=[shardId#25237, worklistShardItemId#25238L, qty#48179, demandChannel#48159, demandStream#48160... [2515] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_7890 {
id="cluster_7890";
isCluster="true";
label="InMemoryTableScan";
2524 [id="node_2524" labelType="html" label="MapPartitionsRDD [2524] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2525 [id="node_2525" labelType="html" label="MapPartitionsRDD [2525] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
2526 [id="node_2526" labelType="html" label="MapPartitionsRDD [2526] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
2491->2492;
2492->2493;
2493->2494;
2494->2495;
2495->2510;
2510->2511;
2511->2512;
2512->2513;
2513->2514;
2514->2515;
2515->2524;
2524->2525;
2525->2526;
}
2490,2491
2495
2515