digraph G { id="graph_115839"; subgraph graph_stage_115839 { id="graph_stage_115839"; isCluster="true"; label="Stage 115839"; subgraph cluster_144777 { id="cluster_144777"; isCluster="true"; label="Exchange"; 55667 [id="node_55667" labelType="html" label="ShuffledRowRDD [55667] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144774 { id="cluster_144774"; isCluster="true"; label="WholeStageCodegen (1)"; 55668 [id="node_55668" labelType="html" label="MapPartitionsRDD [55668] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144797 { id="cluster_144797"; isCluster="true"; label="Exchange"; 55679 [id="node_55679" labelType="html" label="ShuffledRowRDD [55679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144794 { id="cluster_144794"; isCluster="true"; label="WholeStageCodegen (4)"; 55680 [id="node_55680" labelType="html" label="MapPartitionsRDD [55680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144832 { id="cluster_144832"; isCluster="true"; label="Exchange"; 55683 [id="node_55683" labelType="html" label="ShuffledRowRDD [55683] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144829 { id="cluster_144829"; isCluster="true"; label="WholeStageCodegen (6)"; 55684 [id="node_55684" labelType="html" label="MapPartitionsRDD [55684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144786 { id="cluster_144786"; isCluster="true"; label="WholeStageCodegen (7)"; 55685 [id="node_55685" labelType="html" label="ZippedPartitionsRDD2 [55685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55686 [id="node_55686" labelType="html" label="MapPartitionsRDD [55686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144785 { id="cluster_144785"; isCluster="true"; label="InMemoryTableScan"; 55687 [id="node_55687" labelType="html" label="MapPartitionsRDD [55687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55688 [id="node_55688" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1117306 AS qty#1117308, demandChannel#1117301, demandStream#1117302, cachedKpis#1117307 AS kpis#1117309]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1117305L, cachedShardId#1117304], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1752232]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [55688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144783 { id="cluster_144783"; isCluster="true"; label="Exchange"; 55695 [id="node_55695" labelType="html" label="ShuffledRowRDD [55695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144780 { id="cluster_144780"; isCluster="true"; label="WholeStageCodegen (4)"; 55696 [id="node_55696" labelType="html" label="MapPartitionsRDD [55696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144766 { id="cluster_144766"; isCluster="true"; label="WholeStageCodegen (5)"; 55697 [id="node_55697" labelType="html" label="ZippedPartitionsRDD2 [55697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55698 [id="node_55698" labelType="html" label="MapPartitionsRDD [55698] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144847 { id="cluster_144847"; isCluster="true"; label="InMemoryTableScan"; 55699 [id="node_55699" labelType="html" label="MapPartitionsRDD [55699] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55700 [id="node_55700" labelType="html" label="MapPartitionsRDD [55700] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55701 [id="node_55701" labelType="html" label="MapPartitionsRDD [55701] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144844 { id="cluster_144844"; isCluster="true"; label="WholeStageCodegen (6)"; 55702 [id="node_55702" labelType="html" label="MapPartitionsRDD [55702] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144765 { id="cluster_144765"; isCluster="true"; label="Union"; 55703 [id="node_55703" labelType="html" label="UnionRDD [55703] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144764 { id="cluster_144764"; isCluster="true"; label="InMemoryTableScan"; 55704 [id="node_55704" labelType="html" label="MapPartitionsRDD [55704] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55705 [id="node_55705" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1117541, null AS demandStream#1117542, [] AS kpis#1117576, true AS isNewlyCalculated#1117544]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1117533, ), isnull(shardId#1117533), coalesce(worklistShardItemId#1117534L, 0), isnull(worklistShardItemId#1117534L), coalesce(version#1117535, 0), isnull(version#1117535), coalesce(product#1117536, ), isnull(product#1117536), coalesce(plant#1117537, ), isnull(plant#1117537), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55705] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145054 { id="cluster_145054"; isCluster="true"; label="Exchange"; 55801 [id="node_55801" labelType="html" label="ShuffledRowRDD [55801] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145048 { id="cluster_145048"; isCluster="true"; label="WholeStageCodegen (6)"; 55802 [id="node_55802" labelType="html" label="MapPartitionsRDD [55802] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145047 { id="cluster_145047"; isCluster="true"; label="SortAggregate"; 55803 [id="node_55803" labelType="html" label="MapPartitionsRDD [55803] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145046 { id="cluster_145046"; isCluster="true"; label="InMemoryTableScan"; 55804 [id="node_55804" labelType="html" label="MapPartitionsRDD [55804] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55805 [id="node_55805" labelType="html" label="SortAggregate(key=[demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L, demandStream#1120078], functions=[first(kpis#1120106, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1120097, demandChannel#1120077, demandStream#1120078, kpis#1120239])\n+- *(6) Sort [demandChannel#1120077 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1120097 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1120078 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L, demandStream#1120078, 37), ENSURE_REQUIREMENTS, [plan_id=1753162]\n +- SortAggregate(key=[demandChannel#1120077, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1120097)) AS qty#1120097, worklistShardItemId#1100458L, demandStream#1120078], functions=[partial_first(kpis#1120106, false)], output=[demandChannel#1120077, shardId#1100457, qty#1120097, worklistShardItemId#1100458L,... [55805] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145213 { id="cluster_145213"; isCluster="true"; label="InMemoryTableScan"; 55843 [id="node_55843" labelType="html" label="MapPartitionsRDD [55843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55844 [id="node_55844" labelType="html" label="MapPartitionsRDD [55844] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55845 [id="node_55845" labelType="html" label="MapPartitionsRDD [55845] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145209 { id="cluster_145209"; isCluster="true"; label="WholeStageCodegen (1)"; 55846 [id="node_55846" labelType="html" label="MapPartitionsRDD [55846] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145217 { id="cluster_145217"; isCluster="true"; label="InMemoryTableScan"; 55847 [id="node_55847" labelType="html" label="MapPartitionsRDD [55847] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55848 [id="node_55848" labelType="html" label="MapPartitionsRDD [55848] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55849 [id="node_55849" labelType="html" label="MapPartitionsRDD [55849] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145214 { id="cluster_145214"; isCluster="true"; label="WholeStageCodegen (2)"; 55850 [id="node_55850" labelType="html" label="MapPartitionsRDD [55850] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145208 { id="cluster_145208"; isCluster="true"; label="Union"; 55851 [id="node_55851" labelType="html" label="UnionRDD [55851] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145184 { id="cluster_145184"; isCluster="true"; label="WholeStageCodegen (5)"; 55852 [id="node_55852" labelType="html" label="MapPartitionsRDD [55852] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145183 { id="cluster_145183"; isCluster="true"; label="InMemoryTableScan"; 55853 [id="node_55853" labelType="html" label="MapPartitionsRDD [55853] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55854 [id="node_55854" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1120910, qty#1100464, demandChannel#1117541, demandStream#1117542, kpis#1117576]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1121007, worklistShardItemId#1121008L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1117541, demandStream#1117542, kpis#1117576]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1117544 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1117541, demandStream#1117542, isNewlyCalculated#1117544, kpis#1117576, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1117544, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [55854] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55855 [id="node_55855" labelType="html" label="MapPartitionsRDD [55855] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55856 [id="node_55856" labelType="html" label="MapPartitionsRDD [55856] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55857 [id="node_55857" labelType="html" label="MapPartitionsRDD [55857] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145182 { id="cluster_145182"; isCluster="true"; label="CollectLimit"; 55858 [id="node_55858" labelType="html" label="MapPartitionsRDD [55858] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55859 [id="node_55859" labelType="html" label="MapPartitionsRDD [55859] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55667->55668; 55679->55680; 55683->55684; 55680->55685; 55684->55685; 55685->55686; 55686->55687; 55687->55688; 55695->55696; 55668->55697; 55696->55697; 55697->55698; 55688->55699; 55699->55700; 55700->55701; 55701->55702; 55698->55703; 55702->55703; 55703->55704; 55704->55705; 55801->55802; 55802->55803; 55803->55804; 55804->55805; 55705->55843; 55843->55844; 55844->55845; 55845->55846; 55805->55847; 55847->55848; 55848->55849; 55849->55850; 55846->55851; 55850->55851; 55851->55852; 55852->55853; 55853->55854; 55854->55855; 55855->55856; 55856->55857; 55857->55858; 55858->55859; }