digraph G { id="graph_116040"; subgraph graph_stage_116040 { id="graph_stage_116040"; isCluster="true"; label="Stage 116040"; 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_145700 { id="cluster_145700"; isCluster="true"; label="InMemoryTableScan"; 56039 [id="node_56039" labelType="html" label="MapPartitionsRDD [56039] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56040 [id="node_56040" labelType="html" label="MapPartitionsRDD [56040] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56041 [id="node_56041" labelType="html" label="MapPartitionsRDD [56041] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145695 { id="cluster_145695"; isCluster="true"; label="WholeStageCodegen (3)"; 56042 [id="node_56042" labelType="html" label="MapPartitionsRDD [56042] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145694 { id="cluster_145694"; isCluster="true"; label="Exchange"; 56043 [id="node_56043" labelType="html" label="MapPartitionsRDD [56043] [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; 55973->56039; 56039->56040; 56040->56041; 56041->56042; 56042->56043; }