From 6ffa0a34f462cb889f20b2568061d5e804cd3f0b Mon Sep 17 00:00:00 2001 From: Steve Vaughan Jr Date: Tue, 7 May 2024 09:28:08 -0400 Subject: [PATCH] Missed ExecutedWriteSummary --- .../execution/datasources/FileFormatDataWriter.scala | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala index 13dc002f69b21..700984f333a17 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatDataWriter.scala +++ b/sql/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]()) + +}