digraph G { id="graph_120251"; subgraph graph_stage_120251 { id="graph_stage_120251"; isCluster="true"; label="Stage 120251"; subgraph cluster_149758 { id="cluster_149758"; isCluster="true"; label="Exchange"; 57785 [id="node_57785" labelType="html" label="ShuffledRowRDD [57785] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149755 { id="cluster_149755"; isCluster="true"; label="WholeStageCodegen (1)"; 57786 [id="node_57786" labelType="html" label="MapPartitionsRDD [57786] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149778 { id="cluster_149778"; isCluster="true"; label="Exchange"; 57797 [id="node_57797" labelType="html" label="ShuffledRowRDD [57797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149775 { id="cluster_149775"; isCluster="true"; label="WholeStageCodegen (4)"; 57798 [id="node_57798" labelType="html" label="MapPartitionsRDD [57798] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149807 { id="cluster_149807"; isCluster="true"; label="Exchange"; 57801 [id="node_57801" labelType="html" label="ShuffledRowRDD [57801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149804 { id="cluster_149804"; isCluster="true"; label="WholeStageCodegen (6)"; 57802 [id="node_57802" labelType="html" label="MapPartitionsRDD [57802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149767 { id="cluster_149767"; isCluster="true"; label="WholeStageCodegen (7)"; 57803 [id="node_57803" labelType="html" label="ZippedPartitionsRDD2 [57803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57804 [id="node_57804" labelType="html" label="MapPartitionsRDD [57804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149766 { id="cluster_149766"; isCluster="true"; label="InMemoryTableScan"; 57805 [id="node_57805" labelType="html" label="MapPartitionsRDD [57805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57806 [id="node_57806" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1161792 AS qty#1161794, demandChannel#1161787, demandStream#1161788, cachedKpis#1161793 AS kpis#1161795]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1161791L, cachedShardId#1161790], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1764825]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [57806] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149764 { id="cluster_149764"; isCluster="true"; label="Exchange"; 57813 [id="node_57813" labelType="html" label="ShuffledRowRDD [57813] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149761 { id="cluster_149761"; isCluster="true"; label="WholeStageCodegen (4)"; 57814 [id="node_57814" labelType="html" label="MapPartitionsRDD [57814] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149747 { id="cluster_149747"; isCluster="true"; label="WholeStageCodegen (5)"; 57815 [id="node_57815" labelType="html" label="ZippedPartitionsRDD2 [57815] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57816 [id="node_57816" labelType="html" label="MapPartitionsRDD [57816] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149822 { id="cluster_149822"; isCluster="true"; label="InMemoryTableScan"; 57817 [id="node_57817" labelType="html" label="MapPartitionsRDD [57817] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57818 [id="node_57818" labelType="html" label="MapPartitionsRDD [57818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57819 [id="node_57819" labelType="html" label="MapPartitionsRDD [57819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149819 { id="cluster_149819"; isCluster="true"; label="WholeStageCodegen (6)"; 57820 [id="node_57820" labelType="html" label="MapPartitionsRDD [57820] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149746 { id="cluster_149746"; isCluster="true"; label="Union"; 57821 [id="node_57821" labelType="html" label="UnionRDD [57821] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149745 { id="cluster_149745"; isCluster="true"; label="InMemoryTableScan"; 57822 [id="node_57822" labelType="html" label="MapPartitionsRDD [57822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57823 [id="node_57823" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1162027, null AS demandStream#1162028, [] AS kpis#1162062, true AS isNewlyCalculated#1162030]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1162019, ), isnull(shardId#1162019), coalesce(worklistShardItemId#1162020L, 0), isnull(worklistShardItemId#1162020L), coalesce(version#1162021, 0), isnull(version#1162021), coalesce(product#1162022, ), isnull(product#1162022), coalesce(plant#1162023, ), isnull(plant#1162023), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57823] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150035 { id="cluster_150035"; isCluster="true"; label="Exchange"; 57919 [id="node_57919" labelType="html" label="ShuffledRowRDD [57919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150029 { id="cluster_150029"; isCluster="true"; label="WholeStageCodegen (6)"; 57920 [id="node_57920" labelType="html" label="MapPartitionsRDD [57920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150028 { id="cluster_150028"; isCluster="true"; label="SortAggregate"; 57921 [id="node_57921" labelType="html" label="MapPartitionsRDD [57921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150027 { id="cluster_150027"; isCluster="true"; label="InMemoryTableScan"; 57922 [id="node_57922" labelType="html" label="MapPartitionsRDD [57922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57923 [id="node_57923" labelType="html" label="SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])\n+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]\n +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,... [57923] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150194 { id="cluster_150194"; isCluster="true"; label="InMemoryTableScan"; 57961 [id="node_57961" labelType="html" label="MapPartitionsRDD [57961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57962 [id="node_57962" labelType="html" label="MapPartitionsRDD [57962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57963 [id="node_57963" labelType="html" label="MapPartitionsRDD [57963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150190 { id="cluster_150190"; isCluster="true"; label="WholeStageCodegen (1)"; 57964 [id="node_57964" labelType="html" label="MapPartitionsRDD [57964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150198 { id="cluster_150198"; isCluster="true"; label="InMemoryTableScan"; 57965 [id="node_57965" labelType="html" label="MapPartitionsRDD [57965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57966 [id="node_57966" labelType="html" label="MapPartitionsRDD [57966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57967 [id="node_57967" labelType="html" label="MapPartitionsRDD [57967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150195 { id="cluster_150195"; isCluster="true"; label="WholeStageCodegen (2)"; 57968 [id="node_57968" labelType="html" label="MapPartitionsRDD [57968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150189 { id="cluster_150189"; isCluster="true"; label="Union"; 57969 [id="node_57969" labelType="html" label="UnionRDD [57969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150165 { id="cluster_150165"; isCluster="true"; label="WholeStageCodegen (5)"; 57970 [id="node_57970" labelType="html" label="MapPartitionsRDD [57970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150164 { id="cluster_150164"; isCluster="true"; label="InMemoryTableScan"; 57971 [id="node_57971" labelType="html" label="MapPartitionsRDD [57971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57972 [id="node_57972" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1165396, qty#1100464, demandChannel#1162027, demandStream#1162028, kpis#1162062]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1165493, worklistShardItemId#1165494L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1162027, demandStream#1162028, kpis#1162062]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1162030 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1162027, demandStream#1162028, isNewlyCalculated#1162030, kpis#1162062, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1162030, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [57972] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57973 [id="node_57973" labelType="html" label="MapPartitionsRDD [57973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57974 [id="node_57974" labelType="html" label="MapPartitionsRDD [57974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57975 [id="node_57975" labelType="html" label="MapPartitionsRDD [57975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150163 { id="cluster_150163"; isCluster="true"; label="CollectLimit"; 57976 [id="node_57976" labelType="html" label="MapPartitionsRDD [57976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57977 [id="node_57977" labelType="html" label="MapPartitionsRDD [57977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57785->57786; 57797->57798; 57801->57802; 57798->57803; 57802->57803; 57803->57804; 57804->57805; 57805->57806; 57813->57814; 57786->57815; 57814->57815; 57815->57816; 57806->57817; 57817->57818; 57818->57819; 57819->57820; 57816->57821; 57820->57821; 57821->57822; 57822->57823; 57919->57920; 57920->57921; 57921->57922; 57922->57923; 57823->57961; 57961->57962; 57962->57963; 57963->57964; 57923->57965; 57965->57966; 57966->57967; 57967->57968; 57964->57969; 57968->57969; 57969->57970; 57970->57971; 57971->57972; 57972->57973; 57973->57974; 57974->57975; 57975->57976; 57976->57977; }