CacheBackedTaskHistoryRepository.java 文件源码

@Override
public Map<String, FileCollectionSnapshot> getInputFilesSnapshot() {
    if (inputFilesSnapshot == null) {
        ImmutableSortedMap.Builder<String, FileCollectionSnapshot> builder = ImmutableSortedMap.naturalOrder();
        for (Map.Entry<String, Long> entry : inputFilesSnapshotIds.entrySet()) {
            builder.put(entry.getKey(), snapshotRepository.get(entry.getValue()));
        }
        inputFilesSnapshot = builder.build();
    }
    return inputFilesSnapshot;
}