digraph G { subgraph clusterstage_120710 { label="Stage 120710"; subgraph cluster569081 { label="Exchange"; 205209 [labelType="html" label="ShuffledRowRDD [205209] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster569077 { label="WholeStageCodegen (1)"; 205210 [labelType="html" label="MapPartitionsRDD [205210] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster569076 { label="MapGroups"; 205211 [labelType="html" label="MapPartitionsRDD [205211] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster569073 { label="WholeStageCodegen (2)"; 205212 [labelType="html" label="MapPartitionsRDD [205212] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster569082 { label="mapPartitionsInternal"; 205213 [labelType="html" label="MapPartitionsRDD [205213] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster569083 { label="mapPartitionsInternal"; 205214 [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#3336123, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3336124L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3336125, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3336126L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@1e84960b, value#3336117.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3336117], [path#3336107, length#3336108L, isDir#3336109, modificationTime#3336110L], obj#3336122: org.apache.spark.sql.delta.SerializableFileStatus\n ... [205214] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 205209->205210; 205210->205211; 205211->205212; 205212->205213; 205213->205214; }