digraph G { subgraph clusterstage_119893 { label="Stage 119893"; subgraph cluster564654 { label="Exchange"; 203290 [labelType="html" label="ShuffledRowRDD [203290] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564650 { label="WholeStageCodegen (1)"; 203291 [labelType="html" label="MapPartitionsRDD [203291] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564649 { label="MapGroups"; 203292 [labelType="html" label="MapPartitionsRDD [203292] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564646 { label="WholeStageCodegen (2)"; 203293 [labelType="html" label="MapPartitionsRDD [203293] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564655 { label="mapPartitionsInternal"; 203294 [labelType="html" label="MapPartitionsRDD [203294] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564656 { label="mapPartitionsInternal"; 203295 [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#3304051, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3304052L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3304053, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3304054L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@17d1857, value#3304045.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3304045], [path#3304035, length#3304036L, isDir#3304037, modificationTime#3304038L], obj#3304050: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203295] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203290->203291; 203291->203292; 203292->203293; 203293->203294; 203294->203295; }