digraph G { id="graph_102721"; subgraph graph_stage_102721 { id="graph_stage_102721"; isCluster="true"; label="Stage 102721"; subgraph cluster_128514 { id="cluster_128514"; isCluster="true"; label="Exchange"; 49191 [id="node_49191" labelType="html" label="ShuffledRowRDD [49191] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128511 { id="cluster_128511"; isCluster="true"; label="WholeStageCodegen (1)"; 49192 [id="node_49192" labelType="html" label="MapPartitionsRDD [49192] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128534 { id="cluster_128534"; isCluster="true"; label="Exchange"; 49203 [id="node_49203" labelType="html" label="ShuffledRowRDD [49203] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128531 { id="cluster_128531"; isCluster="true"; label="WholeStageCodegen (4)"; 49204 [id="node_49204" labelType="html" label="MapPartitionsRDD [49204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128569 { id="cluster_128569"; isCluster="true"; label="Exchange"; 49207 [id="node_49207" labelType="html" label="ShuffledRowRDD [49207] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128566 { id="cluster_128566"; isCluster="true"; label="WholeStageCodegen (6)"; 49208 [id="node_49208" labelType="html" label="MapPartitionsRDD [49208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128523 { id="cluster_128523"; isCluster="true"; label="WholeStageCodegen (7)"; 49209 [id="node_49209" labelType="html" label="ZippedPartitionsRDD2 [49209] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49210 [id="node_49210" labelType="html" label="MapPartitionsRDD [49210] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128522 { id="cluster_128522"; isCluster="true"; label="InMemoryTableScan"; 49211 [id="node_49211" labelType="html" label="MapPartitionsRDD [49211] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49212 [id="node_49212" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#984307 AS qty#984309, demandChannel#984302, demandStream#984303, cachedKpis#984308 AS kpis#984310]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#984306L, cachedShardId#984305], 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=1625710]\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=1625706]\n : +- *(2) Has... [49212] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128520 { id="cluster_128520"; isCluster="true"; label="Exchange"; 49219 [id="node_49219" labelType="html" label="ShuffledRowRDD [49219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128517 { id="cluster_128517"; isCluster="true"; label="WholeStageCodegen (4)"; 49220 [id="node_49220" labelType="html" label="MapPartitionsRDD [49220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128503 { id="cluster_128503"; isCluster="true"; label="WholeStageCodegen (5)"; 49221 [id="node_49221" labelType="html" label="ZippedPartitionsRDD2 [49221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49222 [id="node_49222" labelType="html" label="MapPartitionsRDD [49222] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128584 { id="cluster_128584"; isCluster="true"; label="InMemoryTableScan"; 49223 [id="node_49223" labelType="html" label="MapPartitionsRDD [49223] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49224 [id="node_49224" labelType="html" label="MapPartitionsRDD [49224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49225 [id="node_49225" labelType="html" label="MapPartitionsRDD [49225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128581 { id="cluster_128581"; isCluster="true"; label="WholeStageCodegen (6)"; 49226 [id="node_49226" labelType="html" label="MapPartitionsRDD [49226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128502 { id="cluster_128502"; isCluster="true"; label="Union"; 49227 [id="node_49227" labelType="html" label="UnionRDD [49227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128501 { id="cluster_128501"; isCluster="true"; label="InMemoryTableScan"; 49228 [id="node_49228" labelType="html" label="MapPartitionsRDD [49228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49229 [id="node_49229" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#984542, null AS demandStream#984543, [] AS kpis#984577, true AS isNewlyCalculated#984545]\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#984534, ), isnull(shardId#984534), coalesce(worklistShardItemId#984535L, 0), isnull(worklistShardItemId#984535L), coalesce(version#984536, 0), isnull(version#984536), coalesce(product#984537, ), isnull(product#984537), coalesce(plant#984538, ), isnull(plant#984538), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#984309, 0.0))), isnull(qty#... [49229] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128934 { id="cluster_128934"; isCluster="true"; label="InMemoryTableScan"; 49359 [id="node_49359" labelType="html" label="MapPartitionsRDD [49359] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49360 [id="node_49360" labelType="html" label="MapPartitionsRDD [49360] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49361 [id="node_49361" labelType="html" label="MapPartitionsRDD [49361] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128930 { id="cluster_128930"; isCluster="true"; label="WholeStageCodegen (3)"; 49362 [id="node_49362" labelType="html" label="MapPartitionsRDD [49362] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128929 { id="cluster_128929"; isCluster="true"; label="Exchange"; 49363 [id="node_49363" labelType="html" label="MapPartitionsRDD [49363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49191->49192; 49203->49204; 49207->49208; 49204->49209; 49208->49209; 49209->49210; 49210->49211; 49211->49212; 49219->49220; 49192->49221; 49220->49221; 49221->49222; 49212->49223; 49223->49224; 49224->49225; 49225->49226; 49222->49227; 49226->49227; 49227->49228; 49228->49229; 49229->49359; 49359->49360; 49360->49361; 49361->49362; 49362->49363; }