digraph G {
id="graph_445921";
subgraph graph_stage_445921 {
id="graph_stage_445921";
isCluster="true";
label="Stage 445921";
subgraph cluster_3149491 {
id="cluster_3149491";
isCluster="true";
label="Exchange";
1242339 [id="node_1242339" labelType="html" label="ShuffledRowRDD [1242339] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149486 {
id="cluster_3149486";
isCluster="true";
label="WholeStageCodegen (5)";
1242340 [id="node_1242340" labelType="html" label="MapPartitionsRDD [1242340] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149485 {
id="cluster_3149485";
isCluster="true";
label="SortAggregate";
1242341 [id="node_1242341" labelType="html" label="MapPartitionsRDD [1242341] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149484 {
id="cluster_3149484";
isCluster="true";
label="InMemoryTableScan";
1242342 [id="node_1242342" labelType="html" label="MapPartitionsRDD [1242342] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242343 [id="node_1242343" labelType="html" label="SortAggregate(key=[demandChannel#21536740, shardId#21517301, qty#21536760, worklistShardItemId#21517302L, demandStream#21536741], functions=[first(kpis#21536769, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21536760, demandChannel#21536740, demandStream#21536741, kpis#21536882])\n+- *(5) Sort [demandChannel#21536740 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21536760 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21536741 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21536740, shardId#21517301, qty#21536760, worklistShardItemId#21517302L, demandStream#21536741, 20), ENSURE_REQUIREMENTS, [plan_id=21352532]\n +- SortAggregate(key=[demandChannel#21536740, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21536760)) AS qty#21536760, worklistShardItemId#21517302L, demandStream#21536741], functions=[partial_first(kpis#21536769, false)], output=[demandChannel#21536740, shardId#21517301, qty#215367... [1242343] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149596 {
id="cluster_3149596";
isCluster="true";
label="InMemoryTableScan";
1242358 [id="node_1242358" labelType="html" label="MapPartitionsRDD [1242358] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242359 [id="node_1242359" labelType="html" label="MapPartitionsRDD [1242359] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242360 [id="node_1242360" labelType="html" label="MapPartitionsRDD [1242360] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149571 {
id="cluster_3149571";
isCluster="true";
label="WholeStageCodegen (3)";
1242361 [id="node_1242361" labelType="html" label="MapPartitionsRDD [1242361] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149570 {
id="cluster_3149570";
isCluster="true";
label="InMemoryTableScan";
1242362 [id="node_1242362" labelType="html" label="MapPartitionsRDD [1242362] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242363 [id="node_1242363" labelType="html" label="*(3) Project [shardId#21517301, worklistShardItemId#21517302L, version#21537231, qty#21536760, demandChannel#21536740, demandStream#21536741, kpis#21536769]\n+- *(3) BroadcastHashJoin [shardId#21517301, worklistShardItemId#21517302L], [shardId#21537236, worklistShardItemId#21537237L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#21517301) AND isnotnull(worklistShardItemId#21517302L))\n : +- InMemoryTableScan [shardId#21517301, worklistShardItemId#21517302L, qty#21536760, demandChannel#21536740, demandStream#21536741, kpis#21536769], [isnotnull(shardId#21517301), isnotnull(worklistShardItemId#21517302L)]\n : +- InMemoryRelation [shardId#21517301, worklistShardItemId#21517302L, qty#21536760, demandChannel#21536740, demandStream#21536741, kpis#21536769], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#21536740, shardId#21517301, qty#21536760, worklistShardItemId#21517302L, demandStream#21536741], functions=[first(kpis#21536769, false)], ou... [1242363] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242364 [id="node_1242364" labelType="html" label="MapPartitionsRDD [1242364] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242365 [id="node_1242365" labelType="html" label="MapPartitionsRDD [1242365] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242366 [id="node_1242366" labelType="html" label="MapPartitionsRDD [1242366] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
subgraph cluster_3149569 {
id="cluster_3149569";
isCluster="true";
label="CollectLimit";
1242367 [id="node_1242367" labelType="html" label="MapPartitionsRDD [1242367] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
1242368 [id="node_1242368" labelType="html" label="MapPartitionsRDD [1242368] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"];
}
}
1242339->1242340;
1242340->1242341;
1242341->1242342;
1242342->1242343;
1242343->1242358;
1242358->1242359;
1242359->1242360;
1242360->1242361;
1242361->1242362;
1242362->1242363;
1242363->1242364;
1242364->1242365;
1242365->1242366;
1242366->1242367;
1242367->1242368;
}
1242338,1242339
1242343
1242363