digraph G { id="graph_102441"; subgraph graph_stage_102441 { id="graph_stage_102441"; isCluster="true"; label="Stage 102441"; subgraph cluster_127893 { id="cluster_127893"; isCluster="true"; label="Exchange"; 48927 [id="node_48927" labelType="html" label="ShuffledRowRDD [48927] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127890 { id="cluster_127890"; isCluster="true"; label="WholeStageCodegen (1)"; 48928 [id="node_48928" labelType="html" label="MapPartitionsRDD [48928] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127913 { id="cluster_127913"; isCluster="true"; label="Exchange"; 48939 [id="node_48939" labelType="html" label="ShuffledRowRDD [48939] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127910 { id="cluster_127910"; isCluster="true"; label="WholeStageCodegen (4)"; 48940 [id="node_48940" labelType="html" label="MapPartitionsRDD [48940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127948 { id="cluster_127948"; isCluster="true"; label="Exchange"; 48943 [id="node_48943" labelType="html" label="ShuffledRowRDD [48943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127945 { id="cluster_127945"; isCluster="true"; label="WholeStageCodegen (6)"; 48944 [id="node_48944" labelType="html" label="MapPartitionsRDD [48944] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127902 { id="cluster_127902"; isCluster="true"; label="WholeStageCodegen (7)"; 48945 [id="node_48945" labelType="html" label="ZippedPartitionsRDD2 [48945] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48946 [id="node_48946" labelType="html" label="MapPartitionsRDD [48946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127901 { id="cluster_127901"; isCluster="true"; label="InMemoryTableScan"; 48947 [id="node_48947" labelType="html" label="MapPartitionsRDD [48947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48948 [id="node_48948" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#978749 AS qty#978751, demandChannel#978744, demandStream#978745, cachedKpis#978750 AS kpis#978752]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#978748L, cachedShardId#978747], 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=1624120]\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=1624116]\n : +- *(2) Has... [48948] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127899 { id="cluster_127899"; isCluster="true"; label="Exchange"; 48955 [id="node_48955" labelType="html" label="ShuffledRowRDD [48955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127896 { id="cluster_127896"; isCluster="true"; label="WholeStageCodegen (4)"; 48956 [id="node_48956" labelType="html" label="MapPartitionsRDD [48956] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127882 { id="cluster_127882"; isCluster="true"; label="WholeStageCodegen (5)"; 48957 [id="node_48957" labelType="html" label="ZippedPartitionsRDD2 [48957] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48958 [id="node_48958" labelType="html" label="MapPartitionsRDD [48958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127963 { id="cluster_127963"; isCluster="true"; label="InMemoryTableScan"; 48959 [id="node_48959" labelType="html" label="MapPartitionsRDD [48959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48960 [id="node_48960" labelType="html" label="MapPartitionsRDD [48960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48961 [id="node_48961" labelType="html" label="MapPartitionsRDD [48961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127960 { id="cluster_127960"; isCluster="true"; label="WholeStageCodegen (6)"; 48962 [id="node_48962" labelType="html" label="MapPartitionsRDD [48962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127881 { id="cluster_127881"; isCluster="true"; label="Union"; 48963 [id="node_48963" labelType="html" label="UnionRDD [48963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127880 { id="cluster_127880"; isCluster="true"; label="InMemoryTableScan"; 48964 [id="node_48964" labelType="html" label="MapPartitionsRDD [48964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48965 [id="node_48965" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#978984, null AS demandStream#978985, [] AS kpis#979019, true AS isNewlyCalculated#978987]\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#978976, ), isnull(shardId#978976), coalesce(worklistShardItemId#978977L, 0), isnull(worklistShardItemId#978977L), coalesce(version#978978, 0), isnull(version#978978), coalesce(product#978979, ), isnull(product#978979), coalesce(plant#978980, ), isnull(plant#978980), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#978751, 0.0))), isnull(qty#... [48965] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128313 { id="cluster_128313"; isCluster="true"; label="InMemoryTableScan"; 49095 [id="node_49095" labelType="html" label="MapPartitionsRDD [49095] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49096 [id="node_49096" labelType="html" label="MapPartitionsRDD [49096] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49097 [id="node_49097" labelType="html" label="MapPartitionsRDD [49097] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128309 { id="cluster_128309"; isCluster="true"; label="WholeStageCodegen (3)"; 49098 [id="node_49098" labelType="html" label="MapPartitionsRDD [49098] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128308 { id="cluster_128308"; isCluster="true"; label="Exchange"; 49099 [id="node_49099" labelType="html" label="MapPartitionsRDD [49099] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48927->48928; 48939->48940; 48943->48944; 48940->48945; 48944->48945; 48945->48946; 48946->48947; 48947->48948; 48955->48956; 48928->48957; 48956->48957; 48957->48958; 48948->48959; 48959->48960; 48960->48961; 48961->48962; 48958->48963; 48962->48963; 48963->48964; 48964->48965; 48965->49095; 49095->49096; 49096->49097; 49097->49098; 49098->49099; }