digraph G { id="graph_90695"; subgraph graph_stage_90695 { id="graph_stage_90695"; isCluster="true"; label="Stage 90695"; subgraph cluster_109236 { id="cluster_109236"; isCluster="true"; label="Exchange"; 41806 [id="node_41806" labelType="html" label="ShuffledRowRDD [41806] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109233 { id="cluster_109233"; isCluster="true"; label="WholeStageCodegen (1)"; 41807 [id="node_41807" labelType="html" label="MapPartitionsRDD [41807] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109256 { id="cluster_109256"; isCluster="true"; label="Exchange"; 41818 [id="node_41818" labelType="html" label="ShuffledRowRDD [41818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109253 { id="cluster_109253"; isCluster="true"; label="WholeStageCodegen (4)"; 41819 [id="node_41819" labelType="html" label="MapPartitionsRDD [41819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109285 { id="cluster_109285"; isCluster="true"; label="Exchange"; 41822 [id="node_41822" labelType="html" label="ShuffledRowRDD [41822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109282 { id="cluster_109282"; isCluster="true"; label="WholeStageCodegen (6)"; 41823 [id="node_41823" labelType="html" label="MapPartitionsRDD [41823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109245 { id="cluster_109245"; isCluster="true"; label="WholeStageCodegen (7)"; 41824 [id="node_41824" labelType="html" label="ZippedPartitionsRDD2 [41824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41825 [id="node_41825" labelType="html" label="MapPartitionsRDD [41825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109244 { id="cluster_109244"; isCluster="true"; label="InMemoryTableScan"; 41826 [id="node_41826" labelType="html" label="MapPartitionsRDD [41826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41827 [id="node_41827" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#837979 AS qty#837981, demandChannel#837974, demandStream#837975, cachedKpis#837980 AS kpis#837982]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#837978L, cachedShardId#837977], 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=1375257]\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=1375253]\n : +- *(2) Has... [41827] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109242 { id="cluster_109242"; isCluster="true"; label="Exchange"; 41834 [id="node_41834" labelType="html" label="ShuffledRowRDD [41834] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109239 { id="cluster_109239"; isCluster="true"; label="WholeStageCodegen (4)"; 41835 [id="node_41835" labelType="html" label="MapPartitionsRDD [41835] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109225 { id="cluster_109225"; isCluster="true"; label="WholeStageCodegen (5)"; 41836 [id="node_41836" labelType="html" label="ZippedPartitionsRDD2 [41836] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41837 [id="node_41837" labelType="html" label="MapPartitionsRDD [41837] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109306 { id="cluster_109306"; isCluster="true"; label="InMemoryTableScan"; 41838 [id="node_41838" labelType="html" label="MapPartitionsRDD [41838] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41839 [id="node_41839" labelType="html" label="MapPartitionsRDD [41839] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41840 [id="node_41840" labelType="html" label="MapPartitionsRDD [41840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109303 { id="cluster_109303"; isCluster="true"; label="WholeStageCodegen (6)"; 41841 [id="node_41841" labelType="html" label="MapPartitionsRDD [41841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109224 { id="cluster_109224"; isCluster="true"; label="Union"; 41842 [id="node_41842" labelType="html" label="UnionRDD [41842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109223 { id="cluster_109223"; isCluster="true"; label="InMemoryTableScan"; 41843 [id="node_41843" labelType="html" label="MapPartitionsRDD [41843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41844 [id="node_41844" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#838214, null AS demandStream#838215, [] AS kpis#838249, true AS isNewlyCalculated#838217]\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#838206, ), isnull(shardId#838206), coalesce(worklistShardItemId#838207L, 0), isnull(worklistShardItemId#838207L), coalesce(version#838208, 0), isnull(version#838208), coalesce(product#838209, ), isnull(product#838209), coalesce(plant#838210, ), isnull(plant#838210), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#837981, 0.0))), isnull(qty#... [41844] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109512 { id="cluster_109512"; isCluster="true"; label="Exchange"; 41940 [id="node_41940" labelType="html" label="ShuffledRowRDD [41940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109507 { id="cluster_109507"; isCluster="true"; label="WholeStageCodegen (6)"; 41941 [id="node_41941" labelType="html" label="MapPartitionsRDD [41941] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109506 { id="cluster_109506"; isCluster="true"; label="SortAggregate"; 41942 [id="node_41942" labelType="html" label="MapPartitionsRDD [41942] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109505 { id="cluster_109505"; isCluster="true"; label="InMemoryTableScan"; 41943 [id="node_41943" labelType="html" label="MapPartitionsRDD [41943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41944 [id="node_41944" labelType="html" label="SortAggregate(key=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[first(kpis#840779, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#840770, demandChannel#840750, demandStream#840751, kpis#840912])\n+- *(6) Sort [demandChannel#840750 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#840770 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#840751 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, 37), ENSURE_REQUIREMENTS, [plan_id=1376187]\n +- SortAggregate(key=[demandChannel#840750, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#840770)) AS qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[partial_first(kpis#840779, false)], output=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, first#84098... [41944] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109672 { id="cluster_109672"; isCluster="true"; label="InMemoryTableScan"; 41982 [id="node_41982" labelType="html" label="MapPartitionsRDD [41982] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41983 [id="node_41983" labelType="html" label="MapPartitionsRDD [41983] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41984 [id="node_41984" labelType="html" label="MapPartitionsRDD [41984] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109668 { id="cluster_109668"; isCluster="true"; label="WholeStageCodegen (1)"; 41985 [id="node_41985" labelType="html" label="MapPartitionsRDD [41985] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109676 { id="cluster_109676"; isCluster="true"; label="InMemoryTableScan"; 41986 [id="node_41986" labelType="html" label="MapPartitionsRDD [41986] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41987 [id="node_41987" labelType="html" label="MapPartitionsRDD [41987] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41988 [id="node_41988" labelType="html" label="MapPartitionsRDD [41988] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109673 { id="cluster_109673"; isCluster="true"; label="WholeStageCodegen (2)"; 41989 [id="node_41989" labelType="html" label="MapPartitionsRDD [41989] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109667 { id="cluster_109667"; isCluster="true"; label="Union"; 41990 [id="node_41990" labelType="html" label="UnionRDD [41990] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109643 { id="cluster_109643"; isCluster="true"; label="WholeStageCodegen (5)"; 41991 [id="node_41991" labelType="html" label="MapPartitionsRDD [41991] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109642 { id="cluster_109642"; isCluster="true"; label="InMemoryTableScan"; 41992 [id="node_41992" labelType="html" label="MapPartitionsRDD [41992] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41993 [id="node_41993" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#841583, qty#815747, demandChannel#838214, demandStream#838215, kpis#838249]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#841680, worklistShardItemId#841681L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#838214, demandStream#838215, kpis#838249]\n : : +- *(1) Filter ((NOT isNewlyCalculated#838217 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#838214, demandStream#838215, isNewlyCalculated#838217, kpis#838249, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#838217, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#838214, demandStream#838215... [41993] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109701 { id="cluster_109701"; isCluster="true"; label="InMemoryTableScan"; 42002 [id="node_42002" labelType="html" label="MapPartitionsRDD [42002] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42003 [id="node_42003" labelType="html" label="MapPartitionsRDD [42003] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42004 [id="node_42004" labelType="html" label="MapPartitionsRDD [42004] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 41806->41807; 41818->41819; 41822->41823; 41819->41824; 41823->41824; 41824->41825; 41825->41826; 41826->41827; 41834->41835; 41807->41836; 41835->41836; 41836->41837; 41827->41838; 41838->41839; 41839->41840; 41840->41841; 41837->41842; 41841->41842; 41842->41843; 41843->41844; 41940->41941; 41941->41942; 41942->41943; 41943->41944; 41844->41982; 41982->41983; 41983->41984; 41984->41985; 41944->41986; 41986->41987; 41987->41988; 41988->41989; 41985->41990; 41989->41990; 41990->41991; 41991->41992; 41992->41993; 41993->42002; 42002->42003; 42003->42004; }