digraph G { id="graph_107413"; subgraph graph_stage_107413 { id="graph_stage_107413"; isCluster="true"; label="Stage 107413"; subgraph cluster_135409 { id="cluster_135409"; isCluster="true"; label="Exchange"; 51886 [id="node_51886" labelType="html" label="ShuffledRowRDD [51886] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135406 { id="cluster_135406"; isCluster="true"; label="WholeStageCodegen (1)"; 51887 [id="node_51887" labelType="html" label="MapPartitionsRDD [51887] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135429 { id="cluster_135429"; isCluster="true"; label="Exchange"; 51898 [id="node_51898" labelType="html" label="ShuffledRowRDD [51898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135426 { id="cluster_135426"; isCluster="true"; label="WholeStageCodegen (4)"; 51899 [id="node_51899" labelType="html" label="MapPartitionsRDD [51899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135458 { id="cluster_135458"; isCluster="true"; label="Exchange"; 51902 [id="node_51902" labelType="html" label="ShuffledRowRDD [51902] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135455 { id="cluster_135455"; isCluster="true"; label="WholeStageCodegen (6)"; 51903 [id="node_51903" labelType="html" label="MapPartitionsRDD [51903] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135418 { id="cluster_135418"; isCluster="true"; label="WholeStageCodegen (7)"; 51904 [id="node_51904" labelType="html" label="ZippedPartitionsRDD2 [51904] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51905 [id="node_51905" labelType="html" label="MapPartitionsRDD [51905] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135417 { id="cluster_135417"; isCluster="true"; label="InMemoryTableScan"; 51906 [id="node_51906" labelType="html" label="MapPartitionsRDD [51906] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51907 [id="node_51907" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1039302 AS qty#1039304, demandChannel#1039297, demandStream#1039298, cachedKpis#1039303 AS kpis#1039305]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1039301L, cachedShardId#1039300], 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=1681589]\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... [51907] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135415 { id="cluster_135415"; isCluster="true"; label="Exchange"; 51914 [id="node_51914" labelType="html" label="ShuffledRowRDD [51914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135412 { id="cluster_135412"; isCluster="true"; label="WholeStageCodegen (4)"; 51915 [id="node_51915" labelType="html" label="MapPartitionsRDD [51915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135398 { id="cluster_135398"; isCluster="true"; label="WholeStageCodegen (5)"; 51916 [id="node_51916" labelType="html" label="ZippedPartitionsRDD2 [51916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51917 [id="node_51917" labelType="html" label="MapPartitionsRDD [51917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135473 { id="cluster_135473"; isCluster="true"; label="InMemoryTableScan"; 51918 [id="node_51918" labelType="html" label="MapPartitionsRDD [51918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51919 [id="node_51919" labelType="html" label="MapPartitionsRDD [51919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51920 [id="node_51920" labelType="html" label="MapPartitionsRDD [51920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135470 { id="cluster_135470"; isCluster="true"; label="WholeStageCodegen (6)"; 51921 [id="node_51921" labelType="html" label="MapPartitionsRDD [51921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135397 { id="cluster_135397"; isCluster="true"; label="Union"; 51922 [id="node_51922" labelType="html" label="UnionRDD [51922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135396 { id="cluster_135396"; isCluster="true"; label="InMemoryTableScan"; 51923 [id="node_51923" labelType="html" label="MapPartitionsRDD [51923] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51924 [id="node_51924" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1039537, null AS demandStream#1039538, [] AS kpis#1039572, true AS isNewlyCalculated#1039540]\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#1039529, ), isnull(shardId#1039529), coalesce(worklistShardItemId#1039530L, 0), isnull(worklistShardItemId#1039530L), coalesce(version#1039531, 0), isnull(version#1039531), coalesce(product#1039532, ), isnull(product#1039532), coalesce(plant#1039533, ), isnull(plant#1039533), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51924] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135685 { id="cluster_135685"; isCluster="true"; label="Exchange"; 52020 [id="node_52020" labelType="html" label="ShuffledRowRDD [52020] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135680 { id="cluster_135680"; isCluster="true"; label="WholeStageCodegen (6)"; 52021 [id="node_52021" labelType="html" label="MapPartitionsRDD [52021] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135679 { id="cluster_135679"; isCluster="true"; label="SortAggregate"; 52022 [id="node_52022" labelType="html" label="MapPartitionsRDD [52022] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135678 { id="cluster_135678"; isCluster="true"; label="InMemoryTableScan"; 52023 [id="node_52023" labelType="html" label="MapPartitionsRDD [52023] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52024 [id="node_52024" labelType="html" label="SortAggregate(key=[demandChannel#1042073, shardId#1011815, qty#1042093, worklistShardItemId#1011816L, demandStream#1042074], functions=[first(kpis#1042102, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1042093, demandChannel#1042073, demandStream#1042074, kpis#1042235])\n+- *(6) Sort [demandChannel#1042073 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1042093 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1042074 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1042073, shardId#1011815, qty#1042093, worklistShardItemId#1011816L, demandStream#1042074, 37), ENSURE_REQUIREMENTS, [plan_id=1682519]\n +- SortAggregate(key=[demandChannel#1042073, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1042093)) AS qty#1042093, worklistShardItemId#1011816L, demandStream#1042074], functions=[partial_first(kpis#1042102, false)], output=[demandChannel#1042073, shardId#1011815, qty#1042093, worklistShardItemId#1011816L,... [52024] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135845 { id="cluster_135845"; isCluster="true"; label="InMemoryTableScan"; 52062 [id="node_52062" labelType="html" label="MapPartitionsRDD [52062] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52063 [id="node_52063" labelType="html" label="MapPartitionsRDD [52063] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52064 [id="node_52064" labelType="html" label="MapPartitionsRDD [52064] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135841 { id="cluster_135841"; isCluster="true"; label="WholeStageCodegen (1)"; 52065 [id="node_52065" labelType="html" label="MapPartitionsRDD [52065] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135849 { id="cluster_135849"; isCluster="true"; label="InMemoryTableScan"; 52066 [id="node_52066" labelType="html" label="MapPartitionsRDD [52066] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52067 [id="node_52067" labelType="html" label="MapPartitionsRDD [52067] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52068 [id="node_52068" labelType="html" label="MapPartitionsRDD [52068] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135846 { id="cluster_135846"; isCluster="true"; label="WholeStageCodegen (2)"; 52069 [id="node_52069" labelType="html" label="MapPartitionsRDD [52069] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135840 { id="cluster_135840"; isCluster="true"; label="Union"; 52070 [id="node_52070" labelType="html" label="UnionRDD [52070] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135816 { id="cluster_135816"; isCluster="true"; label="WholeStageCodegen (5)"; 52071 [id="node_52071" labelType="html" label="MapPartitionsRDD [52071] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135815 { id="cluster_135815"; isCluster="true"; label="InMemoryTableScan"; 52072 [id="node_52072" labelType="html" label="MapPartitionsRDD [52072] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52073 [id="node_52073" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1042906, qty#1011822, demandChannel#1039537, demandStream#1039538, kpis#1039572]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1043003, worklistShardItemId#1043004L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1039537, demandStream#1039538, kpis#1039572]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1039540 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1039537, demandStream#1039538, isNewlyCalculated#1039540, kpis#1039572, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1039540, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [52073] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52074 [id="node_52074" labelType="html" label="MapPartitionsRDD [52074] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52075 [id="node_52075" labelType="html" label="MapPartitionsRDD [52075] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52076 [id="node_52076" labelType="html" label="MapPartitionsRDD [52076] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135814 { id="cluster_135814"; isCluster="true"; label="CollectLimit"; 52077 [id="node_52077" labelType="html" label="MapPartitionsRDD [52077] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52078 [id="node_52078" labelType="html" label="MapPartitionsRDD [52078] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51886->51887; 51898->51899; 51902->51903; 51899->51904; 51903->51904; 51904->51905; 51905->51906; 51906->51907; 51914->51915; 51887->51916; 51915->51916; 51916->51917; 51907->51918; 51918->51919; 51919->51920; 51920->51921; 51917->51922; 51921->51922; 51922->51923; 51923->51924; 52020->52021; 52021->52022; 52022->52023; 52023->52024; 51924->52062; 52062->52063; 52063->52064; 52064->52065; 52024->52066; 52066->52067; 52067->52068; 52068->52069; 52065->52070; 52069->52070; 52070->52071; 52071->52072; 52072->52073; 52073->52074; 52074->52075; 52075->52076; 52076->52077; 52077->52078; }