voonhous commented on code in PR #17876:
URL: https://github.com/apache/hudi/pull/17876#discussion_r2693049126
##########
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java:
##########
@@ -345,27 +347,18 @@ public static Dataset<Row> coalesceOrRepartition(Dataset
dataset, int numPartiti
/**
* Kafka reset offset strategies.
*/
+ @AllArgsConstructor
+ @Getter
+ @ToString
public enum MissingCheckpointStrategy {
READ_LATEST("Read from latest commit in hoodie source table"),
READ_UPTO_LATEST_COMMIT("Read everything upto latest commit");
+ @Getter
private final String description;
- MissingCheckpointStrategy(String description) {
- this.description = description;
- }
-
- public String getDescription() {
- return description;
- }
-
private static MissingCheckpointStrategy nullEnum() {
return null;
}
-
- @Override
- public String toString() {
Review Comment:
I'm okay with leaving it as is, any particular reason why?
--
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]
