digraph G { id="graph_99761"; subgraph graph_stage_99761 { id="graph_stage_99761"; isCluster="true"; label="Stage 99761"; subgraph cluster_119215 { id="cluster_119215"; isCluster="true"; label="Exchange"; 45851 [id="node_45851" labelType="html" label="ShuffledRowRDD [45851] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119212 { id="cluster_119212"; isCluster="true"; label="WholeStageCodegen (1)"; 45852 [id="node_45852" labelType="html" label="MapPartitionsRDD [45852] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119235 { id="cluster_119235"; isCluster="true"; label="Exchange"; 45863 [id="node_45863" labelType="html" label="ShuffledRowRDD [45863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119232 { id="cluster_119232"; isCluster="true"; label="WholeStageCodegen (4)"; 45864 [id="node_45864" labelType="html" label="MapPartitionsRDD [45864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119270 { id="cluster_119270"; isCluster="true"; label="Exchange"; 45867 [id="node_45867" labelType="html" label="ShuffledRowRDD [45867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119267 { id="cluster_119267"; isCluster="true"; label="WholeStageCodegen (6)"; 45868 [id="node_45868" labelType="html" label="MapPartitionsRDD [45868] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119224 { id="cluster_119224"; isCluster="true"; label="WholeStageCodegen (7)"; 45869 [id="node_45869" labelType="html" label="ZippedPartitionsRDD2 [45869] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45870 [id="node_45870" labelType="html" label="MapPartitionsRDD [45870] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119223 { id="cluster_119223"; isCluster="true"; label="InMemoryTableScan"; 45871 [id="node_45871" labelType="html" label="MapPartitionsRDD [45871] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45872 [id="node_45872" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#921681 AS qty#921683, demandChannel#921676, demandStream#921677, cachedKpis#921682 AS kpis#921684]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#921680L, cachedShardId#921679], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1449313]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1449309]\n : +- *(2) Has... [45872] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119221 { id="cluster_119221"; isCluster="true"; label="Exchange"; 45879 [id="node_45879" labelType="html" label="ShuffledRowRDD [45879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119218 { id="cluster_119218"; isCluster="true"; label="WholeStageCodegen (4)"; 45880 [id="node_45880" labelType="html" label="MapPartitionsRDD [45880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119204 { id="cluster_119204"; isCluster="true"; label="WholeStageCodegen (5)"; 45881 [id="node_45881" labelType="html" label="ZippedPartitionsRDD2 [45881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45882 [id="node_45882" labelType="html" label="MapPartitionsRDD [45882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119285 { id="cluster_119285"; isCluster="true"; label="InMemoryTableScan"; 45883 [id="node_45883" labelType="html" label="MapPartitionsRDD [45883] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45884 [id="node_45884" labelType="html" label="MapPartitionsRDD [45884] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45885 [id="node_45885" labelType="html" label="MapPartitionsRDD [45885] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119282 { id="cluster_119282"; isCluster="true"; label="WholeStageCodegen (6)"; 45886 [id="node_45886" labelType="html" label="MapPartitionsRDD [45886] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119203 { id="cluster_119203"; isCluster="true"; label="Union"; 45887 [id="node_45887" labelType="html" label="UnionRDD [45887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119202 { id="cluster_119202"; isCluster="true"; label="InMemoryTableScan"; 45888 [id="node_45888" labelType="html" label="MapPartitionsRDD [45888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45889 [id="node_45889" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#921916, null AS demandStream#921917, [] AS kpis#921951, true AS isNewlyCalculated#921919]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#921908, ), isnull(shardId#921908), coalesce(worklistShardItemId#921909L, 0), isnull(worklistShardItemId#921909L), coalesce(version#921910, 0), isnull(version#921910), coalesce(product#921911, ), isnull(product#921911), coalesce(plant#921912, ), isnull(plant#921912), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#921683, 0.0))), isnull(qty#... [45889] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119492 { id="cluster_119492"; isCluster="true"; label="Exchange"; 45985 [id="node_45985" labelType="html" label="ShuffledRowRDD [45985] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119486 { id="cluster_119486"; isCluster="true"; label="WholeStageCodegen (6)"; 45986 [id="node_45986" labelType="html" label="MapPartitionsRDD [45986] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119485 { id="cluster_119485"; isCluster="true"; label="SortAggregate"; 45987 [id="node_45987" labelType="html" label="MapPartitionsRDD [45987] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119484 { id="cluster_119484"; isCluster="true"; label="InMemoryTableScan"; 45988 [id="node_45988" labelType="html" label="MapPartitionsRDD [45988] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45989 [id="node_45989" labelType="html" label="SortAggregate(key=[demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453], functions=[first(kpis#924481, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#924472, demandChannel#924452, demandStream#924453, kpis#924614])\n+- *(6) Sort [demandChannel#924452 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#924472 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#924453 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453, 37), ENSURE_REQUIREMENTS, [plan_id=1450243]\n +- SortAggregate(key=[demandChannel#924452, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#924472)) AS qty#924472, worklistShardItemId#904715L, demandStream#924453], functions=[partial_first(kpis#924481, false)], output=[demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453, first#92469... [45989] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119653 { id="cluster_119653"; isCluster="true"; label="InMemoryTableScan"; 46029 [id="node_46029" labelType="html" label="MapPartitionsRDD [46029] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46030 [id="node_46030" labelType="html" label="MapPartitionsRDD [46030] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46031 [id="node_46031" labelType="html" label="MapPartitionsRDD [46031] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119649 { id="cluster_119649"; isCluster="true"; label="WholeStageCodegen (1)"; 46032 [id="node_46032" labelType="html" label="MapPartitionsRDD [46032] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119657 { id="cluster_119657"; isCluster="true"; label="InMemoryTableScan"; 46033 [id="node_46033" labelType="html" label="MapPartitionsRDD [46033] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46034 [id="node_46034" labelType="html" label="MapPartitionsRDD [46034] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46035 [id="node_46035" labelType="html" label="MapPartitionsRDD [46035] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119654 { id="cluster_119654"; isCluster="true"; label="WholeStageCodegen (2)"; 46036 [id="node_46036" labelType="html" label="MapPartitionsRDD [46036] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119648 { id="cluster_119648"; isCluster="true"; label="Union"; 46037 [id="node_46037" labelType="html" label="UnionRDD [46037] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119623 { id="cluster_119623"; isCluster="true"; label="WholeStageCodegen (5)"; 46038 [id="node_46038" labelType="html" label="MapPartitionsRDD [46038] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119622 { id="cluster_119622"; isCluster="true"; label="InMemoryTableScan"; 46039 [id="node_46039" labelType="html" label="MapPartitionsRDD [46039] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46040 [id="node_46040" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#925285, qty#904721, demandChannel#921916, demandStream#921917, kpis#921951]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#925382, worklistShardItemId#925383L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#921916, demandStream#921917, kpis#921951]\n : : +- *(1) Filter ((NOT isNewlyCalculated#921919 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#921916, demandStream#921917, isNewlyCalculated#921919, kpis#921951, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#921919, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#921916, demandStream#921917... [46040] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119682 { id="cluster_119682"; isCluster="true"; label="InMemoryTableScan"; 46049 [id="node_46049" labelType="html" label="MapPartitionsRDD [46049] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46050 [id="node_46050" labelType="html" label="MapPartitionsRDD [46050] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46051 [id="node_46051" labelType="html" label="MapPartitionsRDD [46051] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45851->45852; 45863->45864; 45867->45868; 45864->45869; 45868->45869; 45869->45870; 45870->45871; 45871->45872; 45879->45880; 45852->45881; 45880->45881; 45881->45882; 45872->45883; 45883->45884; 45884->45885; 45885->45886; 45882->45887; 45886->45887; 45887->45888; 45888->45889; 45985->45986; 45986->45987; 45987->45988; 45988->45989; 45889->46029; 46029->46030; 46030->46031; 46031->46032; 45989->46033; 46033->46034; 46034->46035; 46035->46036; 46032->46037; 46036->46037; 46037->46038; 46038->46039; 46039->46040; 46040->46049; 46049->46050; 46050->46051; }