digraph G { id="graph_100195"; subgraph graph_stage_100195 { id="graph_stage_100195"; isCluster="true"; label="Stage 100195"; subgraph cluster_120459 { id="cluster_120459"; isCluster="true"; label="Exchange"; 46381 [id="node_46381" labelType="html" label="ShuffledRowRDD [46381] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120456 { id="cluster_120456"; isCluster="true"; label="WholeStageCodegen (1)"; 46382 [id="node_46382" labelType="html" label="MapPartitionsRDD [46382] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120479 { id="cluster_120479"; isCluster="true"; label="Exchange"; 46393 [id="node_46393" labelType="html" label="ShuffledRowRDD [46393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120476 { id="cluster_120476"; isCluster="true"; label="WholeStageCodegen (4)"; 46394 [id="node_46394" labelType="html" label="MapPartitionsRDD [46394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120514 { id="cluster_120514"; isCluster="true"; label="Exchange"; 46397 [id="node_46397" labelType="html" label="ShuffledRowRDD [46397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120511 { id="cluster_120511"; isCluster="true"; label="WholeStageCodegen (6)"; 46398 [id="node_46398" labelType="html" label="MapPartitionsRDD [46398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120468 { id="cluster_120468"; isCluster="true"; label="WholeStageCodegen (7)"; 46399 [id="node_46399" labelType="html" label="ZippedPartitionsRDD2 [46399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46400 [id="node_46400" labelType="html" label="MapPartitionsRDD [46400] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120467 { id="cluster_120467"; isCluster="true"; label="InMemoryTableScan"; 46401 [id="node_46401" labelType="html" label="MapPartitionsRDD [46401] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46402 [id="node_46402" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#932797 AS qty#932799, demandChannel#932792, demandStream#932793, cachedKpis#932798 AS kpis#932800]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#932796L, cachedShardId#932795], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1452493]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1452489]\n : +- *(2) Has... [46402] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120465 { id="cluster_120465"; isCluster="true"; label="Exchange"; 46409 [id="node_46409" labelType="html" label="ShuffledRowRDD [46409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120462 { id="cluster_120462"; isCluster="true"; label="WholeStageCodegen (4)"; 46410 [id="node_46410" labelType="html" label="MapPartitionsRDD [46410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120448 { id="cluster_120448"; isCluster="true"; label="WholeStageCodegen (5)"; 46411 [id="node_46411" labelType="html" label="ZippedPartitionsRDD2 [46411] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46412 [id="node_46412" labelType="html" label="MapPartitionsRDD [46412] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120529 { id="cluster_120529"; isCluster="true"; label="InMemoryTableScan"; 46413 [id="node_46413" labelType="html" label="MapPartitionsRDD [46413] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46414 [id="node_46414" labelType="html" label="MapPartitionsRDD [46414] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46415 [id="node_46415" labelType="html" label="MapPartitionsRDD [46415] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120526 { id="cluster_120526"; isCluster="true"; label="WholeStageCodegen (6)"; 46416 [id="node_46416" labelType="html" label="MapPartitionsRDD [46416] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120447 { id="cluster_120447"; isCluster="true"; label="Union"; 46417 [id="node_46417" labelType="html" label="UnionRDD [46417] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120446 { id="cluster_120446"; isCluster="true"; label="InMemoryTableScan"; 46418 [id="node_46418" labelType="html" label="MapPartitionsRDD [46418] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46419 [id="node_46419" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#933032, null AS demandStream#933033, [] AS kpis#933067, true AS isNewlyCalculated#933035]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#933024, ), isnull(shardId#933024), coalesce(worklistShardItemId#933025L, 0), isnull(worklistShardItemId#933025L), coalesce(version#933026, 0), isnull(version#933026), coalesce(product#933027, ), isnull(product#933027), coalesce(plant#933028, ), isnull(plant#933028), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#932799, 0.0))), isnull(qty#... [46419] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120735 { id="cluster_120735"; isCluster="true"; label="Exchange"; 46515 [id="node_46515" labelType="html" label="ShuffledRowRDD [46515] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120730 { id="cluster_120730"; isCluster="true"; label="WholeStageCodegen (6)"; 46516 [id="node_46516" labelType="html" label="MapPartitionsRDD [46516] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120729 { id="cluster_120729"; isCluster="true"; label="SortAggregate"; 46517 [id="node_46517" labelType="html" label="MapPartitionsRDD [46517] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120728 { id="cluster_120728"; isCluster="true"; label="InMemoryTableScan"; 46518 [id="node_46518" labelType="html" label="MapPartitionsRDD [46518] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46519 [id="node_46519" labelType="html" label="SortAggregate(key=[demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569], functions=[first(kpis#935597, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#935588, demandChannel#935568, demandStream#935569, kpis#935730])\n+- *(6) Sort [demandChannel#935568 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#935588 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#935569 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569, 37), ENSURE_REQUIREMENTS, [plan_id=1453423]\n +- SortAggregate(key=[demandChannel#935568, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#935588)) AS qty#935588, worklistShardItemId#904715L, demandStream#935569], functions=[partial_first(kpis#935597, false)], output=[demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569, first#93580... [46519] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120895 { id="cluster_120895"; isCluster="true"; label="InMemoryTableScan"; 46557 [id="node_46557" labelType="html" label="MapPartitionsRDD [46557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46558 [id="node_46558" labelType="html" label="MapPartitionsRDD [46558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46559 [id="node_46559" labelType="html" label="MapPartitionsRDD [46559] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120891 { id="cluster_120891"; isCluster="true"; label="WholeStageCodegen (1)"; 46560 [id="node_46560" labelType="html" label="MapPartitionsRDD [46560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120899 { id="cluster_120899"; isCluster="true"; label="InMemoryTableScan"; 46561 [id="node_46561" labelType="html" label="MapPartitionsRDD [46561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46562 [id="node_46562" labelType="html" label="MapPartitionsRDD [46562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46563 [id="node_46563" labelType="html" label="MapPartitionsRDD [46563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120896 { id="cluster_120896"; isCluster="true"; label="WholeStageCodegen (2)"; 46564 [id="node_46564" labelType="html" label="MapPartitionsRDD [46564] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120890 { id="cluster_120890"; isCluster="true"; label="Union"; 46565 [id="node_46565" labelType="html" label="UnionRDD [46565] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120866 { id="cluster_120866"; isCluster="true"; label="WholeStageCodegen (5)"; 46566 [id="node_46566" labelType="html" label="MapPartitionsRDD [46566] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120865 { id="cluster_120865"; isCluster="true"; label="InMemoryTableScan"; 46567 [id="node_46567" labelType="html" label="MapPartitionsRDD [46567] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46568 [id="node_46568" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#936401, qty#904721, demandChannel#933032, demandStream#933033, kpis#933067]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#936498, worklistShardItemId#936499L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#933032, demandStream#933033, kpis#933067]\n : : +- *(1) Filter ((NOT isNewlyCalculated#933035 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#933032, demandStream#933033, isNewlyCalculated#933035, kpis#933067, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#933035, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#933032, demandStream#933033... [46568] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46569 [id="node_46569" labelType="html" label="MapPartitionsRDD [46569] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46570 [id="node_46570" labelType="html" label="MapPartitionsRDD [46570] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46571 [id="node_46571" labelType="html" label="MapPartitionsRDD [46571] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120864 { id="cluster_120864"; isCluster="true"; label="CollectLimit"; 46572 [id="node_46572" labelType="html" label="MapPartitionsRDD [46572] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46573 [id="node_46573" labelType="html" label="MapPartitionsRDD [46573] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46381->46382; 46393->46394; 46397->46398; 46394->46399; 46398->46399; 46399->46400; 46400->46401; 46401->46402; 46409->46410; 46382->46411; 46410->46411; 46411->46412; 46402->46413; 46413->46414; 46414->46415; 46415->46416; 46412->46417; 46416->46417; 46417->46418; 46418->46419; 46515->46516; 46516->46517; 46517->46518; 46518->46519; 46419->46557; 46557->46558; 46558->46559; 46559->46560; 46519->46561; 46561->46562; 46562->46563; 46563->46564; 46560->46565; 46564->46565; 46565->46566; 46566->46567; 46567->46568; 46568->46569; 46569->46570; 46570->46571; 46571->46572; 46572->46573; }