digraph G { id="graph_107675"; subgraph graph_stage_107675 { id="graph_stage_107675"; isCluster="true"; label="Stage 107675"; subgraph cluster_136030 { id="cluster_136030"; isCluster="true"; label="Exchange"; 52150 [id="node_52150" labelType="html" label="ShuffledRowRDD [52150] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136027 { id="cluster_136027"; isCluster="true"; label="WholeStageCodegen (1)"; 52151 [id="node_52151" labelType="html" label="MapPartitionsRDD [52151] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136050 { id="cluster_136050"; isCluster="true"; label="Exchange"; 52162 [id="node_52162" labelType="html" label="ShuffledRowRDD [52162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136047 { id="cluster_136047"; isCluster="true"; label="WholeStageCodegen (4)"; 52163 [id="node_52163" labelType="html" label="MapPartitionsRDD [52163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136079 { id="cluster_136079"; isCluster="true"; label="Exchange"; 52166 [id="node_52166" labelType="html" label="ShuffledRowRDD [52166] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136076 { id="cluster_136076"; isCluster="true"; label="WholeStageCodegen (6)"; 52167 [id="node_52167" labelType="html" label="MapPartitionsRDD [52167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136039 { id="cluster_136039"; isCluster="true"; label="WholeStageCodegen (7)"; 52168 [id="node_52168" labelType="html" label="ZippedPartitionsRDD2 [52168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52169 [id="node_52169" labelType="html" label="MapPartitionsRDD [52169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136038 { id="cluster_136038"; isCluster="true"; label="InMemoryTableScan"; 52170 [id="node_52170" labelType="html" label="MapPartitionsRDD [52170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52171 [id="node_52171" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1044860 AS qty#1044862, demandChannel#1044855, demandStream#1044856, cachedKpis#1044861 AS kpis#1044863]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1044859L, cachedShardId#1044858], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1683138]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [52171] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136036 { id="cluster_136036"; isCluster="true"; label="Exchange"; 52178 [id="node_52178" labelType="html" label="ShuffledRowRDD [52178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136033 { id="cluster_136033"; isCluster="true"; label="WholeStageCodegen (4)"; 52179 [id="node_52179" labelType="html" label="MapPartitionsRDD [52179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136019 { id="cluster_136019"; isCluster="true"; label="WholeStageCodegen (5)"; 52180 [id="node_52180" labelType="html" label="ZippedPartitionsRDD2 [52180] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52181 [id="node_52181" labelType="html" label="MapPartitionsRDD [52181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136100 { id="cluster_136100"; isCluster="true"; label="InMemoryTableScan"; 52182 [id="node_52182" labelType="html" label="MapPartitionsRDD [52182] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52183 [id="node_52183" labelType="html" label="MapPartitionsRDD [52183] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52184 [id="node_52184" labelType="html" label="MapPartitionsRDD [52184] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136097 { id="cluster_136097"; isCluster="true"; label="WholeStageCodegen (6)"; 52185 [id="node_52185" labelType="html" label="MapPartitionsRDD [52185] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136018 { id="cluster_136018"; isCluster="true"; label="Union"; 52186 [id="node_52186" labelType="html" label="UnionRDD [52186] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136017 { id="cluster_136017"; isCluster="true"; label="InMemoryTableScan"; 52187 [id="node_52187" labelType="html" label="MapPartitionsRDD [52187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52188 [id="node_52188" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1045095, null AS demandStream#1045096, [] AS kpis#1045130, true AS isNewlyCalculated#1045098]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1045087, ), isnull(shardId#1045087), coalesce(worklistShardItemId#1045088L, 0), isnull(worklistShardItemId#1045088L), coalesce(version#1045089, 0), isnull(version#1045089), coalesce(product#1045090, ), isnull(product#1045090), coalesce(plant#1045091, ), isnull(plant#1045091), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52188] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136228 { id="cluster_136228"; isCluster="true"; label="Exchange"; 52233 [id="node_52233" labelType="html" label="ShuffledRowRDD [52233] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136227 { id="cluster_136227"; isCluster="true"; label="ObjectHashAggregate"; 52234 [id="node_52234" labelType="html" label="MapPartitionsRDD [52234] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136239 { id="cluster_136239"; isCluster="true"; label="InMemoryTableScan"; 52235 [id="node_52235" labelType="html" label="MapPartitionsRDD [52235] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52236 [id="node_52236" labelType="html" label="MapPartitionsRDD [52236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52237 [id="node_52237" labelType="html" label="MapPartitionsRDD [52237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136235 { id="cluster_136235"; isCluster="true"; label="WholeStageCodegen (12)"; 52238 [id="node_52238" labelType="html" label="MapPartitionsRDD [52238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136226 { id="cluster_136226"; isCluster="true"; label="Union"; 52239 [id="node_52239" labelType="html" label="UnionRDD [52239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136225 { id="cluster_136225"; isCluster="true"; label="Exchange"; 52240 [id="node_52240" labelType="html" label="MapPartitionsRDD [52240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52150->52151; 52162->52163; 52166->52167; 52163->52168; 52167->52168; 52168->52169; 52169->52170; 52170->52171; 52178->52179; 52151->52180; 52179->52180; 52180->52181; 52171->52182; 52182->52183; 52183->52184; 52184->52185; 52181->52186; 52185->52186; 52186->52187; 52187->52188; 52233->52234; 52188->52235; 52235->52236; 52236->52237; 52237->52238; 52234->52239; 52238->52239; 52239->52240; }