digraph G {
id="graph_112762";
subgraph graph_stage_112762 {
id="graph_stage_112762";
isCluster="true";
label="Stage 112762";
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_140092 {
id="cluster_140092";
isCluster="true";
label="Exchange";
53892 [id="node_53892" labelType="html" label="ShuffledRowRDD [53892] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140086 {
id="cluster_140086";
isCluster="true";
label="WholeStageCodegen (6)";
53893 [id="node_53893" labelType="html" label="MapPartitionsRDD [53893] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140085 {
id="cluster_140085";
isCluster="true";
label="SortAggregate";
53894 [id="node_53894" labelType="html" label="MapPartitionsRDD [53894] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140084 {
id="cluster_140084";
isCluster="true";
label="InMemoryTableScan";
53895 [id="node_53895" labelType="html" label="MapPartitionsRDD [53895] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53896 [id="node_53896" labelType="html" label="SortAggregate(key=[demandChannel#1081278, shardId#1011815, qty#1081298, worklistShardItemId#1011816L, demandStream#1081279], functions=[first(kpis#1081307, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1081298, demandChannel#1081278, demandStream#1081279, kpis#1081440])\n+- *(6) Sort [demandChannel#1081278 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1081298 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1081279 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1081278, shardId#1011815, qty#1081298, worklistShardItemId#1011816L, demandStream#1081279, 37), ENSURE_REQUIREMENTS, [plan_id=1693664]\n +- SortAggregate(key=[demandChannel#1081278, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1081298)) AS qty#1081298, worklistShardItemId#1011816L, demandStream#1081279], functions=[partial_first(kpis#1081307, false)], output=[demandChannel#1081278, shardId#1011815, qty#1081298, worklistShardItemId#1011816L,... [53896] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140251 {
id="cluster_140251";
isCluster="true";
label="InMemoryTableScan";
53934 [id="node_53934" labelType="html" label="MapPartitionsRDD [53934] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53935 [id="node_53935" labelType="html" label="MapPartitionsRDD [53935] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53936 [id="node_53936" labelType="html" label="MapPartitionsRDD [53936] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140247 {
id="cluster_140247";
isCluster="true";
label="WholeStageCodegen (1)";
53937 [id="node_53937" labelType="html" label="MapPartitionsRDD [53937] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140255 {
id="cluster_140255";
isCluster="true";
label="InMemoryTableScan";
53938 [id="node_53938" labelType="html" label="MapPartitionsRDD [53938] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53939 [id="node_53939" labelType="html" label="MapPartitionsRDD [53939] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53940 [id="node_53940" labelType="html" label="MapPartitionsRDD [53940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140252 {
id="cluster_140252";
isCluster="true";
label="WholeStageCodegen (2)";
53941 [id="node_53941" labelType="html" label="MapPartitionsRDD [53941] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140246 {
id="cluster_140246";
isCluster="true";
label="Union";
53942 [id="node_53942" labelType="html" label="UnionRDD [53942] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140222 {
id="cluster_140222";
isCluster="true";
label="WholeStageCodegen (5)";
53943 [id="node_53943" labelType="html" label="MapPartitionsRDD [53943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140221 {
id="cluster_140221";
isCluster="true";
label="InMemoryTableScan";
53944 [id="node_53944" labelType="html" label="MapPartitionsRDD [53944] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53945 [id="node_53945" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1082111, qty#1011822, demandChannel#1078742, demandStream#1078743, kpis#1078777]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1082208, worklistShardItemId#1082209L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1078742, demandStream#1078743, kpis#1078777]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1078745 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1078742, demandStream#1078743, isNewlyCalculated#1078745, kpis#1078777, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1078745, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [53945] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_140280 {
id="cluster_140280";
isCluster="true";
label="InMemoryTableScan";
53954 [id="node_53954" labelType="html" label="MapPartitionsRDD [53954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53955 [id="node_53955" labelType="html" label="MapPartitionsRDD [53955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
53956 [id="node_53956" labelType="html" label="MapPartitionsRDD [53956] [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;
53892->53893;
53893->53894;
53894->53895;
53895->53896;
53796->53934;
53934->53935;
53935->53936;
53936->53937;
53896->53938;
53938->53939;
53939->53940;
53940->53941;
53937->53942;
53941->53942;
53942->53943;
53943->53944;
53944->53945;
53945->53954;
53954->53955;
53955->53956;
}
53757,53758
53769,53770
53773,53774
53785,53786
53891,53892
53779
53796
53896
53945
53770
53771
53774
53775
53776
53777
53778
53779
53786
53787
53788
53789
53790
53791
53792
53793
53794
53795
53796
53892
53893
53894
53895
53896
53934
53935
53936
53937
53938
53939
53940
53941
53942
53943
53944
53945
53954
53955
53956