digraph G { subgraph clusterstage_120194 { label="Stage 120194"; subgraph cluster566285 { label="Exchange"; 203997 [labelType="html" label="ShuffledRowRDD [203997] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster566281 { label="WholeStageCodegen (1)"; 203998 [labelType="html" label="MapPartitionsRDD [203998] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster566280 { label="MapGroups"; 203999 [labelType="html" label="MapPartitionsRDD [203999] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster566277 { label="WholeStageCodegen (2)"; 204000 [labelType="html" label="MapPartitionsRDD [204000] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster566286 { label="mapPartitionsInternal"; 204001 [labelType="html" label="MapPartitionsRDD [204001] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster566287 { label="mapPartitionsInternal"; 204002 [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#3315867, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3315868L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3315869, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3315870L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@17178158, value#3315861.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3315861], [path#3315851, length#3315852L, isDir#3315853, modificationTime#3315854L], obj#3315866: org.apache.spark.sql.delta.SerializableFileStatus\n ... [204002] [Cached] [Unordered]<br>$anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203997->203998; 203998->203999; 203999->204000; 204000->204001; 204001->204002; }