digraph G { id="graph_102368"; subgraph graph_stage_102368 { id="graph_stage_102368"; isCluster="true"; label="Stage 102368"; 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_128097 { id="cluster_128097"; isCluster="true"; label="InMemoryTableScan"; 49004 [id="node_49004" labelType="html" label="MapPartitionsRDD [49004] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49005 [id="node_49005" labelType="html" label="MapPartitionsRDD [49005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49006 [id="node_49006" labelType="html" label="MapPartitionsRDD [49006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128093 { id="cluster_128093"; isCluster="true"; label="WholeStageCodegen (11)"; 49007 [id="node_49007" labelType="html" label="MapPartitionsRDD [49007] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128092 { id="cluster_128092"; isCluster="true"; label="ObjectHashAggregate"; 49008 [id="node_49008" labelType="html" label="MapPartitionsRDD [49008] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128091 { id="cluster_128091"; isCluster="true"; label="Exchange"; 49009 [id="node_49009" labelType="html" label="MapPartitionsRDD [49009] [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->49004; 49004->49005; 49005->49006; 49006->49007; 49007->49008; 49008->49009; }