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


---