digraph G {
id="graph_172688";
subgraph graph_stage_172688 {
id="graph_stage_172688";
isCluster="true";
label="Stage 172688";
subgraph cluster_1239652 {
id="cluster_1239652";
isCluster="true";
label="Exchange";
482187 [id="node_482187" labelType="html" label="ShuffledRowRDD [482187] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239647 {
id="cluster_1239647";
isCluster="true";
label="WholeStageCodegen (5)";
482188 [id="node_482188" labelType="html" label="MapPartitionsRDD [482188] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239646 {
id="cluster_1239646";
isCluster="true";
label="SortAggregate";
482189 [id="node_482189" labelType="html" label="MapPartitionsRDD [482189] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239645 {
id="cluster_1239645";
isCluster="true";
label="InMemoryTableScan";
482190 [id="node_482190" labelType="html" label="MapPartitionsRDD [482190] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482191 [id="node_482191" labelType="html" label="SortAggregate(key=[demandChannel#8535533, shardId#7905118, qty#8535553, worklistShardItemId#7905119L, demandStream#8535534], functions=[first(kpis#8535562, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8535553, demandChannel#8535533, demandStream#8535534, kpis#8535675])\n+- *(5) Sort [demandChannel#8535533 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8535553 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8535534 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8535533, shardId#7905118, qty#8535553, worklistShardItemId#7905119L, demandStream#8535534, 30), ENSURE_REQUIREMENTS, [plan_id=11181278]\n +- SortAggregate(key=[demandChannel#8535533, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8535553)) AS qty#8535553, worklistShardItemId#7905119L, demandStream#8535534], functions=[partial_first(kpis#8535562, false)], output=[demandChannel#8535533, shardId#7905118, qty#8535553, worklistShardItemId#7905119L... [482191] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239757 {
id="cluster_1239757";
isCluster="true";
label="InMemoryTableScan";
482206 [id="node_482206" labelType="html" label="MapPartitionsRDD [482206] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482207 [id="node_482207" labelType="html" label="MapPartitionsRDD [482207] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482208 [id="node_482208" labelType="html" label="MapPartitionsRDD [482208] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239732 {
id="cluster_1239732";
isCluster="true";
label="WholeStageCodegen (3)";
482209 [id="node_482209" labelType="html" label="MapPartitionsRDD [482209] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239731 {
id="cluster_1239731";
isCluster="true";
label="InMemoryTableScan";
482210 [id="node_482210" labelType="html" label="MapPartitionsRDD [482210] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482211 [id="node_482211" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8536024, qty#8535553, demandChannel#8535533, demandStream#8535534, kpis#8535562]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8536029, worklistShardItemId#8536030L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8535553, demandChannel#8535533, demandStream#8535534, kpis#8535562], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8535553, demandChannel#8535533, demandStream#8535534, kpis#8535562], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8535533, shardId#7905118, qty#8535553, worklistShardItemId#7905119L, demandStream#8535534], functions=[first(kpis#8535562, false)], output=[shardId#7905118, worklistSh... [482211] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_1239775 {
id="cluster_1239775";
isCluster="true";
label="InMemoryTableScan";
482220 [id="node_482220" labelType="html" label="MapPartitionsRDD [482220] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482221 [id="node_482221" labelType="html" label="MapPartitionsRDD [482221] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
482222 [id="node_482222" labelType="html" label="MapPartitionsRDD [482222] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
482187->482188;
482188->482189;
482189->482190;
482190->482191;
482191->482206;
482206->482207;
482207->482208;
482208->482209;
482209->482210;
482210->482211;
482211->482220;
482220->482221;
482221->482222;
}
482186,482187
482191
482211