digraph G { id="graph_117846"; subgraph graph_stage_117846 { id="graph_stage_117846"; isCluster="true"; label="Stage 117846"; subgraph cluster_147895 { id="cluster_147895"; isCluster="true"; label="Exchange"; 56993 [id="node_56993" labelType="html" label="ShuffledRowRDD [56993] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147892 { id="cluster_147892"; isCluster="true"; label="WholeStageCodegen (1)"; 56994 [id="node_56994" labelType="html" label="MapPartitionsRDD [56994] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147915 { id="cluster_147915"; isCluster="true"; label="Exchange"; 57005 [id="node_57005" labelType="html" label="ShuffledRowRDD [57005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147912 { id="cluster_147912"; isCluster="true"; label="WholeStageCodegen (4)"; 57006 [id="node_57006" labelType="html" label="MapPartitionsRDD [57006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147944 { id="cluster_147944"; isCluster="true"; label="Exchange"; 57009 [id="node_57009" labelType="html" label="ShuffledRowRDD [57009] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147941 { id="cluster_147941"; isCluster="true"; label="WholeStageCodegen (6)"; 57010 [id="node_57010" labelType="html" label="MapPartitionsRDD [57010] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147904 { id="cluster_147904"; isCluster="true"; label="WholeStageCodegen (7)"; 57011 [id="node_57011" labelType="html" label="ZippedPartitionsRDD2 [57011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57012 [id="node_57012" labelType="html" label="MapPartitionsRDD [57012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147903 { id="cluster_147903"; isCluster="true"; label="InMemoryTableScan"; 57013 [id="node_57013" labelType="html" label="MapPartitionsRDD [57013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57014 [id="node_57014" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1145118 AS qty#1145120, demandChannel#1145113, demandStream#1145114, cachedKpis#1145119 AS kpis#1145121]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1145117L, cachedShardId#1145116], 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=1760137]\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... [57014] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147901 { id="cluster_147901"; isCluster="true"; label="Exchange"; 57021 [id="node_57021" labelType="html" label="ShuffledRowRDD [57021] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147898 { id="cluster_147898"; isCluster="true"; label="WholeStageCodegen (4)"; 57022 [id="node_57022" labelType="html" label="MapPartitionsRDD [57022] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147884 { id="cluster_147884"; isCluster="true"; label="WholeStageCodegen (5)"; 57023 [id="node_57023" labelType="html" label="ZippedPartitionsRDD2 [57023] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57024 [id="node_57024" labelType="html" label="MapPartitionsRDD [57024] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147959 { id="cluster_147959"; isCluster="true"; label="InMemoryTableScan"; 57025 [id="node_57025" labelType="html" label="MapPartitionsRDD [57025] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57026 [id="node_57026" labelType="html" label="MapPartitionsRDD [57026] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57027 [id="node_57027" labelType="html" label="MapPartitionsRDD [57027] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147956 { id="cluster_147956"; isCluster="true"; label="WholeStageCodegen (6)"; 57028 [id="node_57028" labelType="html" label="MapPartitionsRDD [57028] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147883 { id="cluster_147883"; isCluster="true"; label="Union"; 57029 [id="node_57029" labelType="html" label="UnionRDD [57029] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147882 { id="cluster_147882"; isCluster="true"; label="InMemoryTableScan"; 57030 [id="node_57030" labelType="html" label="MapPartitionsRDD [57030] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57031 [id="node_57031" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1145353, null AS demandStream#1145354, [] AS kpis#1145388, true AS isNewlyCalculated#1145356]\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#1145345, ), isnull(shardId#1145345), coalesce(worklistShardItemId#1145346L, 0), isnull(worklistShardItemId#1145346L), coalesce(version#1145347, 0), isnull(version#1145347), coalesce(product#1145348, ), isnull(product#1145348), coalesce(plant#1145349, ), isnull(plant#1145349), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57031] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148315 { id="cluster_148315"; isCluster="true"; label="InMemoryTableScan"; 57161 [id="node_57161" labelType="html" label="MapPartitionsRDD [57161] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57162 [id="node_57162" labelType="html" label="MapPartitionsRDD [57162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57163 [id="node_57163" labelType="html" label="MapPartitionsRDD [57163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148311 { id="cluster_148311"; isCluster="true"; label="WholeStageCodegen (3)"; 57164 [id="node_57164" labelType="html" label="MapPartitionsRDD [57164] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148310 { id="cluster_148310"; isCluster="true"; label="Exchange"; 57165 [id="node_57165" labelType="html" label="MapPartitionsRDD [57165] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56993->56994; 57005->57006; 57009->57010; 57006->57011; 57010->57011; 57011->57012; 57012->57013; 57013->57014; 57021->57022; 56994->57023; 57022->57023; 57023->57024; 57014->57025; 57025->57026; 57026->57027; 57027->57028; 57024->57029; 57028->57029; 57029->57030; 57030->57031; 57031->57161; 57161->57162; 57162->57163; 57163->57164; 57164->57165; }