lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Refactoring getter to avoid double extrametadata in json representation

Browse Source
This commit is contained in:
Nishith Agarwal
2020-01-23 23:34:22 -08:00
committed by Balaji Varadarajan
parent f9d2f66dc1
commit 185ff646ad
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java
View File

@@ -47,7 +47,7 @@ public class HoodieCommitMetadata implements Serializable {
protected Map<String, List<HoodieWriteStat>> partitionToWriteStats; protected Map<String, List<HoodieWriteStat>> partitionToWriteStats;
protected Boolean compacted; protected Boolean compacted;
private Map<String, String> extraMetadataMap; private Map<String, String> extraMetadata;
// for ser/deser // for ser/deser
public HoodieCommitMetadata() { public HoodieCommitMetadata() {
@@ -55,7 +55,7 @@ public class HoodieCommitMetadata implements Serializable {
} }
public HoodieCommitMetadata(boolean compacted) { public HoodieCommitMetadata(boolean compacted) {
extraMetadataMap = new HashMap<>(); extraMetadata = new HashMap<>();
partitionToWriteStats = new HashMap<>(); partitionToWriteStats = new HashMap<>();
this.compacted = compacted; this.compacted = compacted;
} }
@@ -68,7 +68,7 @@ public class HoodieCommitMetadata implements Serializable {
} }
public void addMetadata(String metaKey, String value) { public void addMetadata(String metaKey, String value) {
extraMetadataMap.put(metaKey, value); extraMetadata.put(metaKey, value);
} }
public List<HoodieWriteStat> getWriteStats(String partitionPath) { public List<HoodieWriteStat> getWriteStats(String partitionPath) {
@@ -76,7 +76,7 @@ public class HoodieCommitMetadata implements Serializable {
} }
public Map<String, String> getExtraMetadata() { public Map<String, String> getExtraMetadata() {
return extraMetadataMap; return extraMetadata;
} }
public Map<String, List<HoodieWriteStat>> getPartitionToWriteStats() { public Map<String, List<HoodieWriteStat>> getPartitionToWriteStats() {
@@ -84,7 +84,7 @@ public class HoodieCommitMetadata implements Serializable {
} }
public String getMetadata(String metaKey) { public String getMetadata(String metaKey) {
return extraMetadataMap.get(metaKey); return extraMetadata.get(metaKey);
} }
public Boolean getCompacted() { public Boolean getCompacted() {
@@ -343,6 +343,6 @@ public class HoodieCommitMetadata implements Serializable {
@Override @Override
public String toString() { public String toString() {
return "HoodieCommitMetadata{partitionToWriteStats=" + partitionToWriteStats + ", compacted=" + compacted return "HoodieCommitMetadata{partitionToWriteStats=" + partitionToWriteStats + ", compacted=" + compacted
+ ", extraMetadataMap=" + extraMetadataMap + '}'; + ", extraMetadata=" + extraMetadata + '}';
} }
} }