digraph G { id="graph_99963"; subgraph graph_stage_99963 { id="graph_stage_99963"; isCluster="true"; label="Stage 99963"; subgraph cluster_120459 { id="cluster_120459"; isCluster="true"; label="Exchange"; 46381 [id="node_46381" labelType="html" label="ShuffledRowRDD [46381] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120456 { id="cluster_120456"; isCluster="true"; label="WholeStageCodegen (1)"; 46382 [id="node_46382" labelType="html" label="MapPartitionsRDD [46382] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120479 { id="cluster_120479"; isCluster="true"; label="Exchange"; 46393 [id="node_46393" labelType="html" label="ShuffledRowRDD [46393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120476 { id="cluster_120476"; isCluster="true"; label="WholeStageCodegen (4)"; 46394 [id="node_46394" labelType="html" label="MapPartitionsRDD [46394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120514 { id="cluster_120514"; isCluster="true"; label="Exchange"; 46397 [id="node_46397" labelType="html" label="ShuffledRowRDD [46397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120511 { id="cluster_120511"; isCluster="true"; label="WholeStageCodegen (6)"; 46398 [id="node_46398" labelType="html" label="MapPartitionsRDD [46398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120468 { id="cluster_120468"; isCluster="true"; label="WholeStageCodegen (7)"; 46399 [id="node_46399" labelType="html" label="ZippedPartitionsRDD2 [46399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46400 [id="node_46400" labelType="html" label="MapPartitionsRDD [46400] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120467 { id="cluster_120467"; isCluster="true"; label="InMemoryTableScan"; 46401 [id="node_46401" labelType="html" label="MapPartitionsRDD [46401] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46402 [id="node_46402" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#932797 AS qty#932799, demandChannel#932792, demandStream#932793, cachedKpis#932798 AS kpis#932800]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#932796L, cachedShardId#932795], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1452493]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1452489]\n : +- *(2) Has... [46402] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120465 { id="cluster_120465"; isCluster="true"; label="Exchange"; 46409 [id="node_46409" labelType="html" label="ShuffledRowRDD [46409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120462 { id="cluster_120462"; isCluster="true"; label="WholeStageCodegen (4)"; 46410 [id="node_46410" labelType="html" label="MapPartitionsRDD [46410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120448 { id="cluster_120448"; isCluster="true"; label="WholeStageCodegen (5)"; 46411 [id="node_46411" labelType="html" label="ZippedPartitionsRDD2 [46411] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46412 [id="node_46412" labelType="html" label="MapPartitionsRDD [46412] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120529 { id="cluster_120529"; isCluster="true"; label="InMemoryTableScan"; 46413 [id="node_46413" labelType="html" label="MapPartitionsRDD [46413] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46414 [id="node_46414" labelType="html" label="MapPartitionsRDD [46414] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46415 [id="node_46415" labelType="html" label="MapPartitionsRDD [46415] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120526 { id="cluster_120526"; isCluster="true"; label="WholeStageCodegen (6)"; 46416 [id="node_46416" labelType="html" label="MapPartitionsRDD [46416] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120447 { id="cluster_120447"; isCluster="true"; label="Union"; 46417 [id="node_46417" labelType="html" label="UnionRDD [46417] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120446 { id="cluster_120446"; isCluster="true"; label="InMemoryTableScan"; 46418 [id="node_46418" labelType="html" label="MapPartitionsRDD [46418] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46419 [id="node_46419" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#933032, null AS demandStream#933033, [] AS kpis#933067, true AS isNewlyCalculated#933035]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#933024, ), isnull(shardId#933024), coalesce(worklistShardItemId#933025L, 0), isnull(worklistShardItemId#933025L), coalesce(version#933026, 0), isnull(version#933026), coalesce(product#933027, ), isnull(product#933027), coalesce(plant#933028, ), isnull(plant#933028), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#932799, 0.0))), isnull(qty#... [46419] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46420 [id="node_46420" labelType="html" label="MapPartitionsRDD [46420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46421 [id="node_46421" labelType="html" label="MapPartitionsRDD [46421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46422 [id="node_46422" labelType="html" label="MapPartitionsRDD [46422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120441 { id="cluster_120441"; isCluster="true"; label="WholeStageCodegen (15)"; 46423 [id="node_46423" labelType="html" label="MapPartitionsRDD [46423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120440 { id="cluster_120440"; isCluster="true"; label="Exchange"; 46424 [id="node_46424" labelType="html" label="MapPartitionsRDD [46424] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46381->46382; 46393->46394; 46397->46398; 46394->46399; 46398->46399; 46399->46400; 46400->46401; 46401->46402; 46409->46410; 46382->46411; 46410->46411; 46411->46412; 46402->46413; 46413->46414; 46414->46415; 46415->46416; 46412->46417; 46416->46417; 46417->46418; 46418->46419; 46419->46420; 46420->46421; 46421->46422; 46422->46423; 46423->46424; }