digraph G { id="graph_95778"; subgraph graph_stage_95778 { id="graph_stage_95778"; isCluster="true"; label="Stage 95778"; subgraph cluster_112964 { id="cluster_112964"; isCluster="true"; label="Exchange"; 43392 [id="node_43392" labelType="html" label="ShuffledRowRDD [43392] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112961 { id="cluster_112961"; isCluster="true"; label="WholeStageCodegen (1)"; 43393 [id="node_43393" labelType="html" label="MapPartitionsRDD [43393] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112984 { id="cluster_112984"; isCluster="true"; label="Exchange"; 43404 [id="node_43404" labelType="html" label="ShuffledRowRDD [43404] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112981 { id="cluster_112981"; isCluster="true"; label="WholeStageCodegen (4)"; 43405 [id="node_43405" labelType="html" label="MapPartitionsRDD [43405] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113019 { id="cluster_113019"; isCluster="true"; label="Exchange"; 43408 [id="node_43408" labelType="html" label="ShuffledRowRDD [43408] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113016 { id="cluster_113016"; isCluster="true"; label="WholeStageCodegen (6)"; 43409 [id="node_43409" labelType="html" label="MapPartitionsRDD [43409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112973 { id="cluster_112973"; isCluster="true"; label="WholeStageCodegen (7)"; 43410 [id="node_43410" labelType="html" label="ZippedPartitionsRDD2 [43410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43411 [id="node_43411" labelType="html" label="MapPartitionsRDD [43411] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112972 { id="cluster_112972"; isCluster="true"; label="InMemoryTableScan"; 43412 [id="node_43412" labelType="html" label="MapPartitionsRDD [43412] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43413 [id="node_43413" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#871327 AS qty#871329, demandChannel#871322, demandStream#871323, cachedKpis#871328 AS kpis#871330]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#871326L, cachedShardId#871325], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1384711]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1384707]\n : +- *(2) Has... [43413] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112970 { id="cluster_112970"; isCluster="true"; label="Exchange"; 43420 [id="node_43420" labelType="html" label="ShuffledRowRDD [43420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112967 { id="cluster_112967"; isCluster="true"; label="WholeStageCodegen (4)"; 43421 [id="node_43421" labelType="html" label="MapPartitionsRDD [43421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112953 { id="cluster_112953"; isCluster="true"; label="WholeStageCodegen (5)"; 43422 [id="node_43422" labelType="html" label="ZippedPartitionsRDD2 [43422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43423 [id="node_43423" labelType="html" label="MapPartitionsRDD [43423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113034 { id="cluster_113034"; isCluster="true"; label="InMemoryTableScan"; 43424 [id="node_43424" labelType="html" label="MapPartitionsRDD [43424] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43425 [id="node_43425" labelType="html" label="MapPartitionsRDD [43425] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43426 [id="node_43426" labelType="html" label="MapPartitionsRDD [43426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113031 { id="cluster_113031"; isCluster="true"; label="WholeStageCodegen (6)"; 43427 [id="node_43427" labelType="html" label="MapPartitionsRDD [43427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112952 { id="cluster_112952"; isCluster="true"; label="Union"; 43428 [id="node_43428" labelType="html" label="UnionRDD [43428] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112951 { id="cluster_112951"; isCluster="true"; label="InMemoryTableScan"; 43429 [id="node_43429" labelType="html" label="MapPartitionsRDD [43429] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43430 [id="node_43430" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#871562, null AS demandStream#871563, [] AS kpis#871597, true AS isNewlyCalculated#871565]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#871554, ), isnull(shardId#871554), coalesce(worklistShardItemId#871555L, 0), isnull(worklistShardItemId#871555L), coalesce(version#871556, 0), isnull(version#871556), coalesce(product#871557, ), isnull(product#871557), coalesce(plant#871558, ), isnull(plant#871558), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#871329, 0.0))), isnull(qty#... [43430] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113384 { id="cluster_113384"; isCluster="true"; label="InMemoryTableScan"; 43560 [id="node_43560" labelType="html" label="MapPartitionsRDD [43560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43561 [id="node_43561" labelType="html" label="MapPartitionsRDD [43561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43562 [id="node_43562" labelType="html" label="MapPartitionsRDD [43562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113380 { id="cluster_113380"; isCluster="true"; label="WholeStageCodegen (3)"; 43563 [id="node_43563" labelType="html" label="MapPartitionsRDD [43563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113379 { id="cluster_113379"; isCluster="true"; label="Exchange"; 43564 [id="node_43564" labelType="html" label="MapPartitionsRDD [43564] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43392->43393; 43404->43405; 43408->43409; 43405->43410; 43409->43410; 43410->43411; 43411->43412; 43412->43413; 43420->43421; 43393->43422; 43421->43422; 43422->43423; 43413->43424; 43424->43425; 43425->43426; 43426->43427; 43423->43428; 43427->43428; 43428->43429; 43429->43430; 43430->43560; 43560->43561; 43561->43562; 43562->43563; 43563->43564; }