digraph G { id="graph_96095"; subgraph graph_stage_96095 { id="graph_stage_96095"; isCluster="true"; label="Stage 96095"; subgraph cluster_113596 { id="cluster_113596"; isCluster="true"; label="Exchange"; 43660 [id="node_43660" labelType="html" label="ShuffledRowRDD [43660] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113593 { id="cluster_113593"; isCluster="true"; label="WholeStageCodegen (1)"; 43661 [id="node_43661" labelType="html" label="MapPartitionsRDD [43661] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113616 { id="cluster_113616"; isCluster="true"; label="Exchange"; 43672 [id="node_43672" labelType="html" label="ShuffledRowRDD [43672] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113613 { id="cluster_113613"; isCluster="true"; label="WholeStageCodegen (4)"; 43673 [id="node_43673" labelType="html" label="MapPartitionsRDD [43673] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113651 { id="cluster_113651"; isCluster="true"; label="Exchange"; 43676 [id="node_43676" labelType="html" label="ShuffledRowRDD [43676] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113648 { id="cluster_113648"; isCluster="true"; label="WholeStageCodegen (6)"; 43677 [id="node_43677" labelType="html" label="MapPartitionsRDD [43677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113605 { id="cluster_113605"; isCluster="true"; label="WholeStageCodegen (7)"; 43678 [id="node_43678" labelType="html" label="ZippedPartitionsRDD2 [43678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43679 [id="node_43679" labelType="html" label="MapPartitionsRDD [43679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113604 { id="cluster_113604"; isCluster="true"; label="InMemoryTableScan"; 43680 [id="node_43680" labelType="html" label="MapPartitionsRDD [43680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43681 [id="node_43681" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#876907 AS qty#876909, demandChannel#876902, demandStream#876903, cachedKpis#876908 AS kpis#876910]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#876906L, cachedShardId#876905], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1386312]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1386308]\n : +- *(2) Has... [43681] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113602 { id="cluster_113602"; isCluster="true"; label="Exchange"; 43688 [id="node_43688" labelType="html" label="ShuffledRowRDD [43688] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113599 { id="cluster_113599"; isCluster="true"; label="WholeStageCodegen (4)"; 43689 [id="node_43689" labelType="html" label="MapPartitionsRDD [43689] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113585 { id="cluster_113585"; isCluster="true"; label="WholeStageCodegen (5)"; 43690 [id="node_43690" labelType="html" label="ZippedPartitionsRDD2 [43690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43691 [id="node_43691" labelType="html" label="MapPartitionsRDD [43691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113666 { id="cluster_113666"; isCluster="true"; label="InMemoryTableScan"; 43692 [id="node_43692" labelType="html" label="MapPartitionsRDD [43692] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43693 [id="node_43693" labelType="html" label="MapPartitionsRDD [43693] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43694 [id="node_43694" labelType="html" label="MapPartitionsRDD [43694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113663 { id="cluster_113663"; isCluster="true"; label="WholeStageCodegen (6)"; 43695 [id="node_43695" labelType="html" label="MapPartitionsRDD [43695] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113584 { id="cluster_113584"; isCluster="true"; label="Union"; 43696 [id="node_43696" labelType="html" label="UnionRDD [43696] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113583 { id="cluster_113583"; isCluster="true"; label="InMemoryTableScan"; 43697 [id="node_43697" labelType="html" label="MapPartitionsRDD [43697] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43698 [id="node_43698" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#877142, null AS demandStream#877143, [] AS kpis#877177, true AS isNewlyCalculated#877145]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#877134, ), isnull(shardId#877134), coalesce(worklistShardItemId#877135L, 0), isnull(worklistShardItemId#877135L), coalesce(version#877136, 0), isnull(version#877136), coalesce(product#877137, ), isnull(product#877137), coalesce(plant#877138, ), isnull(plant#877138), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#876909, 0.0))), isnull(qty#... [43698] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113873 { id="cluster_113873"; isCluster="true"; label="Exchange"; 43794 [id="node_43794" labelType="html" label="ShuffledRowRDD [43794] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113867 { id="cluster_113867"; isCluster="true"; label="WholeStageCodegen (6)"; 43795 [id="node_43795" labelType="html" label="MapPartitionsRDD [43795] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113866 { id="cluster_113866"; isCluster="true"; label="SortAggregate"; 43796 [id="node_43796" labelType="html" label="MapPartitionsRDD [43796] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_113865 { id="cluster_113865"; isCluster="true"; label="InMemoryTableScan"; 43797 [id="node_43797" labelType="html" label="MapPartitionsRDD [43797] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43798 [id="node_43798" labelType="html" label="SortAggregate(key=[demandChannel#879678, shardId#815740, qty#879698, worklistShardItemId#815741L, demandStream#879679], functions=[first(kpis#879707, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#879698, demandChannel#879678, demandStream#879679, kpis#879840])\n+- *(6) Sort [demandChannel#879678 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#879698 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#879679 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#879678, shardId#815740, qty#879698, worklistShardItemId#815741L, demandStream#879679, 37), ENSURE_REQUIREMENTS, [plan_id=1387242]\n +- SortAggregate(key=[demandChannel#879678, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#879698)) AS qty#879698, worklistShardItemId#815741L, demandStream#879679], functions=[partial_first(kpis#879707, false)], output=[demandChannel#879678, shardId#815740, qty#879698, worklistShardItemId#815741L, demandStream#879679, first#87991... [43798] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114032 { id="cluster_114032"; isCluster="true"; label="InMemoryTableScan"; 43836 [id="node_43836" labelType="html" label="MapPartitionsRDD [43836] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43837 [id="node_43837" labelType="html" label="MapPartitionsRDD [43837] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43838 [id="node_43838" labelType="html" label="MapPartitionsRDD [43838] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114028 { id="cluster_114028"; isCluster="true"; label="WholeStageCodegen (1)"; 43839 [id="node_43839" labelType="html" label="MapPartitionsRDD [43839] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114036 { id="cluster_114036"; isCluster="true"; label="InMemoryTableScan"; 43840 [id="node_43840" labelType="html" label="MapPartitionsRDD [43840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43841 [id="node_43841" labelType="html" label="MapPartitionsRDD [43841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43842 [id="node_43842" labelType="html" label="MapPartitionsRDD [43842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114033 { id="cluster_114033"; isCluster="true"; label="WholeStageCodegen (2)"; 43843 [id="node_43843" labelType="html" label="MapPartitionsRDD [43843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114027 { id="cluster_114027"; isCluster="true"; label="Union"; 43844 [id="node_43844" labelType="html" label="UnionRDD [43844] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114003 { id="cluster_114003"; isCluster="true"; label="WholeStageCodegen (5)"; 43845 [id="node_43845" labelType="html" label="MapPartitionsRDD [43845] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114002 { id="cluster_114002"; isCluster="true"; label="InMemoryTableScan"; 43846 [id="node_43846" labelType="html" label="MapPartitionsRDD [43846] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43847 [id="node_43847" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#880511, qty#815747, demandChannel#877142, demandStream#877143, kpis#877177]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#880608, worklistShardItemId#880609L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#877142, demandStream#877143, kpis#877177]\n : : +- *(1) Filter ((NOT isNewlyCalculated#877145 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#877142, demandStream#877143, isNewlyCalculated#877145, kpis#877177, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#877145, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#877142, demandStream#877143... [43847] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43848 [id="node_43848" labelType="html" label="MapPartitionsRDD [43848] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43849 [id="node_43849" labelType="html" label="MapPartitionsRDD [43849] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43850 [id="node_43850" labelType="html" label="MapPartitionsRDD [43850] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114001 { id="cluster_114001"; isCluster="true"; label="CollectLimit"; 43851 [id="node_43851" labelType="html" label="MapPartitionsRDD [43851] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43852 [id="node_43852" labelType="html" label="MapPartitionsRDD [43852] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43660->43661; 43672->43673; 43676->43677; 43673->43678; 43677->43678; 43678->43679; 43679->43680; 43680->43681; 43688->43689; 43661->43690; 43689->43690; 43690->43691; 43681->43692; 43692->43693; 43693->43694; 43694->43695; 43691->43696; 43695->43696; 43696->43697; 43697->43698; 43794->43795; 43795->43796; 43796->43797; 43797->43798; 43698->43836; 43836->43837; 43837->43838; 43838->43839; 43798->43840; 43840->43841; 43841->43842; 43842->43843; 43839->43844; 43843->43844; 43844->43845; 43845->43846; 43846->43847; 43847->43848; 43848->43849; 43849->43850; 43850->43851; 43851->43852; }