digraph G { id="graph_117047"; subgraph graph_stage_117047 { id="graph_stage_117047"; isCluster="true"; label="Stage 117047"; subgraph cluster_146653 { id="cluster_146653"; isCluster="true"; label="Exchange"; 56465 [id="node_56465" labelType="html" label="ShuffledRowRDD [56465] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146650 { id="cluster_146650"; isCluster="true"; label="WholeStageCodegen (1)"; 56466 [id="node_56466" labelType="html" label="MapPartitionsRDD [56466] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146673 { id="cluster_146673"; isCluster="true"; label="Exchange"; 56477 [id="node_56477" labelType="html" label="ShuffledRowRDD [56477] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146670 { id="cluster_146670"; isCluster="true"; label="WholeStageCodegen (4)"; 56478 [id="node_56478" labelType="html" label="MapPartitionsRDD [56478] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146708 { id="cluster_146708"; isCluster="true"; label="Exchange"; 56481 [id="node_56481" labelType="html" label="ShuffledRowRDD [56481] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146705 { id="cluster_146705"; isCluster="true"; label="WholeStageCodegen (6)"; 56482 [id="node_56482" labelType="html" label="MapPartitionsRDD [56482] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146662 { id="cluster_146662"; isCluster="true"; label="WholeStageCodegen (7)"; 56483 [id="node_56483" labelType="html" label="ZippedPartitionsRDD2 [56483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56484 [id="node_56484" labelType="html" label="MapPartitionsRDD [56484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146661 { id="cluster_146661"; isCluster="true"; label="InMemoryTableScan"; 56485 [id="node_56485" labelType="html" label="MapPartitionsRDD [56485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56486 [id="node_56486" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1134002 AS qty#1134004, demandChannel#1133997, demandStream#1133998, cachedKpis#1134003 AS kpis#1134005]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1134001L, cachedShardId#1134000], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1756957]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [56486] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146659 { id="cluster_146659"; isCluster="true"; label="Exchange"; 56493 [id="node_56493" labelType="html" label="ShuffledRowRDD [56493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146656 { id="cluster_146656"; isCluster="true"; label="WholeStageCodegen (4)"; 56494 [id="node_56494" labelType="html" label="MapPartitionsRDD [56494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146643 { id="cluster_146643"; isCluster="true"; label="WholeStageCodegen (5)"; 56495 [id="node_56495" labelType="html" label="ZippedPartitionsRDD2 [56495] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56496 [id="node_56496" labelType="html" label="MapPartitionsRDD [56496] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146723 { id="cluster_146723"; isCluster="true"; label="InMemoryTableScan"; 56497 [id="node_56497" labelType="html" label="MapPartitionsRDD [56497] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56498 [id="node_56498" labelType="html" label="MapPartitionsRDD [56498] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56499 [id="node_56499" labelType="html" label="MapPartitionsRDD [56499] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146720 { id="cluster_146720"; isCluster="true"; label="WholeStageCodegen (6)"; 56500 [id="node_56500" labelType="html" label="MapPartitionsRDD [56500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146641 { id="cluster_146641"; isCluster="true"; label="Union"; 56501 [id="node_56501" labelType="html" label="UnionRDD [56501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146640 { id="cluster_146640"; isCluster="true"; label="InMemoryTableScan"; 56502 [id="node_56502" labelType="html" label="MapPartitionsRDD [56502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56503 [id="node_56503" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1134237, null AS demandStream#1134238, [] AS kpis#1134272, true AS isNewlyCalculated#1134240]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1134229, ), isnull(shardId#1134229), coalesce(worklistShardItemId#1134230L, 0), isnull(worklistShardItemId#1134230L), coalesce(version#1134231, 0), isnull(version#1134231), coalesce(product#1134232, ), isnull(product#1134232), coalesce(plant#1134233, ), isnull(plant#1134233), knownfloatingpointnormalized(normalizenanandzero(coalesce... [56503] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146857 { id="cluster_146857"; isCluster="true"; label="InMemoryTableScan"; 56542 [id="node_56542" labelType="html" label="MapPartitionsRDD [56542] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56543 [id="node_56543" labelType="html" label="MapPartitionsRDD [56543] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56544 [id="node_56544" labelType="html" label="MapPartitionsRDD [56544] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146853 { id="cluster_146853"; isCluster="true"; label="WholeStageCodegen (11)"; 56545 [id="node_56545" labelType="html" label="MapPartitionsRDD [56545] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146852 { id="cluster_146852"; isCluster="true"; label="ObjectHashAggregate"; 56546 [id="node_56546" labelType="html" label="MapPartitionsRDD [56546] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146851 { id="cluster_146851"; isCluster="true"; label="Exchange"; 56547 [id="node_56547" labelType="html" label="MapPartitionsRDD [56547] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56465->56466; 56477->56478; 56481->56482; 56478->56483; 56482->56483; 56483->56484; 56484->56485; 56485->56486; 56493->56494; 56466->56495; 56494->56495; 56495->56496; 56486->56497; 56497->56498; 56498->56499; 56499->56500; 56496->56501; 56500->56501; 56501->56502; 56502->56503; 56503->56542; 56542->56543; 56543->56544; 56544->56545; 56545->56546; 56546->56547; }