digraph G { subgraph clusterstage_121097 { label="Stage 121097"; subgraph cluster571178 { label="Exchange"; 206118 [labelType="html" label="ShuffledRowRDD [206118] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster571174 { label="WholeStageCodegen (1)"; 206119 [labelType="html" label="MapPartitionsRDD [206119] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster571173 { label="MapGroups"; 206120 [labelType="html" label="MapPartitionsRDD [206120] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster571170 { label="WholeStageCodegen (2)"; 206121 [labelType="html" label="MapPartitionsRDD [206121] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster571179 { label="mapPartitionsInternal"; 206122 [labelType="html" label="MapPartitionsRDD [206122] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster571180 { label="mapPartitionsInternal"; 206123 [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#3351315, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3351316L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3351317, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3351318L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@3b1a410c, value#3351309.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3351309], [path#3351299, length#3351300L, isDir#3351301, modificationTime#3351302L], obj#3351314: org.apache.spark.sql.delta.SerializableFileStatus\n ... [206123] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 206118->206119; 206119->206120; 206120->206121; 206121->206122; 206122->206123; }