digraph G { id="graph_99689"; subgraph graph_stage_99689 { id="graph_stage_99689"; isCluster="true"; label="Stage 99689"; subgraph cluster_119215 { id="cluster_119215"; isCluster="true"; label="Exchange"; 45851 [id="node_45851" labelType="html" label="ShuffledRowRDD [45851] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119212 { id="cluster_119212"; isCluster="true"; label="WholeStageCodegen (1)"; 45852 [id="node_45852" labelType="html" label="MapPartitionsRDD [45852] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119235 { id="cluster_119235"; isCluster="true"; label="Exchange"; 45863 [id="node_45863" labelType="html" label="ShuffledRowRDD [45863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119232 { id="cluster_119232"; isCluster="true"; label="WholeStageCodegen (4)"; 45864 [id="node_45864" labelType="html" label="MapPartitionsRDD [45864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119270 { id="cluster_119270"; isCluster="true"; label="Exchange"; 45867 [id="node_45867" labelType="html" label="ShuffledRowRDD [45867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119267 { id="cluster_119267"; isCluster="true"; label="WholeStageCodegen (6)"; 45868 [id="node_45868" labelType="html" label="MapPartitionsRDD [45868] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119224 { id="cluster_119224"; isCluster="true"; label="WholeStageCodegen (7)"; 45869 [id="node_45869" labelType="html" label="ZippedPartitionsRDD2 [45869] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45870 [id="node_45870" labelType="html" label="MapPartitionsRDD [45870] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119223 { id="cluster_119223"; isCluster="true"; label="InMemoryTableScan"; 45871 [id="node_45871" labelType="html" label="MapPartitionsRDD [45871] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45872 [id="node_45872" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#921681 AS qty#921683, demandChannel#921676, demandStream#921677, cachedKpis#921682 AS kpis#921684]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#921680L, cachedShardId#921679], 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=1449313]\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=1449309]\n : +- *(2) Has... [45872] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119221 { id="cluster_119221"; isCluster="true"; label="Exchange"; 45879 [id="node_45879" labelType="html" label="ShuffledRowRDD [45879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119218 { id="cluster_119218"; isCluster="true"; label="WholeStageCodegen (4)"; 45880 [id="node_45880" labelType="html" label="MapPartitionsRDD [45880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119204 { id="cluster_119204"; isCluster="true"; label="WholeStageCodegen (5)"; 45881 [id="node_45881" labelType="html" label="ZippedPartitionsRDD2 [45881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45882 [id="node_45882" labelType="html" label="MapPartitionsRDD [45882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119285 { id="cluster_119285"; isCluster="true"; label="InMemoryTableScan"; 45883 [id="node_45883" labelType="html" label="MapPartitionsRDD [45883] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45884 [id="node_45884" labelType="html" label="MapPartitionsRDD [45884] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45885 [id="node_45885" labelType="html" label="MapPartitionsRDD [45885] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119282 { id="cluster_119282"; isCluster="true"; label="WholeStageCodegen (6)"; 45886 [id="node_45886" labelType="html" label="MapPartitionsRDD [45886] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119203 { id="cluster_119203"; isCluster="true"; label="Union"; 45887 [id="node_45887" labelType="html" label="UnionRDD [45887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119202 { id="cluster_119202"; isCluster="true"; label="InMemoryTableScan"; 45888 [id="node_45888" labelType="html" label="MapPartitionsRDD [45888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45889 [id="node_45889" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#921916, null AS demandStream#921917, [] AS kpis#921951, true AS isNewlyCalculated#921919]\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#921908, ), isnull(shardId#921908), coalesce(worklistShardItemId#921909L, 0), isnull(worklistShardItemId#921909L), coalesce(version#921910, 0), isnull(version#921910), coalesce(product#921911, ), isnull(product#921911), coalesce(plant#921912, ), isnull(plant#921912), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#921683, 0.0))), isnull(qty#... [45889] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119637 { id="cluster_119637"; isCluster="true"; label="InMemoryTableScan"; 46020 [id="node_46020" labelType="html" label="MapPartitionsRDD [46020] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46021 [id="node_46021" labelType="html" label="MapPartitionsRDD [46021] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46022 [id="node_46022" labelType="html" label="MapPartitionsRDD [46022] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119632 { id="cluster_119632"; isCluster="true"; label="WholeStageCodegen (3)"; 46024 [id="node_46024" labelType="html" label="MapPartitionsRDD [46024] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119631 { id="cluster_119631"; isCluster="true"; label="Exchange"; 46025 [id="node_46025" labelType="html" label="MapPartitionsRDD [46025] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45851->45852; 45863->45864; 45867->45868; 45864->45869; 45868->45869; 45869->45870; 45870->45871; 45871->45872; 45879->45880; 45852->45881; 45880->45881; 45881->45882; 45872->45883; 45883->45884; 45884->45885; 45885->45886; 45882->45887; 45886->45887; 45887->45888; 45888->45889; 45889->46020; 46020->46021; 46021->46022; 46022->46024; 46024->46025; }