digraph G { id="graph_107063"; subgraph graph_stage_107063 { id="graph_stage_107063"; isCluster="true"; label="Stage 107063"; subgraph cluster_135409 { id="cluster_135409"; isCluster="true"; label="Exchange"; 51886 [id="node_51886" labelType="html" label="ShuffledRowRDD [51886] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135406 { id="cluster_135406"; isCluster="true"; label="WholeStageCodegen (1)"; 51887 [id="node_51887" labelType="html" label="MapPartitionsRDD [51887] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135429 { id="cluster_135429"; isCluster="true"; label="Exchange"; 51898 [id="node_51898" labelType="html" label="ShuffledRowRDD [51898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135426 { id="cluster_135426"; isCluster="true"; label="WholeStageCodegen (4)"; 51899 [id="node_51899" labelType="html" label="MapPartitionsRDD [51899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135458 { id="cluster_135458"; isCluster="true"; label="Exchange"; 51902 [id="node_51902" labelType="html" label="ShuffledRowRDD [51902] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135455 { id="cluster_135455"; isCluster="true"; label="WholeStageCodegen (6)"; 51903 [id="node_51903" labelType="html" label="MapPartitionsRDD [51903] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135418 { id="cluster_135418"; isCluster="true"; label="WholeStageCodegen (7)"; 51904 [id="node_51904" labelType="html" label="ZippedPartitionsRDD2 [51904] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51905 [id="node_51905" labelType="html" label="MapPartitionsRDD [51905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135417 { id="cluster_135417"; isCluster="true"; label="InMemoryTableScan"; 51906 [id="node_51906" labelType="html" label="MapPartitionsRDD [51906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51907 [id="node_51907" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1039302 AS qty#1039304, demandChannel#1039297, demandStream#1039298, cachedKpis#1039303 AS kpis#1039305]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1039301L, cachedShardId#1039300], 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=1681589]\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... [51907] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135415 { id="cluster_135415"; isCluster="true"; label="Exchange"; 51914 [id="node_51914" labelType="html" label="ShuffledRowRDD [51914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135412 { id="cluster_135412"; isCluster="true"; label="WholeStageCodegen (4)"; 51915 [id="node_51915" labelType="html" label="MapPartitionsRDD [51915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135398 { id="cluster_135398"; isCluster="true"; label="WholeStageCodegen (5)"; 51916 [id="node_51916" labelType="html" label="ZippedPartitionsRDD2 [51916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51917 [id="node_51917" labelType="html" label="MapPartitionsRDD [51917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135473 { id="cluster_135473"; isCluster="true"; label="InMemoryTableScan"; 51918 [id="node_51918" labelType="html" label="MapPartitionsRDD [51918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51919 [id="node_51919" labelType="html" label="MapPartitionsRDD [51919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51920 [id="node_51920" labelType="html" label="MapPartitionsRDD [51920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135470 { id="cluster_135470"; isCluster="true"; label="WholeStageCodegen (6)"; 51921 [id="node_51921" labelType="html" label="MapPartitionsRDD [51921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135397 { id="cluster_135397"; isCluster="true"; label="Union"; 51922 [id="node_51922" labelType="html" label="UnionRDD [51922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135396 { id="cluster_135396"; isCluster="true"; label="InMemoryTableScan"; 51923 [id="node_51923" labelType="html" label="MapPartitionsRDD [51923] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51924 [id="node_51924" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1039537, null AS demandStream#1039538, [] AS kpis#1039572, true AS isNewlyCalculated#1039540]\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#1039529, ), isnull(shardId#1039529), coalesce(worklistShardItemId#1039530L, 0), isnull(worklistShardItemId#1039530L), coalesce(version#1039531, 0), isnull(version#1039531), coalesce(product#1039532, ), isnull(product#1039532), coalesce(plant#1039533, ), isnull(plant#1039533), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51924] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135700 { id="cluster_135700"; isCluster="true"; label="InMemoryTableScan"; 51990 [id="node_51990" labelType="html" label="MapPartitionsRDD [51990] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51991 [id="node_51991" labelType="html" label="MapPartitionsRDD [51991] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51992 [id="node_51992" labelType="html" label="MapPartitionsRDD [51992] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135695 { id="cluster_135695"; isCluster="true"; label="WholeStageCodegen (3)"; 51993 [id="node_51993" labelType="html" label="MapPartitionsRDD [51993] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135694 { id="cluster_135694"; isCluster="true"; label="Exchange"; 51994 [id="node_51994" labelType="html" label="MapPartitionsRDD [51994] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51886->51887; 51898->51899; 51902->51903; 51899->51904; 51903->51904; 51904->51905; 51905->51906; 51906->51907; 51914->51915; 51887->51916; 51915->51916; 51916->51917; 51907->51918; 51918->51919; 51919->51920; 51920->51921; 51917->51922; 51921->51922; 51922->51923; 51923->51924; 51924->51990; 51990->51991; 51991->51992; 51992->51993; 51993->51994; }