digraph G { id="graph_95706"; subgraph graph_stage_95706 { id="graph_stage_95706"; isCluster="true"; label="Stage 95706"; 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_113162 { id="cluster_113162"; isCluster="true"; label="Exchange"; 43475 [id="node_43475" labelType="html" label="ShuffledRowRDD [43475] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113161 { id="cluster_113161"; isCluster="true"; label="ObjectHashAggregate"; 43476 [id="node_43476" labelType="html" label="MapPartitionsRDD [43476] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113173 { id="cluster_113173"; isCluster="true"; label="InMemoryTableScan"; 43477 [id="node_43477" labelType="html" label="MapPartitionsRDD [43477] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43478 [id="node_43478" labelType="html" label="MapPartitionsRDD [43478] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43479 [id="node_43479" labelType="html" label="MapPartitionsRDD [43479] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113169 { id="cluster_113169"; isCluster="true"; label="WholeStageCodegen (12)"; 43480 [id="node_43480" labelType="html" label="MapPartitionsRDD [43480] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113160 { id="cluster_113160"; isCluster="true"; label="Union"; 43481 [id="node_43481" labelType="html" label="UnionRDD [43481] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113159 { id="cluster_113159"; isCluster="true"; label="Exchange"; 43482 [id="node_43482" labelType="html" label="MapPartitionsRDD [43482] [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; 43475->43476; 43430->43477; 43477->43478; 43478->43479; 43479->43480; 43476->43481; 43480->43481; 43481->43482; }