digraph G {
id="graph_106132";
subgraph graph_stage_106132 {
id="graph_stage_106132";
isCluster="true";
label="Stage 106132";
subgraph cluster_134167 {
id="cluster_134167";
isCluster="true";
label="Exchange";
51358 [id="node_51358" labelType="html" label="ShuffledRowRDD [51358] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134164 {
id="cluster_134164";
isCluster="true";
label="WholeStageCodegen (1)";
51359 [id="node_51359" labelType="html" label="MapPartitionsRDD [51359] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134187 {
id="cluster_134187";
isCluster="true";
label="Exchange";
51370 [id="node_51370" labelType="html" label="ShuffledRowRDD [51370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134184 {
id="cluster_134184";
isCluster="true";
label="WholeStageCodegen (4)";
51371 [id="node_51371" labelType="html" label="MapPartitionsRDD [51371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134216 {
id="cluster_134216";
isCluster="true";
label="Exchange";
51374 [id="node_51374" labelType="html" label="ShuffledRowRDD [51374] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134213 {
id="cluster_134213";
isCluster="true";
label="WholeStageCodegen (6)";
51375 [id="node_51375" labelType="html" label="MapPartitionsRDD [51375] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134176 {
id="cluster_134176";
isCluster="true";
label="WholeStageCodegen (7)";
51376 [id="node_51376" labelType="html" label="ZippedPartitionsRDD2 [51376] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51377 [id="node_51377" labelType="html" label="MapPartitionsRDD [51377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134175 {
id="cluster_134175";
isCluster="true";
label="InMemoryTableScan";
51378 [id="node_51378" labelType="html" label="MapPartitionsRDD [51378] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51379 [id="node_51379" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1028186 AS qty#1028188, demandChannel#1028181, demandStream#1028182, cachedKpis#1028187 AS kpis#1028189]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1028185L, cachedShardId#1028184], 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=1678424]\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... [51379] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134173 {
id="cluster_134173";
isCluster="true";
label="Exchange";
51386 [id="node_51386" labelType="html" label="ShuffledRowRDD [51386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134170 {
id="cluster_134170";
isCluster="true";
label="WholeStageCodegen (4)";
51387 [id="node_51387" labelType="html" label="MapPartitionsRDD [51387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134156 {
id="cluster_134156";
isCluster="true";
label="WholeStageCodegen (5)";
51388 [id="node_51388" labelType="html" label="ZippedPartitionsRDD2 [51388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51389 [id="node_51389" labelType="html" label="MapPartitionsRDD [51389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134237 {
id="cluster_134237";
isCluster="true";
label="InMemoryTableScan";
51390 [id="node_51390" labelType="html" label="MapPartitionsRDD [51390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51391 [id="node_51391" labelType="html" label="MapPartitionsRDD [51391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51392 [id="node_51392" labelType="html" label="MapPartitionsRDD [51392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134234 {
id="cluster_134234";
isCluster="true";
label="WholeStageCodegen (6)";
51393 [id="node_51393" labelType="html" label="MapPartitionsRDD [51393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134155 {
id="cluster_134155";
isCluster="true";
label="Union";
51394 [id="node_51394" labelType="html" label="UnionRDD [51394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134154 {
id="cluster_134154";
isCluster="true";
label="InMemoryTableScan";
51395 [id="node_51395" labelType="html" label="MapPartitionsRDD [51395] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51396 [id="node_51396" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1028421, null AS demandStream#1028422, [] AS kpis#1028456, true AS isNewlyCalculated#1028424]\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#1028413, ), isnull(shardId#1028413), coalesce(worklistShardItemId#1028414L, 0), isnull(worklistShardItemId#1028414L), coalesce(version#1028415, 0), isnull(version#1028415), coalesce(product#1028416, ), isnull(product#1028416), coalesce(plant#1028417, ), isnull(plant#1028417), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51396] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134371 {
id="cluster_134371";
isCluster="true";
label="InMemoryTableScan";
51435 [id="node_51435" labelType="html" label="MapPartitionsRDD [51435] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51436 [id="node_51436" labelType="html" label="MapPartitionsRDD [51436] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
51437 [id="node_51437" labelType="html" label="MapPartitionsRDD [51437] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134367 {
id="cluster_134367";
isCluster="true";
label="WholeStageCodegen (11)";
51438 [id="node_51438" labelType="html" label="MapPartitionsRDD [51438] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134366 {
id="cluster_134366";
isCluster="true";
label="ObjectHashAggregate";
51439 [id="node_51439" labelType="html" label="MapPartitionsRDD [51439] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_134365 {
id="cluster_134365";
isCluster="true";
label="Exchange";
51440 [id="node_51440" labelType="html" label="MapPartitionsRDD [51440] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
51358->51359;
51370->51371;
51374->51375;
51371->51376;
51375->51376;
51376->51377;
51377->51378;
51378->51379;
51386->51387;
51359->51388;
51387->51388;
51388->51389;
51379->51390;
51390->51391;
51391->51392;
51392->51393;
51389->51394;
51393->51394;
51394->51395;
51395->51396;
51396->51435;
51435->51436;
51436->51437;
51437->51438;
51438->51439;
51439->51440;
}
51357,51358
51369,51370
51373,51374
51385,51386
51379
51396
51370
51371
51374
51375
51376
51377
51378
51379
51386
51387
51388
51389
51390
51391
51392
51393
51394
51395
51396
51435
51436
51437
51438
51439
51440