digraph G { id="graph_90587"; subgraph graph_stage_90587 { id="graph_stage_90587"; isCluster="true"; label="Stage 90587"; subgraph cluster_109236 { id="cluster_109236"; isCluster="true"; label="Exchange"; 41806 [id="node_41806" labelType="html" label="ShuffledRowRDD [41806] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109233 { id="cluster_109233"; isCluster="true"; label="WholeStageCodegen (1)"; 41807 [id="node_41807" labelType="html" label="MapPartitionsRDD [41807] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109256 { id="cluster_109256"; isCluster="true"; label="Exchange"; 41818 [id="node_41818" labelType="html" label="ShuffledRowRDD [41818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109253 { id="cluster_109253"; isCluster="true"; label="WholeStageCodegen (4)"; 41819 [id="node_41819" labelType="html" label="MapPartitionsRDD [41819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109285 { id="cluster_109285"; isCluster="true"; label="Exchange"; 41822 [id="node_41822" labelType="html" label="ShuffledRowRDD [41822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109282 { id="cluster_109282"; isCluster="true"; label="WholeStageCodegen (6)"; 41823 [id="node_41823" labelType="html" label="MapPartitionsRDD [41823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109245 { id="cluster_109245"; isCluster="true"; label="WholeStageCodegen (7)"; 41824 [id="node_41824" labelType="html" label="ZippedPartitionsRDD2 [41824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41825 [id="node_41825" labelType="html" label="MapPartitionsRDD [41825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109244 { id="cluster_109244"; isCluster="true"; label="InMemoryTableScan"; 41826 [id="node_41826" labelType="html" label="MapPartitionsRDD [41826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41827 [id="node_41827" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#837979 AS qty#837981, demandChannel#837974, demandStream#837975, cachedKpis#837980 AS kpis#837982]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#837978L, cachedShardId#837977], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1375257]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1375253]\n : +- *(2) Has... [41827] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109242 { id="cluster_109242"; isCluster="true"; label="Exchange"; 41834 [id="node_41834" labelType="html" label="ShuffledRowRDD [41834] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109239 { id="cluster_109239"; isCluster="true"; label="WholeStageCodegen (4)"; 41835 [id="node_41835" labelType="html" label="MapPartitionsRDD [41835] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109225 { id="cluster_109225"; isCluster="true"; label="WholeStageCodegen (5)"; 41836 [id="node_41836" labelType="html" label="ZippedPartitionsRDD2 [41836] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41837 [id="node_41837" labelType="html" label="MapPartitionsRDD [41837] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109306 { id="cluster_109306"; isCluster="true"; label="InMemoryTableScan"; 41838 [id="node_41838" labelType="html" label="MapPartitionsRDD [41838] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41839 [id="node_41839" labelType="html" label="MapPartitionsRDD [41839] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41840 [id="node_41840" labelType="html" label="MapPartitionsRDD [41840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109303 { id="cluster_109303"; isCluster="true"; label="WholeStageCodegen (6)"; 41841 [id="node_41841" labelType="html" label="MapPartitionsRDD [41841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109224 { id="cluster_109224"; isCluster="true"; label="Union"; 41842 [id="node_41842" labelType="html" label="UnionRDD [41842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109223 { id="cluster_109223"; isCluster="true"; label="InMemoryTableScan"; 41843 [id="node_41843" labelType="html" label="MapPartitionsRDD [41843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41844 [id="node_41844" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#838214, null AS demandStream#838215, [] AS kpis#838249, true AS isNewlyCalculated#838217]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#838206, ), isnull(shardId#838206), coalesce(worklistShardItemId#838207L, 0), isnull(worklistShardItemId#838207L), coalesce(version#838208, 0), isnull(version#838208), coalesce(product#838209, ), isnull(product#838209), coalesce(plant#838210, ), isnull(plant#838210), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#837981, 0.0))), isnull(qty#... [41844] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109656 { id="cluster_109656"; isCluster="true"; label="InMemoryTableScan"; 41974 [id="node_41974" labelType="html" label="MapPartitionsRDD [41974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41975 [id="node_41975" labelType="html" label="MapPartitionsRDD [41975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41976 [id="node_41976" labelType="html" label="MapPartitionsRDD [41976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109652 { id="cluster_109652"; isCluster="true"; label="WholeStageCodegen (3)"; 41977 [id="node_41977" labelType="html" label="MapPartitionsRDD [41977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109651 { id="cluster_109651"; isCluster="true"; label="Exchange"; 41978 [id="node_41978" labelType="html" label="MapPartitionsRDD [41978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 41806->41807; 41818->41819; 41822->41823; 41819->41824; 41823->41824; 41824->41825; 41825->41826; 41826->41827; 41834->41835; 41807->41836; 41835->41836; 41836->41837; 41827->41838; 41838->41839; 41839->41840; 41840->41841; 41837->41842; 41841->41842; 41842->41843; 41843->41844; 41844->41974; 41974->41975; 41975->41976; 41976->41977; 41977->41978; }