digraph G { id="graph_111963"; subgraph graph_stage_111963 { id="graph_stage_111963"; isCluster="true"; label="Stage 111963"; subgraph cluster_138516 { id="cluster_138516"; isCluster="true"; label="Exchange"; 53208 [id="node_53208" labelType="html" label="ShuffledRowRDD [53208] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138513 { id="cluster_138513"; isCluster="true"; label="WholeStageCodegen (1)"; 53209 [id="node_53209" labelType="html" label="MapPartitionsRDD [53209] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138536 { id="cluster_138536"; isCluster="true"; label="Exchange"; 53220 [id="node_53220" labelType="html" label="ShuffledRowRDD [53220] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138533 { id="cluster_138533"; isCluster="true"; label="WholeStageCodegen (4)"; 53221 [id="node_53221" labelType="html" label="MapPartitionsRDD [53221] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138565 { id="cluster_138565"; isCluster="true"; label="Exchange"; 53224 [id="node_53224" labelType="html" label="ShuffledRowRDD [53224] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138562 { id="cluster_138562"; isCluster="true"; label="WholeStageCodegen (6)"; 53225 [id="node_53225" labelType="html" label="MapPartitionsRDD [53225] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138525 { id="cluster_138525"; isCluster="true"; label="WholeStageCodegen (7)"; 53226 [id="node_53226" labelType="html" label="ZippedPartitionsRDD2 [53226] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53227 [id="node_53227" labelType="html" label="MapPartitionsRDD [53227] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138524 { id="cluster_138524"; isCluster="true"; label="InMemoryTableScan"; 53228 [id="node_53228" labelType="html" label="MapPartitionsRDD [53228] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53229 [id="node_53229" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1067092 AS qty#1067094, demandChannel#1067087, demandStream#1067088, cachedKpis#1067093 AS kpis#1067095]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1067091L, cachedShardId#1067090], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1689442]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [53229] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138522 { id="cluster_138522"; isCluster="true"; label="Exchange"; 53236 [id="node_53236" labelType="html" label="ShuffledRowRDD [53236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138519 { id="cluster_138519"; isCluster="true"; label="WholeStageCodegen (4)"; 53237 [id="node_53237" labelType="html" label="MapPartitionsRDD [53237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138505 { id="cluster_138505"; isCluster="true"; label="WholeStageCodegen (5)"; 53238 [id="node_53238" labelType="html" label="ZippedPartitionsRDD2 [53238] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53239 [id="node_53239" labelType="html" label="MapPartitionsRDD [53239] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138586 { id="cluster_138586"; isCluster="true"; label="InMemoryTableScan"; 53240 [id="node_53240" labelType="html" label="MapPartitionsRDD [53240] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53241 [id="node_53241" labelType="html" label="MapPartitionsRDD [53241] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53242 [id="node_53242" labelType="html" label="MapPartitionsRDD [53242] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138583 { id="cluster_138583"; isCluster="true"; label="WholeStageCodegen (6)"; 53243 [id="node_53243" labelType="html" label="MapPartitionsRDD [53243] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138504 { id="cluster_138504"; isCluster="true"; label="Union"; 53244 [id="node_53244" labelType="html" label="UnionRDD [53244] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138503 { id="cluster_138503"; isCluster="true"; label="InMemoryTableScan"; 53245 [id="node_53245" labelType="html" label="MapPartitionsRDD [53245] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53246 [id="node_53246" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1067327, null AS demandStream#1067328, [] AS kpis#1067362, true AS isNewlyCalculated#1067330]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1067319, ), isnull(shardId#1067319), coalesce(worklistShardItemId#1067320L, 0), isnull(worklistShardItemId#1067320L), coalesce(version#1067321, 0), isnull(version#1067321), coalesce(product#1067322, ), isnull(product#1067322), coalesce(plant#1067323, ), isnull(plant#1067323), knownfloatingpointnormalized(normalizenanandzero(coalesce... [53246] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138792 { id="cluster_138792"; isCluster="true"; label="Exchange"; 53342 [id="node_53342" labelType="html" label="ShuffledRowRDD [53342] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138787 { id="cluster_138787"; isCluster="true"; label="WholeStageCodegen (6)"; 53343 [id="node_53343" labelType="html" label="MapPartitionsRDD [53343] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138786 { id="cluster_138786"; isCluster="true"; label="SortAggregate"; 53344 [id="node_53344" labelType="html" label="MapPartitionsRDD [53344] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138785 { id="cluster_138785"; isCluster="true"; label="InMemoryTableScan"; 53345 [id="node_53345" labelType="html" label="MapPartitionsRDD [53345] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53346 [id="node_53346" labelType="html" label="SortAggregate(key=[demandChannel#1069863, shardId#1011815, qty#1069883, worklistShardItemId#1011816L, demandStream#1069864], functions=[first(kpis#1069892, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1069883, demandChannel#1069863, demandStream#1069864, kpis#1070025])\n+- *(6) Sort [demandChannel#1069863 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1069883 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1069864 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1069863, shardId#1011815, qty#1069883, worklistShardItemId#1011816L, demandStream#1069864, 37), ENSURE_REQUIREMENTS, [plan_id=1690372]\n +- SortAggregate(key=[demandChannel#1069863, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1069883)) AS qty#1069883, worklistShardItemId#1011816L, demandStream#1069864], functions=[partial_first(kpis#1069892, false)], output=[demandChannel#1069863, shardId#1011815, qty#1069883, worklistShardItemId#1011816L,... [53346] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138952 { id="cluster_138952"; isCluster="true"; label="InMemoryTableScan"; 53384 [id="node_53384" labelType="html" label="MapPartitionsRDD [53384] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53385 [id="node_53385" labelType="html" label="MapPartitionsRDD [53385] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53386 [id="node_53386" labelType="html" label="MapPartitionsRDD [53386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138948 { id="cluster_138948"; isCluster="true"; label="WholeStageCodegen (1)"; 53387 [id="node_53387" labelType="html" label="MapPartitionsRDD [53387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138956 { id="cluster_138956"; isCluster="true"; label="InMemoryTableScan"; 53388 [id="node_53388" labelType="html" label="MapPartitionsRDD [53388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53389 [id="node_53389" labelType="html" label="MapPartitionsRDD [53389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53390 [id="node_53390" labelType="html" label="MapPartitionsRDD [53390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138953 { id="cluster_138953"; isCluster="true"; label="WholeStageCodegen (2)"; 53391 [id="node_53391" labelType="html" label="MapPartitionsRDD [53391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138947 { id="cluster_138947"; isCluster="true"; label="Union"; 53392 [id="node_53392" labelType="html" label="UnionRDD [53392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138923 { id="cluster_138923"; isCluster="true"; label="WholeStageCodegen (5)"; 53393 [id="node_53393" labelType="html" label="MapPartitionsRDD [53393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138922 { id="cluster_138922"; isCluster="true"; label="InMemoryTableScan"; 53394 [id="node_53394" labelType="html" label="MapPartitionsRDD [53394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53395 [id="node_53395" labelType="html" label="*(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1070696, qty#1011822, demandChannel#1067327, demandStream#1067328, kpis#1067362]\n+- *(5) BroadcastHashJoin [shardId#1011815, worklistShardItemId#1011816L], [shardId#1070793, worklistShardItemId#1070794L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1011815, worklistShardItemId#1011816L, qty#1011822, demandChannel#1067327, demandStream#1067328, kpis#1067362]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1067330 AND isnotnull(shardId#1011815)) AND isnotnull(worklistShardItemId#1011816L))\n : : +- InMemoryTableScan [demandChannel#1067327, demandStream#1067328, isNewlyCalculated#1067330, kpis#1067362, qty#1011822, shardId#1011815, worklistShardItemId#1011816L], [NOT isNewlyCalculated#1067330, isnotnull(shardId#1011815), isnotnull(worklistShardItemId#1011816L)]\n : : +- InMemoryRelation [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, deman... [53395] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_138981 { id="cluster_138981"; isCluster="true"; label="InMemoryTableScan"; 53404 [id="node_53404" labelType="html" label="MapPartitionsRDD [53404] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53405 [id="node_53405" labelType="html" label="MapPartitionsRDD [53405] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 53406 [id="node_53406" labelType="html" label="MapPartitionsRDD [53406] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53208->53209; 53220->53221; 53224->53225; 53221->53226; 53225->53226; 53226->53227; 53227->53228; 53228->53229; 53236->53237; 53209->53238; 53237->53238; 53238->53239; 53229->53240; 53240->53241; 53241->53242; 53242->53243; 53239->53244; 53243->53244; 53244->53245; 53245->53246; 53342->53343; 53343->53344; 53344->53345; 53345->53346; 53246->53384; 53384->53385; 53385->53386; 53386->53387; 53346->53388; 53388->53389; 53389->53390; 53390->53391; 53387->53392; 53391->53392; 53392->53393; 53393->53394; 53394->53395; 53395->53404; 53404->53405; 53405->53406; }