digraph G { id="graph_117954"; subgraph graph_stage_117954 { id="graph_stage_117954"; isCluster="true"; label="Stage 117954"; subgraph cluster_147895 { id="cluster_147895"; isCluster="true"; label="Exchange"; 56993 [id="node_56993" labelType="html" label="ShuffledRowRDD [56993] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147892 { id="cluster_147892"; isCluster="true"; label="WholeStageCodegen (1)"; 56994 [id="node_56994" labelType="html" label="MapPartitionsRDD [56994] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147915 { id="cluster_147915"; isCluster="true"; label="Exchange"; 57005 [id="node_57005" labelType="html" label="ShuffledRowRDD [57005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147912 { id="cluster_147912"; isCluster="true"; label="WholeStageCodegen (4)"; 57006 [id="node_57006" labelType="html" label="MapPartitionsRDD [57006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147944 { id="cluster_147944"; isCluster="true"; label="Exchange"; 57009 [id="node_57009" labelType="html" label="ShuffledRowRDD [57009] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147941 { id="cluster_147941"; isCluster="true"; label="WholeStageCodegen (6)"; 57010 [id="node_57010" labelType="html" label="MapPartitionsRDD [57010] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147904 { id="cluster_147904"; isCluster="true"; label="WholeStageCodegen (7)"; 57011 [id="node_57011" labelType="html" label="ZippedPartitionsRDD2 [57011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57012 [id="node_57012" labelType="html" label="MapPartitionsRDD [57012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147903 { id="cluster_147903"; isCluster="true"; label="InMemoryTableScan"; 57013 [id="node_57013" labelType="html" label="MapPartitionsRDD [57013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57014 [id="node_57014" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1145118 AS qty#1145120, demandChannel#1145113, demandStream#1145114, cachedKpis#1145119 AS kpis#1145121]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1145117L, cachedShardId#1145116], 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=1760137]\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... [57014] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147901 { id="cluster_147901"; isCluster="true"; label="Exchange"; 57021 [id="node_57021" labelType="html" label="ShuffledRowRDD [57021] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147898 { id="cluster_147898"; isCluster="true"; label="WholeStageCodegen (4)"; 57022 [id="node_57022" labelType="html" label="MapPartitionsRDD [57022] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147884 { id="cluster_147884"; isCluster="true"; label="WholeStageCodegen (5)"; 57023 [id="node_57023" labelType="html" label="ZippedPartitionsRDD2 [57023] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57024 [id="node_57024" labelType="html" label="MapPartitionsRDD [57024] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147959 { id="cluster_147959"; isCluster="true"; label="InMemoryTableScan"; 57025 [id="node_57025" labelType="html" label="MapPartitionsRDD [57025] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57026 [id="node_57026" labelType="html" label="MapPartitionsRDD [57026] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57027 [id="node_57027" labelType="html" label="MapPartitionsRDD [57027] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147956 { id="cluster_147956"; isCluster="true"; label="WholeStageCodegen (6)"; 57028 [id="node_57028" labelType="html" label="MapPartitionsRDD [57028] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147883 { id="cluster_147883"; isCluster="true"; label="Union"; 57029 [id="node_57029" labelType="html" label="UnionRDD [57029] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147882 { id="cluster_147882"; isCluster="true"; label="InMemoryTableScan"; 57030 [id="node_57030" labelType="html" label="MapPartitionsRDD [57030] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57031 [id="node_57031" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1145353, null AS demandStream#1145354, [] AS kpis#1145388, true AS isNewlyCalculated#1145356]\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#1145345, ), isnull(shardId#1145345), coalesce(worklistShardItemId#1145346L, 0), isnull(worklistShardItemId#1145346L), coalesce(version#1145347, 0), isnull(version#1145347), coalesce(product#1145348, ), isnull(product#1145348), coalesce(plant#1145349, ), isnull(plant#1145349), knownfloatingpointnormalized(normalizenanandzero(coalesce... [57031] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148171 { id="cluster_148171"; isCluster="true"; label="Exchange"; 57127 [id="node_57127" labelType="html" label="ShuffledRowRDD [57127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148166 { id="cluster_148166"; isCluster="true"; label="WholeStageCodegen (6)"; 57128 [id="node_57128" labelType="html" label="MapPartitionsRDD [57128] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148165 { id="cluster_148165"; isCluster="true"; label="SortAggregate"; 57129 [id="node_57129" labelType="html" label="MapPartitionsRDD [57129] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148164 { id="cluster_148164"; isCluster="true"; label="InMemoryTableScan"; 57130 [id="node_57130" labelType="html" label="MapPartitionsRDD [57130] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57131 [id="node_57131" labelType="html" label="SortAggregate(key=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[first(kpis#1147918, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1147909, demandChannel#1147889, demandStream#1147890, kpis#1148051])\n+- *(6) Sort [demandChannel#1147889 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1147909 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1147890 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L, demandStream#1147890, 37), ENSURE_REQUIREMENTS, [plan_id=1761067]\n +- SortAggregate(key=[demandChannel#1147889, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1147909)) AS qty#1147909, worklistShardItemId#1100458L, demandStream#1147890], functions=[partial_first(kpis#1147918, false)], output=[demandChannel#1147889, shardId#1100457, qty#1147909, worklistShardItemId#1100458L,... [57131] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148331 { id="cluster_148331"; isCluster="true"; label="InMemoryTableScan"; 57169 [id="node_57169" labelType="html" label="MapPartitionsRDD [57169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57170 [id="node_57170" labelType="html" label="MapPartitionsRDD [57170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57171 [id="node_57171" labelType="html" label="MapPartitionsRDD [57171] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148327 { id="cluster_148327"; isCluster="true"; label="WholeStageCodegen (1)"; 57172 [id="node_57172" labelType="html" label="MapPartitionsRDD [57172] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148335 { id="cluster_148335"; isCluster="true"; label="InMemoryTableScan"; 57173 [id="node_57173" labelType="html" label="MapPartitionsRDD [57173] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57174 [id="node_57174" labelType="html" label="MapPartitionsRDD [57174] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57175 [id="node_57175" labelType="html" label="MapPartitionsRDD [57175] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148332 { id="cluster_148332"; isCluster="true"; label="WholeStageCodegen (2)"; 57176 [id="node_57176" labelType="html" label="MapPartitionsRDD [57176] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148326 { id="cluster_148326"; isCluster="true"; label="Union"; 57177 [id="node_57177" labelType="html" label="UnionRDD [57177] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148302 { id="cluster_148302"; isCluster="true"; label="WholeStageCodegen (5)"; 57178 [id="node_57178" labelType="html" label="MapPartitionsRDD [57178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148301 { id="cluster_148301"; isCluster="true"; label="InMemoryTableScan"; 57179 [id="node_57179" labelType="html" label="MapPartitionsRDD [57179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57180 [id="node_57180" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1148722, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1148819, worklistShardItemId#1148820L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1145353, demandStream#1145354, kpis#1145388]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1145356 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1145353, demandStream#1145354, isNewlyCalculated#1145356, kpis#1145388, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1145356, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [57180] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148360 { id="cluster_148360"; isCluster="true"; label="InMemoryTableScan"; 57189 [id="node_57189" labelType="html" label="MapPartitionsRDD [57189] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57190 [id="node_57190" labelType="html" label="MapPartitionsRDD [57190] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57191 [id="node_57191" labelType="html" label="MapPartitionsRDD [57191] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56993->56994; 57005->57006; 57009->57010; 57006->57011; 57010->57011; 57011->57012; 57012->57013; 57013->57014; 57021->57022; 56994->57023; 57022->57023; 57023->57024; 57014->57025; 57025->57026; 57026->57027; 57027->57028; 57024->57029; 57028->57029; 57029->57030; 57030->57031; 57127->57128; 57128->57129; 57129->57130; 57130->57131; 57031->57169; 57169->57170; 57170->57171; 57171->57172; 57131->57173; 57173->57174; 57174->57175; 57175->57176; 57172->57177; 57176->57177; 57177->57178; 57178->57179; 57179->57180; 57180->57189; 57189->57190; 57190->57191; }