Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2678#discussion_r216198665
--- Diff:
core/src/main/java/org/apache/carbondata/core/indexstore/blockletindex/SegmentIndexFileStore.java
---
@@ -76,20 +77,29 @@
*/
private Map<String, List<String>> carbonMergeFileToIndexFilesMap;
+ private Configuration configuration;
+
public SegmentIndexFileStore() {
carbonIndexMap = new HashMap<>();
carbonIndexMapWithFullPath = new TreeMap<>();
carbonMergeFileToIndexFilesMap = new HashMap<>();
}
+ public SegmentIndexFileStore(Configuration configuration) {
+ carbonIndexMap = new HashMap<>();
+ carbonIndexMapWithFullPath = new TreeMap<>();
+ carbonMergeFileToIndexFilesMap = new HashMap<>();
+ this.configuration = configuration;
+ }
+
/**
* Read all index files and keep the cache in it.
*
* @param segmentPath
* @throws IOException
*/
public void readAllIIndexOfSegment(String segmentPath) throws
IOException {
- CarbonFile[] carbonIndexFiles = getCarbonIndexFiles(segmentPath);
+ CarbonFile[] carbonIndexFiles = getCarbonIndexFiles(segmentPath,
configuration);
--- End diff --
Fixed
---
