Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1851#discussion_r163449480
--- Diff:
core/src/main/java/org/apache/carbondata/core/indexstore/BlockletDataMapIndexStore.java
---
@@ -78,17 +78,19 @@ public BlockletDataMap
get(TableBlockIndexUniqueIdentifier identifier)
String segmentPath = CarbonTablePath.getSegmentPath(
identifier.getAbsoluteTableIdentifier().getTablePath(),
identifier.getSegmentId());
- Map<String, String[]> locationMap = new HashMap<>();
+ Map<String, BlockMetaInfo> blockMetaInfoMap = new HashMap<>();
CarbonFile carbonFile = FileFactory.getCarbonFile(segmentPath);
CarbonFile[] carbonFiles = carbonFile.locationAwareListFiles();
SegmentIndexFileStore indexFileStore = new SegmentIndexFileStore();
indexFileStore.readAllIIndexOfSegment(carbonFiles);
PartitionMapFileStore partitionFileStore = new
PartitionMapFileStore();
partitionFileStore.readAllPartitionsOfSegment(carbonFiles,
segmentPath);
for (CarbonFile file : carbonFiles) {
- locationMap.put(file.getAbsolutePath(), file.getLocations());
+ blockMetaInfoMap
+ .put(file.getAbsolutePath(), new
BlockMetaInfo(file.getLocations(), file.getSize()));
--- End diff --
move `.put` to previous line
---
