digraph G { id="graph_92047"; subgraph graph_stage_92047 { id="graph_stage_92047"; isCluster="true"; label="Stage 92047"; subgraph cluster_110478 { id="cluster_110478"; isCluster="true"; label="Exchange"; 42334 [id="node_42334" labelType="html" label="ShuffledRowRDD [42334] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110475 { id="cluster_110475"; isCluster="true"; label="WholeStageCodegen (1)"; 42335 [id="node_42335" labelType="html" label="MapPartitionsRDD [42335] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110498 { id="cluster_110498"; isCluster="true"; label="Exchange"; 42346 [id="node_42346" labelType="html" label="ShuffledRowRDD [42346] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110495 { id="cluster_110495"; isCluster="true"; label="WholeStageCodegen (4)"; 42347 [id="node_42347" labelType="html" label="MapPartitionsRDD [42347] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110527 { id="cluster_110527"; isCluster="true"; label="Exchange"; 42350 [id="node_42350" labelType="html" label="ShuffledRowRDD [42350] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110524 { id="cluster_110524"; isCluster="true"; label="WholeStageCodegen (6)"; 42351 [id="node_42351" labelType="html" label="MapPartitionsRDD [42351] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110487 { id="cluster_110487"; isCluster="true"; label="WholeStageCodegen (7)"; 42352 [id="node_42352" labelType="html" label="ZippedPartitionsRDD2 [42352] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42353 [id="node_42353" labelType="html" label="MapPartitionsRDD [42353] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110486 { id="cluster_110486"; isCluster="true"; label="InMemoryTableScan"; 42354 [id="node_42354" labelType="html" label="MapPartitionsRDD [42354] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42355 [id="node_42355" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#849095 AS qty#849097, demandChannel#849090, demandStream#849091, cachedKpis#849096 AS kpis#849098]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#849094L, cachedShardId#849093], 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=1378422]\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=1378418]\n : +- *(2) Has... [42355] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110484 { id="cluster_110484"; isCluster="true"; label="Exchange"; 42362 [id="node_42362" labelType="html" label="ShuffledRowRDD [42362] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110481 { id="cluster_110481"; isCluster="true"; label="WholeStageCodegen (4)"; 42363 [id="node_42363" labelType="html" label="MapPartitionsRDD [42363] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110467 { id="cluster_110467"; isCluster="true"; label="WholeStageCodegen (5)"; 42364 [id="node_42364" labelType="html" label="ZippedPartitionsRDD2 [42364] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42365 [id="node_42365" labelType="html" label="MapPartitionsRDD [42365] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110548 { id="cluster_110548"; isCluster="true"; label="InMemoryTableScan"; 42366 [id="node_42366" labelType="html" label="MapPartitionsRDD [42366] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42367 [id="node_42367" labelType="html" label="MapPartitionsRDD [42367] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42368 [id="node_42368" labelType="html" label="MapPartitionsRDD [42368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110545 { id="cluster_110545"; isCluster="true"; label="WholeStageCodegen (6)"; 42369 [id="node_42369" labelType="html" label="MapPartitionsRDD [42369] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110466 { id="cluster_110466"; isCluster="true"; label="Union"; 42370 [id="node_42370" labelType="html" label="UnionRDD [42370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110465 { id="cluster_110465"; isCluster="true"; label="InMemoryTableScan"; 42371 [id="node_42371" labelType="html" label="MapPartitionsRDD [42371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42372 [id="node_42372" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#849330, null AS demandStream#849331, [] AS kpis#849365, true AS isNewlyCalculated#849333]\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#849322, ), isnull(shardId#849322), coalesce(worklistShardItemId#849323L, 0), isnull(worklistShardItemId#849323L), coalesce(version#849324, 0), isnull(version#849324), coalesce(product#849325, ), isnull(product#849325), coalesce(plant#849326, ), isnull(plant#849326), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#849097, 0.0))), isnull(qty#... [42372] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110754 { id="cluster_110754"; isCluster="true"; label="Exchange"; 42468 [id="node_42468" labelType="html" label="ShuffledRowRDD [42468] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110749 { id="cluster_110749"; isCluster="true"; label="WholeStageCodegen (6)"; 42469 [id="node_42469" labelType="html" label="MapPartitionsRDD [42469] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110748 { id="cluster_110748"; isCluster="true"; label="SortAggregate"; 42470 [id="node_42470" labelType="html" label="MapPartitionsRDD [42470] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110747 { id="cluster_110747"; isCluster="true"; label="InMemoryTableScan"; 42471 [id="node_42471" labelType="html" label="MapPartitionsRDD [42471] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42472 [id="node_42472" labelType="html" label="SortAggregate(key=[demandChannel#851866, shardId#815740, qty#851886, worklistShardItemId#815741L, demandStream#851867], functions=[first(kpis#851895, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#851886, demandChannel#851866, demandStream#851867, kpis#852028])\n+- *(6) Sort [demandChannel#851866 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#851886 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#851867 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#851866, shardId#815740, qty#851886, worklistShardItemId#815741L, demandStream#851867, 37), ENSURE_REQUIREMENTS, [plan_id=1379352]\n +- SortAggregate(key=[demandChannel#851866, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#851886)) AS qty#851886, worklistShardItemId#815741L, demandStream#851867], functions=[partial_first(kpis#851895, false)], output=[demandChannel#851866, shardId#815740, qty#851886, worklistShardItemId#815741L, demandStream#851867, first#85210... [42472] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110914 { id="cluster_110914"; isCluster="true"; label="InMemoryTableScan"; 42510 [id="node_42510" labelType="html" label="MapPartitionsRDD [42510] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42511 [id="node_42511" labelType="html" label="MapPartitionsRDD [42511] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42512 [id="node_42512" labelType="html" label="MapPartitionsRDD [42512] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110910 { id="cluster_110910"; isCluster="true"; label="WholeStageCodegen (1)"; 42513 [id="node_42513" labelType="html" label="MapPartitionsRDD [42513] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110918 { id="cluster_110918"; isCluster="true"; label="InMemoryTableScan"; 42514 [id="node_42514" labelType="html" label="MapPartitionsRDD [42514] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42515 [id="node_42515" labelType="html" label="MapPartitionsRDD [42515] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42516 [id="node_42516" labelType="html" label="MapPartitionsRDD [42516] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110915 { id="cluster_110915"; isCluster="true"; label="WholeStageCodegen (2)"; 42517 [id="node_42517" labelType="html" label="MapPartitionsRDD [42517] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110909 { id="cluster_110909"; isCluster="true"; label="Union"; 42518 [id="node_42518" labelType="html" label="UnionRDD [42518] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110885 { id="cluster_110885"; isCluster="true"; label="WholeStageCodegen (5)"; 42519 [id="node_42519" labelType="html" label="MapPartitionsRDD [42519] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110884 { id="cluster_110884"; isCluster="true"; label="InMemoryTableScan"; 42520 [id="node_42520" labelType="html" label="MapPartitionsRDD [42520] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42521 [id="node_42521" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#852699, qty#815747, demandChannel#849330, demandStream#849331, kpis#849365]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#852796, worklistShardItemId#852797L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#849330, demandStream#849331, kpis#849365]\n : : +- *(1) Filter ((NOT isNewlyCalculated#849333 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#849330, demandStream#849331, isNewlyCalculated#849333, kpis#849365, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#849333, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#849330, demandStream#849331... [42521] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42522 [id="node_42522" labelType="html" label="MapPartitionsRDD [42522] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42523 [id="node_42523" labelType="html" label="MapPartitionsRDD [42523] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42524 [id="node_42524" labelType="html" label="MapPartitionsRDD [42524] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110883 { id="cluster_110883"; isCluster="true"; label="CollectLimit"; 42525 [id="node_42525" labelType="html" label="MapPartitionsRDD [42525] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42526 [id="node_42526" labelType="html" label="MapPartitionsRDD [42526] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42334->42335; 42346->42347; 42350->42351; 42347->42352; 42351->42352; 42352->42353; 42353->42354; 42354->42355; 42362->42363; 42335->42364; 42363->42364; 42364->42365; 42355->42366; 42366->42367; 42367->42368; 42368->42369; 42365->42370; 42369->42370; 42370->42371; 42371->42372; 42468->42469; 42469->42470; 42470->42471; 42471->42472; 42372->42510; 42510->42511; 42511->42512; 42512->42513; 42472->42514; 42514->42515; 42515->42516; 42516->42517; 42513->42518; 42517->42518; 42518->42519; 42519->42520; 42520->42521; 42521->42522; 42522->42523; 42523->42524; 42524->42525; 42525->42526; }