digraph G { id="graph_91263"; subgraph graph_stage_91263 { id="graph_stage_91263"; isCluster="true"; label="Stage 91263"; subgraph cluster_109857 { id="cluster_109857"; isCluster="true"; label="Exchange"; 42070 [id="node_42070" labelType="html" label="ShuffledRowRDD [42070] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109854 { id="cluster_109854"; isCluster="true"; label="WholeStageCodegen (1)"; 42071 [id="node_42071" labelType="html" label="MapPartitionsRDD [42071] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109877 { id="cluster_109877"; isCluster="true"; label="Exchange"; 42082 [id="node_42082" labelType="html" label="ShuffledRowRDD [42082] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109874 { id="cluster_109874"; isCluster="true"; label="WholeStageCodegen (4)"; 42083 [id="node_42083" labelType="html" label="MapPartitionsRDD [42083] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109906 { id="cluster_109906"; isCluster="true"; label="Exchange"; 42086 [id="node_42086" labelType="html" label="ShuffledRowRDD [42086] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109903 { id="cluster_109903"; isCluster="true"; label="WholeStageCodegen (6)"; 42087 [id="node_42087" labelType="html" label="MapPartitionsRDD [42087] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109866 { id="cluster_109866"; isCluster="true"; label="WholeStageCodegen (7)"; 42088 [id="node_42088" labelType="html" label="ZippedPartitionsRDD2 [42088] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42089 [id="node_42089" labelType="html" label="MapPartitionsRDD [42089] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109865 { id="cluster_109865"; isCluster="true"; label="InMemoryTableScan"; 42090 [id="node_42090" labelType="html" label="MapPartitionsRDD [42090] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42091 [id="node_42091" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#843537 AS qty#843539, demandChannel#843532, demandStream#843533, cachedKpis#843538 AS kpis#843540]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#843536L, cachedShardId#843535], 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=1376847]\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=1376843]\n : +- *(2) Has... [42091] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109863 { id="cluster_109863"; isCluster="true"; label="Exchange"; 42098 [id="node_42098" labelType="html" label="ShuffledRowRDD [42098] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109860 { id="cluster_109860"; isCluster="true"; label="WholeStageCodegen (4)"; 42099 [id="node_42099" labelType="html" label="MapPartitionsRDD [42099] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109846 { id="cluster_109846"; isCluster="true"; label="WholeStageCodegen (5)"; 42100 [id="node_42100" labelType="html" label="ZippedPartitionsRDD2 [42100] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42101 [id="node_42101" labelType="html" label="MapPartitionsRDD [42101] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109921 { id="cluster_109921"; isCluster="true"; label="InMemoryTableScan"; 42102 [id="node_42102" labelType="html" label="MapPartitionsRDD [42102] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42103 [id="node_42103" labelType="html" label="MapPartitionsRDD [42103] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42104 [id="node_42104" labelType="html" label="MapPartitionsRDD [42104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109918 { id="cluster_109918"; isCluster="true"; label="WholeStageCodegen (6)"; 42105 [id="node_42105" labelType="html" label="MapPartitionsRDD [42105] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109845 { id="cluster_109845"; isCluster="true"; label="Union"; 42106 [id="node_42106" labelType="html" label="UnionRDD [42106] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109844 { id="cluster_109844"; isCluster="true"; label="InMemoryTableScan"; 42107 [id="node_42107" labelType="html" label="MapPartitionsRDD [42107] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42108 [id="node_42108" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#843772, null AS demandStream#843773, [] AS kpis#843807, true AS isNewlyCalculated#843775]\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#843764, ), isnull(shardId#843764), coalesce(worklistShardItemId#843765L, 0), isnull(worklistShardItemId#843765L), coalesce(version#843766, 0), isnull(version#843766), coalesce(product#843767, ), isnull(product#843767), coalesce(plant#843768, ), isnull(plant#843768), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#843539, 0.0))), isnull(qty#... [42108] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110133 { id="cluster_110133"; isCluster="true"; label="Exchange"; 42204 [id="node_42204" labelType="html" label="ShuffledRowRDD [42204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110128 { id="cluster_110128"; isCluster="true"; label="WholeStageCodegen (6)"; 42205 [id="node_42205" labelType="html" label="MapPartitionsRDD [42205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110127 { id="cluster_110127"; isCluster="true"; label="SortAggregate"; 42206 [id="node_42206" labelType="html" label="MapPartitionsRDD [42206] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110126 { id="cluster_110126"; isCluster="true"; label="InMemoryTableScan"; 42207 [id="node_42207" labelType="html" label="MapPartitionsRDD [42207] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42208 [id="node_42208" labelType="html" label="SortAggregate(key=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[first(kpis#846337, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#846328, demandChannel#846308, demandStream#846309, kpis#846470])\n+- *(6) Sort [demandChannel#846308 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#846328 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#846309 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, 37), ENSURE_REQUIREMENTS, [plan_id=1377777]\n +- SortAggregate(key=[demandChannel#846308, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#846328)) AS qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[partial_first(kpis#846337, false)], output=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, first#84654... [42208] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110293 { id="cluster_110293"; isCluster="true"; label="InMemoryTableScan"; 42246 [id="node_42246" labelType="html" label="MapPartitionsRDD [42246] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42247 [id="node_42247" labelType="html" label="MapPartitionsRDD [42247] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42248 [id="node_42248" labelType="html" label="MapPartitionsRDD [42248] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110289 { id="cluster_110289"; isCluster="true"; label="WholeStageCodegen (1)"; 42249 [id="node_42249" labelType="html" label="MapPartitionsRDD [42249] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110297 { id="cluster_110297"; isCluster="true"; label="InMemoryTableScan"; 42250 [id="node_42250" labelType="html" label="MapPartitionsRDD [42250] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42251 [id="node_42251" labelType="html" label="MapPartitionsRDD [42251] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42252 [id="node_42252" labelType="html" label="MapPartitionsRDD [42252] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110294 { id="cluster_110294"; isCluster="true"; label="WholeStageCodegen (2)"; 42253 [id="node_42253" labelType="html" label="MapPartitionsRDD [42253] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110288 { id="cluster_110288"; isCluster="true"; label="Union"; 42254 [id="node_42254" labelType="html" label="UnionRDD [42254] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110264 { id="cluster_110264"; isCluster="true"; label="WholeStageCodegen (5)"; 42255 [id="node_42255" labelType="html" label="MapPartitionsRDD [42255] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110263 { id="cluster_110263"; isCluster="true"; label="InMemoryTableScan"; 42256 [id="node_42256" labelType="html" label="MapPartitionsRDD [42256] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42257 [id="node_42257" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#847141, qty#815747, demandChannel#843772, demandStream#843773, kpis#843807]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#847238, worklistShardItemId#847239L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#843772, demandStream#843773, kpis#843807]\n : : +- *(1) Filter ((NOT isNewlyCalculated#843775 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#843772, demandStream#843773, isNewlyCalculated#843775, kpis#843807, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#843775, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#843772, demandStream#843773... [42257] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42258 [id="node_42258" labelType="html" label="MapPartitionsRDD [42258] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42259 [id="node_42259" labelType="html" label="MapPartitionsRDD [42259] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42260 [id="node_42260" labelType="html" label="MapPartitionsRDD [42260] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110262 { id="cluster_110262"; isCluster="true"; label="CollectLimit"; 42261 [id="node_42261" labelType="html" label="MapPartitionsRDD [42261] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42262 [id="node_42262" labelType="html" label="MapPartitionsRDD [42262] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42070->42071; 42082->42083; 42086->42087; 42083->42088; 42087->42088; 42088->42089; 42089->42090; 42090->42091; 42098->42099; 42071->42100; 42099->42100; 42100->42101; 42091->42102; 42102->42103; 42103->42104; 42104->42105; 42101->42106; 42105->42106; 42106->42107; 42107->42108; 42204->42205; 42205->42206; 42206->42207; 42207->42208; 42108->42246; 42246->42247; 42247->42248; 42248->42249; 42208->42250; 42250->42251; 42251->42252; 42252->42253; 42249->42254; 42253->42254; 42254->42255; 42255->42256; 42256->42257; 42257->42258; 42258->42259; 42259->42260; 42260->42261; 42261->42262; }