digraph G { id="graph_110251"; subgraph graph_stage_110251 { id="graph_stage_110251"; isCluster="true"; label="Stage 110251"; subgraph cluster_137272 { id="cluster_137272"; isCluster="true"; label="Exchange"; 52678 [id="node_52678" labelType="html" label="ShuffledRowRDD [52678] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137269 { id="cluster_137269"; isCluster="true"; label="WholeStageCodegen (1)"; 52679 [id="node_52679" labelType="html" label="MapPartitionsRDD [52679] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137292 { id="cluster_137292"; isCluster="true"; label="Exchange"; 52690 [id="node_52690" labelType="html" label="ShuffledRowRDD [52690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137289 { id="cluster_137289"; isCluster="true"; label="WholeStageCodegen (4)"; 52691 [id="node_52691" labelType="html" label="MapPartitionsRDD [52691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137327 { id="cluster_137327"; isCluster="true"; label="Exchange"; 52694 [id="node_52694" labelType="html" label="ShuffledRowRDD [52694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137324 { id="cluster_137324"; isCluster="true"; label="WholeStageCodegen (6)"; 52695 [id="node_52695" labelType="html" label="MapPartitionsRDD [52695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137281 { id="cluster_137281"; isCluster="true"; label="WholeStageCodegen (7)"; 52696 [id="node_52696" labelType="html" label="ZippedPartitionsRDD2 [52696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52697 [id="node_52697" labelType="html" label="MapPartitionsRDD [52697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137280 { id="cluster_137280"; isCluster="true"; label="InMemoryTableScan"; 52698 [id="node_52698" labelType="html" label="MapPartitionsRDD [52698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52699 [id="node_52699" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1055976 AS qty#1055978, demandChannel#1055971, demandStream#1055972, cachedKpis#1055977 AS kpis#1055979]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1055975L, cachedShardId#1055974], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1686277]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [52699] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137278 { id="cluster_137278"; isCluster="true"; label="Exchange"; 52706 [id="node_52706" labelType="html" label="ShuffledRowRDD [52706] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137275 { id="cluster_137275"; isCluster="true"; label="WholeStageCodegen (4)"; 52707 [id="node_52707" labelType="html" label="MapPartitionsRDD [52707] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137261 { id="cluster_137261"; isCluster="true"; label="WholeStageCodegen (5)"; 52708 [id="node_52708" labelType="html" label="ZippedPartitionsRDD2 [52708] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52709 [id="node_52709" labelType="html" label="MapPartitionsRDD [52709] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137342 { id="cluster_137342"; isCluster="true"; label="InMemoryTableScan"; 52710 [id="node_52710" labelType="html" label="MapPartitionsRDD [52710] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52711 [id="node_52711" labelType="html" label="MapPartitionsRDD [52711] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52712 [id="node_52712" labelType="html" label="MapPartitionsRDD [52712] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137339 { id="cluster_137339"; isCluster="true"; label="WholeStageCodegen (6)"; 52713 [id="node_52713" labelType="html" label="MapPartitionsRDD [52713] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137260 { id="cluster_137260"; isCluster="true"; label="Union"; 52714 [id="node_52714" labelType="html" label="UnionRDD [52714] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137259 { id="cluster_137259"; isCluster="true"; label="InMemoryTableScan"; 52715 [id="node_52715" labelType="html" label="MapPartitionsRDD [52715] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52716 [id="node_52716" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1056211, null AS demandStream#1056212, [] AS kpis#1056246, true AS isNewlyCalculated#1056214]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1056203, ), isnull(shardId#1056203), coalesce(worklistShardItemId#1056204L, 0), isnull(worklistShardItemId#1056204L), coalesce(version#1056205, 0), isnull(version#1056205), coalesce(product#1056206, ), isnull(product#1056206), coalesce(plant#1056207, ), isnull(plant#1056207), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52716] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137549 { id="cluster_137549"; isCluster="true"; label="Exchange"; 52812 [id="node_52812" labelType="html" label="ShuffledRowRDD [52812] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137543 { id="cluster_137543"; isCluster="true"; label="WholeStageCodegen (6)"; 52813 [id="node_52813" labelType="html" label="MapPartitionsRDD [52813] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137542 { id="cluster_137542"; isCluster="true"; label="SortAggregate"; 52814 [id="node_52814" labelType="html" label="MapPartitionsRDD [52814] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137541 { id="cluster_137541"; isCluster="true"; label="InMemoryTableScan"; 52815 [id="node_52815" labelType="html" label="MapPartitionsRDD [52815] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52816 [id="node_52816" labelType="html" label="SortAggregate(key=[demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748], functions=[first(kpis#1058776, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1058767, demandChannel#1058747, demandStream#1058748, kpis#1058909])\n+- *(6) Sort [demandChannel#1058747 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1058767 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1058748 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L, demandStream#1058748, 37), ENSURE_REQUIREMENTS, [plan_id=1687207]\n +- SortAggregate(key=[demandChannel#1058747, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1058767)) AS qty#1058767, worklistShardItemId#1011816L, demandStream#1058748], functions=[partial_first(kpis#1058776, false)], output=[demandChannel#1058747, shardId#1011815, qty#1058767, worklistShardItemId#1011816L,... [52816] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137708 { id="cluster_137708"; isCluster="true"; label="InMemoryTableScan"; 52854 [id="node_52854" labelType="html" label="MapPartitionsRDD [52854] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52855 [id="node_52855" labelType="html" label="MapPartitionsRDD [52855] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52856 [id="node_52856" labelType="html" label="MapPartitionsRDD [52856] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137704 { id="cluster_137704"; isCluster="true"; label="WholeStageCodegen (1)"; 52857 [id="node_52857" labelType="html" label="MapPartitionsRDD [52857] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137712 { id="cluster_137712"; isCluster="true"; label="InMemoryTableScan"; 52858 [id="node_52858" labelType="html" label="MapPartitionsRDD [52858] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52859 [id="node_52859" labelType="html" label="MapPartitionsRDD [52859] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52860 [id="node_52860" labelType="html" label="MapPartitionsRDD [52860] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137709 { id="cluster_137709"; isCluster="true"; label="WholeStageCodegen (2)"; 52861 [id="node_52861" labelType="html" label="MapPartitionsRDD [52861] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137703 { id="cluster_137703"; isCluster="true"; label="Union"; 52862 [id="node_52862" labelType="html" label="UnionRDD [52862] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137679 { id="cluster_137679"; isCluster="true"; label="WholeStageCodegen (5)"; 52863 [id="node_52863" labelType="html" label="MapPartitionsRDD [52863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137678 { id="cluster_137678"; isCluster="true"; label="InMemoryTableScan"; 52864 [id="node_52864" labelType="html" label="MapPartitionsRDD [52864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52865 [id="node_52865" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1059580, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1059677, worklistShardItemId#1059678L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1056211, demandStream#1056212, kpis#1056246]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1056214 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1056211, demandStream#1056212, isNewlyCalculated#1056214, kpis#1056246, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1056214, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [52865] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52866 [id="node_52866" labelType="html" label="MapPartitionsRDD [52866] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52867 [id="node_52867" labelType="html" label="MapPartitionsRDD [52867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52868 [id="node_52868" labelType="html" label="MapPartitionsRDD [52868] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137677 { id="cluster_137677"; isCluster="true"; label="CollectLimit"; 52869 [id="node_52869" labelType="html" label="MapPartitionsRDD [52869] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52870 [id="node_52870" labelType="html" label="MapPartitionsRDD [52870] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52678->52679; 52690->52691; 52694->52695; 52691->52696; 52695->52696; 52696->52697; 52697->52698; 52698->52699; 52706->52707; 52679->52708; 52707->52708; 52708->52709; 52699->52710; 52710->52711; 52711->52712; 52712->52713; 52709->52714; 52713->52714; 52714->52715; 52715->52716; 52812->52813; 52813->52814; 52814->52815; 52815->52816; 52716->52854; 52854->52855; 52855->52856; 52856->52857; 52816->52858; 52858->52859; 52859->52860; 52860->52861; 52857->52862; 52861->52862; 52862->52863; 52863->52864; 52864->52865; 52865->52866; 52866->52867; 52867->52868; 52868->52869; 52869->52870; }