digraph G { id="graph_117405"; subgraph graph_stage_117405 { id="graph_stage_117405"; isCluster="true"; label="Stage 117405"; 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}"]; } subgraph cluster_147694 { id="cluster_147694"; isCluster="true"; label="InMemoryTableScan"; 56897 [id="node_56897" labelType="html" label="MapPartitionsRDD [56897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56898 [id="node_56898" labelType="html" label="MapPartitionsRDD [56898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56899 [id="node_56899" labelType="html" label="MapPartitionsRDD [56899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147690 { id="cluster_147690"; isCluster="true"; label="WholeStageCodegen (3)"; 56900 [id="node_56900" labelType="html" label="MapPartitionsRDD [56900] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147689 { id="cluster_147689"; isCluster="true"; label="Exchange"; 56901 [id="node_56901" labelType="html" label="MapPartitionsRDD [56901] [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->56897; 56897->56898; 56898->56899; 56899->56900; 56900->56901; }