You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@carbondata.apache.org by jackylk <gi...@git.apache.org> on 2018/01/24 04:16:04 UTC
[GitHub] carbondata pull request #1851: [CARBONDATA-2071] Added block size to Bblockl...
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
---