digraph G { id="graph_340411"; subgraph graph_stage_340411 { id="graph_stage_340411"; isCluster="true"; label="Stage 340411"; subgraph cluster_383126 { id="cluster_383126"; isCluster="true"; label="Exchange"; 153208 [id="node_153208" labelType="html" label="ShuffledRowRDD [153208] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383125 { id="cluster_383125"; isCluster="true"; label="ObjectHashAggregate"; 153209 [id="node_153209" labelType="html" label="MapPartitionsRDD [153209] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383124 { id="cluster_383124"; isCluster="true"; label="InMemoryTableScan"; 153210 [id="node_153210" labelType="html" label="MapPartitionsRDD [153210] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153211 [id="node_153211" labelType="html" label="ObjectHashAggregate(keys=[shardId#3579691, resultSeparationId#3595113L], functions=[collect_list(orderProposal#3588007, 0, 0)], output=[shardId#3579691, resultSeparationId#3595113L, orderProposals#3595117])\n+- Exchange hashpartitioning(shardId#3579691, resultSeparationId#3595113L, 30), ENSURE_REQUIREMENTS, [plan_id=1030266]\n +- ObjectHashAggregate(keys=[shardId#3579691, resultSeparationId#3595113L], functions=[partial_collect_list(orderProposal#3588007, 0, 0)], output=[shardId#3579691, resultSeparationId#3595113L, buf#3595153])\n +- Project [shardId#3579691, orderProposal#3588007, CASE WHEN (size(orderProposal#3588007.parentItems, true) > 2000) THEN xxhash64(orderProposal#3588007.orderProposalId, 42) ELSE xxhash64(pmod(cast(orderProposal#3588007.orderProposalId as decimal(20,0)), 44), 42) END AS resultSeparationId#3595113L]\n +- InMemoryTableScan [orderProposal#3588007, shardId#3579691]\n +- InMemoryRelation [shardId#3579691, orderProposal#3588007], StorageLevel(disk, memory, 2 re... [153211] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385242 { id="cluster_385242"; isCluster="true"; label="InMemoryTableScan"; 153998 [id="node_153998" labelType="html" label="MapPartitionsRDD [153998] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153999 [id="node_153999" labelType="html" label="MapPartitionsRDD [153999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 154000 [id="node_154000" labelType="html" label="MapPartitionsRDD [154000] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_385241 { id="cluster_385241"; isCluster="true"; label="Exchange"; 154004 [id="node_154004" labelType="html" label="MapPartitionsRDD [154004] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153208->153209; 153209->153210; 153210->153211; 153211->153998; 153998->153999; 153999->154000; 154000->154004; }