update spark notes

paul356 · Apr 29, 2024 · e1dad27 · e1dad27
1 parent 7ffdc94
commit e1dad27
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/_org/2022-12-31-spark.org b/_org/2022-12-31-spark.org
@@ -54,9 +54,9 @@ SparkCatalog还依赖一些其他类实现其功能
 
 ** spark写流程
 - AppendData --(ExtendedV2Writes strategy)--> AppendData(write = SparkWriteBuilder.build())
-- Spark --> WriteToDataSourceV2Exec.run() --> V2TableWriteExec.writeWithV2
+- Spark --> AppendDataExec.run() --> V2TableWriteExec.writeWithV2
   + SparkWrite.asBatchAppend()
-  + BaseWrite.createBatchWriterFactory()
+  + BatchWrite.createBatchWriterFactory()
   + WriterFactory.createWriter()
   + DataWriter<InternalRow>.write(row)
     * UnpartitionedDataWriter.write(row)