digraph G { id="graph_117143"; subgraph graph_stage_117143 { id="graph_stage_117143"; isCluster="true"; label="Stage 117143"; subgraph cluster_146653 { id="cluster_146653"; isCluster="true"; label="Exchange"; 56465 [id="node_56465" labelType="html" label="ShuffledRowRDD [56465] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146650 { id="cluster_146650"; isCluster="true"; label="WholeStageCodegen (1)"; 56466 [id="node_56466" labelType="html" label="MapPartitionsRDD [56466] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146673 { id="cluster_146673"; isCluster="true"; label="Exchange"; 56477 [id="node_56477" labelType="html" label="ShuffledRowRDD [56477] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146670 { id="cluster_146670"; isCluster="true"; label="WholeStageCodegen (4)"; 56478 [id="node_56478" labelType="html" label="MapPartitionsRDD [56478] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146708 { id="cluster_146708"; isCluster="true"; label="Exchange"; 56481 [id="node_56481" labelType="html" label="ShuffledRowRDD [56481] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146705 { id="cluster_146705"; isCluster="true"; label="WholeStageCodegen (6)"; 56482 [id="node_56482" labelType="html" label="MapPartitionsRDD [56482] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146662 { id="cluster_146662"; isCluster="true"; label="WholeStageCodegen (7)"; 56483 [id="node_56483" labelType="html" label="ZippedPartitionsRDD2 [56483] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56484 [id="node_56484" labelType="html" label="MapPartitionsRDD [56484] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146661 { id="cluster_146661"; isCluster="true"; label="InMemoryTableScan"; 56485 [id="node_56485" labelType="html" label="MapPartitionsRDD [56485] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56486 [id="node_56486" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1134002 AS qty#1134004, demandChannel#1133997, demandStream#1133998, cachedKpis#1134003 AS kpis#1134005]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1134001L, cachedShardId#1134000], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1756957]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [56486] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146659 { id="cluster_146659"; isCluster="true"; label="Exchange"; 56493 [id="node_56493" labelType="html" label="ShuffledRowRDD [56493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146656 { id="cluster_146656"; isCluster="true"; label="WholeStageCodegen (4)"; 56494 [id="node_56494" labelType="html" label="MapPartitionsRDD [56494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146643 { id="cluster_146643"; isCluster="true"; label="WholeStageCodegen (5)"; 56495 [id="node_56495" labelType="html" label="ZippedPartitionsRDD2 [56495] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56496 [id="node_56496" labelType="html" label="MapPartitionsRDD [56496] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146723 { id="cluster_146723"; isCluster="true"; label="InMemoryTableScan"; 56497 [id="node_56497" labelType="html" label="MapPartitionsRDD [56497] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56498 [id="node_56498" labelType="html" label="MapPartitionsRDD [56498] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56499 [id="node_56499" labelType="html" label="MapPartitionsRDD [56499] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146720 { id="cluster_146720"; isCluster="true"; label="WholeStageCodegen (6)"; 56500 [id="node_56500" labelType="html" label="MapPartitionsRDD [56500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146641 { id="cluster_146641"; isCluster="true"; label="Union"; 56501 [id="node_56501" labelType="html" label="UnionRDD [56501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146640 { id="cluster_146640"; isCluster="true"; label="InMemoryTableScan"; 56502 [id="node_56502" labelType="html" label="MapPartitionsRDD [56502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56503 [id="node_56503" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1134237, null AS demandStream#1134238, [] AS kpis#1134272, true AS isNewlyCalculated#1134240]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1134229, ), isnull(shardId#1134229), coalesce(worklistShardItemId#1134230L, 0), isnull(worklistShardItemId#1134230L), coalesce(version#1134231, 0), isnull(version#1134231), coalesce(product#1134232, ), isnull(product#1134232), coalesce(plant#1134233, ), isnull(plant#1134233), knownfloatingpointnormalized(normalizenanandzero(coalesce... [56503] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146930 { id="cluster_146930"; isCluster="true"; label="Exchange"; 56599 [id="node_56599" labelType="html" label="ShuffledRowRDD [56599] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146924 { id="cluster_146924"; isCluster="true"; label="WholeStageCodegen (6)"; 56600 [id="node_56600" labelType="html" label="MapPartitionsRDD [56600] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146923 { id="cluster_146923"; isCluster="true"; label="SortAggregate"; 56601 [id="node_56601" labelType="html" label="MapPartitionsRDD [56601] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146922 { id="cluster_146922"; isCluster="true"; label="InMemoryTableScan"; 56602 [id="node_56602" labelType="html" label="MapPartitionsRDD [56602] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56603 [id="node_56603" labelType="html" label="SortAggregate(key=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[first(kpis#1136802, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1136793, demandChannel#1136773, demandStream#1136774, kpis#1136935])\n+- *(6) Sort [demandChannel#1136773 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1136793 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1136774 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774, 37), ENSURE_REQUIREMENTS, [plan_id=1757887]\n +- SortAggregate(key=[demandChannel#1136773, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1136793)) AS qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[partial_first(kpis#1136802, false)], output=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L,... [56603] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147089 { id="cluster_147089"; isCluster="true"; label="InMemoryTableScan"; 56641 [id="node_56641" labelType="html" label="MapPartitionsRDD [56641] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56642 [id="node_56642" labelType="html" label="MapPartitionsRDD [56642] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56643 [id="node_56643" labelType="html" label="MapPartitionsRDD [56643] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147085 { id="cluster_147085"; isCluster="true"; label="WholeStageCodegen (1)"; 56644 [id="node_56644" labelType="html" label="MapPartitionsRDD [56644] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147093 { id="cluster_147093"; isCluster="true"; label="InMemoryTableScan"; 56645 [id="node_56645" labelType="html" label="MapPartitionsRDD [56645] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56646 [id="node_56646" labelType="html" label="MapPartitionsRDD [56646] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56647 [id="node_56647" labelType="html" label="MapPartitionsRDD [56647] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147090 { id="cluster_147090"; isCluster="true"; label="WholeStageCodegen (2)"; 56648 [id="node_56648" labelType="html" label="MapPartitionsRDD [56648] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147084 { id="cluster_147084"; isCluster="true"; label="Union"; 56649 [id="node_56649" labelType="html" label="UnionRDD [56649] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147060 { id="cluster_147060"; isCluster="true"; label="WholeStageCodegen (5)"; 56650 [id="node_56650" labelType="html" label="MapPartitionsRDD [56650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147059 { id="cluster_147059"; isCluster="true"; label="InMemoryTableScan"; 56651 [id="node_56651" labelType="html" label="MapPartitionsRDD [56651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56652 [id="node_56652" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1137606, qty#1100464, demandChannel#1134237, demandStream#1134238, kpis#1134272]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1137703, worklistShardItemId#1137704L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1134237, demandStream#1134238, kpis#1134272]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1134240 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1134237, demandStream#1134238, isNewlyCalculated#1134240, kpis#1134272, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1134240, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [56652] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56653 [id="node_56653" labelType="html" label="MapPartitionsRDD [56653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56654 [id="node_56654" labelType="html" label="MapPartitionsRDD [56654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56655 [id="node_56655" labelType="html" label="MapPartitionsRDD [56655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147058 { id="cluster_147058"; isCluster="true"; label="CollectLimit"; 56656 [id="node_56656" labelType="html" label="MapPartitionsRDD [56656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56657 [id="node_56657" labelType="html" label="MapPartitionsRDD [56657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56465->56466; 56477->56478; 56481->56482; 56478->56483; 56482->56483; 56483->56484; 56484->56485; 56485->56486; 56493->56494; 56466->56495; 56494->56495; 56495->56496; 56486->56497; 56497->56498; 56498->56499; 56499->56500; 56496->56501; 56500->56501; 56501->56502; 56502->56503; 56599->56600; 56600->56601; 56601->56602; 56602->56603; 56503->56641; 56641->56642; 56642->56643; 56643->56644; 56603->56645; 56645->56646; 56646->56647; 56647->56648; 56644->56649; 56648->56649; 56649->56650; 56650->56651; 56651->56652; 56652->56653; 56653->56654; 56654->56655; 56655->56656; 56656->56657; }