digraph G { id="graph_110810"; subgraph graph_stage_110810 { id="graph_stage_110810"; isCluster="true"; label="Stage 110810"; subgraph cluster_137893 { id="cluster_137893"; isCluster="true"; label="Exchange"; 52942 [id="node_52942" labelType="html" label="ShuffledRowRDD [52942] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137890 { id="cluster_137890"; isCluster="true"; label="WholeStageCodegen (1)"; 52943 [id="node_52943" labelType="html" label="MapPartitionsRDD [52943] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137913 { id="cluster_137913"; isCluster="true"; label="Exchange"; 52954 [id="node_52954" labelType="html" label="ShuffledRowRDD [52954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137910 { id="cluster_137910"; isCluster="true"; label="WholeStageCodegen (4)"; 52955 [id="node_52955" labelType="html" label="MapPartitionsRDD [52955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137942 { id="cluster_137942"; isCluster="true"; label="Exchange"; 52958 [id="node_52958" labelType="html" label="ShuffledRowRDD [52958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137939 { id="cluster_137939"; isCluster="true"; label="WholeStageCodegen (6)"; 52959 [id="node_52959" labelType="html" label="MapPartitionsRDD [52959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137902 { id="cluster_137902"; isCluster="true"; label="WholeStageCodegen (7)"; 52960 [id="node_52960" labelType="html" label="ZippedPartitionsRDD2 [52960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52961 [id="node_52961" labelType="html" label="MapPartitionsRDD [52961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137901 { id="cluster_137901"; isCluster="true"; label="InMemoryTableScan"; 52962 [id="node_52962" labelType="html" label="MapPartitionsRDD [52962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52963 [id="node_52963" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1061534 AS qty#1061536, demandChannel#1061529, demandStream#1061530, cachedKpis#1061535 AS kpis#1061537]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1061533L, cachedShardId#1061532], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1687852]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [52963] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137899 { id="cluster_137899"; isCluster="true"; label="Exchange"; 52970 [id="node_52970" labelType="html" label="ShuffledRowRDD [52970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137896 { id="cluster_137896"; isCluster="true"; label="WholeStageCodegen (4)"; 52971 [id="node_52971" labelType="html" label="MapPartitionsRDD [52971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137882 { id="cluster_137882"; isCluster="true"; label="WholeStageCodegen (5)"; 52972 [id="node_52972" labelType="html" label="ZippedPartitionsRDD2 [52972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52973 [id="node_52973" labelType="html" label="MapPartitionsRDD [52973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137957 { id="cluster_137957"; isCluster="true"; label="InMemoryTableScan"; 52974 [id="node_52974" labelType="html" label="MapPartitionsRDD [52974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52975 [id="node_52975" labelType="html" label="MapPartitionsRDD [52975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52976 [id="node_52976" labelType="html" label="MapPartitionsRDD [52976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137954 { id="cluster_137954"; isCluster="true"; label="WholeStageCodegen (6)"; 52977 [id="node_52977" labelType="html" label="MapPartitionsRDD [52977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137881 { id="cluster_137881"; isCluster="true"; label="Union"; 52978 [id="node_52978" labelType="html" label="UnionRDD [52978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137880 { id="cluster_137880"; isCluster="true"; label="InMemoryTableScan"; 52979 [id="node_52979" labelType="html" label="MapPartitionsRDD [52979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52980 [id="node_52980" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1061769, null AS demandStream#1061770, [] AS kpis#1061804, true AS isNewlyCalculated#1061772]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1061761, ), isnull(shardId#1061761), coalesce(worklistShardItemId#1061762L, 0), isnull(worklistShardItemId#1061762L), coalesce(version#1061763, 0), isnull(version#1061763), coalesce(product#1061764, ), isnull(product#1061764), coalesce(plant#1061765, ), isnull(plant#1061765), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52980] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138184 { id="cluster_138184"; isCluster="true"; label="InMemoryTableScan"; 53046 [id="node_53046" labelType="html" label="MapPartitionsRDD [53046] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53047 [id="node_53047" labelType="html" label="MapPartitionsRDD [53047] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53048 [id="node_53048" labelType="html" label="MapPartitionsRDD [53048] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138179 { id="cluster_138179"; isCluster="true"; label="WholeStageCodegen (3)"; 53049 [id="node_53049" labelType="html" label="MapPartitionsRDD [53049] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138178 { id="cluster_138178"; isCluster="true"; label="Exchange"; 53050 [id="node_53050" labelType="html" label="MapPartitionsRDD [53050] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52942->52943; 52954->52955; 52958->52959; 52955->52960; 52959->52960; 52960->52961; 52961->52962; 52962->52963; 52970->52971; 52943->52972; 52971->52972; 52972->52973; 52963->52974; 52974->52975; 52975->52976; 52976->52977; 52973->52978; 52977->52978; 52978->52979; 52979->52980; 52980->53046; 53046->53047; 53047->53048; 53048->53049; 53049->53050; }