linyanghao commented on code in PR #7218:
URL: https://github.com/apache/iceberg/pull/7218#discussion_r1169175054
##########
core/src/main/java/org/apache/iceberg/actions/BaseRewriteDataFilesAction.java:
##########
@@ -198,6 +200,21 @@ public BaseRewriteDataFilesAction<ThisT> filter(Expression
expr) {
return this;
}
+ /**
+ * If the compaction should use the sequence number of the snapshot at
compaction start time for
+ * new data files, instead of using the sequence number of the newly
produced snapshot.
+ *
+ * <p>This avoids commit conflicts with updates that add newer equality
deletes at a higher
+ * sequence number.
+ *
+ * @param useStarting use starting sequence number if set to true
+ * @return this for method chaining
+ */
+ public BaseRewriteDataFilesAction<ThisT> useStartingSequenceNumber(boolean
useStarting) {
Review Comment:
That makes sense.
--
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]
