digraph G { subgraph clusterstage_121269 { label="Stage 121269"; subgraph cluster572110 { label="Exchange"; 206522 [labelType="html" label="ShuffledRowRDD [206522] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572106 { label="WholeStageCodegen (1)"; 206523 [labelType="html" label="MapPartitionsRDD [206523] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572105 { label="MapGroups"; 206524 [labelType="html" label="MapPartitionsRDD [206524] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572102 { label="WholeStageCodegen (2)"; 206525 [labelType="html" label="MapPartitionsRDD [206525] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572111 { label="mapPartitionsInternal"; 206526 [labelType="html" label="MapPartitionsRDD [206526] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572112 { label="mapPartitionsInternal"; 206527 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).path, true, false, true) AS path#3358067, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3358068L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3358069, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3358070L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@5b9b60f5, value#3358061.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3358061], [path#3358051, length#3358052L, isDir#3358053, modificationTime#3358054L], obj#3358066: org.apache.spark.sql.delta.SerializableFileStatus\n ... [206527] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 206522->206523; 206523->206524; 206524->206525; 206525->206526; 206526->206527; }