digraph G { id="graph_115060"; subgraph graph_stage_115060 { id="graph_stage_115060"; isCluster="true"; label="Stage 115060"; subgraph cluster_141678 { id="cluster_141678"; isCluster="true"; label="Exchange"; 54550 [id="node_54550" labelType="html" label="ShuffledRowRDD [54550] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141675 { id="cluster_141675"; isCluster="true"; label="WholeStageCodegen (1)"; 54551 [id="node_54551" labelType="html" label="MapPartitionsRDD [54551] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141698 { id="cluster_141698"; isCluster="true"; label="Exchange"; 54562 [id="node_54562" labelType="html" label="ShuffledRowRDD [54562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141695 { id="cluster_141695"; isCluster="true"; label="WholeStageCodegen (4)"; 54563 [id="node_54563" labelType="html" label="MapPartitionsRDD [54563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141733 { id="cluster_141733"; isCluster="true"; label="Exchange"; 54566 [id="node_54566" labelType="html" label="ShuffledRowRDD [54566] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141730 { id="cluster_141730"; isCluster="true"; label="WholeStageCodegen (6)"; 54567 [id="node_54567" labelType="html" label="MapPartitionsRDD [54567] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141687 { id="cluster_141687"; isCluster="true"; label="WholeStageCodegen (7)"; 54568 [id="node_54568" labelType="html" label="ZippedPartitionsRDD2 [54568] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54569 [id="node_54569" labelType="html" label="MapPartitionsRDD [54569] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141686 { id="cluster_141686"; isCluster="true"; label="InMemoryTableScan"; 54570 [id="node_54570" labelType="html" label="MapPartitionsRDD [54570] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54571 [id="node_54571" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1095181 AS qty#1095183, demandChannel#1095176, demandStream#1095177, cachedKpis#1095182 AS kpis#1095184]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1095180L, cachedShardId#1095179], 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=1697422]\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... [54571] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141684 { id="cluster_141684"; isCluster="true"; label="Exchange"; 54578 [id="node_54578" labelType="html" label="ShuffledRowRDD [54578] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141681 { id="cluster_141681"; isCluster="true"; label="WholeStageCodegen (4)"; 54579 [id="node_54579" labelType="html" label="MapPartitionsRDD [54579] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141667 { id="cluster_141667"; isCluster="true"; label="WholeStageCodegen (5)"; 54580 [id="node_54580" labelType="html" label="ZippedPartitionsRDD2 [54580] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54581 [id="node_54581" labelType="html" label="MapPartitionsRDD [54581] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141748 { id="cluster_141748"; isCluster="true"; label="InMemoryTableScan"; 54582 [id="node_54582" labelType="html" label="MapPartitionsRDD [54582] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54583 [id="node_54583" labelType="html" label="MapPartitionsRDD [54583] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54584 [id="node_54584" labelType="html" label="MapPartitionsRDD [54584] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141745 { id="cluster_141745"; isCluster="true"; label="WholeStageCodegen (6)"; 54585 [id="node_54585" labelType="html" label="MapPartitionsRDD [54585] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141666 { id="cluster_141666"; isCluster="true"; label="Union"; 54586 [id="node_54586" labelType="html" label="UnionRDD [54586] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141665 { id="cluster_141665"; isCluster="true"; label="InMemoryTableScan"; 54587 [id="node_54587" labelType="html" label="MapPartitionsRDD [54587] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54588 [id="node_54588" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1095416, null AS demandStream#1095417, [] AS kpis#1095451, true AS isNewlyCalculated#1095419]\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#1095408, ), isnull(shardId#1095408), coalesce(worklistShardItemId#1095409L, 0), isnull(worklistShardItemId#1095409L), coalesce(version#1095410, 0), isnull(version#1095410), coalesce(product#1095411, ), isnull(product#1095411), coalesce(plant#1095412, ), isnull(plant#1095412), knownfloatingpointnormalized(normalizenanandzero(coalesce... [54588] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141954 { id="cluster_141954"; isCluster="true"; label="Exchange"; 54684 [id="node_54684" labelType="html" label="ShuffledRowRDD [54684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141949 { id="cluster_141949"; isCluster="true"; label="WholeStageCodegen (6)"; 54685 [id="node_54685" labelType="html" label="MapPartitionsRDD [54685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141948 { id="cluster_141948"; isCluster="true"; label="SortAggregate"; 54686 [id="node_54686" labelType="html" label="MapPartitionsRDD [54686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141947 { id="cluster_141947"; isCluster="true"; label="InMemoryTableScan"; 54687 [id="node_54687" labelType="html" label="MapPartitionsRDD [54687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54688 [id="node_54688" labelType="html" label="SortAggregate(key=[demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L, demandStream#1097953], functions=[first(kpis#1097981, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1097972, demandChannel#1097952, demandStream#1097953, kpis#1098114])\n+- *(6) Sort [demandChannel#1097952 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1097972 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1097953 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L, demandStream#1097953, 37), ENSURE_REQUIREMENTS, [plan_id=1698352]\n +- SortAggregate(key=[demandChannel#1097952, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1097972)) AS qty#1097972, worklistShardItemId#1011816L, demandStream#1097953], functions=[partial_first(kpis#1097981, false)], output=[demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L,... [54688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142114 { id="cluster_142114"; isCluster="true"; label="InMemoryTableScan"; 54726 [id="node_54726" labelType="html" label="MapPartitionsRDD [54726] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54727 [id="node_54727" labelType="html" label="MapPartitionsRDD [54727] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54728 [id="node_54728" labelType="html" label="MapPartitionsRDD [54728] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142110 { id="cluster_142110"; isCluster="true"; label="WholeStageCodegen (1)"; 54729 [id="node_54729" labelType="html" label="MapPartitionsRDD [54729] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142118 { id="cluster_142118"; isCluster="true"; label="InMemoryTableScan"; 54730 [id="node_54730" labelType="html" label="MapPartitionsRDD [54730] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54731 [id="node_54731" labelType="html" label="MapPartitionsRDD [54731] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54732 [id="node_54732" labelType="html" label="MapPartitionsRDD [54732] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142115 { id="cluster_142115"; isCluster="true"; label="WholeStageCodegen (2)"; 54733 [id="node_54733" labelType="html" label="MapPartitionsRDD [54733] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142109 { id="cluster_142109"; isCluster="true"; label="Union"; 54734 [id="node_54734" labelType="html" label="UnionRDD [54734] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142085 { id="cluster_142085"; isCluster="true"; label="WholeStageCodegen (5)"; 54735 [id="node_54735" labelType="html" label="MapPartitionsRDD [54735] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142084 { id="cluster_142084"; isCluster="true"; label="InMemoryTableScan"; 54736 [id="node_54736" labelType="html" label="MapPartitionsRDD [54736] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54737 [id="node_54737" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1098785, qty#1011822, demandChannel#1095416, demandStream#1095417, kpis#1095451]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1098882, worklistShardItemId#1098883L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1095416, demandStream#1095417, kpis#1095451]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1095419 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1095416, demandStream#1095417, isNewlyCalculated#1095419, kpis#1095451, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1095419, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [54737] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54738 [id="node_54738" labelType="html" label="MapPartitionsRDD [54738] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54739 [id="node_54739" labelType="html" label="MapPartitionsRDD [54739] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54740 [id="node_54740" labelType="html" label="MapPartitionsRDD [54740] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142083 { id="cluster_142083"; isCluster="true"; label="CollectLimit"; 54741 [id="node_54741" labelType="html" label="MapPartitionsRDD [54741] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54742 [id="node_54742" labelType="html" label="MapPartitionsRDD [54742] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54550->54551; 54562->54563; 54566->54567; 54563->54568; 54567->54568; 54568->54569; 54569->54570; 54570->54571; 54578->54579; 54551->54580; 54579->54580; 54580->54581; 54571->54582; 54582->54583; 54583->54584; 54584->54585; 54581->54586; 54585->54586; 54586->54587; 54587->54588; 54684->54685; 54685->54686; 54686->54687; 54687->54688; 54588->54726; 54726->54727; 54727->54728; 54728->54729; 54688->54730; 54730->54731; 54731->54732; 54732->54733; 54729->54734; 54733->54734; 54734->54735; 54735->54736; 54736->54737; 54737->54738; 54738->54739; 54739->54740; 54740->54741; 54741->54742; }