digraph G { id="graph_117441"; subgraph graph_stage_117441 { id="graph_stage_117441"; isCluster="true"; label="Stage 117441"; subgraph cluster_147274 { id="cluster_147274"; isCluster="true"; label="Exchange"; 56729 [id="node_56729" labelType="html" label="ShuffledRowRDD [56729] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147271 { id="cluster_147271"; isCluster="true"; label="WholeStageCodegen (1)"; 56730 [id="node_56730" labelType="html" label="MapPartitionsRDD [56730] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147294 { id="cluster_147294"; isCluster="true"; label="Exchange"; 56741 [id="node_56741" labelType="html" label="ShuffledRowRDD [56741] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147291 { id="cluster_147291"; isCluster="true"; label="WholeStageCodegen (4)"; 56742 [id="node_56742" labelType="html" label="MapPartitionsRDD [56742] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147329 { id="cluster_147329"; isCluster="true"; label="Exchange"; 56745 [id="node_56745" labelType="html" label="ShuffledRowRDD [56745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147326 { id="cluster_147326"; isCluster="true"; label="WholeStageCodegen (6)"; 56746 [id="node_56746" labelType="html" label="MapPartitionsRDD [56746] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147283 { id="cluster_147283"; isCluster="true"; label="WholeStageCodegen (7)"; 56747 [id="node_56747" labelType="html" label="ZippedPartitionsRDD2 [56747] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56748 [id="node_56748" labelType="html" label="MapPartitionsRDD [56748] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147282 { id="cluster_147282"; isCluster="true"; label="InMemoryTableScan"; 56749 [id="node_56749" labelType="html" label="MapPartitionsRDD [56749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56750 [id="node_56750" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1139560 AS qty#1139562, demandChannel#1139555, demandStream#1139556, cachedKpis#1139561 AS kpis#1139563]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1139559L, cachedShardId#1139558], 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=1758547]\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... [56750] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147280 { id="cluster_147280"; isCluster="true"; label="Exchange"; 56757 [id="node_56757" labelType="html" label="ShuffledRowRDD [56757] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147277 { id="cluster_147277"; isCluster="true"; label="WholeStageCodegen (4)"; 56758 [id="node_56758" labelType="html" label="MapPartitionsRDD [56758] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147263 { id="cluster_147263"; isCluster="true"; label="WholeStageCodegen (5)"; 56759 [id="node_56759" labelType="html" label="ZippedPartitionsRDD2 [56759] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56760 [id="node_56760" labelType="html" label="MapPartitionsRDD [56760] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147344 { id="cluster_147344"; isCluster="true"; label="InMemoryTableScan"; 56761 [id="node_56761" labelType="html" label="MapPartitionsRDD [56761] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56762 [id="node_56762" labelType="html" label="MapPartitionsRDD [56762] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56763 [id="node_56763" labelType="html" label="MapPartitionsRDD [56763] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147341 { id="cluster_147341"; isCluster="true"; label="WholeStageCodegen (6)"; 56764 [id="node_56764" labelType="html" label="MapPartitionsRDD [56764] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147262 { id="cluster_147262"; isCluster="true"; label="Union"; 56765 [id="node_56765" labelType="html" label="UnionRDD [56765] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147261 { id="cluster_147261"; isCluster="true"; label="InMemoryTableScan"; 56766 [id="node_56766" labelType="html" label="MapPartitionsRDD [56766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56767 [id="node_56767" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1139795, null AS demandStream#1139796, [] AS kpis#1139830, true AS isNewlyCalculated#1139798]\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#1139787, ), isnull(shardId#1139787), coalesce(worklistShardItemId#1139788L, 0), isnull(worklistShardItemId#1139788L), coalesce(version#1139789, 0), isnull(version#1139789), coalesce(product#1139790, ), isnull(product#1139790), coalesce(plant#1139791, ), isnull(plant#1139791), knownfloatingpointnormalized(normalizenanandzero(coalesce... [56767] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147550 { id="cluster_147550"; isCluster="true"; label="Exchange"; 56863 [id="node_56863" labelType="html" label="ShuffledRowRDD [56863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147545 { id="cluster_147545"; isCluster="true"; label="WholeStageCodegen (6)"; 56864 [id="node_56864" labelType="html" label="MapPartitionsRDD [56864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147544 { id="cluster_147544"; isCluster="true"; label="SortAggregate"; 56865 [id="node_56865" labelType="html" label="MapPartitionsRDD [56865] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147543 { id="cluster_147543"; isCluster="true"; label="InMemoryTableScan"; 56866 [id="node_56866" labelType="html" label="MapPartitionsRDD [56866] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56867 [id="node_56867" labelType="html" label="SortAggregate(key=[demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L, demandStream#1142332], functions=[first(kpis#1142360, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1142351, demandChannel#1142331, demandStream#1142332, kpis#1142493])\n+- *(6) Sort [demandChannel#1142331 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1142351 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1142332 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L, demandStream#1142332, 37), ENSURE_REQUIREMENTS, [plan_id=1759477]\n +- SortAggregate(key=[demandChannel#1142331, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1142351)) AS qty#1142351, worklistShardItemId#1100458L, demandStream#1142332], functions=[partial_first(kpis#1142360, false)], output=[demandChannel#1142331, shardId#1100457, qty#1142351, worklistShardItemId#1100458L,... [56867] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147710 { id="cluster_147710"; isCluster="true"; label="InMemoryTableScan"; 56905 [id="node_56905" labelType="html" label="MapPartitionsRDD [56905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56906 [id="node_56906" labelType="html" label="MapPartitionsRDD [56906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56907 [id="node_56907" labelType="html" label="MapPartitionsRDD [56907] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147706 { id="cluster_147706"; isCluster="true"; label="WholeStageCodegen (1)"; 56908 [id="node_56908" labelType="html" label="MapPartitionsRDD [56908] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147714 { id="cluster_147714"; isCluster="true"; label="InMemoryTableScan"; 56909 [id="node_56909" labelType="html" label="MapPartitionsRDD [56909] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56910 [id="node_56910" labelType="html" label="MapPartitionsRDD [56910] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56911 [id="node_56911" labelType="html" label="MapPartitionsRDD [56911] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147711 { id="cluster_147711"; isCluster="true"; label="WholeStageCodegen (2)"; 56912 [id="node_56912" labelType="html" label="MapPartitionsRDD [56912] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147705 { id="cluster_147705"; isCluster="true"; label="Union"; 56913 [id="node_56913" labelType="html" label="UnionRDD [56913] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147681 { id="cluster_147681"; isCluster="true"; label="WholeStageCodegen (5)"; 56914 [id="node_56914" labelType="html" label="MapPartitionsRDD [56914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147680 { id="cluster_147680"; isCluster="true"; label="InMemoryTableScan"; 56915 [id="node_56915" labelType="html" label="MapPartitionsRDD [56915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56916 [id="node_56916" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1143164, qty#1100464, demandChannel#1139795, demandStream#1139796, kpis#1139830]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1143261, worklistShardItemId#1143262L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1139795, demandStream#1139796, kpis#1139830]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1139798 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1139795, demandStream#1139796, isNewlyCalculated#1139798, kpis#1139830, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1139798, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [56916] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56917 [id="node_56917" labelType="html" label="MapPartitionsRDD [56917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56918 [id="node_56918" labelType="html" label="MapPartitionsRDD [56918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56919 [id="node_56919" labelType="html" label="MapPartitionsRDD [56919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147679 { id="cluster_147679"; isCluster="true"; label="CollectLimit"; 56920 [id="node_56920" labelType="html" label="MapPartitionsRDD [56920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56921 [id="node_56921" labelType="html" label="MapPartitionsRDD [56921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56729->56730; 56741->56742; 56745->56746; 56742->56747; 56746->56747; 56747->56748; 56748->56749; 56749->56750; 56757->56758; 56730->56759; 56758->56759; 56759->56760; 56750->56761; 56761->56762; 56762->56763; 56763->56764; 56760->56765; 56764->56765; 56765->56766; 56766->56767; 56863->56864; 56864->56865; 56865->56866; 56866->56867; 56767->56905; 56905->56906; 56906->56907; 56907->56908; 56867->56909; 56909->56910; 56910->56911; 56911->56912; 56908->56913; 56912->56913; 56913->56914; 56914->56915; 56915->56916; 56916->56917; 56917->56918; 56918->56919; 56919->56920; 56920->56921; }