digraph G { id="graph_98057"; subgraph graph_stage_98057 { id="graph_stage_98057"; isCluster="true"; label="Stage 98057"; subgraph cluster_115516 { id="cluster_115516"; isCluster="true"; label="Exchange"; 44474 [id="node_44474" labelType="html" label="ShuffledRowRDD [44474] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115513 { id="cluster_115513"; isCluster="true"; label="WholeStageCodegen (1)"; 44475 [id="node_44475" labelType="html" label="MapPartitionsRDD [44475] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115536 { id="cluster_115536"; isCluster="true"; label="Exchange"; 44486 [id="node_44486" labelType="html" label="ShuffledRowRDD [44486] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115533 { id="cluster_115533"; isCluster="true"; label="WholeStageCodegen (4)"; 44487 [id="node_44487" labelType="html" label="MapPartitionsRDD [44487] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115571 { id="cluster_115571"; isCluster="true"; label="Exchange"; 44490 [id="node_44490" labelType="html" label="ShuffledRowRDD [44490] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115568 { id="cluster_115568"; isCluster="true"; label="WholeStageCodegen (6)"; 44491 [id="node_44491" labelType="html" label="MapPartitionsRDD [44491] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115525 { id="cluster_115525"; isCluster="true"; label="WholeStageCodegen (7)"; 44492 [id="node_44492" labelType="html" label="ZippedPartitionsRDD2 [44492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44493 [id="node_44493" labelType="html" label="MapPartitionsRDD [44493] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115524 { id="cluster_115524"; isCluster="true"; label="InMemoryTableScan"; 44494 [id="node_44494" labelType="html" label="MapPartitionsRDD [44494] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44495 [id="node_44495" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#893880 AS qty#893882, demandChannel#893875, demandStream#893876, cachedKpis#893881 AS kpis#893883]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#893879L, cachedShardId#893878], 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=1391138]\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=1391134]\n : +- *(2) Has... [44495] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115522 { id="cluster_115522"; isCluster="true"; label="Exchange"; 44502 [id="node_44502" labelType="html" label="ShuffledRowRDD [44502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115519 { id="cluster_115519"; isCluster="true"; label="WholeStageCodegen (4)"; 44503 [id="node_44503" labelType="html" label="MapPartitionsRDD [44503] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115505 { id="cluster_115505"; isCluster="true"; label="WholeStageCodegen (5)"; 44504 [id="node_44504" labelType="html" label="ZippedPartitionsRDD2 [44504] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44505 [id="node_44505" labelType="html" label="MapPartitionsRDD [44505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115586 { id="cluster_115586"; isCluster="true"; label="InMemoryTableScan"; 44506 [id="node_44506" labelType="html" label="MapPartitionsRDD [44506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44507 [id="node_44507" labelType="html" label="MapPartitionsRDD [44507] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44508 [id="node_44508" labelType="html" label="MapPartitionsRDD [44508] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115583 { id="cluster_115583"; isCluster="true"; label="WholeStageCodegen (6)"; 44509 [id="node_44509" labelType="html" label="MapPartitionsRDD [44509] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115504 { id="cluster_115504"; isCluster="true"; label="Union"; 44510 [id="node_44510" labelType="html" label="UnionRDD [44510] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115503 { id="cluster_115503"; isCluster="true"; label="InMemoryTableScan"; 44511 [id="node_44511" labelType="html" label="MapPartitionsRDD [44511] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44512 [id="node_44512" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#894115, null AS demandStream#894116, [] AS kpis#894150, true AS isNewlyCalculated#894118]\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#894107, ), isnull(shardId#894107), coalesce(worklistShardItemId#894108L, 0), isnull(worklistShardItemId#894108L), coalesce(version#894109, 0), isnull(version#894109), coalesce(product#894110, ), isnull(product#894110), coalesce(plant#894111, ), isnull(plant#894111), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#893882, 0.0))), isnull(qty#... [44512] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115793 { id="cluster_115793"; isCluster="true"; label="Exchange"; 44608 [id="node_44608" labelType="html" label="ShuffledRowRDD [44608] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115787 { id="cluster_115787"; isCluster="true"; label="WholeStageCodegen (6)"; 44609 [id="node_44609" labelType="html" label="MapPartitionsRDD [44609] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115786 { id="cluster_115786"; isCluster="true"; label="SortAggregate"; 44610 [id="node_44610" labelType="html" label="MapPartitionsRDD [44610] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115785 { id="cluster_115785"; isCluster="true"; label="InMemoryTableScan"; 44611 [id="node_44611" labelType="html" label="MapPartitionsRDD [44611] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44612 [id="node_44612" labelType="html" label="SortAggregate(key=[demandChannel#896651, shardId#815740, qty#896671, worklistShardItemId#815741L, demandStream#896652], functions=[first(kpis#896680, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#896671, demandChannel#896651, demandStream#896652, kpis#896813])\n+- *(6) Sort [demandChannel#896651 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#896671 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#896652 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#896651, shardId#815740, qty#896671, worklistShardItemId#815741L, demandStream#896652, 37), ENSURE_REQUIREMENTS, [plan_id=1392068]\n +- SortAggregate(key=[demandChannel#896651, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#896671)) AS qty#896671, worklistShardItemId#815741L, demandStream#896652], functions=[partial_first(kpis#896680, false)], output=[demandChannel#896651, shardId#815740, qty#896671, worklistShardItemId#815741L, demandStream#896652, first#89688... [44612] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115952 { id="cluster_115952"; isCluster="true"; label="InMemoryTableScan"; 44650 [id="node_44650" labelType="html" label="MapPartitionsRDD [44650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44651 [id="node_44651" labelType="html" label="MapPartitionsRDD [44651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44652 [id="node_44652" labelType="html" label="MapPartitionsRDD [44652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115948 { id="cluster_115948"; isCluster="true"; label="WholeStageCodegen (1)"; 44653 [id="node_44653" labelType="html" label="MapPartitionsRDD [44653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115956 { id="cluster_115956"; isCluster="true"; label="InMemoryTableScan"; 44654 [id="node_44654" labelType="html" label="MapPartitionsRDD [44654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44655 [id="node_44655" labelType="html" label="MapPartitionsRDD [44655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44656 [id="node_44656" labelType="html" label="MapPartitionsRDD [44656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115953 { id="cluster_115953"; isCluster="true"; label="WholeStageCodegen (2)"; 44657 [id="node_44657" labelType="html" label="MapPartitionsRDD [44657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115947 { id="cluster_115947"; isCluster="true"; label="Union"; 44658 [id="node_44658" labelType="html" label="UnionRDD [44658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115923 { id="cluster_115923"; isCluster="true"; label="WholeStageCodegen (5)"; 44659 [id="node_44659" labelType="html" label="MapPartitionsRDD [44659] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115922 { id="cluster_115922"; isCluster="true"; label="InMemoryTableScan"; 44660 [id="node_44660" labelType="html" label="MapPartitionsRDD [44660] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44661 [id="node_44661" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#897484, qty#815747, demandChannel#894115, demandStream#894116, kpis#894150]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#897581, worklistShardItemId#897582L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#894115, demandStream#894116, kpis#894150]\n : : +- *(1) Filter ((NOT isNewlyCalculated#894118 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#894115, demandStream#894116, isNewlyCalculated#894118, kpis#894150, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#894118, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#894115, demandStream#894116... [44661] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115981 { id="cluster_115981"; isCluster="true"; label="InMemoryTableScan"; 44670 [id="node_44670" labelType="html" label="MapPartitionsRDD [44670] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44671 [id="node_44671" labelType="html" label="MapPartitionsRDD [44671] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44672 [id="node_44672" labelType="html" label="MapPartitionsRDD [44672] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44474->44475; 44486->44487; 44490->44491; 44487->44492; 44491->44492; 44492->44493; 44493->44494; 44494->44495; 44502->44503; 44475->44504; 44503->44504; 44504->44505; 44495->44506; 44506->44507; 44507->44508; 44508->44509; 44505->44510; 44509->44510; 44510->44511; 44511->44512; 44608->44609; 44609->44610; 44610->44611; 44611->44612; 44512->44650; 44650->44651; 44651->44652; 44652->44653; 44612->44654; 44654->44655; 44655->44656; 44656->44657; 44653->44658; 44657->44658; 44658->44659; 44659->44660; 44660->44661; 44661->44670; 44670->44671; 44671->44672; }