digraph G { id="graph_97255"; subgraph graph_stage_97255 { id="graph_stage_97255"; isCluster="true"; label="Stage 97255"; 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_115172 { id="cluster_115172"; isCluster="true"; label="Exchange"; 44344 [id="node_44344" labelType="html" label="ShuffledRowRDD [44344] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115166 { id="cluster_115166"; isCluster="true"; label="WholeStageCodegen (6)"; 44345 [id="node_44345" labelType="html" label="MapPartitionsRDD [44345] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115165 { id="cluster_115165"; isCluster="true"; label="SortAggregate"; 44346 [id="node_44346" labelType="html" label="MapPartitionsRDD [44346] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115164 { id="cluster_115164"; isCluster="true"; label="InMemoryTableScan"; 44347 [id="node_44347" labelType="html" label="MapPartitionsRDD [44347] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44348 [id="node_44348" labelType="html" label="SortAggregate(key=[demandChannel#891093, shardId#815740, qty#891113, worklistShardItemId#815741L, demandStream#891094], functions=[first(kpis#891122, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#891113, demandChannel#891093, demandStream#891094, kpis#891255])\n+- *(6) Sort [demandChannel#891093 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#891113 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#891094 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#891093, shardId#815740, qty#891113, worklistShardItemId#815741L, demandStream#891094, 37), ENSURE_REQUIREMENTS, [plan_id=1390493]\n +- SortAggregate(key=[demandChannel#891093, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#891113)) AS qty#891113, worklistShardItemId#815741L, demandStream#891094], functions=[partial_first(kpis#891122, false)], output=[demandChannel#891093, shardId#815740, qty#891113, worklistShardItemId#815741L, demandStream#891094, first#89133... [44348] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115331 { id="cluster_115331"; isCluster="true"; label="InMemoryTableScan"; 44386 [id="node_44386" labelType="html" label="MapPartitionsRDD [44386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44387 [id="node_44387" labelType="html" label="MapPartitionsRDD [44387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44388 [id="node_44388" labelType="html" label="MapPartitionsRDD [44388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115327 { id="cluster_115327"; isCluster="true"; label="WholeStageCodegen (1)"; 44389 [id="node_44389" labelType="html" label="MapPartitionsRDD [44389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115335 { id="cluster_115335"; isCluster="true"; label="InMemoryTableScan"; 44390 [id="node_44390" labelType="html" label="MapPartitionsRDD [44390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44391 [id="node_44391" labelType="html" label="MapPartitionsRDD [44391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44392 [id="node_44392" labelType="html" label="MapPartitionsRDD [44392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115332 { id="cluster_115332"; isCluster="true"; label="WholeStageCodegen (2)"; 44393 [id="node_44393" labelType="html" label="MapPartitionsRDD [44393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115326 { id="cluster_115326"; isCluster="true"; label="Union"; 44394 [id="node_44394" labelType="html" label="UnionRDD [44394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115302 { id="cluster_115302"; isCluster="true"; label="WholeStageCodegen (5)"; 44395 [id="node_44395" labelType="html" label="MapPartitionsRDD [44395] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115301 { id="cluster_115301"; isCluster="true"; label="InMemoryTableScan"; 44396 [id="node_44396" labelType="html" label="MapPartitionsRDD [44396] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44397 [id="node_44397" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#891926, qty#815747, demandChannel#888557, demandStream#888558, kpis#888592]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#892023, worklistShardItemId#892024L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#888557, demandStream#888558, kpis#888592]\n : : +- *(1) Filter ((NOT isNewlyCalculated#888560 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#888557, demandStream#888558, isNewlyCalculated#888560, kpis#888592, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#888560, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#888557, demandStream#888558... [44397] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115360 { id="cluster_115360"; isCluster="true"; label="InMemoryTableScan"; 44406 [id="node_44406" labelType="html" label="MapPartitionsRDD [44406] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44407 [id="node_44407" labelType="html" label="MapPartitionsRDD [44407] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44408 [id="node_44408" labelType="html" label="MapPartitionsRDD [44408] [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; 44344->44345; 44345->44346; 44346->44347; 44347->44348; 44248->44386; 44386->44387; 44387->44388; 44388->44389; 44348->44390; 44390->44391; 44391->44392; 44392->44393; 44389->44394; 44393->44394; 44394->44395; 44395->44396; 44396->44397; 44397->44406; 44406->44407; 44407->44408; }