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;
}
52677,52678
52689,52690
52693,52694
52705,52706
52811,52812
52699
52716
52816
52865
52690
52691
52694
52695
52696
52697
52698
52699
52706
52707
52708
52709
52710
52711
52712
52713
52714
52715
52716
52812
52813
52814
52815
52816
52854
52855
52856
52857
52858
52859
52860
52861
52862
52863
52864
52865
52866
52867
52868
52869
52870