digraph G { id="graph_103163"; subgraph graph_stage_103163 { id="graph_stage_103163"; isCluster="true"; label="Stage 103163"; subgraph cluster_129135 { id="cluster_129135"; isCluster="true"; label="Exchange"; 49455 [id="node_49455" labelType="html" label="ShuffledRowRDD [49455] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129132 { id="cluster_129132"; isCluster="true"; label="WholeStageCodegen (1)"; 49456 [id="node_49456" labelType="html" label="MapPartitionsRDD [49456] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129155 { id="cluster_129155"; isCluster="true"; label="Exchange"; 49467 [id="node_49467" labelType="html" label="ShuffledRowRDD [49467] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129152 { id="cluster_129152"; isCluster="true"; label="WholeStageCodegen (4)"; 49468 [id="node_49468" labelType="html" label="MapPartitionsRDD [49468] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129190 { id="cluster_129190"; isCluster="true"; label="Exchange"; 49471 [id="node_49471" labelType="html" label="ShuffledRowRDD [49471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129187 { id="cluster_129187"; isCluster="true"; label="WholeStageCodegen (6)"; 49472 [id="node_49472" labelType="html" label="MapPartitionsRDD [49472] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129144 { id="cluster_129144"; isCluster="true"; label="WholeStageCodegen (7)"; 49473 [id="node_49473" labelType="html" label="ZippedPartitionsRDD2 [49473] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49474 [id="node_49474" labelType="html" label="MapPartitionsRDD [49474] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129143 { id="cluster_129143"; isCluster="true"; label="InMemoryTableScan"; 49475 [id="node_49475" labelType="html" label="MapPartitionsRDD [49475] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49476 [id="node_49476" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#989865 AS qty#989867, demandChannel#989860, demandStream#989861, cachedKpis#989866 AS kpis#989868]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#989864L, cachedShardId#989863], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1627300]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1627296]\n : +- *(2) Has... [49476] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129141 { id="cluster_129141"; isCluster="true"; label="Exchange"; 49483 [id="node_49483" labelType="html" label="ShuffledRowRDD [49483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129138 { id="cluster_129138"; isCluster="true"; label="WholeStageCodegen (4)"; 49484 [id="node_49484" labelType="html" label="MapPartitionsRDD [49484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129124 { id="cluster_129124"; isCluster="true"; label="WholeStageCodegen (5)"; 49485 [id="node_49485" labelType="html" label="ZippedPartitionsRDD2 [49485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49486 [id="node_49486" labelType="html" label="MapPartitionsRDD [49486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129205 { id="cluster_129205"; isCluster="true"; label="InMemoryTableScan"; 49487 [id="node_49487" labelType="html" label="MapPartitionsRDD [49487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49488 [id="node_49488" labelType="html" label="MapPartitionsRDD [49488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49489 [id="node_49489" labelType="html" label="MapPartitionsRDD [49489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129202 { id="cluster_129202"; isCluster="true"; label="WholeStageCodegen (6)"; 49490 [id="node_49490" labelType="html" label="MapPartitionsRDD [49490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129123 { id="cluster_129123"; isCluster="true"; label="Union"; 49491 [id="node_49491" labelType="html" label="UnionRDD [49491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129122 { id="cluster_129122"; isCluster="true"; label="InMemoryTableScan"; 49492 [id="node_49492" labelType="html" label="MapPartitionsRDD [49492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49493 [id="node_49493" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#990100, null AS demandStream#990101, [] AS kpis#990135, true AS isNewlyCalculated#990103]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#990092, ), isnull(shardId#990092), coalesce(worklistShardItemId#990093L, 0), isnull(worklistShardItemId#990093L), coalesce(version#990094, 0), isnull(version#990094), coalesce(product#990095, ), isnull(product#990095), coalesce(plant#990096, ), isnull(plant#990096), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#989867, 0.0))), isnull(qty#... [49493] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129555 { id="cluster_129555"; isCluster="true"; label="InMemoryTableScan"; 49623 [id="node_49623" labelType="html" label="MapPartitionsRDD [49623] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49624 [id="node_49624" labelType="html" label="MapPartitionsRDD [49624] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49625 [id="node_49625" labelType="html" label="MapPartitionsRDD [49625] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129551 { id="cluster_129551"; isCluster="true"; label="WholeStageCodegen (3)"; 49626 [id="node_49626" labelType="html" label="MapPartitionsRDD [49626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129550 { id="cluster_129550"; isCluster="true"; label="Exchange"; 49627 [id="node_49627" labelType="html" label="MapPartitionsRDD [49627] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49455->49456; 49467->49468; 49471->49472; 49468->49473; 49472->49473; 49473->49474; 49474->49475; 49475->49476; 49483->49484; 49456->49485; 49484->49485; 49485->49486; 49476->49487; 49487->49488; 49488->49489; 49489->49490; 49486->49491; 49490->49491; 49491->49492; 49492->49493; 49493->49623; 49623->49624; 49624->49625; 49625->49626; 49626->49627; }