digraph G { id="graph_97357"; subgraph graph_stage_97357 { id="graph_stage_97357"; isCluster="true"; label="Stage 97357"; subgraph cluster_115516 { id="cluster_115516"; isCluster="true"; label="Exchange"; 44474 [id="node_44474" labelType="html" label="ShuffledRowRDD [44474] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115513 { id="cluster_115513"; isCluster="true"; label="WholeStageCodegen (1)"; 44475 [id="node_44475" labelType="html" label="MapPartitionsRDD [44475] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115536 { id="cluster_115536"; isCluster="true"; label="Exchange"; 44486 [id="node_44486" labelType="html" label="ShuffledRowRDD [44486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115533 { id="cluster_115533"; isCluster="true"; label="WholeStageCodegen (4)"; 44487 [id="node_44487" labelType="html" label="MapPartitionsRDD [44487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115571 { id="cluster_115571"; isCluster="true"; label="Exchange"; 44490 [id="node_44490" labelType="html" label="ShuffledRowRDD [44490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115568 { id="cluster_115568"; isCluster="true"; label="WholeStageCodegen (6)"; 44491 [id="node_44491" labelType="html" label="MapPartitionsRDD [44491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115525 { id="cluster_115525"; isCluster="true"; label="WholeStageCodegen (7)"; 44492 [id="node_44492" labelType="html" label="ZippedPartitionsRDD2 [44492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44493 [id="node_44493" labelType="html" label="MapPartitionsRDD [44493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115524 { id="cluster_115524"; isCluster="true"; label="InMemoryTableScan"; 44494 [id="node_44494" labelType="html" label="MapPartitionsRDD [44494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44495 [id="node_44495" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#893880 AS qty#893882, demandChannel#893875, demandStream#893876, cachedKpis#893881 AS kpis#893883]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#893879L, cachedShardId#893878], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1391138]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1391134]\n : +- *(2) Has... [44495] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115522 { id="cluster_115522"; isCluster="true"; label="Exchange"; 44502 [id="node_44502" labelType="html" label="ShuffledRowRDD [44502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115519 { id="cluster_115519"; isCluster="true"; label="WholeStageCodegen (4)"; 44503 [id="node_44503" labelType="html" label="MapPartitionsRDD [44503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115505 { id="cluster_115505"; isCluster="true"; label="WholeStageCodegen (5)"; 44504 [id="node_44504" labelType="html" label="ZippedPartitionsRDD2 [44504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44505 [id="node_44505" labelType="html" label="MapPartitionsRDD [44505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115586 { id="cluster_115586"; isCluster="true"; label="InMemoryTableScan"; 44506 [id="node_44506" labelType="html" label="MapPartitionsRDD [44506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44507 [id="node_44507" labelType="html" label="MapPartitionsRDD [44507] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44508 [id="node_44508" labelType="html" label="MapPartitionsRDD [44508] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115583 { id="cluster_115583"; isCluster="true"; label="WholeStageCodegen (6)"; 44509 [id="node_44509" labelType="html" label="MapPartitionsRDD [44509] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115504 { id="cluster_115504"; isCluster="true"; label="Union"; 44510 [id="node_44510" labelType="html" label="UnionRDD [44510] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115503 { id="cluster_115503"; isCluster="true"; label="InMemoryTableScan"; 44511 [id="node_44511" labelType="html" label="MapPartitionsRDD [44511] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44512 [id="node_44512" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#894115, null AS demandStream#894116, [] AS kpis#894150, true AS isNewlyCalculated#894118]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#894107, ), isnull(shardId#894107), coalesce(worklistShardItemId#894108L, 0), isnull(worklistShardItemId#894108L), coalesce(version#894109, 0), isnull(version#894109), coalesce(product#894110, ), isnull(product#894110), coalesce(plant#894111, ), isnull(plant#894111), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#893882, 0.0))), isnull(qty#... [44512] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44513 [id="node_44513" labelType="html" label="MapPartitionsRDD [44513] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44514 [id="node_44514" labelType="html" label="MapPartitionsRDD [44514] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44515 [id="node_44515" labelType="html" label="MapPartitionsRDD [44515] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115498 { id="cluster_115498"; isCluster="true"; label="WholeStageCodegen (15)"; 44516 [id="node_44516" labelType="html" label="MapPartitionsRDD [44516] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115497 { id="cluster_115497"; isCluster="true"; label="Exchange"; 44517 [id="node_44517" labelType="html" label="MapPartitionsRDD [44517] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44474->44475; 44486->44487; 44490->44491; 44487->44492; 44491->44492; 44492->44493; 44493->44494; 44494->44495; 44502->44503; 44475->44504; 44503->44504; 44504->44505; 44495->44506; 44506->44507; 44507->44508; 44508->44509; 44505->44510; 44509->44510; 44510->44511; 44511->44512; 44512->44513; 44513->44514; 44514->44515; 44515->44516; 44516->44517; }