digraph G { id="graph_96561"; subgraph graph_stage_96561 { id="graph_stage_96561"; isCluster="true"; label="Stage 96561"; subgraph cluster_114274 { id="cluster_114274"; isCluster="true"; label="Exchange"; 43946 [id="node_43946" labelType="html" label="ShuffledRowRDD [43946] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114271 { id="cluster_114271"; isCluster="true"; label="WholeStageCodegen (1)"; 43947 [id="node_43947" labelType="html" label="MapPartitionsRDD [43947] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114294 { id="cluster_114294"; isCluster="true"; label="Exchange"; 43958 [id="node_43958" labelType="html" label="ShuffledRowRDD [43958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114291 { id="cluster_114291"; isCluster="true"; label="WholeStageCodegen (4)"; 43959 [id="node_43959" labelType="html" label="MapPartitionsRDD [43959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114329 { id="cluster_114329"; isCluster="true"; label="Exchange"; 43962 [id="node_43962" labelType="html" label="ShuffledRowRDD [43962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114326 { id="cluster_114326"; isCluster="true"; label="WholeStageCodegen (6)"; 43963 [id="node_43963" labelType="html" label="MapPartitionsRDD [43963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114283 { id="cluster_114283"; isCluster="true"; label="WholeStageCodegen (7)"; 43964 [id="node_43964" labelType="html" label="ZippedPartitionsRDD2 [43964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43965 [id="node_43965" labelType="html" label="MapPartitionsRDD [43965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114282 { id="cluster_114282"; isCluster="true"; label="InMemoryTableScan"; 43966 [id="node_43966" labelType="html" label="MapPartitionsRDD [43966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43967 [id="node_43967" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#882764 AS qty#882766, demandChannel#882759, demandStream#882760, cachedKpis#882765 AS kpis#882767]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#882763L, cachedShardId#882762], 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=1388014]\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=1388010]\n : +- *(2) Has... [43967] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114280 { id="cluster_114280"; isCluster="true"; label="Exchange"; 43974 [id="node_43974" labelType="html" label="ShuffledRowRDD [43974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114277 { id="cluster_114277"; isCluster="true"; label="WholeStageCodegen (4)"; 43975 [id="node_43975" labelType="html" label="MapPartitionsRDD [43975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114263 { id="cluster_114263"; isCluster="true"; label="WholeStageCodegen (5)"; 43976 [id="node_43976" labelType="html" label="ZippedPartitionsRDD2 [43976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43977 [id="node_43977" labelType="html" label="MapPartitionsRDD [43977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114344 { id="cluster_114344"; isCluster="true"; label="InMemoryTableScan"; 43978 [id="node_43978" labelType="html" label="MapPartitionsRDD [43978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43979 [id="node_43979" labelType="html" label="MapPartitionsRDD [43979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43980 [id="node_43980" labelType="html" label="MapPartitionsRDD [43980] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114341 { id="cluster_114341"; isCluster="true"; label="WholeStageCodegen (6)"; 43981 [id="node_43981" labelType="html" label="MapPartitionsRDD [43981] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114262 { id="cluster_114262"; isCluster="true"; label="Union"; 43982 [id="node_43982" labelType="html" label="UnionRDD [43982] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114261 { id="cluster_114261"; isCluster="true"; label="InMemoryTableScan"; 43983 [id="node_43983" labelType="html" label="MapPartitionsRDD [43983] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43984 [id="node_43984" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#882999, null AS demandStream#883000, [] AS kpis#883034, true AS isNewlyCalculated#883002]\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#882991, ), isnull(shardId#882991), coalesce(worklistShardItemId#882992L, 0), isnull(worklistShardItemId#882992L), coalesce(version#882993, 0), isnull(version#882993), coalesce(product#882994, ), isnull(product#882994), coalesce(plant#882995, ), isnull(plant#882995), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#882766, 0.0))), isnull(qty#... [43984] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114550 { id="cluster_114550"; isCluster="true"; label="Exchange"; 44080 [id="node_44080" labelType="html" label="ShuffledRowRDD [44080] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114545 { id="cluster_114545"; isCluster="true"; label="WholeStageCodegen (6)"; 44081 [id="node_44081" labelType="html" label="MapPartitionsRDD [44081] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114544 { id="cluster_114544"; isCluster="true"; label="SortAggregate"; 44082 [id="node_44082" labelType="html" label="MapPartitionsRDD [44082] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114543 { id="cluster_114543"; isCluster="true"; label="InMemoryTableScan"; 44083 [id="node_44083" labelType="html" label="MapPartitionsRDD [44083] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44084 [id="node_44084" labelType="html" label="SortAggregate(key=[demandChannel#885535, shardId#815740, qty#885555, worklistShardItemId#815741L, demandStream#885536], functions=[first(kpis#885564, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#885555, demandChannel#885535, demandStream#885536, kpis#885697])\n+- *(6) Sort [demandChannel#885535 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#885555 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#885536 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#885535, shardId#815740, qty#885555, worklistShardItemId#815741L, demandStream#885536, 37), ENSURE_REQUIREMENTS, [plan_id=1388944]\n +- SortAggregate(key=[demandChannel#885535, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#885555)) AS qty#885555, worklistShardItemId#815741L, demandStream#885536], functions=[partial_first(kpis#885564, false)], output=[demandChannel#885535, shardId#815740, qty#885555, worklistShardItemId#815741L, demandStream#885536, first#88577... [44084] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114710 { id="cluster_114710"; isCluster="true"; label="InMemoryTableScan"; 44122 [id="node_44122" labelType="html" label="MapPartitionsRDD [44122] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44123 [id="node_44123" labelType="html" label="MapPartitionsRDD [44123] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44124 [id="node_44124" labelType="html" label="MapPartitionsRDD [44124] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114706 { id="cluster_114706"; isCluster="true"; label="WholeStageCodegen (1)"; 44125 [id="node_44125" labelType="html" label="MapPartitionsRDD [44125] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114714 { id="cluster_114714"; isCluster="true"; label="InMemoryTableScan"; 44126 [id="node_44126" labelType="html" label="MapPartitionsRDD [44126] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44127 [id="node_44127" labelType="html" label="MapPartitionsRDD [44127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44128 [id="node_44128" labelType="html" label="MapPartitionsRDD [44128] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114711 { id="cluster_114711"; isCluster="true"; label="WholeStageCodegen (2)"; 44129 [id="node_44129" labelType="html" label="MapPartitionsRDD [44129] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114705 { id="cluster_114705"; isCluster="true"; label="Union"; 44130 [id="node_44130" labelType="html" label="UnionRDD [44130] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114681 { id="cluster_114681"; isCluster="true"; label="WholeStageCodegen (5)"; 44131 [id="node_44131" labelType="html" label="MapPartitionsRDD [44131] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114680 { id="cluster_114680"; isCluster="true"; label="InMemoryTableScan"; 44132 [id="node_44132" labelType="html" label="MapPartitionsRDD [44132] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44133 [id="node_44133" labelType="html" label="*(5) Project [shardId#815740, worklistShardItemId#815741L, version#886368, qty#815747, demandChannel#882999, demandStream#883000, kpis#883034]\n+- *(5) BroadcastHashJoin [shardId#815740, worklistShardItemId#815741L], [shardId#886465, worklistShardItemId#886466L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#815740, worklistShardItemId#815741L, qty#815747, demandChannel#882999, demandStream#883000, kpis#883034]\n : : +- *(1) Filter ((NOT isNewlyCalculated#883002 AND isnotnull(shardId#815740)) AND isnotnull(worklistShardItemId#815741L))\n : : +- InMemoryTableScan [demandChannel#882999, demandStream#883000, isNewlyCalculated#883002, kpis#883034, qty#815747, shardId#815740, worklistShardItemId#815741L], [NOT isNewlyCalculated#883002, isnotnull(shardId#815740), isnotnull(worklistShardItemId#815741L)]\n : : +- InMemoryRelation [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, demandChannel#882999, demandStream#883000... [44133] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44134 [id="node_44134" labelType="html" label="MapPartitionsRDD [44134] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44135 [id="node_44135" labelType="html" label="MapPartitionsRDD [44135] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44136 [id="node_44136" labelType="html" label="MapPartitionsRDD [44136] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_114679 { id="cluster_114679"; isCluster="true"; label="CollectLimit"; 44137 [id="node_44137" labelType="html" label="MapPartitionsRDD [44137] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44138 [id="node_44138" labelType="html" label="MapPartitionsRDD [44138] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43946->43947; 43958->43959; 43962->43963; 43959->43964; 43963->43964; 43964->43965; 43965->43966; 43966->43967; 43974->43975; 43947->43976; 43975->43976; 43976->43977; 43967->43978; 43978->43979; 43979->43980; 43980->43981; 43977->43982; 43981->43982; 43982->43983; 43983->43984; 44080->44081; 44081->44082; 44082->44083; 44083->44084; 43984->44122; 44122->44123; 44123->44124; 44124->44125; 44084->44126; 44126->44127; 44127->44128; 44128->44129; 44125->44130; 44129->44130; 44130->44131; 44131->44132; 44132->44133; 44133->44134; 44134->44135; 44135->44136; 44136->44137; 44137->44138; }