digraph G { id="graph_102459"; subgraph graph_stage_102459 { id="graph_stage_102459"; isCluster="true"; label="Stage 102459"; subgraph cluster_127893 { id="cluster_127893"; isCluster="true"; label="Exchange"; 48927 [id="node_48927" labelType="html" label="ShuffledRowRDD [48927] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127890 { id="cluster_127890"; isCluster="true"; label="WholeStageCodegen (1)"; 48928 [id="node_48928" labelType="html" label="MapPartitionsRDD [48928] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127913 { id="cluster_127913"; isCluster="true"; label="Exchange"; 48939 [id="node_48939" labelType="html" label="ShuffledRowRDD [48939] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127910 { id="cluster_127910"; isCluster="true"; label="WholeStageCodegen (4)"; 48940 [id="node_48940" labelType="html" label="MapPartitionsRDD [48940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127948 { id="cluster_127948"; isCluster="true"; label="Exchange"; 48943 [id="node_48943" labelType="html" label="ShuffledRowRDD [48943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127945 { id="cluster_127945"; isCluster="true"; label="WholeStageCodegen (6)"; 48944 [id="node_48944" labelType="html" label="MapPartitionsRDD [48944] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127902 { id="cluster_127902"; isCluster="true"; label="WholeStageCodegen (7)"; 48945 [id="node_48945" labelType="html" label="ZippedPartitionsRDD2 [48945] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48946 [id="node_48946" labelType="html" label="MapPartitionsRDD [48946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127901 { id="cluster_127901"; isCluster="true"; label="InMemoryTableScan"; 48947 [id="node_48947" labelType="html" label="MapPartitionsRDD [48947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48948 [id="node_48948" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#978749 AS qty#978751, demandChannel#978744, demandStream#978745, cachedKpis#978750 AS kpis#978752]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#978748L, cachedShardId#978747], 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=1624120]\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=1624116]\n : +- *(2) Has... [48948] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127899 { id="cluster_127899"; isCluster="true"; label="Exchange"; 48955 [id="node_48955" labelType="html" label="ShuffledRowRDD [48955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127896 { id="cluster_127896"; isCluster="true"; label="WholeStageCodegen (4)"; 48956 [id="node_48956" labelType="html" label="MapPartitionsRDD [48956] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127882 { id="cluster_127882"; isCluster="true"; label="WholeStageCodegen (5)"; 48957 [id="node_48957" labelType="html" label="ZippedPartitionsRDD2 [48957] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48958 [id="node_48958" labelType="html" label="MapPartitionsRDD [48958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127963 { id="cluster_127963"; isCluster="true"; label="InMemoryTableScan"; 48959 [id="node_48959" labelType="html" label="MapPartitionsRDD [48959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48960 [id="node_48960" labelType="html" label="MapPartitionsRDD [48960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48961 [id="node_48961" labelType="html" label="MapPartitionsRDD [48961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127960 { id="cluster_127960"; isCluster="true"; label="WholeStageCodegen (6)"; 48962 [id="node_48962" labelType="html" label="MapPartitionsRDD [48962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127881 { id="cluster_127881"; isCluster="true"; label="Union"; 48963 [id="node_48963" labelType="html" label="UnionRDD [48963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_127880 { id="cluster_127880"; isCluster="true"; label="InMemoryTableScan"; 48964 [id="node_48964" labelType="html" label="MapPartitionsRDD [48964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 48965 [id="node_48965" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#978984, null AS demandStream#978985, [] AS kpis#979019, true AS isNewlyCalculated#978987]\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#978976, ), isnull(shardId#978976), coalesce(worklistShardItemId#978977L, 0), isnull(worklistShardItemId#978977L), coalesce(version#978978, 0), isnull(version#978978), coalesce(product#978979, ), isnull(product#978979), coalesce(plant#978980, ), isnull(plant#978980), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#978751, 0.0))), isnull(qty#... [48965] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128170 { id="cluster_128170"; isCluster="true"; label="Exchange"; 49061 [id="node_49061" labelType="html" label="ShuffledRowRDD [49061] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128164 { id="cluster_128164"; isCluster="true"; label="WholeStageCodegen (6)"; 49062 [id="node_49062" labelType="html" label="MapPartitionsRDD [49062] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128163 { id="cluster_128163"; isCluster="true"; label="SortAggregate"; 49063 [id="node_49063" labelType="html" label="MapPartitionsRDD [49063] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128162 { id="cluster_128162"; isCluster="true"; label="InMemoryTableScan"; 49064 [id="node_49064" labelType="html" label="MapPartitionsRDD [49064] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49065 [id="node_49065" labelType="html" label="SortAggregate(key=[demandChannel#981520, shardId#943631, qty#981540, worklistShardItemId#943632L, demandStream#981521], functions=[first(kpis#981549, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#981540, demandChannel#981520, demandStream#981521, kpis#981682])\n+- *(6) Sort [demandChannel#981520 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#981540 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#981521 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#981520, shardId#943631, qty#981540, worklistShardItemId#943632L, demandStream#981521, 37), ENSURE_REQUIREMENTS, [plan_id=1625050]\n +- SortAggregate(key=[demandChannel#981520, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#981540)) AS qty#981540, worklistShardItemId#943632L, demandStream#981521], functions=[partial_first(kpis#981549, false)], output=[demandChannel#981520, shardId#943631, qty#981540, worklistShardItemId#943632L, demandStream#981521, first#98175... [49065] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128329 { id="cluster_128329"; isCluster="true"; label="InMemoryTableScan"; 49103 [id="node_49103" labelType="html" label="MapPartitionsRDD [49103] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49104 [id="node_49104" labelType="html" label="MapPartitionsRDD [49104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49105 [id="node_49105" labelType="html" label="MapPartitionsRDD [49105] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128325 { id="cluster_128325"; isCluster="true"; label="WholeStageCodegen (1)"; 49106 [id="node_49106" labelType="html" label="MapPartitionsRDD [49106] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128333 { id="cluster_128333"; isCluster="true"; label="InMemoryTableScan"; 49107 [id="node_49107" labelType="html" label="MapPartitionsRDD [49107] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49108 [id="node_49108" labelType="html" label="MapPartitionsRDD [49108] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49109 [id="node_49109" labelType="html" label="MapPartitionsRDD [49109] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128330 { id="cluster_128330"; isCluster="true"; label="WholeStageCodegen (2)"; 49110 [id="node_49110" labelType="html" label="MapPartitionsRDD [49110] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128324 { id="cluster_128324"; isCluster="true"; label="Union"; 49111 [id="node_49111" labelType="html" label="UnionRDD [49111] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128300 { id="cluster_128300"; isCluster="true"; label="WholeStageCodegen (5)"; 49112 [id="node_49112" labelType="html" label="MapPartitionsRDD [49112] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128299 { id="cluster_128299"; isCluster="true"; label="InMemoryTableScan"; 49113 [id="node_49113" labelType="html" label="MapPartitionsRDD [49113] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49114 [id="node_49114" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#982353, qty#943638, demandChannel#978984, demandStream#978985, kpis#979019]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#982450, worklistShardItemId#982451L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#978984, demandStream#978985, kpis#979019]\n : : +- *(1) Filter ((NOT isNewlyCalculated#978987 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#978984, demandStream#978985, isNewlyCalculated#978987, kpis#979019, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#978987, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#978984, demandStream#978985... [49114] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49115 [id="node_49115" labelType="html" label="MapPartitionsRDD [49115] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49116 [id="node_49116" labelType="html" label="MapPartitionsRDD [49116] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49117 [id="node_49117" labelType="html" label="MapPartitionsRDD [49117] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128298 { id="cluster_128298"; isCluster="true"; label="CollectLimit"; 49118 [id="node_49118" labelType="html" label="MapPartitionsRDD [49118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49119 [id="node_49119" labelType="html" label="MapPartitionsRDD [49119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 48927->48928; 48939->48940; 48943->48944; 48940->48945; 48944->48945; 48945->48946; 48946->48947; 48947->48948; 48955->48956; 48928->48957; 48956->48957; 48957->48958; 48948->48959; 48959->48960; 48960->48961; 48961->48962; 48958->48963; 48962->48963; 48963->48964; 48964->48965; 49061->49062; 49062->49063; 49063->49064; 49064->49065; 48965->49103; 49103->49104; 49104->49105; 49105->49106; 49065->49107; 49107->49108; 49108->49109; 49109->49110; 49106->49111; 49110->49111; 49111->49112; 49112->49113; 49113->49114; 49114->49115; 49115->49116; 49116->49117; 49117->49118; 49118->49119; }