digraph G { id="graph_99897"; subgraph graph_stage_99897 { id="graph_stage_99897"; isCluster="true"; label="Stage 99897"; subgraph cluster_119838 { id="cluster_119838"; isCluster="true"; label="Exchange"; 46117 [id="node_46117" labelType="html" label="ShuffledRowRDD [46117] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119835 { id="cluster_119835"; isCluster="true"; label="WholeStageCodegen (1)"; 46118 [id="node_46118" labelType="html" label="MapPartitionsRDD [46118] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119858 { id="cluster_119858"; isCluster="true"; label="Exchange"; 46129 [id="node_46129" labelType="html" label="ShuffledRowRDD [46129] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119855 { id="cluster_119855"; isCluster="true"; label="WholeStageCodegen (4)"; 46130 [id="node_46130" labelType="html" label="MapPartitionsRDD [46130] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119887 { id="cluster_119887"; isCluster="true"; label="Exchange"; 46133 [id="node_46133" labelType="html" label="ShuffledRowRDD [46133] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119884 { id="cluster_119884"; isCluster="true"; label="WholeStageCodegen (6)"; 46134 [id="node_46134" labelType="html" label="MapPartitionsRDD [46134] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119847 { id="cluster_119847"; isCluster="true"; label="WholeStageCodegen (7)"; 46135 [id="node_46135" labelType="html" label="ZippedPartitionsRDD2 [46135] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46136 [id="node_46136" labelType="html" label="MapPartitionsRDD [46136] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119846 { id="cluster_119846"; isCluster="true"; label="InMemoryTableScan"; 46137 [id="node_46137" labelType="html" label="MapPartitionsRDD [46137] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46138 [id="node_46138" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#927239 AS qty#927241, demandChannel#927234, demandStream#927235, cachedKpis#927240 AS kpis#927242]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#927238L, cachedShardId#927237], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1450903]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1450899]\n : +- *(2) Has... [46138] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119844 { id="cluster_119844"; isCluster="true"; label="Exchange"; 46145 [id="node_46145" labelType="html" label="ShuffledRowRDD [46145] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119841 { id="cluster_119841"; isCluster="true"; label="WholeStageCodegen (4)"; 46146 [id="node_46146" labelType="html" label="MapPartitionsRDD [46146] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119827 { id="cluster_119827"; isCluster="true"; label="WholeStageCodegen (5)"; 46147 [id="node_46147" labelType="html" label="ZippedPartitionsRDD2 [46147] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46148 [id="node_46148" labelType="html" label="MapPartitionsRDD [46148] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119908 { id="cluster_119908"; isCluster="true"; label="InMemoryTableScan"; 46149 [id="node_46149" labelType="html" label="MapPartitionsRDD [46149] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46150 [id="node_46150" labelType="html" label="MapPartitionsRDD [46150] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46151 [id="node_46151" labelType="html" label="MapPartitionsRDD [46151] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119905 { id="cluster_119905"; isCluster="true"; label="WholeStageCodegen (6)"; 46152 [id="node_46152" labelType="html" label="MapPartitionsRDD [46152] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119826 { id="cluster_119826"; isCluster="true"; label="Union"; 46153 [id="node_46153" labelType="html" label="UnionRDD [46153] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119825 { id="cluster_119825"; isCluster="true"; label="InMemoryTableScan"; 46154 [id="node_46154" labelType="html" label="MapPartitionsRDD [46154] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46155 [id="node_46155" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#927474, null AS demandStream#927475, [] AS kpis#927509, true AS isNewlyCalculated#927477]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#927466, ), isnull(shardId#927466), coalesce(worklistShardItemId#927467L, 0), isnull(worklistShardItemId#927467L), coalesce(version#927468, 0), isnull(version#927468), coalesce(product#927469, ), isnull(product#927469), coalesce(plant#927470, ), isnull(plant#927470), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#927241, 0.0))), isnull(qty#... [46155] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120114 { id="cluster_120114"; isCluster="true"; label="Exchange"; 46251 [id="node_46251" labelType="html" label="ShuffledRowRDD [46251] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120109 { id="cluster_120109"; isCluster="true"; label="WholeStageCodegen (6)"; 46252 [id="node_46252" labelType="html" label="MapPartitionsRDD [46252] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120108 { id="cluster_120108"; isCluster="true"; label="SortAggregate"; 46253 [id="node_46253" labelType="html" label="MapPartitionsRDD [46253] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120107 { id="cluster_120107"; isCluster="true"; label="InMemoryTableScan"; 46254 [id="node_46254" labelType="html" label="MapPartitionsRDD [46254] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46255 [id="node_46255" labelType="html" label="SortAggregate(key=[demandChannel#930010, shardId#904714, qty#930030, worklistShardItemId#904715L, demandStream#930011], functions=[first(kpis#930039, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#930030, demandChannel#930010, demandStream#930011, kpis#930172])\n+- *(6) Sort [demandChannel#930010 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#930030 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#930011 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#930010, shardId#904714, qty#930030, worklistShardItemId#904715L, demandStream#930011, 37), ENSURE_REQUIREMENTS, [plan_id=1451833]\n +- SortAggregate(key=[demandChannel#930010, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#930030)) AS qty#930030, worklistShardItemId#904715L, demandStream#930011], functions=[partial_first(kpis#930039, false)], output=[demandChannel#930010, shardId#904714, qty#930030, worklistShardItemId#904715L, demandStream#930011, first#93024... [46255] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120274 { id="cluster_120274"; isCluster="true"; label="InMemoryTableScan"; 46293 [id="node_46293" labelType="html" label="MapPartitionsRDD [46293] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46294 [id="node_46294" labelType="html" label="MapPartitionsRDD [46294] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46295 [id="node_46295" labelType="html" label="MapPartitionsRDD [46295] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120270 { id="cluster_120270"; isCluster="true"; label="WholeStageCodegen (1)"; 46296 [id="node_46296" labelType="html" label="MapPartitionsRDD [46296] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120278 { id="cluster_120278"; isCluster="true"; label="InMemoryTableScan"; 46297 [id="node_46297" labelType="html" label="MapPartitionsRDD [46297] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46298 [id="node_46298" labelType="html" label="MapPartitionsRDD [46298] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46299 [id="node_46299" labelType="html" label="MapPartitionsRDD [46299] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120275 { id="cluster_120275"; isCluster="true"; label="WholeStageCodegen (2)"; 46300 [id="node_46300" labelType="html" label="MapPartitionsRDD [46300] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120269 { id="cluster_120269"; isCluster="true"; label="Union"; 46301 [id="node_46301" labelType="html" label="UnionRDD [46301] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120245 { id="cluster_120245"; isCluster="true"; label="WholeStageCodegen (5)"; 46302 [id="node_46302" labelType="html" label="MapPartitionsRDD [46302] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120244 { id="cluster_120244"; isCluster="true"; label="InMemoryTableScan"; 46303 [id="node_46303" labelType="html" label="MapPartitionsRDD [46303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46304 [id="node_46304" labelType="html" label="*(5) Project [shardId#904714, worklistShardItemId#904715L, version#930843, qty#904721, demandChannel#927474, demandStream#927475, kpis#927509]\n+- *(5) BroadcastHashJoin [shardId#904714, worklistShardItemId#904715L], [shardId#930940, worklistShardItemId#930941L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#904714, worklistShardItemId#904715L, qty#904721, demandChannel#927474, demandStream#927475, kpis#927509]\n : : +- *(1) Filter ((NOT isNewlyCalculated#927477 AND isnotnull(shardId#904714)) AND isnotnull(worklistShardItemId#904715L))\n : : +- InMemoryTableScan [demandChannel#927474, demandStream#927475, isNewlyCalculated#927477, kpis#927509, qty#904721, shardId#904714, worklistShardItemId#904715L], [NOT isNewlyCalculated#927477, isnotnull(shardId#904714), isnotnull(worklistShardItemId#904715L)]\n : : +- InMemoryRelation [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, demandChannel#927474, demandStream#927475... [46304] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46305 [id="node_46305" labelType="html" label="MapPartitionsRDD [46305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46306 [id="node_46306" labelType="html" label="MapPartitionsRDD [46306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46307 [id="node_46307" labelType="html" label="MapPartitionsRDD [46307] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120243 { id="cluster_120243"; isCluster="true"; label="CollectLimit"; 46308 [id="node_46308" labelType="html" label="MapPartitionsRDD [46308] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 46309 [id="node_46309" labelType="html" label="MapPartitionsRDD [46309] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46117->46118; 46129->46130; 46133->46134; 46130->46135; 46134->46135; 46135->46136; 46136->46137; 46137->46138; 46145->46146; 46118->46147; 46146->46147; 46147->46148; 46138->46149; 46149->46150; 46150->46151; 46151->46152; 46148->46153; 46152->46153; 46153->46154; 46154->46155; 46251->46252; 46252->46253; 46253->46254; 46254->46255; 46155->46293; 46293->46294; 46294->46295; 46295->46296; 46255->46297; 46297->46298; 46298->46299; 46299->46300; 46296->46301; 46300->46301; 46301->46302; 46302->46303; 46303->46304; 46304->46305; 46305->46306; 46306->46307; 46307->46308; 46308->46309; }