digraph G { id="graph_1345725"; subgraph graph_stage_1345725 { id="graph_stage_1345725"; isCluster="true"; label="Stage 1345725"; subgraph cluster_1040280 { id="cluster_1040280"; isCluster="true"; label="Exchange"; 394976 [id="node_394976" labelType="html" label="ShuffledRowRDD [394976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040279 { id="cluster_1040279"; isCluster="true"; label="ObjectHashAggregate"; 394977 [id="node_394977" labelType="html" label="MapPartitionsRDD [394977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040278 { id="cluster_1040278"; isCluster="true"; label="InMemoryTableScan"; 394978 [id="node_394978" labelType="html" label="MapPartitionsRDD [394978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 394979 [id="node_394979" labelType="html" label="ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, orderProposals#5597945])\n+- Exchange hashpartitioning(shardId#5594062, resultSeparationId#5597941L, 30), ENSURE_REQUIREMENTS, [plan_id=2904443]\n +- ObjectHashAggregate(keys=[shardId#5594062, resultSeparationId#5597941L], functions=[partial_collect_list(orderProposal#5596205, 0, 0)], output=[shardId#5594062, resultSeparationId#5597941L, buf#5597981])\n +- Project [shardId#5594062, orderProposal#5596205, CASE WHEN (size(orderProposal#5596205.parentItems, true) > 2000) THEN xxhash64(orderProposal#5596205.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#5596205.orderProposalId as decimal(20,0)), 0), 42) END AS resultSeparationId#5597941L]\n +- InMemoryTableScan [orderProposal#5596205, shardId#5594062]\n +- InMemoryRelation [shardId#5594062, orderProposal#5596205], StorageLevel(disk, memory, 2 rep... [394979] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040863 { id="cluster_1040863"; isCluster="true"; label="InMemoryTableScan"; 395202 [id="node_395202" labelType="html" label="MapPartitionsRDD [395202] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 395203 [id="node_395203" labelType="html" label="MapPartitionsRDD [395203] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; 395204 [id="node_395204" labelType="html" label="MapPartitionsRDD [395204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040862 { id="cluster_1040862"; isCluster="true"; label="Exchange"; 395205 [id="node_395205" labelType="html" label="MapPartitionsRDD [395205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 394976->394977; 394977->394978; 394978->394979; 394979->395202; 395202->395203; 395203->395204; 395204->395205; }