digraph G { id="graph_107341"; subgraph graph_stage_107341 { id="graph_stage_107341"; isCluster="true"; label="Stage 107341"; 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_135829 { id="cluster_135829"; isCluster="true"; label="InMemoryTableScan"; 52054 [id="node_52054" labelType="html" label="MapPartitionsRDD [52054] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52055 [id="node_52055" labelType="html" label="MapPartitionsRDD [52055] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52056 [id="node_52056" labelType="html" label="MapPartitionsRDD [52056] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135825 { id="cluster_135825"; isCluster="true"; label="WholeStageCodegen (3)"; 52057 [id="node_52057" labelType="html" label="MapPartitionsRDD [52057] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135824 { id="cluster_135824"; isCluster="true"; label="Exchange"; 52058 [id="node_52058" labelType="html" label="MapPartitionsRDD [52058] [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->52054; 52054->52055; 52055->52056; 52056->52057; 52057->52058; }