carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipesala <...@git.apache.org>
Subject [GitHub] carbondata pull request #1367: [CARBONDATA-1398] Support query from specifie...
Date Thu, 09 Nov 2017 12:15:13 GMT
Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1367#discussion_r149945420
  
    --- Diff: hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
    @@ -449,14 +449,14 @@ private BitSet setMatchedPartitions(String partitionIds, CarbonTable
carbonTable
     
         //for each segment fetch blocks matching filter in Driver BTree
         for (String segmentNo : getSegmentsToAccess(job)) {
    -      List<DataRefNode> dataRefNodes = getDataBlocksOfSegment(job, filterExpressionProcessor,
    -          absoluteTableIdentifier, filterResolver, matchedPartitions, segmentNo,
    -          cacheClient, updateStatusManager, partitionInfo);
           // Get the UpdateVO for those tables on which IUD operations being performed.
           if (isIUDTable) {
             invalidBlockVOForSegmentId =
                 updateStatusManager.getInvalidTimestampRange(segmentNo);
           }
    +      List<DataRefNode> dataRefNodes = getDataBlocksOfSegment(job, filterExpressionProcessor,
    --- End diff --
    
    Not using CarbonInputFormat.java class, please use CarbonTableInputFormat.java


---

Mime
View raw message