digraph G { id="graph_116354"; subgraph graph_stage_116354 { id="graph_stage_116354"; isCluster="true"; label="Stage 116354"; subgraph cluster_145409 { id="cluster_145409"; isCluster="true"; label="Exchange"; 55935 [id="node_55935" labelType="html" label="ShuffledRowRDD [55935] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145406 { id="cluster_145406"; isCluster="true"; label="WholeStageCodegen (1)"; 55936 [id="node_55936" labelType="html" label="MapPartitionsRDD [55936] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145429 { id="cluster_145429"; isCluster="true"; label="Exchange"; 55947 [id="node_55947" labelType="html" label="ShuffledRowRDD [55947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145426 { id="cluster_145426"; isCluster="true"; label="WholeStageCodegen (4)"; 55948 [id="node_55948" labelType="html" label="MapPartitionsRDD [55948] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145452 { id="cluster_145452"; isCluster="true"; label="Exchange"; 55951 [id="node_55951" labelType="html" label="ShuffledRowRDD [55951] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145449 { id="cluster_145449"; isCluster="true"; label="WholeStageCodegen (6)"; 55952 [id="node_55952" labelType="html" label="MapPartitionsRDD [55952] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145418 { id="cluster_145418"; isCluster="true"; label="WholeStageCodegen (7)"; 55953 [id="node_55953" labelType="html" label="ZippedPartitionsRDD2 [55953] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55954 [id="node_55954" labelType="html" label="MapPartitionsRDD [55954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145417 { id="cluster_145417"; isCluster="true"; label="InMemoryTableScan"; 55955 [id="node_55955" labelType="html" label="MapPartitionsRDD [55955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55956 [id="node_55956" labelType="html" label="*(7) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, cachedQty#1122886 AS qty#1122888, demandChannel#1122881, demandStream#1122882, cachedKpis#1122887 AS kpis#1122889]\n+- *(7) SortMergeJoin [worklistShardItemId#1100458L, shardId#1100457], [cachedWorklistShardItemId#1122885L, cachedShardId#1122884], Inner\n :- *(4) Sort [worklistShardItemId#1100458L ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1100458L, shardId#1100457, 37), ENSURE_REQUIREMENTS, [plan_id=1753792]\n : +- *(3) HashAggregate(keys=[plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460], functions=[], output=[shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461])\n : +- Exchange hashpartitioning(plant#1100461, shardId#1100457, version#1100459, worklistShardItemId#1100458L, product#1100460, 37), ENSURE_REQUIREMENTS, [plan_id=1... [55956] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145415 { id="cluster_145415"; isCluster="true"; label="Exchange"; 55963 [id="node_55963" labelType="html" label="ShuffledRowRDD [55963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145412 { id="cluster_145412"; isCluster="true"; label="WholeStageCodegen (4)"; 55964 [id="node_55964" labelType="html" label="MapPartitionsRDD [55964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145398 { id="cluster_145398"; isCluster="true"; label="WholeStageCodegen (5)"; 55965 [id="node_55965" labelType="html" label="ZippedPartitionsRDD2 [55965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55966 [id="node_55966" labelType="html" label="MapPartitionsRDD [55966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145479 { id="cluster_145479"; isCluster="true"; label="InMemoryTableScan"; 55967 [id="node_55967" labelType="html" label="MapPartitionsRDD [55967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55968 [id="node_55968" labelType="html" label="MapPartitionsRDD [55968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55969 [id="node_55969" labelType="html" label="MapPartitionsRDD [55969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145476 { id="cluster_145476"; isCluster="true"; label="WholeStageCodegen (6)"; 55970 [id="node_55970" labelType="html" label="MapPartitionsRDD [55970] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145397 { id="cluster_145397"; isCluster="true"; label="Union"; 55971 [id="node_55971" labelType="html" label="UnionRDD [55971] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145396 { id="cluster_145396"; isCluster="true"; label="InMemoryTableScan"; 55972 [id="node_55972" labelType="html" label="MapPartitionsRDD [55972] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 55973 [id="node_55973" labelType="html" label="Union\n:- *(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, null AS demandChannel#1123121, null AS demandStream#1123122, [] AS kpis#1123156, true AS isNewlyCalculated#1123124]\n: +- *(5) SortMergeJoin [coalesce(shardId#1100457, ), isnull(shardId#1100457), coalesce(worklistShardItemId#1100458L, 0), isnull(worklistShardItemId#1100458L), coalesce(version#1100459, 0), isnull(version#1100459), coalesce(product#1100460, ), isnull(product#1100460), coalesce(plant#1100461, ), isnull(plant#1100461), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1100464, 0.0))), isnull(qty#1100464)], [coalesce(shardId#1123113, ), isnull(shardId#1123113), coalesce(worklistShardItemId#1123114L, 0), isnull(worklistShardItemId#1123114L), coalesce(version#1123115, 0), isnull(version#1123115), coalesce(product#1123116, ), isnull(product#1123116), coalesce(plant#1123117, ), isnull(plant#1123117), knownfloatingpointnormalized(normalizenanandzero(coalesce... [55973] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145685 { id="cluster_145685"; isCluster="true"; label="Exchange"; 56069 [id="node_56069" labelType="html" label="ShuffledRowRDD [56069] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145680 { id="cluster_145680"; isCluster="true"; label="WholeStageCodegen (6)"; 56070 [id="node_56070" labelType="html" label="MapPartitionsRDD [56070] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145679 { id="cluster_145679"; isCluster="true"; label="SortAggregate"; 56071 [id="node_56071" labelType="html" label="MapPartitionsRDD [56071] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145678 { id="cluster_145678"; isCluster="true"; label="InMemoryTableScan"; 56072 [id="node_56072" labelType="html" label="MapPartitionsRDD [56072] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56073 [id="node_56073" labelType="html" label="SortAggregate(key=[demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[first(kpis#1125686, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1125677, demandChannel#1125657, demandStream#1125658, kpis#1125819])\n+- *(6) Sort [demandChannel#1125657 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1125677 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1125658 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L, demandStream#1125658, 37), ENSURE_REQUIREMENTS, [plan_id=1754722]\n +- SortAggregate(key=[demandChannel#1125657, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1125677)) AS qty#1125677, worklistShardItemId#1100458L, demandStream#1125658], functions=[partial_first(kpis#1125686, false)], output=[demandChannel#1125657, shardId#1100457, qty#1125677, worklistShardItemId#1100458L,... [56073] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145845 { id="cluster_145845"; isCluster="true"; label="InMemoryTableScan"; 56111 [id="node_56111" labelType="html" label="MapPartitionsRDD [56111] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56112 [id="node_56112" labelType="html" label="MapPartitionsRDD [56112] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56113 [id="node_56113" labelType="html" label="MapPartitionsRDD [56113] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145841 { id="cluster_145841"; isCluster="true"; label="WholeStageCodegen (1)"; 56114 [id="node_56114" labelType="html" label="MapPartitionsRDD [56114] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145849 { id="cluster_145849"; isCluster="true"; label="InMemoryTableScan"; 56115 [id="node_56115" labelType="html" label="MapPartitionsRDD [56115] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56116 [id="node_56116" labelType="html" label="MapPartitionsRDD [56116] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56117 [id="node_56117" labelType="html" label="MapPartitionsRDD [56117] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145846 { id="cluster_145846"; isCluster="true"; label="WholeStageCodegen (2)"; 56118 [id="node_56118" labelType="html" label="MapPartitionsRDD [56118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145840 { id="cluster_145840"; isCluster="true"; label="Union"; 56119 [id="node_56119" labelType="html" label="UnionRDD [56119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145816 { id="cluster_145816"; isCluster="true"; label="WholeStageCodegen (5)"; 56120 [id="node_56120" labelType="html" label="MapPartitionsRDD [56120] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145815 { id="cluster_145815"; isCluster="true"; label="InMemoryTableScan"; 56121 [id="node_56121" labelType="html" label="MapPartitionsRDD [56121] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56122 [id="node_56122" labelType="html" label="*(5) Project [shardId#1100457, worklistShardItemId#1100458L, version#1126490, qty#1100464, demandChannel#1123121, demandStream#1123122, kpis#1123156]\n+- *(5) BroadcastHashJoin [shardId#1100457, worklistShardItemId#1100458L], [shardId#1126587, worklistShardItemId#1126588L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#1100457, worklistShardItemId#1100458L, qty#1100464, demandChannel#1123121, demandStream#1123122, kpis#1123156]\n : : +- *(1) Filter ((NOT isNewlyCalculated#1123124 AND isnotnull(shardId#1100457)) AND isnotnull(worklistShardItemId#1100458L))\n : : +- InMemoryTableScan [demandChannel#1123121, demandStream#1123122, isNewlyCalculated#1123124, kpis#1123156, qty#1100464, shardId#1100457, worklistShardItemId#1100458L], [NOT isNewlyCalculated#1123124, isnotnull(shardId#1100457), isnotnull(worklistShardItemId#1100458L)]\n : : +- InMemoryRelation [shardId#1100457, worklistShardItemId#1100458L, version#1100459, product#1100460, plant#1100461, qty#1100464, deman... [56122] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145874 { id="cluster_145874"; isCluster="true"; label="InMemoryTableScan"; 56131 [id="node_56131" labelType="html" label="MapPartitionsRDD [56131] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56132 [id="node_56132" labelType="html" label="MapPartitionsRDD [56132] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56133 [id="node_56133" labelType="html" label="MapPartitionsRDD [56133] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55935->55936; 55947->55948; 55951->55952; 55948->55953; 55952->55953; 55953->55954; 55954->55955; 55955->55956; 55963->55964; 55936->55965; 55964->55965; 55965->55966; 55956->55967; 55967->55968; 55968->55969; 55969->55970; 55966->55971; 55970->55971; 55971->55972; 55972->55973; 56069->56070; 56070->56071; 56071->56072; 56072->56073; 55973->56111; 56111->56112; 56112->56113; 56113->56114; 56073->56115; 56115->56116; 56116->56117; 56117->56118; 56114->56119; 56118->56119; 56119->56120; 56120->56121; 56121->56122; 56122->56131; 56131->56132; 56132->56133; }