digraph G { id="graph_94101"; subgraph graph_stage_94101 { id="graph_stage_94101"; isCluster="true"; label="Stage 94101"; subgraph cluster_111720 { id="cluster_111720"; isCluster="true"; label="Exchange"; 42862 [id="node_42862" labelType="html" label="ShuffledRowRDD [42862] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111717 { id="cluster_111717"; isCluster="true"; label="WholeStageCodegen (1)"; 42863 [id="node_42863" labelType="html" label="MapPartitionsRDD [42863] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111740 { id="cluster_111740"; isCluster="true"; label="Exchange"; 42874 [id="node_42874" labelType="html" label="ShuffledRowRDD [42874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111737 { id="cluster_111737"; isCluster="true"; label="WholeStageCodegen (4)"; 42875 [id="node_42875" labelType="html" label="MapPartitionsRDD [42875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111775 { id="cluster_111775"; isCluster="true"; label="Exchange"; 42878 [id="node_42878" labelType="html" label="ShuffledRowRDD [42878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111772 { id="cluster_111772"; isCluster="true"; label="WholeStageCodegen (6)"; 42879 [id="node_42879" labelType="html" label="MapPartitionsRDD [42879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111729 { id="cluster_111729"; isCluster="true"; label="WholeStageCodegen (7)"; 42880 [id="node_42880" labelType="html" label="ZippedPartitionsRDD2 [42880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42881 [id="node_42881" labelType="html" label="MapPartitionsRDD [42881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111728 { id="cluster_111728"; isCluster="true"; label="InMemoryTableScan"; 42882 [id="node_42882" labelType="html" label="MapPartitionsRDD [42882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42883 [id="node_42883" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#860211 AS qty#860213, demandChannel#860206, demandStream#860207, cachedKpis#860212 AS kpis#860214]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#860210L, cachedShardId#860209], 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=1381587]\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=1381583]\n : +- *(2) Has... [42883] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111726 { id="cluster_111726"; isCluster="true"; label="Exchange"; 42890 [id="node_42890" labelType="html" label="ShuffledRowRDD [42890] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111723 { id="cluster_111723"; isCluster="true"; label="WholeStageCodegen (4)"; 42891 [id="node_42891" labelType="html" label="MapPartitionsRDD [42891] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111709 { id="cluster_111709"; isCluster="true"; label="WholeStageCodegen (5)"; 42892 [id="node_42892" labelType="html" label="ZippedPartitionsRDD2 [42892] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42893 [id="node_42893" labelType="html" label="MapPartitionsRDD [42893] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111790 { id="cluster_111790"; isCluster="true"; label="InMemoryTableScan"; 42894 [id="node_42894" labelType="html" label="MapPartitionsRDD [42894] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42895 [id="node_42895" labelType="html" label="MapPartitionsRDD [42895] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42896 [id="node_42896" labelType="html" label="MapPartitionsRDD [42896] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111787 { id="cluster_111787"; isCluster="true"; label="WholeStageCodegen (6)"; 42897 [id="node_42897" labelType="html" label="MapPartitionsRDD [42897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111708 { id="cluster_111708"; isCluster="true"; label="Union"; 42898 [id="node_42898" labelType="html" label="UnionRDD [42898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111707 { id="cluster_111707"; isCluster="true"; label="InMemoryTableScan"; 42899 [id="node_42899" labelType="html" label="MapPartitionsRDD [42899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42900 [id="node_42900" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#860446, null AS demandStream#860447, [] AS kpis#860481, true AS isNewlyCalculated#860449]\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#860438, ), isnull(shardId#860438), coalesce(worklistShardItemId#860439L, 0), isnull(worklistShardItemId#860439L), coalesce(version#860440, 0), isnull(version#860440), coalesce(product#860441, ), isnull(product#860441), coalesce(plant#860442, ), isnull(plant#860442), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#860213, 0.0))), isnull(qty#... [42900] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111996 { id="cluster_111996"; isCluster="true"; label="Exchange"; 42996 [id="node_42996" labelType="html" label="ShuffledRowRDD [42996] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111991 { id="cluster_111991"; isCluster="true"; label="WholeStageCodegen (6)"; 42997 [id="node_42997" labelType="html" label="MapPartitionsRDD [42997] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111990 { id="cluster_111990"; isCluster="true"; label="SortAggregate"; 42998 [id="node_42998" labelType="html" label="MapPartitionsRDD [42998] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111989 { id="cluster_111989"; isCluster="true"; label="InMemoryTableScan"; 42999 [id="node_42999" labelType="html" label="MapPartitionsRDD [42999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43000 [id="node_43000" labelType="html" label="SortAggregate(key=[demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983], functions=[first(kpis#863011, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#863002, demandChannel#862982, demandStream#862983, kpis#863144])\n+- *(6) Sort [demandChannel#862982 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#863002 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#862983 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983, 37), ENSURE_REQUIREMENTS, [plan_id=1382517]\n +- SortAggregate(key=[demandChannel#862982, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#863002)) AS qty#863002, worklistShardItemId#815741L, demandStream#862983], functions=[partial_first(kpis#863011, false)], output=[demandChannel#862982, shardId#815740, qty#863002, worklistShardItemId#815741L, demandStream#862983, first#86322... [43000] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112156 { id="cluster_112156"; isCluster="true"; label="InMemoryTableScan"; 43038 [id="node_43038" labelType="html" label="MapPartitionsRDD [43038] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43039 [id="node_43039" labelType="html" label="MapPartitionsRDD [43039] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43040 [id="node_43040" labelType="html" label="MapPartitionsRDD [43040] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112152 { id="cluster_112152"; isCluster="true"; label="WholeStageCodegen (1)"; 43041 [id="node_43041" labelType="html" label="MapPartitionsRDD [43041] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112160 { id="cluster_112160"; isCluster="true"; label="InMemoryTableScan"; 43042 [id="node_43042" labelType="html" label="MapPartitionsRDD [43042] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43043 [id="node_43043" labelType="html" label="MapPartitionsRDD [43043] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43044 [id="node_43044" labelType="html" label="MapPartitionsRDD [43044] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112157 { id="cluster_112157"; isCluster="true"; label="WholeStageCodegen (2)"; 43045 [id="node_43045" labelType="html" label="MapPartitionsRDD [43045] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112151 { id="cluster_112151"; isCluster="true"; label="Union"; 43046 [id="node_43046" labelType="html" label="UnionRDD [43046] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112127 { id="cluster_112127"; isCluster="true"; label="WholeStageCodegen (5)"; 43047 [id="node_43047" labelType="html" label="MapPartitionsRDD [43047] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112126 { id="cluster_112126"; isCluster="true"; label="InMemoryTableScan"; 43048 [id="node_43048" labelType="html" label="MapPartitionsRDD [43048] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43049 [id="node_43049" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#863815, qty#815747, demandChannel#860446, demandStream#860447, kpis#860481]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#863912, worklistShardItemId#863913L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#860446, demandStream#860447, kpis#860481]\n : : +- *(1) Filter ((NOT isNewlyCalculated#860449 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#860446, demandStream#860447, isNewlyCalculated#860449, kpis#860481, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#860449, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#860446, demandStream#860447... [43049] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43050 [id="node_43050" labelType="html" label="MapPartitionsRDD [43050] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43051 [id="node_43051" labelType="html" label="MapPartitionsRDD [43051] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43052 [id="node_43052" labelType="html" label="MapPartitionsRDD [43052] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112125 { id="cluster_112125"; isCluster="true"; label="CollectLimit"; 43053 [id="node_43053" labelType="html" label="MapPartitionsRDD [43053] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43054 [id="node_43054" labelType="html" label="MapPartitionsRDD [43054] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42862->42863; 42874->42875; 42878->42879; 42875->42880; 42879->42880; 42880->42881; 42881->42882; 42882->42883; 42890->42891; 42863->42892; 42891->42892; 42892->42893; 42883->42894; 42894->42895; 42895->42896; 42896->42897; 42893->42898; 42897->42898; 42898->42899; 42899->42900; 42996->42997; 42997->42998; 42998->42999; 42999->43000; 42900->43038; 43038->43039; 43039->43040; 43040->43041; 43000->43042; 43042->43043; 43043->43044; 43044->43045; 43041->43046; 43045->43046; 43046->43047; 43047->43048; 43048->43049; 43049->43050; 43050->43051; 43051->43052; 43052->43053; 43053->43054; }