lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix typo in IntervalTreeBasedGlobalIndexFileFilter (#3993)

Browse Source 
Co-authored-by: 闫杜峰 <yandufeng@sinochem.com>
This commit is contained in:
dufeng1010
2021-11-15 14:39:43 +08:00
committed by GitHub
parent a0dae41409
commit 3c4319729c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/IntervalTreeBasedGlobalIndexFileFilter.java
View File

@@ -46,8 +46,8 @@ class IntervalTreeBasedGlobalIndexFileFilter implements IndexFileFilter {
IntervalTreeBasedGlobalIndexFileFilter(final Map<String, List<BloomIndexFileInfo>> partitionToFileIndexInfo) {
List<BloomIndexFileInfo> allIndexFiles = new ArrayList<>();
partitionToFileIndexInfo.forEach((parition, bloomIndexFileInfoList) -> bloomIndexFileInfoList.forEach(file -> {
fileIdToPartitionPathMap.put(file.getFileId(), parition);
partitionToFileIndexInfo.forEach((partition, bloomIndexFileInfoList) -> bloomIndexFileInfoList.forEach(file -> {
fileIdToPartitionPathMap.put(file.getFileId(), partition);
allIndexFiles.add(file);
}));