digraph G {
id="graph_91957";
subgraph graph_stage_91957 {
id="graph_stage_91957";
isCluster="true";
label="Stage 91957";
subgraph cluster_110478 {
id="cluster_110478";
isCluster="true";
label="Exchange";
42334 [id="node_42334" labelType="html" label="ShuffledRowRDD [42334] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110475 {
id="cluster_110475";
isCluster="true";
label="WholeStageCodegen (1)";
42335 [id="node_42335" labelType="html" label="MapPartitionsRDD [42335] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110498 {
id="cluster_110498";
isCluster="true";
label="Exchange";
42346 [id="node_42346" labelType="html" label="ShuffledRowRDD [42346] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110495 {
id="cluster_110495";
isCluster="true";
label="WholeStageCodegen (4)";
42347 [id="node_42347" labelType="html" label="MapPartitionsRDD [42347] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110527 {
id="cluster_110527";
isCluster="true";
label="Exchange";
42350 [id="node_42350" labelType="html" label="ShuffledRowRDD [42350] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110524 {
id="cluster_110524";
isCluster="true";
label="WholeStageCodegen (6)";
42351 [id="node_42351" labelType="html" label="MapPartitionsRDD [42351] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110487 {
id="cluster_110487";
isCluster="true";
label="WholeStageCodegen (7)";
42352 [id="node_42352" labelType="html" label="ZippedPartitionsRDD2 [42352] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42353 [id="node_42353" labelType="html" label="MapPartitionsRDD [42353] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110486 {
id="cluster_110486";
isCluster="true";
label="InMemoryTableScan";
42354 [id="node_42354" labelType="html" label="MapPartitionsRDD [42354] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42355 [id="node_42355" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#849095 AS qty#849097, demandChannel#849090, demandStream#849091, cachedKpis#849096 AS kpis#849098]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#849094L, cachedShardId#849093], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1378422]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1378418]\n : +- *(2) Has... [42355] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110484 {
id="cluster_110484";
isCluster="true";
label="Exchange";
42362 [id="node_42362" labelType="html" label="ShuffledRowRDD [42362] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110481 {
id="cluster_110481";
isCluster="true";
label="WholeStageCodegen (4)";
42363 [id="node_42363" labelType="html" label="MapPartitionsRDD [42363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110467 {
id="cluster_110467";
isCluster="true";
label="WholeStageCodegen (5)";
42364 [id="node_42364" labelType="html" label="ZippedPartitionsRDD2 [42364] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42365 [id="node_42365" labelType="html" label="MapPartitionsRDD [42365] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110548 {
id="cluster_110548";
isCluster="true";
label="InMemoryTableScan";
42366 [id="node_42366" labelType="html" label="MapPartitionsRDD [42366] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42367 [id="node_42367" labelType="html" label="MapPartitionsRDD [42367] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42368 [id="node_42368" labelType="html" label="MapPartitionsRDD [42368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110545 {
id="cluster_110545";
isCluster="true";
label="WholeStageCodegen (6)";
42369 [id="node_42369" labelType="html" label="MapPartitionsRDD [42369] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110466 {
id="cluster_110466";
isCluster="true";
label="Union";
42370 [id="node_42370" labelType="html" label="UnionRDD [42370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110465 {
id="cluster_110465";
isCluster="true";
label="InMemoryTableScan";
42371 [id="node_42371" labelType="html" label="MapPartitionsRDD [42371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42372 [id="node_42372" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#849330, null AS demandStream#849331, [] AS kpis#849365, true AS isNewlyCalculated#849333]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#849322, ), isnull(shardId#849322), coalesce(worklistShardItemId#849323L, 0), isnull(worklistShardItemId#849323L), coalesce(version#849324, 0), isnull(version#849324), coalesce(product#849325, ), isnull(product#849325), coalesce(plant#849326, ), isnull(plant#849326), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#849097, 0.0))), isnull(qty#... [42372] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110898 {
id="cluster_110898";
isCluster="true";
label="InMemoryTableScan";
42502 [id="node_42502" labelType="html" label="MapPartitionsRDD [42502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42503 [id="node_42503" labelType="html" label="MapPartitionsRDD [42503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
42504 [id="node_42504" labelType="html" label="MapPartitionsRDD [42504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110894 {
id="cluster_110894";
isCluster="true";
label="WholeStageCodegen (3)";
42505 [id="node_42505" labelType="html" label="MapPartitionsRDD [42505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_110893 {
id="cluster_110893";
isCluster="true";
label="Exchange";
42506 [id="node_42506" labelType="html" label="MapPartitionsRDD [42506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
42334->42335;
42346->42347;
42350->42351;
42347->42352;
42351->42352;
42352->42353;
42353->42354;
42354->42355;
42362->42363;
42335->42364;
42363->42364;
42364->42365;
42355->42366;
42366->42367;
42367->42368;
42368->42369;
42365->42370;
42369->42370;
42370->42371;
42371->42372;
42372->42502;
42502->42503;
42503->42504;
42504->42505;
42505->42506;
}
42333,42334
42345,42346
42349,42350
42361,42362
42355
42372
42346
42347
42350
42351
42352
42353
42354
42355
42362
42363
42364
42365
42366
42367
42368
42369
42370
42371
42372
42502
42503
42504
42505
42506