digraph G { id="graph_115669"; subgraph graph_stage_115669 { id="graph_stage_115669"; isCluster="true"; label="Stage 115669"; subgraph cluster_144777 { id="cluster_144777"; isCluster="true"; label="Exchange"; 55667 [id="node_55667" labelType="html" label="ShuffledRowRDD [55667] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144774 { id="cluster_144774"; isCluster="true"; label="WholeStageCodegen (1)"; 55668 [id="node_55668" labelType="html" label="MapPartitionsRDD [55668] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144797 { id="cluster_144797"; isCluster="true"; label="Exchange"; 55679 [id="node_55679" labelType="html" label="ShuffledRowRDD [55679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144794 { id="cluster_144794"; isCluster="true"; label="WholeStageCodegen (4)"; 55680 [id="node_55680" labelType="html" label="MapPartitionsRDD [55680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144832 { id="cluster_144832"; isCluster="true"; label="Exchange"; 55683 [id="node_55683" labelType="html" label="ShuffledRowRDD [55683] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144829 { id="cluster_144829"; isCluster="true"; label="WholeStageCodegen (6)"; 55684 [id="node_55684" labelType="html" label="MapPartitionsRDD [55684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144786 { id="cluster_144786"; isCluster="true"; label="WholeStageCodegen (7)"; 55685 [id="node_55685" labelType="html" label="ZippedPartitionsRDD2 [55685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55686 [id="node_55686" labelType="html" label="MapPartitionsRDD [55686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144785 { id="cluster_144785"; isCluster="true"; label="InMemoryTableScan"; 55687 [id="node_55687" labelType="html" label="MapPartitionsRDD [55687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55688 [id="node_55688" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1117306 AS qty#1117308, demandChannel#1117301, demandStream#1117302, cachedKpis#1117307 AS kpis#1117309]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1117305L, cachedShardId#1117304], 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=1752232]\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... [55688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144783 { id="cluster_144783"; isCluster="true"; label="Exchange"; 55695 [id="node_55695" labelType="html" label="ShuffledRowRDD [55695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144780 { id="cluster_144780"; isCluster="true"; label="WholeStageCodegen (4)"; 55696 [id="node_55696" labelType="html" label="MapPartitionsRDD [55696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144766 { id="cluster_144766"; isCluster="true"; label="WholeStageCodegen (5)"; 55697 [id="node_55697" labelType="html" label="ZippedPartitionsRDD2 [55697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55698 [id="node_55698" labelType="html" label="MapPartitionsRDD [55698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144847 { id="cluster_144847"; isCluster="true"; label="InMemoryTableScan"; 55699 [id="node_55699" labelType="html" label="MapPartitionsRDD [55699] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55700 [id="node_55700" labelType="html" label="MapPartitionsRDD [55700] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55701 [id="node_55701" labelType="html" label="MapPartitionsRDD [55701] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144844 { id="cluster_144844"; isCluster="true"; label="WholeStageCodegen (6)"; 55702 [id="node_55702" labelType="html" label="MapPartitionsRDD [55702] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144765 { id="cluster_144765"; isCluster="true"; label="Union"; 55703 [id="node_55703" labelType="html" label="UnionRDD [55703] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144764 { id="cluster_144764"; isCluster="true"; label="InMemoryTableScan"; 55704 [id="node_55704" labelType="html" label="MapPartitionsRDD [55704] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55705 [id="node_55705" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1117541, null AS demandStream#1117542, [] AS kpis#1117576, true AS isNewlyCalculated#1117544]\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#1117533, ), isnull(shardId#1117533), coalesce(worklistShardItemId#1117534L, 0), isnull(worklistShardItemId#1117534L), coalesce(version#1117535, 0), isnull(version#1117535), coalesce(product#1117536, ), isnull(product#1117536), coalesce(plant#1117537, ), isnull(plant#1117537), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55705] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145068 { id="cluster_145068"; isCluster="true"; label="InMemoryTableScan"; 55771 [id="node_55771" labelType="html" label="MapPartitionsRDD [55771] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55772 [id="node_55772" labelType="html" label="MapPartitionsRDD [55772] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55773 [id="node_55773" labelType="html" label="MapPartitionsRDD [55773] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145063 { id="cluster_145063"; isCluster="true"; label="WholeStageCodegen (3)"; 55774 [id="node_55774" labelType="html" label="MapPartitionsRDD [55774] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145062 { id="cluster_145062"; isCluster="true"; label="Exchange"; 55775 [id="node_55775" labelType="html" label="MapPartitionsRDD [55775] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55667->55668; 55679->55680; 55683->55684; 55680->55685; 55684->55685; 55685->55686; 55686->55687; 55687->55688; 55695->55696; 55668->55697; 55696->55697; 55697->55698; 55688->55699; 55699->55700; 55700->55701; 55701->55702; 55698->55703; 55702->55703; 55703->55704; 55704->55705; 55705->55771; 55771->55772; 55772->55773; 55773->55774; 55774->55775; }