digraph G {
id="graph_100231";
subgraph graph_stage_100231 {
id="graph_stage_100231";
isCluster="true";
label="Stage 100231";
subgraph cluster_120459 {
id="cluster_120459";
isCluster="true";
label="Exchange";
46381 [id="node_46381" labelType="html" label="ShuffledRowRDD [46381] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120456 {
id="cluster_120456";
isCluster="true";
label="WholeStageCodegen (1)";
46382 [id="node_46382" labelType="html" label="MapPartitionsRDD [46382] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120479 {
id="cluster_120479";
isCluster="true";
label="Exchange";
46393 [id="node_46393" labelType="html" label="ShuffledRowRDD [46393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120476 {
id="cluster_120476";
isCluster="true";
label="WholeStageCodegen (4)";
46394 [id="node_46394" labelType="html" label="MapPartitionsRDD [46394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120514 {
id="cluster_120514";
isCluster="true";
label="Exchange";
46397 [id="node_46397" labelType="html" label="ShuffledRowRDD [46397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120511 {
id="cluster_120511";
isCluster="true";
label="WholeStageCodegen (6)";
46398 [id="node_46398" labelType="html" label="MapPartitionsRDD [46398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120468 {
id="cluster_120468";
isCluster="true";
label="WholeStageCodegen (7)";
46399 [id="node_46399" labelType="html" label="ZippedPartitionsRDD2 [46399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46400 [id="node_46400" labelType="html" label="MapPartitionsRDD [46400] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120467 {
id="cluster_120467";
isCluster="true";
label="InMemoryTableScan";
46401 [id="node_46401" labelType="html" label="MapPartitionsRDD [46401] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46402 [id="node_46402" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#932797 AS qty#932799, demandChannel#932792, demandStream#932793, cachedKpis#932798 AS kpis#932800]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#932796L, cachedShardId#932795], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1452493]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1452489]\n : +- *(2) Has... [46402] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120465 {
id="cluster_120465";
isCluster="true";
label="Exchange";
46409 [id="node_46409" labelType="html" label="ShuffledRowRDD [46409] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120462 {
id="cluster_120462";
isCluster="true";
label="WholeStageCodegen (4)";
46410 [id="node_46410" labelType="html" label="MapPartitionsRDD [46410] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120448 {
id="cluster_120448";
isCluster="true";
label="WholeStageCodegen (5)";
46411 [id="node_46411" labelType="html" label="ZippedPartitionsRDD2 [46411] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46412 [id="node_46412" labelType="html" label="MapPartitionsRDD [46412] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120529 {
id="cluster_120529";
isCluster="true";
label="InMemoryTableScan";
46413 [id="node_46413" labelType="html" label="MapPartitionsRDD [46413] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46414 [id="node_46414" labelType="html" label="MapPartitionsRDD [46414] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46415 [id="node_46415" labelType="html" label="MapPartitionsRDD [46415] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120526 {
id="cluster_120526";
isCluster="true";
label="WholeStageCodegen (6)";
46416 [id="node_46416" labelType="html" label="MapPartitionsRDD [46416] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120447 {
id="cluster_120447";
isCluster="true";
label="Union";
46417 [id="node_46417" labelType="html" label="UnionRDD [46417] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120446 {
id="cluster_120446";
isCluster="true";
label="InMemoryTableScan";
46418 [id="node_46418" labelType="html" label="MapPartitionsRDD [46418] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46419 [id="node_46419" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#933032, null AS demandStream#933033, [] AS kpis#933067, true AS isNewlyCalculated#933035]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#933024, ), isnull(shardId#933024), coalesce(worklistShardItemId#933025L, 0), isnull(worklistShardItemId#933025L), coalesce(version#933026, 0), isnull(version#933026), coalesce(product#933027, ), isnull(product#933027), coalesce(plant#933028, ), isnull(plant#933028), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#932799, 0.0))), isnull(qty#... [46419] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120735 {
id="cluster_120735";
isCluster="true";
label="Exchange";
46515 [id="node_46515" labelType="html" label="ShuffledRowRDD [46515] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120730 {
id="cluster_120730";
isCluster="true";
label="WholeStageCodegen (6)";
46516 [id="node_46516" labelType="html" label="MapPartitionsRDD [46516] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120729 {
id="cluster_120729";
isCluster="true";
label="SortAggregate";
46517 [id="node_46517" labelType="html" label="MapPartitionsRDD [46517] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120728 {
id="cluster_120728";
isCluster="true";
label="InMemoryTableScan";
46518 [id="node_46518" labelType="html" label="MapPartitionsRDD [46518] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46519 [id="node_46519" labelType="html" label="SortAggregate(key=[demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569], functions=[first(kpis#935597, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#935588, demandChannel#935568, demandStream#935569, kpis#935730])\n+- *(6) Sort [demandChannel#935568 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#935588 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#935569 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569, 37), ENSURE_REQUIREMENTS, [plan_id=1453423]\n +- SortAggregate(key=[demandChannel#935568, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#935588)) AS qty#935588, worklistShardItemId#904715L, demandStream#935569], functions=[partial_first(kpis#935597, false)], output=[demandChannel#935568, shardId#904714, qty#935588, worklistShardItemId#904715L, demandStream#935569, first#93580... [46519] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120895 {
id="cluster_120895";
isCluster="true";
label="InMemoryTableScan";
46557 [id="node_46557" labelType="html" label="MapPartitionsRDD [46557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46558 [id="node_46558" labelType="html" label="MapPartitionsRDD [46558] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46559 [id="node_46559" labelType="html" label="MapPartitionsRDD [46559] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120891 {
id="cluster_120891";
isCluster="true";
label="WholeStageCodegen (1)";
46560 [id="node_46560" labelType="html" label="MapPartitionsRDD [46560] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120899 {
id="cluster_120899";
isCluster="true";
label="InMemoryTableScan";
46561 [id="node_46561" labelType="html" label="MapPartitionsRDD [46561] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46562 [id="node_46562" labelType="html" label="MapPartitionsRDD [46562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46563 [id="node_46563" labelType="html" label="MapPartitionsRDD [46563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120896 {
id="cluster_120896";
isCluster="true";
label="WholeStageCodegen (2)";
46564 [id="node_46564" labelType="html" label="MapPartitionsRDD [46564] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120890 {
id="cluster_120890";
isCluster="true";
label="Union";
46565 [id="node_46565" labelType="html" label="UnionRDD [46565] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120866 {
id="cluster_120866";
isCluster="true";
label="WholeStageCodegen (5)";
46566 [id="node_46566" labelType="html" label="MapPartitionsRDD [46566] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120865 {
id="cluster_120865";
isCluster="true";
label="InMemoryTableScan";
46567 [id="node_46567" labelType="html" label="MapPartitionsRDD [46567] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46568 [id="node_46568" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#936401, qty#904721, demandChannel#933032, demandStream#933033, kpis#933067]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#936498, worklistShardItemId#936499L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#933032, demandStream#933033, kpis#933067]\n : : +- *(1) Filter ((NOT isNewlyCalculated#933035 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#933032, demandStream#933033, isNewlyCalculated#933035, kpis#933067, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#933035, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#933032, demandStream#933033... [46568] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_120924 {
id="cluster_120924";
isCluster="true";
label="InMemoryTableScan";
46577 [id="node_46577" labelType="html" label="MapPartitionsRDD [46577] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46578 [id="node_46578" labelType="html" label="MapPartitionsRDD [46578] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46579 [id="node_46579" labelType="html" label="MapPartitionsRDD [46579] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
46381->46382;
46393->46394;
46397->46398;
46394->46399;
46398->46399;
46399->46400;
46400->46401;
46401->46402;
46409->46410;
46382->46411;
46410->46411;
46411->46412;
46402->46413;
46413->46414;
46414->46415;
46415->46416;
46412->46417;
46416->46417;
46417->46418;
46418->46419;
46515->46516;
46516->46517;
46517->46518;
46518->46519;
46419->46557;
46557->46558;
46558->46559;
46559->46560;
46519->46561;
46561->46562;
46562->46563;
46563->46564;
46560->46565;
46564->46565;
46565->46566;
46566->46567;
46567->46568;
46568->46577;
46577->46578;
46578->46579;
}
46380,46381
46392,46393
46396,46397
46408,46409
46514,46515
46402
46419
46519
46568
46393
46394
46397
46398
46399
46400
46401
46402
46409
46410
46411
46412
46413
46414
46415
46416
46417
46418
46419
46515
46516
46517
46518
46519
46557
46558
46559
46560
46561
46562
46563
46564
46565
46566
46567
46568
46577
46578
46579