digraph G {
id="graph_446468";
subgraph graph_stage_446468 {
id="graph_stage_446468";
isCluster="true";
label="Stage 446468";
subgraph cluster_3153377 {
id="cluster_3153377";
isCluster="true";
label="Exchange";
1243929 [id="node_1243929" labelType="html" label="ShuffledRowRDD [1243929] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153372 {
id="cluster_3153372";
isCluster="true";
label="WholeStageCodegen (5)";
1243930 [id="node_1243930" labelType="html" label="MapPartitionsRDD [1243930] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153371 {
id="cluster_3153371";
isCluster="true";
label="SortAggregate";
1243931 [id="node_1243931" labelType="html" label="MapPartitionsRDD [1243931] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153370 {
id="cluster_3153370";
isCluster="true";
label="InMemoryTableScan";
1243932 [id="node_1243932" labelType="html" label="MapPartitionsRDD [1243932] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243933 [id="node_1243933" labelType="html" label="SortAggregate(key=[demandChannel#21564021, shardId#21517301, qty#21564041, worklistShardItemId#21517302L, demandStream#21564022], functions=[first(kpis#21564050, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21564041, demandChannel#21564021, demandStream#21564022, kpis#21564163])\n+- *(5) Sort [demandChannel#21564021 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21564041 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21564022 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21564021, shardId#21517301, qty#21564041, worklistShardItemId#21517302L, demandStream#21564022, 20), ENSURE_REQUIREMENTS, [plan_id=21363224]\n +- SortAggregate(key=[demandChannel#21564021, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21564041)) AS qty#21564041, worklistShardItemId#21517302L, demandStream#21564022], functions=[partial_first(kpis#21564050, false)], output=[demandChannel#21564021, shardId#21517301, qty#215640... [1243933] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153482 {
id="cluster_3153482";
isCluster="true";
label="InMemoryTableScan";
1243948 [id="node_1243948" labelType="html" label="MapPartitionsRDD [1243948] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243949 [id="node_1243949" labelType="html" label="MapPartitionsRDD [1243949] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243950 [id="node_1243950" labelType="html" label="MapPartitionsRDD [1243950] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153457 {
id="cluster_3153457";
isCluster="true";
label="WholeStageCodegen (3)";
1243951 [id="node_1243951" labelType="html" label="MapPartitionsRDD [1243951] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153456 {
id="cluster_3153456";
isCluster="true";
label="InMemoryTableScan";
1243952 [id="node_1243952" labelType="html" label="MapPartitionsRDD [1243952] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243953 [id="node_1243953" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21564512, qty#21564041, demandChannel#21564021, demandStream#21564022, kpis#21564050]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21564517, worklistShardItemId#21564518L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21564041, demandChannel#21564021, demandStream#21564022, kpis#21564050], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21564041, demandChannel#21564021, demandStream#21564022, kpis#21564050], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21564021, shardId#21517301, qty#21564041, worklistShardItemId#21517302L, demandStream#21564022], functions=[first(kpis#21564050, false)], ou... [1243953] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3153500 {
id="cluster_3153500";
isCluster="true";
label="InMemoryTableScan";
1243962 [id="node_1243962" labelType="html" label="MapPartitionsRDD [1243962] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243963 [id="node_1243963" labelType="html" label="MapPartitionsRDD [1243963] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1243964 [id="node_1243964" labelType="html" label="MapPartitionsRDD [1243964] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1243929->1243930;
1243930->1243931;
1243931->1243932;
1243932->1243933;
1243933->1243948;
1243948->1243949;
1243949->1243950;
1243950->1243951;
1243951->1243952;
1243952->1243953;
1243953->1243962;
1243962->1243963;
1243963->1243964;
}
1243928,1243929
1243933
1243953