digraph G { id="graph_96833"; subgraph graph_stage_96833 { id="graph_stage_96833"; isCluster="true"; label="Stage 96833"; subgraph cluster_114895 { id="cluster_114895"; isCluster="true"; label="Exchange"; 44210 [id="node_44210" labelType="html" label="ShuffledRowRDD [44210] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114892 { id="cluster_114892"; isCluster="true"; label="WholeStageCodegen (1)"; 44211 [id="node_44211" labelType="html" label="MapPartitionsRDD [44211] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114911 { id="cluster_114911"; isCluster="true"; label="Exchange"; 44222 [id="node_44222" labelType="html" label="ShuffledRowRDD [44222] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114908 { id="cluster_114908"; isCluster="true"; label="WholeStageCodegen (4)"; 44223 [id="node_44223" labelType="html" label="MapPartitionsRDD [44223] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114950 { id="cluster_114950"; isCluster="true"; label="Exchange"; 44226 [id="node_44226" labelType="html" label="ShuffledRowRDD [44226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114947 { id="cluster_114947"; isCluster="true"; label="WholeStageCodegen (6)"; 44227 [id="node_44227" labelType="html" label="MapPartitionsRDD [44227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114904 { id="cluster_114904"; isCluster="true"; label="WholeStageCodegen (7)"; 44228 [id="node_44228" labelType="html" label="ZippedPartitionsRDD2 [44228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44229 [id="node_44229" labelType="html" label="MapPartitionsRDD [44229] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114903 { id="cluster_114903"; isCluster="true"; label="InMemoryTableScan"; 44230 [id="node_44230" labelType="html" label="MapPartitionsRDD [44230] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44231 [id="node_44231" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#888322 AS qty#888324, demandChannel#888317, demandStream#888318, cachedKpis#888323 AS kpis#888325]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#888321L, cachedShardId#888320], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1389563]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1389559]\n : +- *(2) Has... [44231] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114901 { id="cluster_114901"; isCluster="true"; label="Exchange"; 44238 [id="node_44238" labelType="html" label="ShuffledRowRDD [44238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114898 { id="cluster_114898"; isCluster="true"; label="WholeStageCodegen (4)"; 44239 [id="node_44239" labelType="html" label="MapPartitionsRDD [44239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114884 { id="cluster_114884"; isCluster="true"; label="WholeStageCodegen (5)"; 44240 [id="node_44240" labelType="html" label="ZippedPartitionsRDD2 [44240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44241 [id="node_44241" labelType="html" label="MapPartitionsRDD [44241] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114965 { id="cluster_114965"; isCluster="true"; label="InMemoryTableScan"; 44242 [id="node_44242" labelType="html" label="MapPartitionsRDD [44242] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44243 [id="node_44243" labelType="html" label="MapPartitionsRDD [44243] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44244 [id="node_44244" labelType="html" label="MapPartitionsRDD [44244] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114962 { id="cluster_114962"; isCluster="true"; label="WholeStageCodegen (6)"; 44245 [id="node_44245" labelType="html" label="MapPartitionsRDD [44245] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114883 { id="cluster_114883"; isCluster="true"; label="Union"; 44246 [id="node_44246" labelType="html" label="UnionRDD [44246] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114882 { id="cluster_114882"; isCluster="true"; label="InMemoryTableScan"; 44247 [id="node_44247" labelType="html" label="MapPartitionsRDD [44247] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44248 [id="node_44248" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#888557, null AS demandStream#888558, [] AS kpis#888592, true AS isNewlyCalculated#888560]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#888549, ), isnull(shardId#888549), coalesce(worklistShardItemId#888550L, 0), isnull(worklistShardItemId#888550L), coalesce(version#888551, 0), isnull(version#888551), coalesce(product#888552, ), isnull(product#888552), coalesce(plant#888553, ), isnull(plant#888553), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#888324, 0.0))), isnull(qty#... [44248] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115186 { id="cluster_115186"; isCluster="true"; label="InMemoryTableScan"; 44314 [id="node_44314" labelType="html" label="MapPartitionsRDD [44314] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44315 [id="node_44315" labelType="html" label="MapPartitionsRDD [44315] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44316 [id="node_44316" labelType="html" label="MapPartitionsRDD [44316] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115181 { id="cluster_115181"; isCluster="true"; label="WholeStageCodegen (3)"; 44317 [id="node_44317" labelType="html" label="MapPartitionsRDD [44317] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115180 { id="cluster_115180"; isCluster="true"; label="Exchange"; 44318 [id="node_44318" labelType="html" label="MapPartitionsRDD [44318] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44210->44211; 44222->44223; 44226->44227; 44223->44228; 44227->44228; 44228->44229; 44229->44230; 44230->44231; 44238->44239; 44211->44240; 44239->44240; 44240->44241; 44231->44242; 44242->44243; 44243->44244; 44244->44245; 44241->44246; 44245->44246; 44246->44247; 44247->44248; 44248->44314; 44314->44315; 44315->44316; 44316->44317; 44317->44318; }