Missed ExecutedWriteSummary

snmvaughan · May 7, 2024 · 6ffa0a3 · 6ffa0a3
1 parent 4ddc486
commit 6ffa0a3
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala b/...core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala
@@ -639,3 +639,13 @@ case class ExecutedWriteSummary(
     updatedPartitions: Set[String],
     stats: Seq[WriteTaskStats],
     updatedPartitionsMap: Map[InternalRow, String])
+
+object ExecutedWriteSummary {
+
+  // The original case class parameter list provided for backward compatibility.
+  def apply(
+    updatedPartitions: Set[String],
+    stats: Seq[WriteTaskStats]): ExecutedWriteSummary = new ExecutedWriteSummary (
+      updatedPartitions, stats, Map[InternalRow, String]())
+
+}