digraph G { subgraph clusterstage_119936 { label="Stage 119936"; subgraph cluster564887 { label="Exchange"; 203391 [labelType="html" label="ShuffledRowRDD [203391] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564883 { label="WholeStageCodegen (1)"; 203392 [labelType="html" label="MapPartitionsRDD [203392] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564882 { label="MapGroups"; 203393 [labelType="html" label="MapPartitionsRDD [203393] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564879 { label="WholeStageCodegen (2)"; 203394 [labelType="html" label="MapPartitionsRDD [203394] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564888 { label="mapPartitionsInternal"; 203395 [labelType="html" label="MapPartitionsRDD [203395] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564889 { label="mapPartitionsInternal"; 203396 [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#3305739, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3305740L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3305741, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3305742L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@1f2a012d, value#3305733.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3305733], [path#3305723, length#3305724L, isDir#3305725, modificationTime#3305726L], obj#3305738: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203396] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203391->203392; 203392->203393; 203393->203394; 203394->203395; 203395->203396; }