digraph G { id="graph_108107"; subgraph graph_stage_108107 { id="graph_stage_108107"; isCluster="true"; label="Stage 108107"; subgraph cluster_136030 { id="cluster_136030"; isCluster="true"; label="Exchange"; 52150 [id="node_52150" labelType="html" label="ShuffledRowRDD [52150] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136027 { id="cluster_136027"; isCluster="true"; label="WholeStageCodegen (1)"; 52151 [id="node_52151" labelType="html" label="MapPartitionsRDD [52151] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136050 { id="cluster_136050"; isCluster="true"; label="Exchange"; 52162 [id="node_52162" labelType="html" label="ShuffledRowRDD [52162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136047 { id="cluster_136047"; isCluster="true"; label="WholeStageCodegen (4)"; 52163 [id="node_52163" labelType="html" label="MapPartitionsRDD [52163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136079 { id="cluster_136079"; isCluster="true"; label="Exchange"; 52166 [id="node_52166" labelType="html" label="ShuffledRowRDD [52166] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136076 { id="cluster_136076"; isCluster="true"; label="WholeStageCodegen (6)"; 52167 [id="node_52167" labelType="html" label="MapPartitionsRDD [52167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136039 { id="cluster_136039"; isCluster="true"; label="WholeStageCodegen (7)"; 52168 [id="node_52168" labelType="html" label="ZippedPartitionsRDD2 [52168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52169 [id="node_52169" labelType="html" label="MapPartitionsRDD [52169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136038 { id="cluster_136038"; isCluster="true"; label="InMemoryTableScan"; 52170 [id="node_52170" labelType="html" label="MapPartitionsRDD [52170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52171 [id="node_52171" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1044860 AS qty#1044862, demandChannel#1044855, demandStream#1044856, cachedKpis#1044861 AS kpis#1044863]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1044859L, cachedShardId#1044858], 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=1683138]\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... [52171] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136036 { id="cluster_136036"; isCluster="true"; label="Exchange"; 52178 [id="node_52178" labelType="html" label="ShuffledRowRDD [52178] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136033 { id="cluster_136033"; isCluster="true"; label="WholeStageCodegen (4)"; 52179 [id="node_52179" labelType="html" label="MapPartitionsRDD [52179] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136019 { id="cluster_136019"; isCluster="true"; label="WholeStageCodegen (5)"; 52180 [id="node_52180" labelType="html" label="ZippedPartitionsRDD2 [52180] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52181 [id="node_52181" labelType="html" label="MapPartitionsRDD [52181] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136100 { id="cluster_136100"; isCluster="true"; label="InMemoryTableScan"; 52182 [id="node_52182" labelType="html" label="MapPartitionsRDD [52182] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52183 [id="node_52183" labelType="html" label="MapPartitionsRDD [52183] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52184 [id="node_52184" labelType="html" label="MapPartitionsRDD [52184] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136097 { id="cluster_136097"; isCluster="true"; label="WholeStageCodegen (6)"; 52185 [id="node_52185" labelType="html" label="MapPartitionsRDD [52185] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136018 { id="cluster_136018"; isCluster="true"; label="Union"; 52186 [id="node_52186" labelType="html" label="UnionRDD [52186] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136017 { id="cluster_136017"; isCluster="true"; label="InMemoryTableScan"; 52187 [id="node_52187" labelType="html" label="MapPartitionsRDD [52187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52188 [id="node_52188" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1045095, null AS demandStream#1045096, [] AS kpis#1045130, true AS isNewlyCalculated#1045098]\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#1045087, ), isnull(shardId#1045087), coalesce(worklistShardItemId#1045088L, 0), isnull(worklistShardItemId#1045088L), coalesce(version#1045089, 0), isnull(version#1045089), coalesce(product#1045090, ), isnull(product#1045090), coalesce(plant#1045091, ), isnull(plant#1045091), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52188] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136450 { id="cluster_136450"; isCluster="true"; label="InMemoryTableScan"; 52318 [id="node_52318" labelType="html" label="MapPartitionsRDD [52318] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52319 [id="node_52319" labelType="html" label="MapPartitionsRDD [52319] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52320 [id="node_52320" labelType="html" label="MapPartitionsRDD [52320] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136446 { id="cluster_136446"; isCluster="true"; label="WholeStageCodegen (3)"; 52321 [id="node_52321" labelType="html" label="MapPartitionsRDD [52321] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136445 { id="cluster_136445"; isCluster="true"; label="Exchange"; 52322 [id="node_52322" labelType="html" label="MapPartitionsRDD [52322] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52150->52151; 52162->52163; 52166->52167; 52163->52168; 52167->52168; 52168->52169; 52169->52170; 52170->52171; 52178->52179; 52151->52180; 52179->52180; 52180->52181; 52171->52182; 52182->52183; 52183->52184; 52184->52185; 52181->52186; 52185->52186; 52186->52187; 52187->52188; 52188->52318; 52318->52319; 52319->52320; 52320->52321; 52321->52322; }