digraph G {
id="graph_27657";
subgraph graph_stage_27657 {
id="graph_stage_27657";
isCluster="true";
label="Stage 27657";
subgraph cluster_204724 {
id="cluster_204724";
isCluster="true";
label="Exchange";
77647 [id="node_77647" labelType="html" label="ShuffledRowRDD [77647] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204719 {
id="cluster_204719";
isCluster="true";
label="WholeStageCodegen (5)";
77648 [id="node_77648" labelType="html" label="MapPartitionsRDD [77648] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204718 {
id="cluster_204718";
isCluster="true";
label="SortAggregate";
77649 [id="node_77649" labelType="html" label="MapPartitionsRDD [77649] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204717 {
id="cluster_204717";
isCluster="true";
label="InMemoryTableScan";
77650 [id="node_77650" labelType="html" label="MapPartitionsRDD [77650] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77651 [id="node_77651" labelType="html" label="SortAggregate(key=[demandChannel#1355833, shardId#1310127, qty#1355853, worklistShardItemId#1310128L, demandStream#1355834], functions=[first(kpis#1355862, false)], output=[shardId#1310127, worklistShardItemId#1310128L, qty#1355853, demandChannel#1355833, demandStream#1355834, kpis#1355975])\n+- *(5) Sort [demandChannel#1355833 ASC NULLS FIRST, shardId#1310127 ASC NULLS FIRST, qty#1355853 ASC NULLS FIRST, worklistShardItemId#1310128L ASC NULLS FIRST, demandStream#1355834 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1355833, shardId#1310127, qty#1355853, worklistShardItemId#1310128L, demandStream#1355834, 30), ENSURE_REQUIREMENTS, [plan_id=2202947]\n +- SortAggregate(key=[demandChannel#1355833, shardId#1310127, knownfloatingpointnormalized(normalizenanandzero(qty#1355853)) AS qty#1355853, worklistShardItemId#1310128L, demandStream#1355834], functions=[partial_first(kpis#1355862, false)], output=[demandChannel#1355833, shardId#1310127, qty#1355853, worklistShardItemId#1310128L,... [77651] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204829 {
id="cluster_204829";
isCluster="true";
label="InMemoryTableScan";
77666 [id="node_77666" labelType="html" label="MapPartitionsRDD [77666] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77667 [id="node_77667" labelType="html" label="MapPartitionsRDD [77667] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77668 [id="node_77668" labelType="html" label="MapPartitionsRDD [77668] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204804 {
id="cluster_204804";
isCluster="true";
label="WholeStageCodegen (3)";
77669 [id="node_77669" labelType="html" label="MapPartitionsRDD [77669] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204803 {
id="cluster_204803";
isCluster="true";
label="InMemoryTableScan";
77670 [id="node_77670" labelType="html" label="MapPartitionsRDD [77670] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77671 [id="node_77671" labelType="html" label="*(3) Project [shardId#1310127, worklistShardItemId#1310128L, version#1356324, qty#1355853, demandChannel#1355833, demandStream#1355834, kpis#1355862]\n+- *(3) BroadcastHashJoin [shardId#1310127, worklistShardItemId#1310128L], [shardId#1356329, worklistShardItemId#1356330L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#1310127) AND isnotnull(worklistShardItemId#1310128L))\n : +- InMemoryTableScan [shardId#1310127, worklistShardItemId#1310128L, qty#1355853, demandChannel#1355833, demandStream#1355834, kpis#1355862], [isnotnull(shardId#1310127), isnotnull(worklistShardItemId#1310128L)]\n : +- InMemoryRelation [shardId#1310127, worklistShardItemId#1310128L, qty#1355853, demandChannel#1355833, demandStream#1355834, kpis#1355862], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#1355833, shardId#1310127, qty#1355853, worklistShardItemId#1310128L, demandStream#1355834], functions=[first(kpis#1355862, false)], output=[shardId#1310127, worklistSh... [77671] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
subgraph cluster_204847 {
id="cluster_204847";
isCluster="true";
label="InMemoryTableScan";
77680 [id="node_77680" labelType="html" label="MapPartitionsRDD [77680] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77681 [id="node_77681" labelType="html" label="MapPartitionsRDD [77681] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
77682 [id="node_77682" labelType="html" label="MapPartitionsRDD [77682] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"];
}
}
77647->77648;
77648->77649;
77649->77650;
77650->77651;
77651->77666;
77666->77667;
77667->77668;
77668->77669;
77669->77670;
77670->77671;
77671->77680;
77680->77681;
77681->77682;
}
77646,77647
77651
77671