digraph G { id="graph_95814"; subgraph graph_stage_95814 { id="graph_stage_95814"; isCluster="true"; label="Stage 95814"; 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_113240 { id="cluster_113240"; isCluster="true"; label="Exchange"; 43526 [id="node_43526" labelType="html" label="ShuffledRowRDD [43526] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113235 { id="cluster_113235"; isCluster="true"; label="WholeStageCodegen (6)"; 43527 [id="node_43527" labelType="html" label="MapPartitionsRDD [43527] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113234 { id="cluster_113234"; isCluster="true"; label="SortAggregate"; 43528 [id="node_43528" labelType="html" label="MapPartitionsRDD [43528] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113233 { id="cluster_113233"; isCluster="true"; label="InMemoryTableScan"; 43529 [id="node_43529" labelType="html" label="MapPartitionsRDD [43529] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43530 [id="node_43530" labelType="html" label="SortAggregate(key=[demandChannel#874098, shardId#815740, qty#874118, worklistShardItemId#815741L, demandStream#874099], functions=[first(kpis#874127, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#874118, demandChannel#874098, demandStream#874099, kpis#874260])\n+- *(6) Sort [demandChannel#874098 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#874118 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#874099 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#874098, shardId#815740, qty#874118, worklistShardItemId#815741L, demandStream#874099, 37), ENSURE_REQUIREMENTS, [plan_id=1385641]\n +- SortAggregate(key=[demandChannel#874098, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#874118)) AS qty#874118, worklistShardItemId#815741L, demandStream#874099], functions=[partial_first(kpis#874127, false)], output=[demandChannel#874098, shardId#815740, qty#874118, worklistShardItemId#815741L, demandStream#874099, first#87433... [43530] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113400 { id="cluster_113400"; isCluster="true"; label="InMemoryTableScan"; 43568 [id="node_43568" labelType="html" label="MapPartitionsRDD [43568] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43569 [id="node_43569" labelType="html" label="MapPartitionsRDD [43569] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43570 [id="node_43570" labelType="html" label="MapPartitionsRDD [43570] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113396 { id="cluster_113396"; isCluster="true"; label="WholeStageCodegen (1)"; 43571 [id="node_43571" labelType="html" label="MapPartitionsRDD [43571] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113404 { id="cluster_113404"; isCluster="true"; label="InMemoryTableScan"; 43572 [id="node_43572" labelType="html" label="MapPartitionsRDD [43572] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43573 [id="node_43573" labelType="html" label="MapPartitionsRDD [43573] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43574 [id="node_43574" labelType="html" label="MapPartitionsRDD [43574] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113401 { id="cluster_113401"; isCluster="true"; label="WholeStageCodegen (2)"; 43575 [id="node_43575" labelType="html" label="MapPartitionsRDD [43575] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113395 { id="cluster_113395"; isCluster="true"; label="Union"; 43576 [id="node_43576" labelType="html" label="UnionRDD [43576] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113371 { id="cluster_113371"; isCluster="true"; label="WholeStageCodegen (5)"; 43577 [id="node_43577" labelType="html" label="MapPartitionsRDD [43577] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113370 { id="cluster_113370"; isCluster="true"; label="InMemoryTableScan"; 43578 [id="node_43578" labelType="html" label="MapPartitionsRDD [43578] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43579 [id="node_43579" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#874931, qty#815747, demandChannel#871562, demandStream#871563, kpis#871597]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#875028, worklistShardItemId#875029L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#871562, demandStream#871563, kpis#871597]\n : : +- *(1) Filter ((NOT isNewlyCalculated#871565 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#871562, demandStream#871563, isNewlyCalculated#871565, kpis#871597, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#871565, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#871562, demandStream#871563... [43579] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113429 { id="cluster_113429"; isCluster="true"; label="InMemoryTableScan"; 43588 [id="node_43588" labelType="html" label="MapPartitionsRDD [43588] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43589 [id="node_43589" labelType="html" label="MapPartitionsRDD [43589] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43590 [id="node_43590" labelType="html" label="MapPartitionsRDD [43590] [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; 43526->43527; 43527->43528; 43528->43529; 43529->43530; 43430->43568; 43568->43569; 43569->43570; 43570->43571; 43530->43572; 43572->43573; 43573->43574; 43574->43575; 43571->43576; 43575->43576; 43576->43577; 43577->43578; 43578->43579; 43579->43588; 43588->43589; 43589->43590; }