digraph G { id="graph_91607"; subgraph graph_stage_91607 { id="graph_stage_91607"; isCluster="true"; label="Stage 91607"; subgraph cluster_110478 { id="cluster_110478"; isCluster="true"; label="Exchange"; 42334 [id="node_42334" labelType="html" label="ShuffledRowRDD [42334] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110475 { id="cluster_110475"; isCluster="true"; label="WholeStageCodegen (1)"; 42335 [id="node_42335" labelType="html" label="MapPartitionsRDD [42335] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110498 { id="cluster_110498"; isCluster="true"; label="Exchange"; 42346 [id="node_42346" labelType="html" label="ShuffledRowRDD [42346] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110495 { id="cluster_110495"; isCluster="true"; label="WholeStageCodegen (4)"; 42347 [id="node_42347" labelType="html" label="MapPartitionsRDD [42347] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110527 { id="cluster_110527"; isCluster="true"; label="Exchange"; 42350 [id="node_42350" labelType="html" label="ShuffledRowRDD [42350] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110524 { id="cluster_110524"; isCluster="true"; label="WholeStageCodegen (6)"; 42351 [id="node_42351" labelType="html" label="MapPartitionsRDD [42351] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110487 { id="cluster_110487"; isCluster="true"; label="WholeStageCodegen (7)"; 42352 [id="node_42352" labelType="html" label="ZippedPartitionsRDD2 [42352] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42353 [id="node_42353" labelType="html" label="MapPartitionsRDD [42353] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110486 { id="cluster_110486"; isCluster="true"; label="InMemoryTableScan"; 42354 [id="node_42354" labelType="html" label="MapPartitionsRDD [42354] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42355 [id="node_42355" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#849095 AS qty#849097, demandChannel#849090, demandStream#849091, cachedKpis#849096 AS kpis#849098]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#849094L, cachedShardId#849093], 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=1378422]\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=1378418]\n : +- *(2) Has... [42355] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110484 { id="cluster_110484"; isCluster="true"; label="Exchange"; 42362 [id="node_42362" labelType="html" label="ShuffledRowRDD [42362] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110481 { id="cluster_110481"; isCluster="true"; label="WholeStageCodegen (4)"; 42363 [id="node_42363" labelType="html" label="MapPartitionsRDD [42363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110467 { id="cluster_110467"; isCluster="true"; label="WholeStageCodegen (5)"; 42364 [id="node_42364" labelType="html" label="ZippedPartitionsRDD2 [42364] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42365 [id="node_42365" labelType="html" label="MapPartitionsRDD [42365] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110548 { id="cluster_110548"; isCluster="true"; label="InMemoryTableScan"; 42366 [id="node_42366" labelType="html" label="MapPartitionsRDD [42366] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42367 [id="node_42367" labelType="html" label="MapPartitionsRDD [42367] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42368 [id="node_42368" labelType="html" label="MapPartitionsRDD [42368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110545 { id="cluster_110545"; isCluster="true"; label="WholeStageCodegen (6)"; 42369 [id="node_42369" labelType="html" label="MapPartitionsRDD [42369] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110466 { id="cluster_110466"; isCluster="true"; label="Union"; 42370 [id="node_42370" labelType="html" label="UnionRDD [42370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110465 { id="cluster_110465"; isCluster="true"; label="InMemoryTableScan"; 42371 [id="node_42371" labelType="html" label="MapPartitionsRDD [42371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42372 [id="node_42372" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#849330, null AS demandStream#849331, [] AS kpis#849365, true AS isNewlyCalculated#849333]\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#849322, ), isnull(shardId#849322), coalesce(worklistShardItemId#849323L, 0), isnull(worklistShardItemId#849323L), coalesce(version#849324, 0), isnull(version#849324), coalesce(product#849325, ), isnull(product#849325), coalesce(plant#849326, ), isnull(plant#849326), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#849097, 0.0))), isnull(qty#... [42372] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110769 { id="cluster_110769"; isCluster="true"; label="InMemoryTableScan"; 42438 [id="node_42438" labelType="html" label="MapPartitionsRDD [42438] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42439 [id="node_42439" labelType="html" label="MapPartitionsRDD [42439] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42440 [id="node_42440" labelType="html" label="MapPartitionsRDD [42440] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110764 { id="cluster_110764"; isCluster="true"; label="WholeStageCodegen (3)"; 42441 [id="node_42441" labelType="html" label="MapPartitionsRDD [42441] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110763 { id="cluster_110763"; isCluster="true"; label="Exchange"; 42442 [id="node_42442" labelType="html" label="MapPartitionsRDD [42442] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42334->42335; 42346->42347; 42350->42351; 42347->42352; 42351->42352; 42352->42353; 42353->42354; 42354->42355; 42362->42363; 42335->42364; 42363->42364; 42364->42365; 42355->42366; 42366->42367; 42367->42368; 42368->42369; 42365->42370; 42369->42370; 42370->42371; 42371->42372; 42372->42438; 42438->42439; 42439->42440; 42440->42441; 42441->42442; }