digraph G { id="graph_111664"; subgraph graph_stage_111664 { id="graph_stage_111664"; isCluster="true"; label="Stage 111664"; subgraph cluster_137893 { id="cluster_137893"; isCluster="true"; label="Exchange"; 52942 [id="node_52942" labelType="html" label="ShuffledRowRDD [52942] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137890 { id="cluster_137890"; isCluster="true"; label="WholeStageCodegen (1)"; 52943 [id="node_52943" labelType="html" label="MapPartitionsRDD [52943] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137913 { id="cluster_137913"; isCluster="true"; label="Exchange"; 52954 [id="node_52954" labelType="html" label="ShuffledRowRDD [52954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137910 { id="cluster_137910"; isCluster="true"; label="WholeStageCodegen (4)"; 52955 [id="node_52955" labelType="html" label="MapPartitionsRDD [52955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137942 { id="cluster_137942"; isCluster="true"; label="Exchange"; 52958 [id="node_52958" labelType="html" label="ShuffledRowRDD [52958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137939 { id="cluster_137939"; isCluster="true"; label="WholeStageCodegen (6)"; 52959 [id="node_52959" labelType="html" label="MapPartitionsRDD [52959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137902 { id="cluster_137902"; isCluster="true"; label="WholeStageCodegen (7)"; 52960 [id="node_52960" labelType="html" label="ZippedPartitionsRDD2 [52960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52961 [id="node_52961" labelType="html" label="MapPartitionsRDD [52961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137901 { id="cluster_137901"; isCluster="true"; label="InMemoryTableScan"; 52962 [id="node_52962" labelType="html" label="MapPartitionsRDD [52962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52963 [id="node_52963" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1061534 AS qty#1061536, demandChannel#1061529, demandStream#1061530, cachedKpis#1061535 AS kpis#1061537]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1061533L, cachedShardId#1061532], 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=1687852]\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... [52963] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137899 { id="cluster_137899"; isCluster="true"; label="Exchange"; 52970 [id="node_52970" labelType="html" label="ShuffledRowRDD [52970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137896 { id="cluster_137896"; isCluster="true"; label="WholeStageCodegen (4)"; 52971 [id="node_52971" labelType="html" label="MapPartitionsRDD [52971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137882 { id="cluster_137882"; isCluster="true"; label="WholeStageCodegen (5)"; 52972 [id="node_52972" labelType="html" label="ZippedPartitionsRDD2 [52972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52973 [id="node_52973" labelType="html" label="MapPartitionsRDD [52973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137957 { id="cluster_137957"; isCluster="true"; label="InMemoryTableScan"; 52974 [id="node_52974" labelType="html" label="MapPartitionsRDD [52974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52975 [id="node_52975" labelType="html" label="MapPartitionsRDD [52975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52976 [id="node_52976" labelType="html" label="MapPartitionsRDD [52976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137954 { id="cluster_137954"; isCluster="true"; label="WholeStageCodegen (6)"; 52977 [id="node_52977" labelType="html" label="MapPartitionsRDD [52977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137881 { id="cluster_137881"; isCluster="true"; label="Union"; 52978 [id="node_52978" labelType="html" label="UnionRDD [52978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_137880 { id="cluster_137880"; isCluster="true"; label="InMemoryTableScan"; 52979 [id="node_52979" labelType="html" label="MapPartitionsRDD [52979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 52980 [id="node_52980" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1061769, null AS demandStream#1061770, [] AS kpis#1061804, true AS isNewlyCalculated#1061772]\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#1061761, ), isnull(shardId#1061761), coalesce(worklistShardItemId#1061762L, 0), isnull(worklistShardItemId#1061762L), coalesce(version#1061763, 0), isnull(version#1061763), coalesce(product#1061764, ), isnull(product#1061764), coalesce(plant#1061765, ), isnull(plant#1061765), knownfloatingpointnormalized(normalizenanandzero(coalesce... [52980] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138169 { id="cluster_138169"; isCluster="true"; label="Exchange"; 53076 [id="node_53076" labelType="html" label="ShuffledRowRDD [53076] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138164 { id="cluster_138164"; isCluster="true"; label="WholeStageCodegen (6)"; 53077 [id="node_53077" labelType="html" label="MapPartitionsRDD [53077] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138163 { id="cluster_138163"; isCluster="true"; label="SortAggregate"; 53078 [id="node_53078" labelType="html" label="MapPartitionsRDD [53078] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138162 { id="cluster_138162"; isCluster="true"; label="InMemoryTableScan"; 53079 [id="node_53079" labelType="html" label="MapPartitionsRDD [53079] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53080 [id="node_53080" labelType="html" label="SortAggregate(key=[demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L, demandStream#1064306], functions=[first(kpis#1064334, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1064325, demandChannel#1064305, demandStream#1064306, kpis#1064467])\n+- *(6) Sort [demandChannel#1064305 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1064325 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1064306 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L, demandStream#1064306, 37), ENSURE_REQUIREMENTS, [plan_id=1688782]\n +- SortAggregate(key=[demandChannel#1064305, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1064325)) AS qty#1064325, worklistShardItemId#1011816L, demandStream#1064306], functions=[partial_first(kpis#1064334, false)], output=[demandChannel#1064305, shardId#1011815, qty#1064325, worklistShardItemId#1011816L,... [53080] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138329 { id="cluster_138329"; isCluster="true"; label="InMemoryTableScan"; 53118 [id="node_53118" labelType="html" label="MapPartitionsRDD [53118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53119 [id="node_53119" labelType="html" label="MapPartitionsRDD [53119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53120 [id="node_53120" labelType="html" label="MapPartitionsRDD [53120] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138325 { id="cluster_138325"; isCluster="true"; label="WholeStageCodegen (1)"; 53121 [id="node_53121" labelType="html" label="MapPartitionsRDD [53121] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138333 { id="cluster_138333"; isCluster="true"; label="InMemoryTableScan"; 53122 [id="node_53122" labelType="html" label="MapPartitionsRDD [53122] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53123 [id="node_53123" labelType="html" label="MapPartitionsRDD [53123] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53124 [id="node_53124" labelType="html" label="MapPartitionsRDD [53124] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138330 { id="cluster_138330"; isCluster="true"; label="WholeStageCodegen (2)"; 53125 [id="node_53125" labelType="html" label="MapPartitionsRDD [53125] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138324 { id="cluster_138324"; isCluster="true"; label="Union"; 53126 [id="node_53126" labelType="html" label="UnionRDD [53126] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138300 { id="cluster_138300"; isCluster="true"; label="WholeStageCodegen (5)"; 53127 [id="node_53127" labelType="html" label="MapPartitionsRDD [53127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138299 { id="cluster_138299"; isCluster="true"; label="InMemoryTableScan"; 53128 [id="node_53128" labelType="html" label="MapPartitionsRDD [53128] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53129 [id="node_53129" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1065138, qty#1011822, demandChannel#1061769, demandStream#1061770, kpis#1061804]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1065235, worklistShardItemId#1065236L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1061769, demandStream#1061770, kpis#1061804]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1061772 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1061769, demandStream#1061770, isNewlyCalculated#1061772, kpis#1061804, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1061772, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [53129] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138358 { id="cluster_138358"; isCluster="true"; label="InMemoryTableScan"; 53138 [id="node_53138" labelType="html" label="MapPartitionsRDD [53138] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53139 [id="node_53139" labelType="html" label="MapPartitionsRDD [53139] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53140 [id="node_53140" labelType="html" label="MapPartitionsRDD [53140] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52942->52943; 52954->52955; 52958->52959; 52955->52960; 52959->52960; 52960->52961; 52961->52962; 52962->52963; 52970->52971; 52943->52972; 52971->52972; 52972->52973; 52963->52974; 52974->52975; 52975->52976; 52976->52977; 52973->52978; 52977->52978; 52978->52979; 52979->52980; 53076->53077; 53077->53078; 53078->53079; 53079->53080; 52980->53118; 53118->53119; 53119->53120; 53120->53121; 53080->53122; 53122->53123; 53123->53124; 53124->53125; 53121->53126; 53125->53126; 53126->53127; 53127->53128; 53128->53129; 53129->53138; 53138->53139; 53139->53140; }