digraph G { subgraph clusterstage_121699 { label="Stage 121699"; subgraph cluster574440 { label="Exchange"; 207532 [labelType="html" label="ShuffledRowRDD [207532] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574436 { label="WholeStageCodegen (1)"; 207533 [labelType="html" label="MapPartitionsRDD [207533] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574435 { label="MapGroups"; 207534 [labelType="html" label="MapPartitionsRDD [207534] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574432 { label="WholeStageCodegen (2)"; 207535 [labelType="html" label="MapPartitionsRDD [207535] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574441 { label="mapPartitionsInternal"; 207536 [labelType="html" label="MapPartitionsRDD [207536] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574442 { label="mapPartitionsInternal"; 207537 [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#3374947, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3374948L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3374949, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3374950L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@1d32138d, value#3374941.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3374941], [path#3374931, length#3374932L, isDir#3374933, modificationTime#3374934L], obj#3374946: org.apache.spark.sql.delta.SerializableFileStatus\n ... [207537] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 207532->207533; 207533->207534; 207534->207535; 207535->207536; 207536->207537; }