digraph G { id="graph_119721"; subgraph graph_stage_119721 { id="graph_stage_119721"; isCluster="true"; label="Stage 119721"; subgraph cluster_149758 { id="cluster_149758"; isCluster="true"; label="Exchange"; 57785 [id="node_57785" labelType="html" label="ShuffledRowRDD [57785] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149755 { id="cluster_149755"; isCluster="true"; label="WholeStageCodegen (1)"; 57786 [id="node_57786" labelType="html" label="MapPartitionsRDD [57786] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149778 { id="cluster_149778"; isCluster="true"; label="Exchange"; 57797 [id="node_57797" labelType="html" label="ShuffledRowRDD [57797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149775 { id="cluster_149775"; isCluster="true"; label="WholeStageCodegen (4)"; 57798 [id="node_57798" labelType="html" label="MapPartitionsRDD [57798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149807 { id="cluster_149807"; isCluster="true"; label="Exchange"; 57801 [id="node_57801" labelType="html" label="ShuffledRowRDD [57801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149804 { id="cluster_149804"; isCluster="true"; label="WholeStageCodegen (6)"; 57802 [id="node_57802" labelType="html" label="MapPartitionsRDD [57802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149767 { id="cluster_149767"; isCluster="true"; label="WholeStageCodegen (7)"; 57803 [id="node_57803" labelType="html" label="ZippedPartitionsRDD2 [57803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57804 [id="node_57804" labelType="html" label="MapPartitionsRDD [57804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149766 { id="cluster_149766"; isCluster="true"; label="InMemoryTableScan"; 57805 [id="node_57805" labelType="html" label="MapPartitionsRDD [57805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57806 [id="node_57806" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], 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=1764825]\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... [57806] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149764 { id="cluster_149764"; isCluster="true"; label="Exchange"; 57813 [id="node_57813" labelType="html" label="ShuffledRowRDD [57813] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149761 { id="cluster_149761"; isCluster="true"; label="WholeStageCodegen (4)"; 57814 [id="node_57814" labelType="html" label="MapPartitionsRDD [57814] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149747 { id="cluster_149747"; isCluster="true"; label="WholeStageCodegen (5)"; 57815 [id="node_57815" labelType="html" label="ZippedPartitionsRDD2 [57815] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57816 [id="node_57816" labelType="html" label="MapPartitionsRDD [57816] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149822 { id="cluster_149822"; isCluster="true"; label="InMemoryTableScan"; 57817 [id="node_57817" labelType="html" label="MapPartitionsRDD [57817] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57818 [id="node_57818" labelType="html" label="MapPartitionsRDD [57818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57819 [id="node_57819" labelType="html" label="MapPartitionsRDD [57819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149819 { id="cluster_149819"; isCluster="true"; label="WholeStageCodegen (6)"; 57820 [id="node_57820" labelType="html" label="MapPartitionsRDD [57820] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149746 { id="cluster_149746"; isCluster="true"; label="Union"; 57821 [id="node_57821" labelType="html" label="UnionRDD [57821] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149745 { id="cluster_149745"; isCluster="true"; label="InMemoryTableScan"; 57822 [id="node_57822" labelType="html" label="MapPartitionsRDD [57822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57823 [id="node_57823" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1162027, null AS demandStream#1162028, [] AS kpis#1162062, true AS isNewlyCalculated#1162030]\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#1162019, ), isnull(shardId#1162019), coalesce(worklistShardItemId#1162020L, 0), isnull(worklistShardItemId#1162020L), coalesce(version#1162021, 0), isnull(version#1162021), coalesce(product#1162022, ), isnull(product#1162022), coalesce(plant#1162023, ), isnull(plant#1162023), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57823] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150049 { id="cluster_150049"; isCluster="true"; label="InMemoryTableScan"; 57889 [id="node_57889" labelType="html" label="MapPartitionsRDD [57889] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57890 [id="node_57890" labelType="html" label="MapPartitionsRDD [57890] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57891 [id="node_57891" labelType="html" label="MapPartitionsRDD [57891] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150044 { id="cluster_150044"; isCluster="true"; label="WholeStageCodegen (3)"; 57892 [id="node_57892" labelType="html" label="MapPartitionsRDD [57892] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150043 { id="cluster_150043"; isCluster="true"; label="Exchange"; 57893 [id="node_57893" labelType="html" label="MapPartitionsRDD [57893] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57785->57786; 57797->57798; 57801->57802; 57798->57803; 57802->57803; 57803->57804; 57804->57805; 57805->57806; 57813->57814; 57786->57815; 57814->57815; 57815->57816; 57806->57817; 57817->57818; 57818->57819; 57819->57820; 57816->57821; 57820->57821; 57821->57822; 57822->57823; 57823->57889; 57889->57890; 57890->57891; 57891->57892; 57892->57893; }