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; }