pvary commented on code in PR #14297:
URL: https://github.com/apache/iceberg/pull/14297#discussion_r2981851097
##########
parquet/src/main/java/org/apache/iceberg/parquet/Parquet.java:
##########
@@ -208,6 +209,21 @@ public WriteBuilder
variantShreddingFunc(VariantShreddingFunction func) {
return this;
}
+ /**
+ * Set a pre-computed Parquet {@link MessageType} to use as the file
schema, bypassing the
+ * default conversion from the Iceberg schema.
+ *
+ * <p>The provided schema must have Parquet field IDs that match the
Iceberg schema's field IDs.
+ * This method is mutually exclusive with {@link #variantShreddingFunc}.
+ *
+ * @param newFileSchema the Parquet message type to write
+ * @return this for method chaining
+ */
+ public WriteBuilder withFileSchema(MessageType newFileSchema) {
+ this.fileSchema = newFileSchema;
+ return this;
+ }
Review Comment:
Is there an easy way to encode this to the engineSchema?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
