digraph G { id="graph_103271"; subgraph graph_stage_103271 { id="graph_stage_103271"; isCluster="true"; label="Stage 103271"; subgraph cluster_129135 { id="cluster_129135"; isCluster="true"; label="Exchange"; 49455 [id="node_49455" labelType="html" label="ShuffledRowRDD [49455] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129132 { id="cluster_129132"; isCluster="true"; label="WholeStageCodegen (1)"; 49456 [id="node_49456" labelType="html" label="MapPartitionsRDD [49456] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129155 { id="cluster_129155"; isCluster="true"; label="Exchange"; 49467 [id="node_49467" labelType="html" label="ShuffledRowRDD [49467] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129152 { id="cluster_129152"; isCluster="true"; label="WholeStageCodegen (4)"; 49468 [id="node_49468" labelType="html" label="MapPartitionsRDD [49468] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129190 { id="cluster_129190"; isCluster="true"; label="Exchange"; 49471 [id="node_49471" labelType="html" label="ShuffledRowRDD [49471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129187 { id="cluster_129187"; isCluster="true"; label="WholeStageCodegen (6)"; 49472 [id="node_49472" labelType="html" label="MapPartitionsRDD [49472] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129144 { id="cluster_129144"; isCluster="true"; label="WholeStageCodegen (7)"; 49473 [id="node_49473" labelType="html" label="ZippedPartitionsRDD2 [49473] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49474 [id="node_49474" labelType="html" label="MapPartitionsRDD [49474] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129143 { id="cluster_129143"; isCluster="true"; label="InMemoryTableScan"; 49475 [id="node_49475" labelType="html" label="MapPartitionsRDD [49475] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49476 [id="node_49476" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#989865 AS qty#989867, demandChannel#989860, demandStream#989861, cachedKpis#989866 AS kpis#989868]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#989864L, cachedShardId#989863], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1627300]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1627296]\n : +- *(2) Has... [49476] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129141 { id="cluster_129141"; isCluster="true"; label="Exchange"; 49483 [id="node_49483" labelType="html" label="ShuffledRowRDD [49483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129138 { id="cluster_129138"; isCluster="true"; label="WholeStageCodegen (4)"; 49484 [id="node_49484" labelType="html" label="MapPartitionsRDD [49484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129124 { id="cluster_129124"; isCluster="true"; label="WholeStageCodegen (5)"; 49485 [id="node_49485" labelType="html" label="ZippedPartitionsRDD2 [49485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49486 [id="node_49486" labelType="html" label="MapPartitionsRDD [49486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129205 { id="cluster_129205"; isCluster="true"; label="InMemoryTableScan"; 49487 [id="node_49487" labelType="html" label="MapPartitionsRDD [49487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49488 [id="node_49488" labelType="html" label="MapPartitionsRDD [49488] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49489 [id="node_49489" labelType="html" label="MapPartitionsRDD [49489] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129202 { id="cluster_129202"; isCluster="true"; label="WholeStageCodegen (6)"; 49490 [id="node_49490" labelType="html" label="MapPartitionsRDD [49490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129123 { id="cluster_129123"; isCluster="true"; label="Union"; 49491 [id="node_49491" labelType="html" label="UnionRDD [49491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129122 { id="cluster_129122"; isCluster="true"; label="InMemoryTableScan"; 49492 [id="node_49492" labelType="html" label="MapPartitionsRDD [49492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49493 [id="node_49493" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#990100, null AS demandStream#990101, [] AS kpis#990135, true AS isNewlyCalculated#990103]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#990092, ), isnull(shardId#990092), coalesce(worklistShardItemId#990093L, 0), isnull(worklistShardItemId#990093L), coalesce(version#990094, 0), isnull(version#990094), coalesce(product#990095, ), isnull(product#990095), coalesce(plant#990096, ), isnull(plant#990096), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#989867, 0.0))), isnull(qty#... [49493] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129411 { id="cluster_129411"; isCluster="true"; label="Exchange"; 49589 [id="node_49589" labelType="html" label="ShuffledRowRDD [49589] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129406 { id="cluster_129406"; isCluster="true"; label="WholeStageCodegen (6)"; 49590 [id="node_49590" labelType="html" label="MapPartitionsRDD [49590] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129405 { id="cluster_129405"; isCluster="true"; label="SortAggregate"; 49591 [id="node_49591" labelType="html" label="MapPartitionsRDD [49591] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129404 { id="cluster_129404"; isCluster="true"; label="InMemoryTableScan"; 49592 [id="node_49592" labelType="html" label="MapPartitionsRDD [49592] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49593 [id="node_49593" labelType="html" label="SortAggregate(key=[demandChannel#992636, shardId#943631, qty#992656, worklistShardItemId#943632L, demandStream#992637], functions=[first(kpis#992665, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#992656, demandChannel#992636, demandStream#992637, kpis#992798])\n+- *(6) Sort [demandChannel#992636 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#992656 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#992637 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#992636, shardId#943631, qty#992656, worklistShardItemId#943632L, demandStream#992637, 37), ENSURE_REQUIREMENTS, [plan_id=1628230]\n +- SortAggregate(key=[demandChannel#992636, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#992656)) AS qty#992656, worklistShardItemId#943632L, demandStream#992637], functions=[partial_first(kpis#992665, false)], output=[demandChannel#992636, shardId#943631, qty#992656, worklistShardItemId#943632L, demandStream#992637, first#99287... [49593] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129571 { id="cluster_129571"; isCluster="true"; label="InMemoryTableScan"; 49631 [id="node_49631" labelType="html" label="MapPartitionsRDD [49631] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49632 [id="node_49632" labelType="html" label="MapPartitionsRDD [49632] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49633 [id="node_49633" labelType="html" label="MapPartitionsRDD [49633] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129567 { id="cluster_129567"; isCluster="true"; label="WholeStageCodegen (1)"; 49634 [id="node_49634" labelType="html" label="MapPartitionsRDD [49634] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129575 { id="cluster_129575"; isCluster="true"; label="InMemoryTableScan"; 49635 [id="node_49635" labelType="html" label="MapPartitionsRDD [49635] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49636 [id="node_49636" labelType="html" label="MapPartitionsRDD [49636] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49637 [id="node_49637" labelType="html" label="MapPartitionsRDD [49637] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129572 { id="cluster_129572"; isCluster="true"; label="WholeStageCodegen (2)"; 49638 [id="node_49638" labelType="html" label="MapPartitionsRDD [49638] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129566 { id="cluster_129566"; isCluster="true"; label="Union"; 49639 [id="node_49639" labelType="html" label="UnionRDD [49639] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129542 { id="cluster_129542"; isCluster="true"; label="WholeStageCodegen (5)"; 49640 [id="node_49640" labelType="html" label="MapPartitionsRDD [49640] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129541 { id="cluster_129541"; isCluster="true"; label="InMemoryTableScan"; 49641 [id="node_49641" labelType="html" label="MapPartitionsRDD [49641] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49642 [id="node_49642" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#993469, qty#943638, demandChannel#990100, demandStream#990101, kpis#990135]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#993566, worklistShardItemId#993567L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#990100, demandStream#990101, kpis#990135]\n : : +- *(1) Filter ((NOT isNewlyCalculated#990103 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#990100, demandStream#990101, isNewlyCalculated#990103, kpis#990135, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#990103, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#990100, demandStream#990101... [49642] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129600 { id="cluster_129600"; isCluster="true"; label="InMemoryTableScan"; 49651 [id="node_49651" labelType="html" label="MapPartitionsRDD [49651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49652 [id="node_49652" labelType="html" label="MapPartitionsRDD [49652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49653 [id="node_49653" labelType="html" label="MapPartitionsRDD [49653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49455->49456; 49467->49468; 49471->49472; 49468->49473; 49472->49473; 49473->49474; 49474->49475; 49475->49476; 49483->49484; 49456->49485; 49484->49485; 49485->49486; 49476->49487; 49487->49488; 49488->49489; 49489->49490; 49486->49491; 49490->49491; 49491->49492; 49492->49493; 49589->49590; 49590->49591; 49591->49592; 49592->49593; 49493->49631; 49631->49632; 49632->49633; 49633->49634; 49593->49635; 49635->49636; 49636->49637; 49637->49638; 49634->49639; 49638->49639; 49639->49640; 49640->49641; 49641->49642; 49642->49651; 49651->49652; 49652->49653; }