digraph G { id="graph_95705"; subgraph graph_stage_95705 { id="graph_stage_95705"; isCluster="true"; label="Stage 95705"; 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_113168 { id="cluster_113168"; isCluster="true"; label="InMemoryTableScan"; 43469 [id="node_43469" labelType="html" label="MapPartitionsRDD [43469] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43470 [id="node_43470" labelType="html" label="MapPartitionsRDD [43470] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43471 [id="node_43471" labelType="html" label="MapPartitionsRDD [43471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113164 { id="cluster_113164"; isCluster="true"; label="WholeStageCodegen (11)"; 43472 [id="node_43472" labelType="html" label="MapPartitionsRDD [43472] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113163 { id="cluster_113163"; isCluster="true"; label="ObjectHashAggregate"; 43473 [id="node_43473" labelType="html" label="MapPartitionsRDD [43473] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113162 { id="cluster_113162"; isCluster="true"; label="Exchange"; 43474 [id="node_43474" labelType="html" label="MapPartitionsRDD [43474] [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->43469; 43469->43470; 43470->43471; 43471->43472; 43472->43473; 43473->43474; }