digraph G { id="graph_111865"; subgraph graph_stage_111865 { id="graph_stage_111865"; isCluster="true"; label="Stage 111865"; 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}"]; } subgraph cluster_138807 { id="cluster_138807"; isCluster="true"; label="InMemoryTableScan"; 53312 [id="node_53312" labelType="html" label="MapPartitionsRDD [53312] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53313 [id="node_53313" labelType="html" label="MapPartitionsRDD [53313] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53314 [id="node_53314" labelType="html" label="MapPartitionsRDD [53314] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138802 { id="cluster_138802"; isCluster="true"; label="WholeStageCodegen (3)"; 53315 [id="node_53315" labelType="html" label="MapPartitionsRDD [53315] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138801 { id="cluster_138801"; isCluster="true"; label="Exchange"; 53316 [id="node_53316" labelType="html" label="MapPartitionsRDD [53316] [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->53312; 53312->53313; 53313->53314; 53314->53315; 53315->53316; }