digraph G { subgraph clusterstage_118474 { label="Stage 118474"; subgraph cluster556965 { label="Exchange"; 199957 [labelType="html" label="ShuffledRowRDD [199957] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster556961 { label="WholeStageCodegen (1)"; 199958 [labelType="html" label="MapPartitionsRDD [199958] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster556960 { label="MapGroups"; 199959 [labelType="html" label="MapPartitionsRDD [199959] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster556957 { label="WholeStageCodegen (2)"; 199960 [labelType="html" label="MapPartitionsRDD [199960] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster556966 { label="mapPartitionsInternal"; 199961 [labelType="html" label="MapPartitionsRDD [199961] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster556967 { label="mapPartitionsInternal"; 199962 [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#3248347, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3248348L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3248349, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3248350L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@3638f1a2, value#3248341.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3248341], [path#3248331, length#3248332L, isDir#3248333, modificationTime#3248334L], obj#3248346: org.apache.spark.sql.delta.SerializableFileStatus\n ... [199962] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 199957->199958; 199958->199959; 199959->199960; 199960->199961; 199961->199962; }