digraph G { id="graph_117209"; subgraph graph_stage_117209 { id="graph_stage_117209"; isCluster="true"; label="Stage 117209"; subgraph cluster_147274 { id="cluster_147274"; isCluster="true"; label="Exchange"; 56729 [id="node_56729" labelType="html" label="ShuffledRowRDD [56729] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147271 { id="cluster_147271"; isCluster="true"; label="WholeStageCodegen (1)"; 56730 [id="node_56730" labelType="html" label="MapPartitionsRDD [56730] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147294 { id="cluster_147294"; isCluster="true"; label="Exchange"; 56741 [id="node_56741" labelType="html" label="ShuffledRowRDD [56741] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147291 { id="cluster_147291"; isCluster="true"; label="WholeStageCodegen (4)"; 56742 [id="node_56742" labelType="html" label="MapPartitionsRDD [56742] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147329 { id="cluster_147329"; isCluster="true"; label="Exchange"; 56745 [id="node_56745" labelType="html" label="ShuffledRowRDD [56745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147326 { id="cluster_147326"; isCluster="true"; label="WholeStageCodegen (6)"; 56746 [id="node_56746" labelType="html" label="MapPartitionsRDD [56746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147283 { id="cluster_147283"; isCluster="true"; label="WholeStageCodegen (7)"; 56747 [id="node_56747" labelType="html" label="ZippedPartitionsRDD2 [56747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56748 [id="node_56748" labelType="html" label="MapPartitionsRDD [56748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147282 { id="cluster_147282"; isCluster="true"; label="InMemoryTableScan"; 56749 [id="node_56749" labelType="html" label="MapPartitionsRDD [56749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56750 [id="node_56750" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1139560 AS qty#1139562, demandChannel#1139555, demandStream#1139556, cachedKpis#1139561 AS kpis#1139563]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1139559L, cachedShardId#1139558], 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=1758547]\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... [56750] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147280 { id="cluster_147280"; isCluster="true"; label="Exchange"; 56757 [id="node_56757" labelType="html" label="ShuffledRowRDD [56757] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147277 { id="cluster_147277"; isCluster="true"; label="WholeStageCodegen (4)"; 56758 [id="node_56758" labelType="html" label="MapPartitionsRDD [56758] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147263 { id="cluster_147263"; isCluster="true"; label="WholeStageCodegen (5)"; 56759 [id="node_56759" labelType="html" label="ZippedPartitionsRDD2 [56759] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56760 [id="node_56760" labelType="html" label="MapPartitionsRDD [56760] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147344 { id="cluster_147344"; isCluster="true"; label="InMemoryTableScan"; 56761 [id="node_56761" labelType="html" label="MapPartitionsRDD [56761] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56762 [id="node_56762" labelType="html" label="MapPartitionsRDD [56762] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56763 [id="node_56763" labelType="html" label="MapPartitionsRDD [56763] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147341 { id="cluster_147341"; isCluster="true"; label="WholeStageCodegen (6)"; 56764 [id="node_56764" labelType="html" label="MapPartitionsRDD [56764] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147262 { id="cluster_147262"; isCluster="true"; label="Union"; 56765 [id="node_56765" labelType="html" label="UnionRDD [56765] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147261 { id="cluster_147261"; isCluster="true"; label="InMemoryTableScan"; 56766 [id="node_56766" labelType="html" label="MapPartitionsRDD [56766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56767 [id="node_56767" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1139795, null AS demandStream#1139796, [] AS kpis#1139830, true AS isNewlyCalculated#1139798]\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#1139787, ), isnull(shardId#1139787), coalesce(worklistShardItemId#1139788L, 0), isnull(worklistShardItemId#1139788L), coalesce(version#1139789, 0), isnull(version#1139789), coalesce(product#1139790, ), isnull(product#1139790), coalesce(plant#1139791, ), isnull(plant#1139791), knownfloatingpointnormalized(normalizenanandzero(coalesce... [56767] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56768 [id="node_56768" labelType="html" label="MapPartitionsRDD [56768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56769 [id="node_56769" labelType="html" label="MapPartitionsRDD [56769] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56770 [id="node_56770" labelType="html" label="MapPartitionsRDD [56770] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147256 { id="cluster_147256"; isCluster="true"; label="WholeStageCodegen (15)"; 56771 [id="node_56771" labelType="html" label="MapPartitionsRDD [56771] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147255 { id="cluster_147255"; isCluster="true"; label="Exchange"; 56772 [id="node_56772" labelType="html" label="MapPartitionsRDD [56772] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56729->56730; 56741->56742; 56745->56746; 56742->56747; 56746->56747; 56747->56748; 56748->56749; 56749->56750; 56757->56758; 56730->56759; 56758->56759; 56759->56760; 56750->56761; 56761->56762; 56762->56763; 56763->56764; 56760->56765; 56764->56765; 56765->56766; 56766->56767; 56767->56768; 56768->56769; 56769->56770; 56770->56771; 56771->56772; }