digraph G {
id="graph_100708";
subgraph graph_stage_100708 {
id="graph_stage_100708";
isCluster="true";
label="Stage 100708";
subgraph cluster_121080 {
id="cluster_121080";
isCluster="true";
label="Exchange";
46645 [id="node_46645" labelType="html" label="ShuffledRowRDD [46645] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121077 {
id="cluster_121077";
isCluster="true";
label="WholeStageCodegen (1)";
46646 [id="node_46646" labelType="html" label="MapPartitionsRDD [46646] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121100 {
id="cluster_121100";
isCluster="true";
label="Exchange";
46657 [id="node_46657" labelType="html" label="ShuffledRowRDD [46657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121097 {
id="cluster_121097";
isCluster="true";
label="WholeStageCodegen (4)";
46658 [id="node_46658" labelType="html" label="MapPartitionsRDD [46658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121129 {
id="cluster_121129";
isCluster="true";
label="Exchange";
46661 [id="node_46661" labelType="html" label="ShuffledRowRDD [46661] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121126 {
id="cluster_121126";
isCluster="true";
label="WholeStageCodegen (6)";
46662 [id="node_46662" labelType="html" label="MapPartitionsRDD [46662] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121089 {
id="cluster_121089";
isCluster="true";
label="WholeStageCodegen (7)";
46663 [id="node_46663" labelType="html" label="ZippedPartitionsRDD2 [46663] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46664 [id="node_46664" labelType="html" label="MapPartitionsRDD [46664] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121088 {
id="cluster_121088";
isCluster="true";
label="InMemoryTableScan";
46665 [id="node_46665" labelType="html" label="MapPartitionsRDD [46665] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46666 [id="node_46666" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#938355 AS qty#938357, demandChannel#938350, demandStream#938351, cachedKpis#938356 AS kpis#938358]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#938354L, cachedShardId#938353], 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=1454068]\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=1454064]\n : +- *(2) Has... [46666] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121086 {
id="cluster_121086";
isCluster="true";
label="Exchange";
46673 [id="node_46673" labelType="html" label="ShuffledRowRDD [46673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121083 {
id="cluster_121083";
isCluster="true";
label="WholeStageCodegen (4)";
46674 [id="node_46674" labelType="html" label="MapPartitionsRDD [46674] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121069 {
id="cluster_121069";
isCluster="true";
label="WholeStageCodegen (5)";
46675 [id="node_46675" labelType="html" label="ZippedPartitionsRDD2 [46675] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46676 [id="node_46676" labelType="html" label="MapPartitionsRDD [46676] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121144 {
id="cluster_121144";
isCluster="true";
label="InMemoryTableScan";
46677 [id="node_46677" labelType="html" label="MapPartitionsRDD [46677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46678 [id="node_46678" labelType="html" label="MapPartitionsRDD [46678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46679 [id="node_46679" labelType="html" label="MapPartitionsRDD [46679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121141 {
id="cluster_121141";
isCluster="true";
label="WholeStageCodegen (6)";
46680 [id="node_46680" labelType="html" label="MapPartitionsRDD [46680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121068 {
id="cluster_121068";
isCluster="true";
label="Union";
46681 [id="node_46681" labelType="html" label="UnionRDD [46681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121067 {
id="cluster_121067";
isCluster="true";
label="InMemoryTableScan";
46682 [id="node_46682" labelType="html" label="MapPartitionsRDD [46682] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46683 [id="node_46683" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#938590, null AS demandStream#938591, [] AS kpis#938625, true AS isNewlyCalculated#938593]\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#938582, ), isnull(shardId#938582), coalesce(worklistShardItemId#938583L, 0), isnull(worklistShardItemId#938583L), coalesce(version#938584, 0), isnull(version#938584), coalesce(product#938585, ), isnull(product#938585), coalesce(plant#938586, ), isnull(plant#938586), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#938357, 0.0))), isnull(qty#... [46683] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121356 {
id="cluster_121356";
isCluster="true";
label="Exchange";
46779 [id="node_46779" labelType="html" label="ShuffledRowRDD [46779] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121351 {
id="cluster_121351";
isCluster="true";
label="WholeStageCodegen (6)";
46780 [id="node_46780" labelType="html" label="MapPartitionsRDD [46780] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121350 {
id="cluster_121350";
isCluster="true";
label="SortAggregate";
46781 [id="node_46781" labelType="html" label="MapPartitionsRDD [46781] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121349 {
id="cluster_121349";
isCluster="true";
label="InMemoryTableScan";
46782 [id="node_46782" labelType="html" label="MapPartitionsRDD [46782] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46783 [id="node_46783" labelType="html" label="SortAggregate(key=[demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127], functions=[first(kpis#941155, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#941146, demandChannel#941126, demandStream#941127, kpis#941288])\n+- *(6) Sort [demandChannel#941126 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#941146 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#941127 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127, 37), ENSURE_REQUIREMENTS, [plan_id=1454998]\n +- SortAggregate(key=[demandChannel#941126, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#941146)) AS qty#941146, worklistShardItemId#904715L, demandStream#941127], functions=[partial_first(kpis#941155, false)], output=[demandChannel#941126, shardId#904714, qty#941146, worklistShardItemId#904715L, demandStream#941127, first#94136... [46783] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121516 {
id="cluster_121516";
isCluster="true";
label="InMemoryTableScan";
46821 [id="node_46821" labelType="html" label="MapPartitionsRDD [46821] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46822 [id="node_46822" labelType="html" label="MapPartitionsRDD [46822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46823 [id="node_46823" labelType="html" label="MapPartitionsRDD [46823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121512 {
id="cluster_121512";
isCluster="true";
label="WholeStageCodegen (1)";
46824 [id="node_46824" labelType="html" label="MapPartitionsRDD [46824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121520 {
id="cluster_121520";
isCluster="true";
label="InMemoryTableScan";
46825 [id="node_46825" labelType="html" label="MapPartitionsRDD [46825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46826 [id="node_46826" labelType="html" label="MapPartitionsRDD [46826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46827 [id="node_46827" labelType="html" label="MapPartitionsRDD [46827] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121517 {
id="cluster_121517";
isCluster="true";
label="WholeStageCodegen (2)";
46828 [id="node_46828" labelType="html" label="MapPartitionsRDD [46828] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121511 {
id="cluster_121511";
isCluster="true";
label="Union";
46829 [id="node_46829" labelType="html" label="UnionRDD [46829] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121487 {
id="cluster_121487";
isCluster="true";
label="WholeStageCodegen (5)";
46830 [id="node_46830" labelType="html" label="MapPartitionsRDD [46830] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121486 {
id="cluster_121486";
isCluster="true";
label="InMemoryTableScan";
46831 [id="node_46831" labelType="html" label="MapPartitionsRDD [46831] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46832 [id="node_46832" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#941959, qty#904721, demandChannel#938590, demandStream#938591, kpis#938625]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#942056, worklistShardItemId#942057L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#938590, demandStream#938591, kpis#938625]\n : : +- *(1) Filter ((NOT isNewlyCalculated#938593 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#938590, demandStream#938591, isNewlyCalculated#938593, kpis#938625, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#938593, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#938590, demandStream#938591... [46832] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_121545 {
id="cluster_121545";
isCluster="true";
label="InMemoryTableScan";
46841 [id="node_46841" labelType="html" label="MapPartitionsRDD [46841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46842 [id="node_46842" labelType="html" label="MapPartitionsRDD [46842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
46843 [id="node_46843" labelType="html" label="MapPartitionsRDD [46843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
46645->46646;
46657->46658;
46661->46662;
46658->46663;
46662->46663;
46663->46664;
46664->46665;
46665->46666;
46673->46674;
46646->46675;
46674->46675;
46675->46676;
46666->46677;
46677->46678;
46678->46679;
46679->46680;
46676->46681;
46680->46681;
46681->46682;
46682->46683;
46779->46780;
46780->46781;
46781->46782;
46782->46783;
46683->46821;
46821->46822;
46822->46823;
46823->46824;
46783->46825;
46825->46826;
46826->46827;
46827->46828;
46824->46829;
46828->46829;
46829->46830;
46830->46831;
46831->46832;
46832->46841;
46841->46842;
46842->46843;
}
46644,46645
46656,46657
46660,46661
46672,46673
46778,46779
46666
46683
46783
46832
46657
46658
46661
46662
46663
46664
46665
46666
46673
46674
46675
46676
46677
46678
46679
46680
46681
46682
46683
46779
46780
46781
46782
46783
46821
46822
46823
46824
46825
46826
46827
46828
46829
46830
46831
46832
46841
46842
46843