Page History

// 获得与查询相关的FileIndexEntries

Map<tsFilePath, TimeIndexEntry[]> filterByPath(PartialPath path, Filter timeFilter) 

// 为路径增加索引，适用场景：(1)文件刷盘封口；(2)版本升级

void createIndexForFiles(FileIndexEntries fileIndexEntries) 

// 为路径删除索引，适用场景：(1)删除文件；(2)根据TTL标记失效的文件

void deleteIndexOfFiles(FileIndexEntries fileIndexEntries) 

public class FileIndexManager {

    private Map<PartialPath, FileIndex> seqIndices;

    private Map<PartialPath, FileIndex> unseqIndices;

    private final ReentrantReadWriteLock lock;

    private static class FileIndexManagerHolder {

        private FileIndexManagerHolder() {
            // allowed to do nothing
        }

        private static final FileIndexManager INSTANCE = new FileIndexManager();
    }

    public static FileIndexManager getInstance() {
        return IndexerManagerHolder.INSTANCE;
    }

    private FileIndexManager() {
        seqIndexers = new ConcurrentHashMap<>();
        unseqIndexers = new ConcurrentHashMap<>();
        lock = new ReentrantReadWriteLock();
    }

    public boolean init() {...}

    public void addSeqIndexer(PartialPath storageGroup, FileIndex fileTimeIndexer) { ... }

    public void addUnseqIndexer(PartialPath storageGroup, FileIndex fileTimeIndexer) { ... }

    public void deleteSeqIndexer(PartialPath storageGroup) { ... }

    public void deleteUnseqIndexer(PartialPath storageGroup) { ... }

    public FileIndex getSeqIndexer(PartialPath storageGroup) { ... }

    public FileIndex getUnseqIndexer(PartialPath storageGroup) { ... }

    // 将TsFileResource转化为FileIndexEntries，用于版本升级

    public static FileIndexEntries convertFromTsFileResource(TsFileResource resource) {... }

}