digraph G { subgraph clusterstage_120495 { label="Stage 120495"; subgraph cluster567916 { label="Exchange"; 204704 [labelType="html" label="ShuffledRowRDD [204704] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567912 { label="WholeStageCodegen (1)"; 204705 [labelType="html" label="MapPartitionsRDD [204705] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567911 { label="MapGroups"; 204706 [labelType="html" label="MapPartitionsRDD [204706] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567908 { label="WholeStageCodegen (2)"; 204707 [labelType="html" label="MapPartitionsRDD [204707] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567917 { label="mapPartitionsInternal"; 204708 [labelType="html" label="MapPartitionsRDD [204708] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567918 { label="mapPartitionsInternal"; 204709 [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#3327683, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3327684L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3327685, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3327686L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@273e3083, value#3327677.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3327677], [path#3327667, length#3327668L, isDir#3327669, modificationTime#3327670L], obj#3327682: org.apache.spark.sql.delta.SerializableFileStatus\n ... [204709] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 204704->204705; 204705->204706; 204706->204707; 204707->204708; 204708->204709; }