digraph G { subgraph clusterstage_119850 { label="Stage 119850"; subgraph cluster564421 { label="Exchange"; 203189 [labelType="html" label="ShuffledRowRDD [203189] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564417 { label="WholeStageCodegen (1)"; 203190 [labelType="html" label="MapPartitionsRDD [203190] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564416 { label="MapGroups"; 203191 [labelType="html" label="MapPartitionsRDD [203191] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564413 { label="WholeStageCodegen (2)"; 203192 [labelType="html" label="MapPartitionsRDD [203192] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564422 { label="mapPartitionsInternal"; 203193 [labelType="html" label="MapPartitionsRDD [203193] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564423 { label="mapPartitionsInternal"; 203194 [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#3302363, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3302364L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3302365, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3302366L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@228fd498, value#3302357.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3302357], [path#3302347, length#3302348L, isDir#3302349, modificationTime#3302350L], obj#3302362: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203194] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203189->203190; 203190->203191; 203191->203192; 203192->203193; 203193->203194; }