digraph G {
id="graph_112403";
subgraph graph_stage_112403 {
id="graph_stage_112403";
isCluster="true";
label="Stage 112403";
subgraph cluster_139815 {
id="cluster_139815";
isCluster="true";
label="Exchange";
53758 [id="node_53758" labelType="html" label="ShuffledRowRDD [53758] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139812 {
id="cluster_139812";
isCluster="true";
label="WholeStageCodegen (1)";
53759 [id="node_53759" labelType="html" label="MapPartitionsRDD [53759] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139835 {
id="cluster_139835";
isCluster="true";
label="Exchange";
53770 [id="node_53770" labelType="html" label="ShuffledRowRDD [53770] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139832 {
id="cluster_139832";
isCluster="true";
label="WholeStageCodegen (4)";
53771 [id="node_53771" labelType="html" label="MapPartitionsRDD [53771] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139870 {
id="cluster_139870";
isCluster="true";
label="Exchange";
53774 [id="node_53774" labelType="html" label="ShuffledRowRDD [53774] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139867 {
id="cluster_139867";
isCluster="true";
label="WholeStageCodegen (6)";
53775 [id="node_53775" labelType="html" label="MapPartitionsRDD [53775] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139824 {
id="cluster_139824";
isCluster="true";
label="WholeStageCodegen (7)";
53776 [id="node_53776" labelType="html" label="ZippedPartitionsRDD2 [53776] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53777 [id="node_53777" labelType="html" label="MapPartitionsRDD [53777] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139823 {
id="cluster_139823";
isCluster="true";
label="InMemoryTableScan";
53778 [id="node_53778" labelType="html" label="MapPartitionsRDD [53778] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53779 [id="node_53779" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1078507 AS qty#1078509, demandChannel#1078502, demandStream#1078503, cachedKpis#1078508 AS kpis#1078510]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1078506L, cachedShardId#1078505], 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=1692734]\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... [53779] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139821 {
id="cluster_139821";
isCluster="true";
label="Exchange";
53786 [id="node_53786" labelType="html" label="ShuffledRowRDD [53786] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139818 {
id="cluster_139818";
isCluster="true";
label="WholeStageCodegen (4)";
53787 [id="node_53787" labelType="html" label="MapPartitionsRDD [53787] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139804 {
id="cluster_139804";
isCluster="true";
label="WholeStageCodegen (5)";
53788 [id="node_53788" labelType="html" label="ZippedPartitionsRDD2 [53788] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53789 [id="node_53789" labelType="html" label="MapPartitionsRDD [53789] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139885 {
id="cluster_139885";
isCluster="true";
label="InMemoryTableScan";
53790 [id="node_53790" labelType="html" label="MapPartitionsRDD [53790] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53791 [id="node_53791" labelType="html" label="MapPartitionsRDD [53791] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53792 [id="node_53792" labelType="html" label="MapPartitionsRDD [53792] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139882 {
id="cluster_139882";
isCluster="true";
label="WholeStageCodegen (6)";
53793 [id="node_53793" labelType="html" label="MapPartitionsRDD [53793] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139803 {
id="cluster_139803";
isCluster="true";
label="Union";
53794 [id="node_53794" labelType="html" label="UnionRDD [53794] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_139802 {
id="cluster_139802";
isCluster="true";
label="InMemoryTableScan";
53795 [id="node_53795" labelType="html" label="MapPartitionsRDD [53795] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53796 [id="node_53796" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1078742, null AS demandStream#1078743, [] AS kpis#1078777, true AS isNewlyCalculated#1078745]\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#1078734, ), isnull(shardId#1078734), coalesce(worklistShardItemId#1078735L, 0), isnull(worklistShardItemId#1078735L), coalesce(version#1078736, 0), isnull(version#1078736), coalesce(product#1078737, ), isnull(product#1078737), coalesce(plant#1078738, ), isnull(plant#1078738), knownfloatingpointnormalized(normalizenanandzero(coalesce... [53796] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140013 {
id="cluster_140013";
isCluster="true";
label="Exchange";
53841 [id="node_53841" labelType="html" label="ShuffledRowRDD [53841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140012 {
id="cluster_140012";
isCluster="true";
label="ObjectHashAggregate";
53842 [id="node_53842" labelType="html" label="MapPartitionsRDD [53842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140024 {
id="cluster_140024";
isCluster="true";
label="InMemoryTableScan";
53843 [id="node_53843" labelType="html" label="MapPartitionsRDD [53843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53844 [id="node_53844" labelType="html" label="MapPartitionsRDD [53844] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53845 [id="node_53845" labelType="html" label="MapPartitionsRDD [53845] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140020 {
id="cluster_140020";
isCluster="true";
label="WholeStageCodegen (12)";
53846 [id="node_53846" labelType="html" label="MapPartitionsRDD [53846] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140011 {
id="cluster_140011";
isCluster="true";
label="Union";
53847 [id="node_53847" labelType="html" label="UnionRDD [53847] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140010 {
id="cluster_140010";
isCluster="true";
label="Exchange";
53848 [id="node_53848" labelType="html" label="MapPartitionsRDD [53848] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
53758->53759;
53770->53771;
53774->53775;
53771->53776;
53775->53776;
53776->53777;
53777->53778;
53778->53779;
53786->53787;
53759->53788;
53787->53788;
53788->53789;
53779->53790;
53790->53791;
53791->53792;
53792->53793;
53789->53794;
53793->53794;
53794->53795;
53795->53796;
53841->53842;
53796->53843;
53843->53844;
53844->53845;
53845->53846;
53842->53847;
53846->53847;
53847->53848;
}
53757,53758
53769,53770
53773,53774
53785,53786
53840,53841
53779
53796
53770
53771
53774
53775
53776
53777
53778
53779
53786
53787
53788
53789
53790
53791
53792
53793
53794
53795
53796
53841
53842
53843
53844
53845
53846
53847
53848