digraph G {
id="graph_115541";
subgraph graph_stage_115541 {
id="graph_stage_115541";
isCluster="true";
label="Stage 115541";
subgraph cluster_144154 {
id="cluster_144154";
isCluster="true";
label="Exchange";
55403 [id="node_55403" labelType="html" label="ShuffledRowRDD [55403] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144151 {
id="cluster_144151";
isCluster="true";
label="WholeStageCodegen (1)";
55404 [id="node_55404" labelType="html" label="MapPartitionsRDD [55404] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144174 {
id="cluster_144174";
isCluster="true";
label="Exchange";
55415 [id="node_55415" labelType="html" label="ShuffledRowRDD [55415] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144171 {
id="cluster_144171";
isCluster="true";
label="WholeStageCodegen (4)";
55416 [id="node_55416" labelType="html" label="MapPartitionsRDD [55416] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144209 {
id="cluster_144209";
isCluster="true";
label="Exchange";
55419 [id="node_55419" labelType="html" label="ShuffledRowRDD [55419] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144206 {
id="cluster_144206";
isCluster="true";
label="WholeStageCodegen (6)";
55420 [id="node_55420" labelType="html" label="MapPartitionsRDD [55420] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144163 {
id="cluster_144163";
isCluster="true";
label="WholeStageCodegen (7)";
55421 [id="node_55421" labelType="html" label="ZippedPartitionsRDD2 [55421] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55422 [id="node_55422" labelType="html" label="MapPartitionsRDD [55422] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144162 {
id="cluster_144162";
isCluster="true";
label="InMemoryTableScan";
55423 [id="node_55423" labelType="html" label="MapPartitionsRDD [55423] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55424 [id="node_55424" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1111580 AS qty#1111582, demandChannel#1111575, demandStream#1111576, cachedKpis#1111581 AS kpis#1111583]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1111579L, cachedShardId#1111578], 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=1750595]\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... [55424] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144160 {
id="cluster_144160";
isCluster="true";
label="Exchange";
55431 [id="node_55431" labelType="html" label="ShuffledRowRDD [55431] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144157 {
id="cluster_144157";
isCluster="true";
label="WholeStageCodegen (4)";
55432 [id="node_55432" labelType="html" label="MapPartitionsRDD [55432] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144143 {
id="cluster_144143";
isCluster="true";
label="WholeStageCodegen (5)";
55433 [id="node_55433" labelType="html" label="ZippedPartitionsRDD2 [55433] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55434 [id="node_55434" labelType="html" label="MapPartitionsRDD [55434] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144225 {
id="cluster_144225";
isCluster="true";
label="InMemoryTableScan";
55435 [id="node_55435" labelType="html" label="MapPartitionsRDD [55435] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55436 [id="node_55436" labelType="html" label="MapPartitionsRDD [55436] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55437 [id="node_55437" labelType="html" label="MapPartitionsRDD [55437] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144222 {
id="cluster_144222";
isCluster="true";
label="WholeStageCodegen (6)";
55438 [id="node_55438" labelType="html" label="MapPartitionsRDD [55438] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144142 {
id="cluster_144142";
isCluster="true";
label="Union";
55439 [id="node_55439" labelType="html" label="UnionRDD [55439] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144141 {
id="cluster_144141";
isCluster="true";
label="InMemoryTableScan";
55440 [id="node_55440" labelType="html" label="MapPartitionsRDD [55440] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55441 [id="node_55441" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1111815, null AS demandStream#1111816, [] AS kpis#1111850, true AS isNewlyCalculated#1111818]\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#1111807, ), isnull(shardId#1111807), coalesce(worklistShardItemId#1111808L, 0), isnull(worklistShardItemId#1111808L), coalesce(version#1111809, 0), isnull(version#1111809), coalesce(product#1111810, ), isnull(product#1111810), coalesce(plant#1111811, ), isnull(plant#1111811), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55441] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144434 {
id="cluster_144434";
isCluster="true";
label="Exchange";
55537 [id="node_55537" labelType="html" label="ShuffledRowRDD [55537] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144428 {
id="cluster_144428";
isCluster="true";
label="WholeStageCodegen (6)";
55538 [id="node_55538" labelType="html" label="MapPartitionsRDD [55538] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144427 {
id="cluster_144427";
isCluster="true";
label="SortAggregate";
55539 [id="node_55539" labelType="html" label="MapPartitionsRDD [55539] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144426 {
id="cluster_144426";
isCluster="true";
label="InMemoryTableScan";
55540 [id="node_55540" labelType="html" label="MapPartitionsRDD [55540] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55541 [id="node_55541" labelType="html" label="SortAggregate(key=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[first(kpis#1114548, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114681])\n+- *(6) Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]\n +- SortAggregate(key=[demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[partial_first(kpis#1114548, false)], output=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L,... [55541] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144592 {
id="cluster_144592";
isCluster="true";
label="InMemoryTableScan";
55579 [id="node_55579" labelType="html" label="MapPartitionsRDD [55579] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55580 [id="node_55580" labelType="html" label="MapPartitionsRDD [55580] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55581 [id="node_55581" labelType="html" label="MapPartitionsRDD [55581] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144588 {
id="cluster_144588";
isCluster="true";
label="WholeStageCodegen (1)";
55582 [id="node_55582" labelType="html" label="MapPartitionsRDD [55582] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144596 {
id="cluster_144596";
isCluster="true";
label="InMemoryTableScan";
55583 [id="node_55583" labelType="html" label="MapPartitionsRDD [55583] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55584 [id="node_55584" labelType="html" label="MapPartitionsRDD [55584] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55585 [id="node_55585" labelType="html" label="MapPartitionsRDD [55585] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144593 {
id="cluster_144593";
isCluster="true";
label="WholeStageCodegen (2)";
55586 [id="node_55586" labelType="html" label="MapPartitionsRDD [55586] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144587 {
id="cluster_144587";
isCluster="true";
label="Union";
55587 [id="node_55587" labelType="html" label="UnionRDD [55587] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144563 {
id="cluster_144563";
isCluster="true";
label="WholeStageCodegen (5)";
55588 [id="node_55588" labelType="html" label="MapPartitionsRDD [55588] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144562 {
id="cluster_144562";
isCluster="true";
label="InMemoryTableScan";
55589 [id="node_55589" labelType="html" label="MapPartitionsRDD [55589] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55590 [id="node_55590" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1115352, qty#1100464, demandChannel#1111815, demandStream#1111816, kpis#1111850]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1115449, worklistShardItemId#1115450L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1111815, demandStream#1111816, kpis#1111850]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1111818 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1111815, demandStream#1111816, isNewlyCalculated#1111818, kpis#1111850, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1111818, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [55590] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55591 [id="node_55591" labelType="html" label="MapPartitionsRDD [55591] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55592 [id="node_55592" labelType="html" label="MapPartitionsRDD [55592] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55593 [id="node_55593" labelType="html" label="MapPartitionsRDD [55593] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_144561 {
id="cluster_144561";
isCluster="true";
label="CollectLimit";
55594 [id="node_55594" labelType="html" label="MapPartitionsRDD [55594] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
55595 [id="node_55595" labelType="html" label="MapPartitionsRDD [55595] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
55403->55404;
55415->55416;
55419->55420;
55416->55421;
55420->55421;
55421->55422;
55422->55423;
55423->55424;
55431->55432;
55404->55433;
55432->55433;
55433->55434;
55424->55435;
55435->55436;
55436->55437;
55437->55438;
55434->55439;
55438->55439;
55439->55440;
55440->55441;
55537->55538;
55538->55539;
55539->55540;
55540->55541;
55441->55579;
55579->55580;
55580->55581;
55581->55582;
55541->55583;
55583->55584;
55584->55585;
55585->55586;
55582->55587;
55586->55587;
55587->55588;
55588->55589;
55589->55590;
55590->55591;
55591->55592;
55592->55593;
55593->55594;
55594->55595;
}
55402,55403
55414,55415
55418,55419
55430,55431
55536,55537
55424
55441
55541
55590