digraph G { id="graph_99489"; subgraph graph_stage_99489 { id="graph_stage_99489"; isCluster="true"; label="Stage 99489"; 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_119419 { id="cluster_119419"; isCluster="true"; label="InMemoryTableScan"; 45928 [id="node_45928" labelType="html" label="MapPartitionsRDD [45928] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45929 [id="node_45929" labelType="html" label="MapPartitionsRDD [45929] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45930 [id="node_45930" labelType="html" label="MapPartitionsRDD [45930] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119415 { id="cluster_119415"; isCluster="true"; label="WholeStageCodegen (11)"; 45931 [id="node_45931" labelType="html" label="MapPartitionsRDD [45931] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119414 { id="cluster_119414"; isCluster="true"; label="ObjectHashAggregate"; 45932 [id="node_45932" labelType="html" label="MapPartitionsRDD [45932] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119413 { id="cluster_119413"; isCluster="true"; label="Exchange"; 45933 [id="node_45933" labelType="html" label="MapPartitionsRDD [45933] [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->45928; 45928->45929; 45929->45930; 45930->45931; 45931->45932; 45932->45933; }