digraph G {
id="graph_99390";
subgraph graph_stage_99390 {
id="graph_stage_99390";
isCluster="true";
label="Stage 99390";
subgraph cluster_118592 {
id="cluster_118592";
isCluster="true";
label="Exchange";
45587 [id="node_45587" labelType="html" label="ShuffledRowRDD [45587] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118589 {
id="cluster_118589";
isCluster="true";
label="WholeStageCodegen (1)";
45588 [id="node_45588" labelType="html" label="MapPartitionsRDD [45588] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118612 {
id="cluster_118612";
isCluster="true";
label="Exchange";
45599 [id="node_45599" labelType="html" label="ShuffledRowRDD [45599] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118609 {
id="cluster_118609";
isCluster="true";
label="WholeStageCodegen (4)";
45600 [id="node_45600" labelType="html" label="MapPartitionsRDD [45600] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118647 {
id="cluster_118647";
isCluster="true";
label="Exchange";
45603 [id="node_45603" labelType="html" label="ShuffledRowRDD [45603] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118644 {
id="cluster_118644";
isCluster="true";
label="WholeStageCodegen (6)";
45604 [id="node_45604" labelType="html" label="MapPartitionsRDD [45604] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118601 {
id="cluster_118601";
isCluster="true";
label="WholeStageCodegen (7)";
45605 [id="node_45605" labelType="html" label="ZippedPartitionsRDD2 [45605] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45606 [id="node_45606" labelType="html" label="MapPartitionsRDD [45606] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118600 {
id="cluster_118600";
isCluster="true";
label="InMemoryTableScan";
45607 [id="node_45607" labelType="html" label="MapPartitionsRDD [45607] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45608 [id="node_45608" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#915955 AS qty#915957, demandChannel#915950, demandStream#915951, cachedKpis#915956 AS kpis#915958]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#915954L, cachedShardId#915953], 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=1447676]\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=1447672]\n : +- *(2) Has... [45608] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118598 {
id="cluster_118598";
isCluster="true";
label="Exchange";
45615 [id="node_45615" labelType="html" label="ShuffledRowRDD [45615] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118595 {
id="cluster_118595";
isCluster="true";
label="WholeStageCodegen (4)";
45616 [id="node_45616" labelType="html" label="MapPartitionsRDD [45616] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118581 {
id="cluster_118581";
isCluster="true";
label="WholeStageCodegen (5)";
45617 [id="node_45617" labelType="html" label="ZippedPartitionsRDD2 [45617] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45618 [id="node_45618" labelType="html" label="MapPartitionsRDD [45618] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118663 {
id="cluster_118663";
isCluster="true";
label="InMemoryTableScan";
45619 [id="node_45619" labelType="html" label="MapPartitionsRDD [45619] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45620 [id="node_45620" labelType="html" label="MapPartitionsRDD [45620] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45621 [id="node_45621" labelType="html" label="MapPartitionsRDD [45621] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118660 {
id="cluster_118660";
isCluster="true";
label="WholeStageCodegen (6)";
45622 [id="node_45622" labelType="html" label="MapPartitionsRDD [45622] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118580 {
id="cluster_118580";
isCluster="true";
label="Union";
45623 [id="node_45623" labelType="html" label="UnionRDD [45623] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118579 {
id="cluster_118579";
isCluster="true";
label="InMemoryTableScan";
45624 [id="node_45624" labelType="html" label="MapPartitionsRDD [45624] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45625 [id="node_45625" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#916190, null AS demandStream#916191, [] AS kpis#916225, true AS isNewlyCalculated#916193]\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#916182, ), isnull(shardId#916182), coalesce(worklistShardItemId#916183L, 0), isnull(worklistShardItemId#916183L), coalesce(version#916184, 0), isnull(version#916184), coalesce(product#916185, ), isnull(product#916185), coalesce(plant#916186, ), isnull(plant#916186), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#915957, 0.0))), isnull(qty#... [45625] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118871 {
id="cluster_118871";
isCluster="true";
label="Exchange";
45721 [id="node_45721" labelType="html" label="ShuffledRowRDD [45721] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118866 {
id="cluster_118866";
isCluster="true";
label="WholeStageCodegen (6)";
45722 [id="node_45722" labelType="html" label="MapPartitionsRDD [45722] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118865 {
id="cluster_118865";
isCluster="true";
label="SortAggregate";
45723 [id="node_45723" labelType="html" label="MapPartitionsRDD [45723] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118864 {
id="cluster_118864";
isCluster="true";
label="InMemoryTableScan";
45724 [id="node_45724" labelType="html" label="MapPartitionsRDD [45724] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45725 [id="node_45725" labelType="html" label="SortAggregate(key=[demandChannel#918894, shardId#904714, qty#918914, worklistShardItemId#904715L, demandStream#918895], functions=[first(kpis#918923, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#918914, demandChannel#918894, demandStream#918895, kpis#919056])\n+- *(6) Sort [demandChannel#918894 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#918914 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#918895 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#918894, shardId#904714, qty#918914, worklistShardItemId#904715L, demandStream#918895, 37), ENSURE_REQUIREMENTS, [plan_id=1448668]\n +- SortAggregate(key=[demandChannel#918894, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#918914)) AS qty#918914, worklistShardItemId#904715L, demandStream#918895], functions=[partial_first(kpis#918923, false)], output=[demandChannel#918894, shardId#904714, qty#918914, worklistShardItemId#904715L, demandStream#918895, first#91913... [45725] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119030 {
id="cluster_119030";
isCluster="true";
label="InMemoryTableScan";
45763 [id="node_45763" labelType="html" label="MapPartitionsRDD [45763] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45764 [id="node_45764" labelType="html" label="MapPartitionsRDD [45764] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45765 [id="node_45765" labelType="html" label="MapPartitionsRDD [45765] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119026 {
id="cluster_119026";
isCluster="true";
label="WholeStageCodegen (1)";
45766 [id="node_45766" labelType="html" label="MapPartitionsRDD [45766] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119034 {
id="cluster_119034";
isCluster="true";
label="InMemoryTableScan";
45767 [id="node_45767" labelType="html" label="MapPartitionsRDD [45767] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45768 [id="node_45768" labelType="html" label="MapPartitionsRDD [45768] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45769 [id="node_45769" labelType="html" label="MapPartitionsRDD [45769] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119031 {
id="cluster_119031";
isCluster="true";
label="WholeStageCodegen (2)";
45770 [id="node_45770" labelType="html" label="MapPartitionsRDD [45770] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119025 {
id="cluster_119025";
isCluster="true";
label="Union";
45771 [id="node_45771" labelType="html" label="UnionRDD [45771] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119001 {
id="cluster_119001";
isCluster="true";
label="WholeStageCodegen (5)";
45772 [id="node_45772" labelType="html" label="MapPartitionsRDD [45772] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_119000 {
id="cluster_119000";
isCluster="true";
label="InMemoryTableScan";
45773 [id="node_45773" labelType="html" label="MapPartitionsRDD [45773] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45774 [id="node_45774" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#919727, qty#904721, demandChannel#916190, demandStream#916191, kpis#916225]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#919824, worklistShardItemId#919825L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#916190, demandStream#916191, kpis#916225]\n : : +- *(1) Filter ((NOT isNewlyCalculated#916193 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#916190, demandStream#916191, isNewlyCalculated#916193, kpis#916225, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#916193, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#916190, demandStream#916191... [45774] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45775 [id="node_45775" labelType="html" label="MapPartitionsRDD [45775] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45776 [id="node_45776" labelType="html" label="MapPartitionsRDD [45776] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45777 [id="node_45777" labelType="html" label="MapPartitionsRDD [45777] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118999 {
id="cluster_118999";
isCluster="true";
label="CollectLimit";
45778 [id="node_45778" labelType="html" label="MapPartitionsRDD [45778] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45779 [id="node_45779" labelType="html" label="MapPartitionsRDD [45779] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
45587->45588;
45599->45600;
45603->45604;
45600->45605;
45604->45605;
45605->45606;
45606->45607;
45607->45608;
45615->45616;
45588->45617;
45616->45617;
45617->45618;
45608->45619;
45619->45620;
45620->45621;
45621->45622;
45618->45623;
45622->45623;
45623->45624;
45624->45625;
45721->45722;
45722->45723;
45723->45724;
45724->45725;
45625->45763;
45763->45764;
45764->45765;
45765->45766;
45725->45767;
45767->45768;
45768->45769;
45769->45770;
45766->45771;
45770->45771;
45771->45772;
45772->45773;
45773->45774;
45774->45775;
45775->45776;
45776->45777;
45777->45778;
45778->45779;
}
45586,45587
45598,45599
45602,45603
45614,45615
45720,45721
45608
45625
45725
45774