voonhous commented on code in PR #17830:
URL: https://github.com/apache/hudi/pull/17830#discussion_r2692956636
##########
hudi-common/src/main/java/org/apache/hudi/common/model/CompactionOperation.java:
##########
@@ -140,36 +115,9 @@ public static CompactionOperation
convertFromAvroRecordInstance(HoodieCompaction
op.dataFileName = Option.ofNullable(operation.getDataFilePath());
op.dataFileCommitTime = op.dataFileName.map(p -> FSUtils.getCommitTime(new
StoragePath(p).getName()));
op.deltaFileNames = new ArrayList<>(operation.getDeltaFilePaths());
- op.id = new HoodieFileGroupId(operation.getPartitionPath(),
operation.getFileId());
+ op.fileGroupId = new HoodieFileGroupId(operation.getPartitionPath(),
operation.getFileId());
op.metrics = operation.getMetrics() == null ? new HashMap<>() : new
HashMap<>(operation.getMetrics());
op.bootstrapFilePath = Option.ofNullable(operation.getBootstrapFilePath());
return op;
}
-
- @Override
- public String toString() {
- return "CompactionOperation{baseInstantTime='" + baseInstantTime + '\'' +
", dataFileCommitTime="
- + dataFileCommitTime + ", deltaFileNames=" + deltaFileNames + ",
dataFileName=" + dataFileName + ", id='" + id
- + '\'' + ", metrics=" + metrics + ", bootstrapFilePath=" +
bootstrapFilePath + '}';
- }
-
- @Override
- public boolean equals(Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- CompactionOperation operation = (CompactionOperation) o;
- return Objects.equals(baseInstantTime, operation.baseInstantTime)
- && Objects.equals(dataFileCommitTime, operation.dataFileCommitTime)
- && Objects.equals(deltaFileNames, operation.deltaFileNames)
- && Objects.equals(dataFileName, operation.dataFileName) &&
Objects.equals(id, operation.id);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(baseInstantTime, id);
Review Comment:
Seems to be a dev error from the getgo in this commit
a7e6cf51974f96c6b4bc945db25658cbb4bc48c7 way before Hudi was opensourced
--
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]
