Skip to content

Commit 025210f

Browse files
committed
Parameter order change
1 parent b1c225b commit 025210f

2 files changed

Lines changed: 12 additions & 4 deletions

File tree

spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/data/SparkParquetWriters.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,12 +78,21 @@ public class SparkParquetWriters {
7878
private SparkParquetWriters() {}
7979

8080
public static <T> ParquetValueWriter<T> buildWriter(StructType dfSchema, MessageType type) {
81-
return buildWriter(null, dfSchema, type);
81+
return buildWriter(null, type, dfSchema);
8282
}
8383

8484
@SuppressWarnings("unchecked")
8585
public static <T> ParquetValueWriter<T> buildWriter(
86-
Schema icebergSchema, StructType dfSchema, MessageType type) {
86+
Schema icebergSchema, MessageType type, StructType dfSchema) {
87+
return (ParquetValueWriter<T>)
88+
ParquetWithSparkSchemaVisitor.visit(
89+
dfSchema != null ? dfSchema : SparkSchemaUtil.convert(icebergSchema),
90+
type,
91+
new WriteBuilder(type));
92+
}
93+
94+
public static <T> ParquetValueWriter<T> buildWriter(
95+
StructType dfSchema, MessageType type, Schema icebergSchema) {
8796
return (ParquetValueWriter<T>)
8897
ParquetWithSparkSchemaVisitor.visit(
8998
dfSchema != null ? dfSchema : SparkSchemaUtil.convert(icebergSchema),

spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/source/SparkFormatModels.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,7 @@ public static void register() {
4848
ParquetFormatModel.create(
4949
InternalRow.class,
5050
StructType.class,
51-
(icebergSchema, fileSchema, engineSchema) ->
52-
SparkParquetWriters.buildWriter(icebergSchema, engineSchema, fileSchema),
51+
SparkParquetWriters::buildWriter,
5352
(icebergSchema, fileSchema, engineSchema, idToConstant) ->
5453
SparkParquetReaders.buildReader(icebergSchema, fileSchema, idToConstant)));
5554

0 commit comments

Comments
 (0)