digraph G { id="graph_111839"; subgraph graph_stage_111839 { id="graph_stage_111839"; isCluster="true"; label="Stage 111839"; subgraph cluster_138516 { id="cluster_138516"; isCluster="true"; label="Exchange"; 53208 [id="node_53208" labelType="html" label="ShuffledRowRDD [53208] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138513 { id="cluster_138513"; isCluster="true"; label="WholeStageCodegen (1)"; 53209 [id="node_53209" labelType="html" label="MapPartitionsRDD [53209] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138536 { id="cluster_138536"; isCluster="true"; label="Exchange"; 53220 [id="node_53220" labelType="html" label="ShuffledRowRDD [53220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138533 { id="cluster_138533"; isCluster="true"; label="WholeStageCodegen (4)"; 53221 [id="node_53221" labelType="html" label="MapPartitionsRDD [53221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138565 { id="cluster_138565"; isCluster="true"; label="Exchange"; 53224 [id="node_53224" labelType="html" label="ShuffledRowRDD [53224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138562 { id="cluster_138562"; isCluster="true"; label="WholeStageCodegen (6)"; 53225 [id="node_53225" labelType="html" label="MapPartitionsRDD [53225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138525 { id="cluster_138525"; isCluster="true"; label="WholeStageCodegen (7)"; 53226 [id="node_53226" labelType="html" label="ZippedPartitionsRDD2 [53226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53227 [id="node_53227" labelType="html" label="MapPartitionsRDD [53227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138524 { id="cluster_138524"; isCluster="true"; label="InMemoryTableScan"; 53228 [id="node_53228" labelType="html" label="MapPartitionsRDD [53228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53229 [id="node_53229" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1067092 AS qty#1067094, demandChannel#1067087, demandStream#1067088, cachedKpis#1067093 AS kpis#1067095]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1067091L, cachedShardId#1067090], 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=1689442]\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... [53229] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138522 { id="cluster_138522"; isCluster="true"; label="Exchange"; 53236 [id="node_53236" labelType="html" label="ShuffledRowRDD [53236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138519 { id="cluster_138519"; isCluster="true"; label="WholeStageCodegen (4)"; 53237 [id="node_53237" labelType="html" label="MapPartitionsRDD [53237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138505 { id="cluster_138505"; isCluster="true"; label="WholeStageCodegen (5)"; 53238 [id="node_53238" labelType="html" label="ZippedPartitionsRDD2 [53238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53239 [id="node_53239" labelType="html" label="MapPartitionsRDD [53239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138586 { id="cluster_138586"; isCluster="true"; label="InMemoryTableScan"; 53240 [id="node_53240" labelType="html" label="MapPartitionsRDD [53240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53241 [id="node_53241" labelType="html" label="MapPartitionsRDD [53241] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53242 [id="node_53242" labelType="html" label="MapPartitionsRDD [53242] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138583 { id="cluster_138583"; isCluster="true"; label="WholeStageCodegen (6)"; 53243 [id="node_53243" labelType="html" label="MapPartitionsRDD [53243] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138504 { id="cluster_138504"; isCluster="true"; label="Union"; 53244 [id="node_53244" labelType="html" label="UnionRDD [53244] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138503 { id="cluster_138503"; isCluster="true"; label="InMemoryTableScan"; 53245 [id="node_53245" labelType="html" label="MapPartitionsRDD [53245] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53246 [id="node_53246" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1067327, null AS demandStream#1067328, [] AS kpis#1067362, true AS isNewlyCalculated#1067330]\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#1067319, ), isnull(shardId#1067319), coalesce(worklistShardItemId#1067320L, 0), isnull(worklistShardItemId#1067320L), coalesce(version#1067321, 0), isnull(version#1067321), coalesce(product#1067322, ), isnull(product#1067322), coalesce(plant#1067323, ), isnull(plant#1067323), knownfloatingpointnormalized(normalizenanandzero(coalesce... [53246] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53247 [id="node_53247" labelType="html" label="MapPartitionsRDD [53247] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53248 [id="node_53248" labelType="html" label="MapPartitionsRDD [53248] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53249 [id="node_53249" labelType="html" label="MapPartitionsRDD [53249] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138498 { id="cluster_138498"; isCluster="true"; label="WholeStageCodegen (15)"; 53250 [id="node_53250" labelType="html" label="MapPartitionsRDD [53250] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138497 { id="cluster_138497"; isCluster="true"; label="Exchange"; 53251 [id="node_53251" labelType="html" label="MapPartitionsRDD [53251] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53208->53209; 53220->53221; 53224->53225; 53221->53226; 53225->53226; 53226->53227; 53227->53228; 53228->53229; 53236->53237; 53209->53238; 53237->53238; 53238->53239; 53229->53240; 53240->53241; 53241->53242; 53242->53243; 53239->53244; 53243->53244; 53244->53245; 53245->53246; 53246->53247; 53247->53248; 53248->53249; 53249->53250; 53250->53251; }